maxcompute

type Char struct {
	Length int `mapstructure:"length"`
}

type Client interface {
	TableHandleFrom(projectSchema ProjectSchema, maskingPolicyHandle TableMaskingPolicyHandle) TableResourceHandle
	ViewHandleFrom(projectSchema ProjectSchema) TableResourceHandle
	ExternalTableHandleFrom(schema ProjectSchema, getter TenantDetailsGetter, maskingPolicyHandle TableMaskingPolicyHandle) TableResourceHandle
	TableMaskingPolicyHandleFrom(projectSchema ProjectSchema, logger log.Logger) TableMaskingPolicyHandle
	SchemaHandleFrom(projectSchema ProjectSchema) TableResourceHandle
	FunctionHandleFrom(projectSchema ProjectSchema) TableResourceHandle
}

type ClientProvider interface {
	Get(account string) (Client, error)
}

type Cluster struct {
	Using   []string     `mapstructure:"using,omitempty"`
	Type    string       `mapstructure:"type,omitempty"`
	SortBy  []SortColumn `mapstructure:"sort_by,omitempty"`
	Buckets int          `mapstructure:"buckets,omitempty"`
}

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

type Decimal struct {
	Precision int32 `mapstructure:"precision"`
	Scale     int32 `mapstructure:"scale"`
}

type ExtTableClients struct {
	GSheet *gsheet.GSheets
	OSS    *oss.Client
	GDrive *gdrive.GDrive
	Lark   *lark.Client
}

type ExternalSource struct {
	SourceType  ExternalTableSourceType `mapstructure:"type,omitempty"`
	ContentType string                  `mapstructure:"content_type,omitempty"`
	SourceURIs  []string                `mapstructure:"uris,omitempty"`

	// Additional configs for CSV, GoogleSheets, LarkSheets formats.
	SerdeProperties map[string]string `mapstructure:"serde_properties"`
	TableProperties map[string]string `mapstructure:"table_properties"`

	SyncInterval     int64    `mapstructure:"sync_interval_in_hrs,omitempty"`
	GetFormattedDate bool     `mapstructure:"fetch_formatted_datetime,omitempty"`
	GetFormattedData bool     `mapstructure:"fetch_formatted_data,omitempty"`
	CleanGDriveCSV   bool     `mapstructure:"clean_gdrive_csv,omitempty"`
	Jars             []string `mapstructure:"jars,omitempty"`
	Location         string   `mapstructure:"location,omitempty"`
	Range            string   `mapstructure:"range,omitempty"`
}

type ExternalTable struct {
	Name     string `mapstructure:"name,omitempty"`
	Project  string `mapstructure:"project,omitempty"`
	Database string `mapstructure:"database,omitempty"`

	Description string          `mapstructure:"description,omitempty"`
	Schema      Schema          `mapstructure:"schema,omitempty"`
	Source      *ExternalSource `mapstructure:"source,omitempty"`

	Hints map[string]string `mapstructure:"hints,omitempty"`
}

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

type ExternalTableSourceType string

type ExternalTableSources []ExternalTableSourceType

type Field struct {
	Name        string `mapstructure:"name,omitempty"`
	Type        string `mapstructure:"type,omitempty"`
	Description string `mapstructure:"description,omitempty"`

	// First label should be the primary label and others as extended
	Labels []string `mapstructure:"labels,omitempty"`

	DefaultValue string `mapstructure:"default_value,omitempty"`
	Required     bool   `mapstructure:"required,omitempty"`

	SourceTimeFormat  string   `mapstructure:"source_time_format,omitempty"`
	SourceTimeFormats []string `mapstructure:"source_time_formats,omitempty"`

	Decimal      *Decimal   `mapstructure:"decimal,omitempty"`
	Char         *Char      `mapstructure:"char,omitempty"`
	VarChar      *VarChar   `mapstructure:"varchar,omitempty"`
	StructSchema []Field    `mapstructure:"struct,omitempty"`
	ArraySchema  *Field     `mapstructure:"array,omitempty"`
	MapSchema    *MapSchema `mapstructure:"map,omitempty"`

	// masking policy fields
	MaskPolicy   string `mapstructure:"mask_policy,omitempty"`
	UnmaskPolicy string `mapstructure:"unmask_policy,omitempty"`
}

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

type MCFunction interface {
	Get(functionName string) (*odps.Function, error)
}

type MapSchema struct {
	Key   Field `mapstructure:"key"`
	Value Field `mapstructure:"value"`
}

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

type MaxCompute struct {
	SyncRepo SyncRepo
	// contains filtered or unexported fields
}

type MaxComputeClient struct {
	*odps.Odps
}

type MaxComputeClientProvider struct{}

type McExternalTable interface {
	CreateExternal(
		schema tableschema.TableSchema,
		createIfNotExists bool,
		serdeProperties map[string]string,
		jars []string,
		hints, alias map[string]string,
	) error
	BatchLoadTables(tableNames []string) ([]*odps.Table, error)
	Delete(tableName string, ifExists bool) error
}

