td_client

type APIError struct {
	Type    int
	Message string
	Cause   error
}

type AddAPIKeyResult struct {
	APIKey string
}

type AuthenticateResult struct {
	Name   string
	APIKey string
}

type Blob interface {
	Reader() (io.ReadCloser, error)
	Size() (int64, error)
	MD5Sum() ([]byte, error)
}

type BufferingBlob struct {
	// contains filtered or unexported fields
}

type BulkImportElement struct {
	Name         string
	Database     string
	Table        string
	Status       string
	JobID        string
	ValidRecords int
	ErrorRecords int
	ValidParts   int
	ErrorParts   int
	UploadFrozen bool
}

type BulkImportResult struct {
	Name       string
	BulkImport string
}

type ConverterFunc func(string) (interface{}, error)

type DeleteScheduleResult struct {
	Name      string
	Cron      string
	Type      string
	Query     string
	Timezone  string
	Delay     int
	Database  string
	UserName  string
	CreatedAt time.Time
}

type EndpointRouter interface {
	Route(requestUri string) string
}

type FixedEndpointRouter struct {
	Endpoint string
}

type InMemoryBlob []byte

type ListAPIKeysResult struct {
	APIKeys []string
}

type ListBulkImportElements []BulkImportElement

type ListBulkImportParts struct {
	Name       string
	BulkImport string
	Parts      []string
}

type ListDataBasesResult []ListDataBasesResultElement

type ListDataBasesResultElement struct {
	Id              string
	UserId          int
	Description     string
	Name            string
	Organization    string
	Count           int
	CreatedAt       time.Time
	UpdatedAt       time.Time
	Permission      string
	DeleteProtected bool
}

type ListJobsOptions struct {
	// contains filtered or unexported fields
}

type ListJobsResult struct {
	ListJobsResultElements ListJobsResultElements
	Count                  int
	From                   int
	To                     int
}

type ListJobsResultElement struct {
	Id         string
	Type       string
	Database   string
	Status     string
	Query      string
	Duration   int
	CreatedAt  time.Time
	UpdatedAt  time.Time
	StartAt    time.Time
	EndAt      time.Time
	CpuTime    float64
	ResultSize int
	NumRecords int
	ResultUrl  string
	Priority   int
	RetryLimit int
}

type ListJobsResultElements []ListJobsResultElement

type ListResultsResult []ListResultsResultElement

type ListResultsResultElement struct {
	Id     int
	UserId int
	Name   string
	Url    string
}

type ListScheduleResult []ScheduleElement

type ListTablesResult []ListTablesResultElement

type ListTablesResultElement struct {
	Id                   int
	UserId               int
	Description          string
	Name                 string
	Type                 string
	Count                int
	CreatedAt            time.Time
	UpdatedAt            time.Time
	LastImport           time.Time
	LastLogTimestamp     time.Time
	EstimatedStorageSize int
	Schema               []interface{}
	ExpireDays           int
	PrimaryKey           string
	PrimaryKeyType       string
	IncludeV             bool
}

type ListUsersResult []ListUsersResultElement

type ListUsersResultElement struct {
	ID            int
	FirstName     string
	LastName      string
	Email         string
	Phone         string
	GravatarURL   string
	Administrator bool
	CreatedAt     time.Time
	UpdatedAt     time.Time
	Name          string
	AccountOwner  bool
	Organization  string
	Roles         []string
}

type Optional struct {
	V       interface{}
	Default interface{}
}

type PerformBulkImportResult struct {
	Name       string
	BulkImport string
	JobID      string
}

type Query struct {
	Type          string
	Query         string
	ResultUrl     string
	Priority      int
	RetryLimit    int
	EngineVersion string
}

type RunScheduleResult struct {
	ID          string
	Type        string
	ScheduledAt time.Time
}

type RunScheduleResultList []RunScheduleResult

type ScheduleElement struct {
	Id              int
	ExecutingUserId int
	Description     string
	Name            string
	Cron            string
	Type            string
	Query           string
	Timezone        string
	Delay           int
	Database        string
	UserName        string
	Priority        int
	RetryLimit      int
	Result          string
	NextTime        string
	CreatedAt       time.Time
}

type ScheduleHistoryElement struct {
	ID               string
	Query            string
	Type             string
	URL              string
	Database         string
	Status           string
	StartAt          time.Time
	EndAt            time.Time
	ScheduledAt      time.Time
	CreatedAt        time.Time
	UpdatedAt        time.Time
	UserName         string
	CPUTime          float64
	Duration         float64
	ResultSize       int
	NumRecords       int
	Result           string
	Priority         int
	RetryLimit       int
	HiveResultSchema []interface{}
	Organization     string
}

type ScheduleHistoryElementList []ScheduleHistoryElement

type ScheduleHistoryList struct {
	History ScheduleHistoryElementList
	Count   int
	From    int
	To      int
}

type ScheduleResult struct {
	ID         string
	Name       string
	Cron       string
	Type       string
	Query      string
	Timezone   string
	Delay      int
	Database   string
	UserName   string
	Priority   int
	RetryLimit int
	Result     string
	Start      string
	CreatedAt  time.Time
}

type ServerStatusResult struct {
	Status string
}

type Settings struct {
	ApiKey            string            // Treasure Data Account API key
	UserAgent         string            // (Optional) Name that will appear as the User-Agent HTTP header
	Router            EndpointRouter    // (Optional) Endpoint router
	ConnectionTimeout time.Duration     // (Optional) Connection timeout
	ReadTimeout       time.Duration     // (Optional) Read timeout.
	SendTimeout       time.Duration     // (Optional) Send timeout.
	RootCAs           *x509.CertPool    // (Optional) Specify the CA certificates.
	Port              int               // (Optional) Port number.
	Proxy             interface{}       // (Optional) HTTP proxy to use.
	Transport         http.RoundTripper // (Optional) Overrides the transport used to establish the connection.
	Headers           map[string]string // (Optional) Additional headers that will be sent to the endpoint.
}

type ShowAccountResult struct {
	Id              int
	Plan            int
	StorageSize     int
	GuaranteedCores int
	MaximumCores    int
	CreatedAt       time.Time
}

type ShowJobResult struct {
	Id               string
	Type             string
	Database         string
	UserName         string
	Status           string
	Query            string
	Debug            ShowJobResultDebugElement
	Url              string
	Duration         int
	CreatedAt        time.Time
	UpdatedAt        time.Time
	StartAt          time.Time
	EndAt            time.Time
	CpuTime          float64
	ResultSize       int
	NumRecords       int
	ResultUrl        string
	Priority         int
	RetryLimit       int
	HiveResultSchema []interface{}
}

type ShowJobResultDebugElement struct {
	CmdOut string
	StdErr string
}

type TDClient struct {
	// contains filtered or unexported fields
}

type TimeoutConn struct {
	Conn         net.Conn
	ReadTimeout  time.Duration
	WriteTimeout time.Duration
	// contains filtered or unexported fields
}

type V3EndpointRouter struct {
	DefaultEndpoint string
	ImportEndpoint  string
}