Documentation
¶
Index ¶
- type BasicOperator
- type Client
- func (c *Client) CreateIngestion(ctx context.Context, dataSetID, ingestionID string, ...) error
- func (c *Client) DescribeDashboard(ctx context.Context, dashboardID string) (*DashboardDetail, error)
- func (c *Client) DescribeDashboardDefinition(ctx context.Context, dashboardID string) (*DashboardDetail, error)
- func (c *Client) DescribeDataSet(ctx context.Context, dataSetID string) (*DataSetDetail, error)
- func (c *Client) DescribeDataSource(ctx context.Context, dataSourceID string) (*DataSourceDetail, error)
- func (c *Client) DescribeIngestion(ctx context.Context, dataSetID, ingestionID string) (*IngestionStatus, error)
- func (c *Client) GetName() string
- func (c *Client) ListDashboards(ctx context.Context) ([]DashboardSummary, error)
- func (c *Client) ListDataSets(ctx context.Context) ([]DataSetSummary, error)
- func (c *Client) ListDataSources(ctx context.Context) ([]DataSourceSummary, error)
- func (c *Client) Ping(ctx context.Context) error
- type Config
- type DashboardDetail
- type DashboardSummary
- type DataSetColumn
- type DataSetDetail
- type DataSetSummary
- type DataSourceDetail
- type DataSourceSummary
- type IngestionStatus
- type PhysicalTable
- type SheetDetail
- type VisualDetail
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type BasicOperator ¶
type BasicOperator struct {
// contains filtered or unexported fields
}
func NewBasicOperator ¶
func NewBasicOperator(conn config.ConnectionGetter) *BasicOperator
func (BasicOperator) Run ¶
func (o BasicOperator) Run(ctx context.Context, ti scheduler.TaskInstance) error
type Client ¶
type Client struct {
// contains filtered or unexported fields
}
func (*Client) CreateIngestion ¶
func (*Client) DescribeDashboard ¶
func (*Client) DescribeDashboardDefinition ¶
func (*Client) DescribeDataSet ¶
func (*Client) DescribeDataSource ¶
func (*Client) DescribeIngestion ¶
func (*Client) ListDashboards ¶
func (c *Client) ListDashboards(ctx context.Context) ([]DashboardSummary, error)
func (*Client) ListDataSets ¶
func (c *Client) ListDataSets(ctx context.Context) ([]DataSetSummary, error)
func (*Client) ListDataSources ¶
func (c *Client) ListDataSources(ctx context.Context) ([]DataSourceSummary, error)
type Config ¶
type Config struct {
Name string `yaml:"name,omitempty" json:"name" mapstructure:"name"`
AwsAccessKeyID string `yaml:"aws_access_key_id,omitempty" json:"aws_access_key_id" mapstructure:"aws_access_key_id"`
AwsSecretAccessKey string `yaml:"aws_secret_access_key,omitempty" json:"aws_secret_access_key" mapstructure:"aws_secret_access_key"`
AwsSessionToken string `yaml:"aws_session_token,omitempty" json:"aws_session_token" mapstructure:"aws_session_token"`
AwsRegion string `yaml:"aws_region,omitempty" json:"aws_region" mapstructure:"aws_region"`
AwsAccountID string `yaml:"aws_account_id,omitempty" json:"aws_account_id" mapstructure:"aws_account_id"`
}
type DashboardDetail ¶
type DashboardDetail struct {
ID string
Name string
Arn string
DataSetArns []string
Sheets []SheetDetail
}
DashboardDetail holds full detail for a dashboard including sheets and visuals.
type DashboardSummary ¶
DashboardSummary holds summary info for a dashboard.
type DataSetColumn ¶
DataSetColumn represents a column in a dataset.
type DataSetDetail ¶
type DataSetDetail struct {
ID string
Name string
Arn string
ImportMode string
Columns []DataSetColumn
PhysicalTableMaps map[string]PhysicalTable
}
DataSetDetail holds full detail for a dataset including columns and physical table maps.
type DataSetSummary ¶
DataSetSummary holds summary info for a dataset as returned by ListDataSets.
type DataSourceDetail ¶
type DataSourceDetail struct {
ID string
Name string
Type string
Arn string
Database string
Schema string
Host string
Port int32
Catalog string
Warehouse string
ConnectionType string
}
DataSourceDetail holds full detail for a data source connection.
type DataSourceSummary ¶
DataSourceSummary holds summary info for a data source.
type IngestionStatus ¶
IngestionStatus holds the status of an ingestion.
type PhysicalTable ¶
type PhysicalTable struct {
DatabaseName string
SchemaName string
TableName string
Columns []DataSetColumn
DataSourceID string
SqlQuery string // CustomSql query text, empty for relational/S3 tables
SqlName string // CustomSql alias name
}
PhysicalTable represents a physical table map entry in a dataset.
type SheetDetail ¶
type SheetDetail struct {
SheetID string
Name string
Visuals []VisualDetail
}
SheetDetail represents a sheet within a dashboard.