maxcompute

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

type Client interface {
	TableHandleFrom(projectSchema ProjectSchema, maskingPolicyHandle TableMaskingPolicyHandle, tableCommentWithMetadata bool) TableResourceHandle
	ViewHandleFrom(projectSchema ProjectSchema, tableCommentWithMetadata bool) TableResourceHandle
	ExternalTableHandleFrom(schema ProjectSchema, getter TenantDetailsGetter, maskingPolicyHandle TableMaskingPolicyHandle, tableCommentWithMetadata bool) 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)
}