type McSQLExecutor interface {
	ExecSQlWithHints(sql string, hints map[string]string) (*odps.Instance, error)
	CurrentSchemaName() string
	SetCurrentSchemaName(schemaName string)
}

type McSchema interface {
	Create(schemaName string, createIfNotExists bool, comment string) error
}

type McTable interface {
	Create(schema tableschema.TableSchema, createIfNotExists bool, hints, alias map[string]string) error
	BatchLoadTables(tableNames []string) ([]*odps.Table, error)
}

type McTableInstance interface {
	Load() error
	ColumnMaskInfos() ([]odps.ColumnMaskInfo, error)
}

type McTableWrapper struct {
	McTable
}

type McTables interface {
	BatchLoadTables(tableNames []string) ([]McTableInstance, error)
}

type Partition struct {
	Columns []string `mapstructure:"field"`
}

type ProjectSchema struct {
	Project string
	Schema  string
}

type ResourceHandle interface {
	Create(res *resource.Resource) error
	Update(res *resource.Resource) error
	Exists(tableName string) bool
}

type ResourceURN struct {
	Project string `mapstructure:"project"`
	Schema  string `mapstructure:"database"`
	Name    string `mapstructure:"name"`
}

type ResourceURNWithUpstreams struct {
	ResourceURN ResourceURN
	Upstreams   []*ResourceURNWithUpstreams
}

type ResourceURNWithUpstreamsList []*ResourceURNWithUpstreams

type ResourceURNs []ResourceURN

type Schema []*Field

type SchemaDetails struct {
	Name        resource.Name `mapstructure:"name,omitempty"`
	Project     string        `mapstructure:"project,omitempty"`
	Database    string        `mapstructure:"database,omitempty"`
	Description string        `mapstructure:"description,omitempty"`
}

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

type SchemaInteractor interface {
	Exists() (bool, error)
}

type SecretProvider interface {
	GetSecret(ctx context.Context, tnnt tenant.Tenant, key string) (*tenant.PlainTextSecret, error)
}

type SortColumn struct {
	Name  string `mapstructure:"name"`
	Order string `mapstructure:"order,omitempty"`
}

type SyncRepo interface {
	Upsert(ctx context.Context, projectName tenant.ProjectName, entityType, identifier string, remarks map[string]string, success bool) error
	Touch(ctx context.Context, projectName tenant.ProjectName, identifiers []string) error
	UpsertRevision(ctx context.Context, projectName tenant.ProjectName, entityType, identifier string, remarks map[string]string, revision int, success bool) error
}

type SyncerService struct {
	SyncRepo              SyncRepo
	MaxSyncDelayTolerance time.Duration
	// contains filtered or unexported fields
}

type Table struct {
	Name     string `mapstructure:"name,omitempty"`
	Project  string `mapstructure:"project,omitempty"`
	Database string `mapstructure:"database,omitempty"`

	Description string     `mapstructure:"description,omitempty"`
	Schema      Schema     `mapstructure:"schema,omitempty"`
	Cluster     *Cluster   `mapstructure:"cluster,omitempty"`
	Partition   *Partition `mapstructure:"partition,omitempty"`
	Lifecycle   int        `mapstructure:"lifecycle,omitempty"`
	Type        string     `mapstructure:"type,omitempty"`

	TableProperties map[string]string      `mapstructure:"table_properties,omitempty"`
	Hints           map[string]string      `mapstructure:"hints,omitempty"`
	ExtraConfig     map[string]interface{} `mapstructure:",remain"`
}

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

type TableMaskingPolicyHandle interface {
	Process(tableName string, schema Schema) error
}

type TableResourceHandle interface {
	ResourceHandle
}

type TenantDetailsGetter interface {
	GetDetails(ctx context.Context, tnnt tenant.Tenant) (*tenant.WithDetails, error)
}

type VarChar struct {
	Length int `mapstructure:"length"`
}

type View struct {
	Name     string `mapstructure:"name,omitempty"`
	Project  string `mapstructure:"project,omitempty"`
	Database string `mapstructure:"database,omitempty"`

	Description string   `mapstructure:"description,omitempty"`
	Columns     []string `mapstructure:"columns,omitempty"`
	ViewQuery   string   `mapstructure:"view_query,omitempty"`
	Lifecycle   int      `mapstructure:"lifecycle,omitempty"`

	Hints map[string]string `mapstructure:"hints,omitempty"`
}

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

type ViewSQLExecutor interface {
	CurrentSchemaName() string
}

type ViewSchema interface {
	Create(schemaName string, createIfNotExists bool, comment string) error
}

type ViewTable interface {
	CreateViewWithHints(schema tableschema.TableSchema, orReplace, createIfNotExists, buildDeferred bool, hints map[string]string) error
	BatchLoadTables(tableNames []string) ([]*odps.Table, error)
}