Documentation
¶
Index ¶
- func NewDataTokenService(client *internal.DataTokenClient) pb.DataTokenServiceServer
- func NewMaterializationService(computeManager *compute.ComputeManager, ...) *materializationService
- func NewQueryV1Service(computeManager *compute.ComputeManager, ...) v1alpha.QueryServiceServer
- func NewQueryV2Service(computeManager *compute.ComputeManager, ...) apiv2alpha.QueryServiceServer
- func NewTableService(computeManager *compute.ComputeManager, fileManager *compute.FileManager, ...) *tableService
- func NewViewService(compileManager *compute.CompileManager, ...) *viewService
- type Analyzer
- type DependencyAnalyzer
- type MaterializationService
- type ResourceDependency
- type TableService
- type ViewService
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewDataTokenService ¶
func NewDataTokenService(client *internal.DataTokenClient) pb.DataTokenServiceServer
NewDataTokenService creates a new user service
func NewMaterializationService ¶
func NewMaterializationService(computeManager *compute.ComputeManager, materializationManager *compute.MaterializationManager, kaskadaTableClient *internal.KaskadaTableClient, kaskadaViewClient *internal.KaskadaViewClient, dataTokenClient *internal.DataTokenClient, materializationClient *internal.MaterializationClient) *materializationService
NewMaterializationService creates a new materialization service
func NewQueryV1Service ¶
func NewQueryV1Service(computeManager *compute.ComputeManager, dataTokenClient *internal.DataTokenClient, kaskadaQueryClient *internal.KaskadaQueryClient, kaskadaTableClient *internal.KaskadaTableClient, objectStoreClient *client.ObjectStoreClient, prepareManager *compute.PrepareManager) v1alpha.QueryServiceServer
NewQueryV1Service creates a new query service
func NewQueryV2Service ¶
func NewQueryV2Service(computeManager *compute.ComputeManager, dataTokenClient *internal.DataTokenClient, kaskadaQueryClient *internal.KaskadaQueryClient) apiv2alpha.QueryServiceServer
NewQueryV2Service creates a new query service
func NewTableService ¶
func NewTableService(computeManager *compute.ComputeManager, fileManager *compute.FileManager, kaskadaTableClient *internal.KaskadaTableClient, objectStoreClient *client.ObjectStoreClient, tableStore *store.TableStore, dependencyAnalyzer *Analyzer) *tableService
NewTableService creates a new table service
func NewViewService ¶
func NewViewService(compileManager *compute.CompileManager, kaskadaTableClient *internal.KaskadaTableClient, kaskadaViewClient *internal.KaskadaViewClient, dependencyAnalyzer *Analyzer) *viewService
NewViewService creates a new view service
Types ¶
type Analyzer ¶
type Analyzer interface {
Analyze(ctx context.Context, owner *ent.Owner, name string, dependencyType schema.DependencyType) (*ResourceDependency, error)
}
func NewDependencyAnalyzer ¶
func NewDependencyAnalyzer(kaskadaViewClient *internal.KaskadaViewClient, materializationClient *internal.MaterializationClient) Analyzer
type DependencyAnalyzer ¶
type DependencyAnalyzer struct {
// contains filtered or unexported fields
}
func (*DependencyAnalyzer) Analyze ¶
func (d *DependencyAnalyzer) Analyze(ctx context.Context, owner *ent.Owner, name string, dependencyType schema.DependencyType) (*ResourceDependency, error)
Analyze implements Analyzer
type MaterializationService ¶
type MaterializationService interface {
ListMaterializations(ctx context.Context, request *v1alpha.ListMaterializationsRequest) (*v1alpha.ListMaterializationsResponse, error)
GetMaterialization(ctx context.Context, request *v1alpha.GetMaterializationRequest) (*v1alpha.GetMaterializationResponse, error)
CreateMaterialization(ctx context.Context, request *v1alpha.CreateMaterializationRequest) (*v1alpha.CreateMaterializationResponse, error)
DeleteMaterialization(ctx context.Context, request *v1alpha.DeleteMaterializationRequest) (*v1alpha.DeleteMaterializationResponse, error)
}
type ResourceDependency ¶
type ResourceDependency struct {
// contains filtered or unexported fields
}
func (*ResourceDependency) ToErrorDetails ¶
func (r *ResourceDependency) ToErrorDetails() errDetails.PreconditionFailure
type TableService ¶
type TableService interface {
SetAnalyzer(analyzer Analyzer)
ListTables(ctx context.Context, request *v1alpha.ListTablesRequest) (*v1alpha.ListTablesResponse, error)
GetTable(ctx context.Context, request *v1alpha.GetTableRequest) (*v1alpha.GetTableResponse, error)
CreateTable(ctx context.Context, request *v1alpha.CreateTableRequest) (*v1alpha.CreateTableResponse, error)
DeleteTable(ctx context.Context, request *v1alpha.DeleteTableRequest) (*v1alpha.DeleteTableResponse, error)
LoadData(ctx context.Context, request *v1alpha.LoadDataRequest) (*v1alpha.LoadDataResponse, error)
}
type ViewService ¶
type ViewService interface {
SetAnalyzer(analyzer Analyzer)
ListViews(ctx context.Context, request *pb.ListViewsRequest) (*pb.ListViewsResponse, error)
GetView(ctx context.Context, request *pb.GetViewRequest) (*pb.GetViewResponse, error)
CreateView(ctx context.Context, request *pb.CreateViewRequest) (*pb.CreateViewResponse, error)
DeleteView(ctx context.Context, request *pb.DeleteViewRequest) (*pb.DeleteViewResponse, error)
}
Source Files
Click to show internal directories.
Click to hide internal directories.