service

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
  • func NewDependencyAnalyzer(kaskadaViewClient *internal.KaskadaViewClient, ...) Analyzer
• type DependencyAnalyzer
  • func (d *DependencyAnalyzer) Analyze(ctx context.Context, owner *ent.Owner, name string, ...) (*ResourceDependency, error)
• type MaterializationService
• type ResourceDependency
  • func (r *ResourceDependency) ToErrorDetails() errDetails.PreconditionFailure
• type TableService
• type ViewService

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)
}