api

package
v0.15.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Nov 22, 2022 License: Apache-2.0 Imports: 18 Imported by: 0

README

runtime/api/

This directory contains gRPC (protocol buffer) definitions for the Runtime's external APIs. They're defined in runtime.proto, which generates the other files in this directory. The actual handlers are implemented in runtime/server/.

We use gRPC-Gateway to map the gRPC definitions to a RESTful API. The mappings are done inline in the proto file, using google.api.http annotations (docs here).

Using protocol buffers to define dual RPC and REST interfaces is a technique widely used at Google. We suggest taking a look at their excellent API design guide, which describes this pattern (notice it's multiple pages).

Generating

After changing the .proto file, you can re-generate the bindings by running (from the repo root):

go generate ./runtime/api

We also have a generated TypeScript client for the runtime in web-common/src/runtime-client. If relevant, you can re-generate it by running:

npm run generate:runtime-client -w web-common

(This is not automated as the frontend may be pinned to an older version of the runtime.)

Documentation

Overview

Package api is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

View Source 
var (
	TimeGrain_name = map[int32]string{
		0: "MILLISECOND",
		1: "SECOND",
		2: "MINUTE",
		3: "HOUR",
		4: "DAY",
		5: "WEEK",
		6: "MONTH",
		7: "YEAR",
		8: "UNSPECIFIED",
	}
	TimeGrain_value = map[string]int32{
		"MILLISECOND": 0,
		"SECOND":      1,
		"MINUTE":      2,
		"HOUR":        3,
		"DAY":         4,
		"WEEK":        5,
		"MONTH":       6,
		"YEAR":        7,
		"UNSPECIFIED": 8,
	}
)

Enum value maps for TimeGrain.

View Source 
var (
	TimeRangeName_name = map[int32]string{
		0: "LastHour",
		1: "Last6Hours",
		2: "LastDay",
		3: "Last2Days",
		4: "Last5Days",
		5: "LastWeek",
		6: "Last2Weeks",
		7: "Last30Days",
		8: "Last60Days",
		9: "AllTime",
	}
	TimeRangeName_value = map[string]int32{
		"LastHour":   0,
		"Last6Hours": 1,
		"LastDay":    2,
		"Last2Days":  3,
		"Last5Days":  4,
		"LastWeek":   5,
		"Last2Weeks": 6,
		"Last30Days": 7,
		"Last60Days": 8,
		"AllTime":    9,
	}
)

Enum value maps for TimeRangeName.

View Source 
var (
	DatabaseObjectType_name = map[int32]string{
		0: "TABLE",
		1: "VIEW",
		2: "FUNCTION",
	}
	DatabaseObjectType_value = map[string]int32{
		"TABLE":    0,
		"VIEW":     1,
		"FUNCTION": 2,
	}
)

Enum value maps for DatabaseObjectType.

View Source 
var (
	CatalogObject_Type_name = map[int32]string{
		0: "TYPE_UNSPECIFIED",
		1: "TYPE_TABLE",
		2: "TYPE_SOURCE",
		3: "TYPE_MODEL",
		4: "TYPE_METRICS_VIEW",
	}
	CatalogObject_Type_value = map[string]int32{
		"TYPE_UNSPECIFIED":  0,
		"TYPE_TABLE":        1,
		"TYPE_SOURCE":       2,
		"TYPE_MODEL":        3,
		"TYPE_METRICS_VIEW": 4,
	}
)

Enum value maps for CatalogObject_Type.

View Source 
var (
	Model_Dialect_name = map[int32]string{
		0: "DIALECT_UNSPECIFIED",
		1: "DIALECT_DUCKDB",
	}
	Model_Dialect_value = map[string]int32{
		"DIALECT_UNSPECIFIED": 0,
		"DIALECT_DUCKDB":      1,
	}
)

Enum value maps for Model_Dialect.

View Source 
var (
	MigrationError_Code_name = map[int32]string{
		0: "CODE_UNSPECIFIED",
		1: "CODE_SYNTAX",
		2: "CODE_VALIDATION",
		3: "CODE_DEPENDENCY",
		4: "CODE_OLAP",
		5: "CODE_SOURCE",
	}
	MigrationError_Code_value = map[string]int32{
		"CODE_UNSPECIFIED": 0,
		"CODE_SYNTAX":      1,
		"CODE_VALIDATION":  2,
		"CODE_DEPENDENCY":  3,
		"CODE_OLAP":        4,
		"CODE_SOURCE":      5,
	}
)

Enum value maps for MigrationError_Code.

View Source 
var (
	Connector_Property_Type_name = map[int32]string{
		0: "TYPE_UNSPECIFIED",
		1: "TYPE_STRING",
		2: "TYPE_NUMBER",
		3: "TYPE_BOOLEAN",
		4: "TYPE_INFORMATIONAL",
	}
	Connector_Property_Type_value = map[string]int32{
		"TYPE_UNSPECIFIED":   0,
		"TYPE_STRING":        1,
		"TYPE_NUMBER":        2,
		"TYPE_BOOLEAN":       3,
		"TYPE_INFORMATIONAL": 4,
	}
)

Enum value maps for Connector_Property_Type.

View Source 
var (
	Type_Code_name = map[int32]string{
		0:  "CODE_UNSPECIFIED",
		1:  "CODE_BOOL",
		2:  "CODE_INT8",
		3:  "CODE_INT16",
		4:  "CODE_INT32",
		5:  "CODE_INT64",
		6:  "CODE_INT128",
		7:  "CODE_UINT8",
		8:  "CODE_UINT16",
		9:  "CODE_UINT32",
		10: "CODE_UINT64",
		11: "CODE_UINT128",
		12: "CODE_FLOAT32",
		13: "CODE_FLOAT64",
		14: "CODE_TIMESTAMP",
		15: "CODE_DATE",
		16: "CODE_TIME",
		17: "CODE_STRING",
		18: "CODE_BYTES",
		19: "CODE_ARRAY",
		20: "CODE_STRUCT",
		21: "CODE_MAP",
		22: "CODE_DECIMAL",
		23: "CODE_JSON",
		24: "CODE_UUID",
	}
	Type_Code_value = map[string]int32{
		"CODE_UNSPECIFIED": 0,
		"CODE_BOOL":        1,
		"CODE_INT8":        2,
		"CODE_INT16":       3,
		"CODE_INT32":       4,
		"CODE_INT64":       5,
		"CODE_INT128":      6,
		"CODE_UINT8":       7,
		"CODE_UINT16":      8,
		"CODE_UINT32":      9,
		"CODE_UINT64":      10,
		"CODE_UINT128":     11,
		"CODE_FLOAT32":     12,
		"CODE_FLOAT64":     13,
		"CODE_TIMESTAMP":   14,
		"CODE_DATE":        15,
		"CODE_TIME":        16,
		"CODE_STRING":      17,
		"CODE_BYTES":       18,
		"CODE_ARRAY":       19,
		"CODE_STRUCT":      20,
		"CODE_MAP":         21,
		"CODE_DECIMAL":     22,
		"CODE_JSON":        23,
		"CODE_UUID":        24,
	}
)

Enum value maps for Type_Code.

View Source 
var File_runtime_proto protoreflect.FileDescriptor
View Source 
var RuntimeService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "rill.runtime.v1.RuntimeService",
	HandlerType: (*RuntimeServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Ping",
			Handler:    _RuntimeService_Ping_Handler,
		},
		{
			MethodName: "ListRepos",
			Handler:    _RuntimeService_ListRepos_Handler,
		},
		{
			MethodName: "GetRepo",
			Handler:    _RuntimeService_GetRepo_Handler,
		},
		{
			MethodName: "CreateRepo",
			Handler:    _RuntimeService_CreateRepo_Handler,
		},
		{
			MethodName: "DeleteRepo",
			Handler:    _RuntimeService_DeleteRepo_Handler,
		},
		{
			MethodName: "ListFiles",
			Handler:    _RuntimeService_ListFiles_Handler,
		},
		{
			MethodName: "GetFile",
			Handler:    _RuntimeService_GetFile_Handler,
		},
		{
			MethodName: "PutFile",
			Handler:    _RuntimeService_PutFile_Handler,
		},
		{
			MethodName: "DeleteFile",
			Handler:    _RuntimeService_DeleteFile_Handler,
		},
		{
			MethodName: "RenameFile",
			Handler:    _RuntimeService_RenameFile_Handler,
		},
		{
			MethodName: "ListInstances",
			Handler:    _RuntimeService_ListInstances_Handler,
		},
		{
			MethodName: "GetInstance",
			Handler:    _RuntimeService_GetInstance_Handler,
		},
		{
			MethodName: "CreateInstance",
			Handler:    _RuntimeService_CreateInstance_Handler,
		},
		{
			MethodName: "DeleteInstance",
			Handler:    _RuntimeService_DeleteInstance_Handler,
		},
		{
			MethodName: "ListCatalogObjects",
			Handler:    _RuntimeService_ListCatalogObjects_Handler,
		},
		{
			MethodName: "GetCatalogObject",
			Handler:    _RuntimeService_GetCatalogObject_Handler,
		},
		{
			MethodName: "TriggerRefresh",
			Handler:    _RuntimeService_TriggerRefresh_Handler,
		},
		{
			MethodName: "TriggerSync",
			Handler:    _RuntimeService_TriggerSync_Handler,
		},
		{
			MethodName: "Migrate",
			Handler:    _RuntimeService_Migrate_Handler,
		},
		{
			MethodName: "PutFileAndMigrate",
			Handler:    _RuntimeService_PutFileAndMigrate_Handler,
		},
		{
			MethodName: "DeleteFileAndMigrate",
			Handler:    _RuntimeService_DeleteFileAndMigrate_Handler,
		},
		{
			MethodName: "RenameFileAndMigrate",
			Handler:    _RuntimeService_RenameFileAndMigrate_Handler,
		},
		{
			MethodName: "MigrateSingle",
			Handler:    _RuntimeService_MigrateSingle_Handler,
		},
		{
			MethodName: "MigrateDelete",
			Handler:    _RuntimeService_MigrateDelete_Handler,
		},
		{
			MethodName: "Query",
			Handler:    _RuntimeService_Query_Handler,
		},
		{
			MethodName: "QueryDirect",
			Handler:    _RuntimeService_QueryDirect_Handler,
		},
		{
			MethodName: "MetricsViewMeta",
			Handler:    _RuntimeService_MetricsViewMeta_Handler,
		},
		{
			MethodName: "MetricsViewToplist",
			Handler:    _RuntimeService_MetricsViewToplist_Handler,
		},
		{
			MethodName: "MetricsViewTimeSeries",
			Handler:    _RuntimeService_MetricsViewTimeSeries_Handler,
		},
		{
			MethodName: "MetricsViewTotals",
			Handler:    _RuntimeService_MetricsViewTotals_Handler,
		},
		{
			MethodName: "EstimateRollupInterval",
			Handler:    _RuntimeService_EstimateRollupInterval_Handler,
		},
		{
			MethodName: "GetTopK",
			Handler:    _RuntimeService_GetTopK_Handler,
		},
		{
			MethodName: "GetNullCount",
			Handler:    _RuntimeService_GetNullCount_Handler,
		},
		{
			MethodName: "GetDescriptiveStatistics",
			Handler:    _RuntimeService_GetDescriptiveStatistics_Handler,
		},
		{
			MethodName: "EstimateSmallestTimeGrain",
			Handler:    _RuntimeService_EstimateSmallestTimeGrain_Handler,
		},
		{
			MethodName: "GetNumericHistogram",
			Handler:    _RuntimeService_GetNumericHistogram_Handler,
		},
		{
			MethodName: "GetRugHistogram",
			Handler:    _RuntimeService_GetRugHistogram_Handler,
		},
		{
			MethodName: "GetTimeRangeSummary",
			Handler:    _RuntimeService_GetTimeRangeSummary_Handler,
		},
		{
			MethodName: "GetCardinalityOfColumn",
			Handler:    _RuntimeService_GetCardinalityOfColumn_Handler,
		},
		{
			MethodName: "GenerateTimeSeries",
			Handler:    _RuntimeService_GenerateTimeSeries_Handler,
		},
		{
			MethodName: "RenameDatabaseObject",
			Handler:    _RuntimeService_RenameDatabaseObject_Handler,
		},
		{
			MethodName: "TableCardinality",
			Handler:    _RuntimeService_TableCardinality_Handler,
		},
		{
			MethodName: "ProfileColumns",
			Handler:    _RuntimeService_ProfileColumns_Handler,
		},
		{
			MethodName: "TableRows",
			Handler:    _RuntimeService_TableRows_Handler,
		},
		{
			MethodName: "ListConnectors",
			Handler:    _RuntimeService_ListConnectors_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "runtime.proto",
}

RuntimeService_ServiceDesc is the grpc.ServiceDesc for RuntimeService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterRuntimeServiceHandler 

func RegisterRuntimeServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterRuntimeServiceHandler registers the http handlers for service RuntimeService to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterRuntimeServiceHandlerClient 

func RegisterRuntimeServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client RuntimeServiceClient) error

RegisterRuntimeServiceHandlerClient registers the http handlers for service RuntimeService to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "RuntimeServiceClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "RuntimeServiceClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "RuntimeServiceClient" to call the correct interceptors.

func RegisterRuntimeServiceHandlerFromEndpoint 

func RegisterRuntimeServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterRuntimeServiceHandlerFromEndpoint is same as RegisterRuntimeServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterRuntimeServiceHandlerServer 

func RegisterRuntimeServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server RuntimeServiceServer) error

RegisterRuntimeServiceHandlerServer registers the http handlers for service RuntimeService to "mux". UnaryRPC :call RuntimeServiceServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterRuntimeServiceHandlerFromEndpoint instead.

func RegisterRuntimeServiceServer 

func RegisterRuntimeServiceServer(s grpc.ServiceRegistrar, srv RuntimeServiceServer)

Types

type BasicMeasureDefinition added in v0.15.0 

type BasicMeasureDefinition struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// mandatory user defined metadata
	Expression string `protobuf:"bytes,2,opt,name=expression,proto3" json:"expression,omitempty"`
	// optional user defined metadata
	SqlName *string `protobuf:"bytes,3,opt,name=sql_name,json=sqlName,proto3,oneof" json:"sql_name,omitempty"`
	// contains filtered or unexported fields
}

func (*BasicMeasureDefinition) Descriptor deprecated added in v0.15.0 

func (*BasicMeasureDefinition) Descriptor() ([]byte, []int)

Deprecated: Use BasicMeasureDefinition.ProtoReflect.Descriptor instead.

func (*BasicMeasureDefinition) GetExpression added in v0.15.0 

func (x *BasicMeasureDefinition) GetExpression() string

func (*BasicMeasureDefinition) GetId added in v0.15.0 

func (x *BasicMeasureDefinition) GetId() string

func (*BasicMeasureDefinition) GetSqlName added in v0.15.0 

func (x *BasicMeasureDefinition) GetSqlName() string

func (*BasicMeasureDefinition) ProtoMessage added in v0.15.0 

func (*BasicMeasureDefinition) ProtoMessage()

func (*BasicMeasureDefinition) ProtoReflect added in v0.15.0 

func (x *BasicMeasureDefinition) ProtoReflect() protoreflect.Message

func (*BasicMeasureDefinition) Reset added in v0.15.0 

func (x *BasicMeasureDefinition) Reset()

func (*BasicMeasureDefinition) String added in v0.15.0 

func (x *BasicMeasureDefinition) String() string

type CardinalityOfColumnRequest added in v0.15.0 

type CardinalityOfColumnRequest struct {
	InstanceId string `protobuf:"bytes,1,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"`
	TableName  string `protobuf:"bytes,2,opt,name=table_name,json=tableName,proto3" json:"table_name,omitempty"`
	ColumnName string `protobuf:"bytes,3,opt,name=column_name,json=columnName,proto3" json:"column_name,omitempty"`
	// contains filtered or unexported fields
}

Request for RuntimeService.GetCardinalityOfColumn. Returns the cardinality for a given column for table table_name

func (*CardinalityOfColumnRequest) Descriptor deprecated added in v0.15.0 

func (*CardinalityOfColumnRequest) Descriptor() ([]byte, []int)

Deprecated: Use CardinalityOfColumnRequest.ProtoReflect.Descriptor instead.

func (*CardinalityOfColumnRequest) GetColumnName added in v0.15.0 

func (x *CardinalityOfColumnRequest) GetColumnName() string

func (*CardinalityOfColumnRequest) GetInstanceId added in v0.15.0 

func (x *CardinalityOfColumnRequest) GetInstanceId() string

func (*CardinalityOfColumnRequest) GetTableName added in v0.15.0 

func (x *CardinalityOfColumnRequest) GetTableName() string

func (*CardinalityOfColumnRequest) ProtoMessage added in v0.15.0 

func (*CardinalityOfColumnRequest) ProtoMessage()

func (*CardinalityOfColumnRequest) ProtoReflect added in v0.15.0 

func (x *CardinalityOfColumnRequest) ProtoReflect() protoreflect.Message

func (*CardinalityOfColumnRequest) Reset added in v0.15.0 

func (x *CardinalityOfColumnRequest) Reset()

func (*CardinalityOfColumnRequest) String added in v0.15.0 

func (x *CardinalityOfColumnRequest) String() string

type CardinalityRequest added in v0.15.0 

type CardinalityRequest struct {
	InstanceId string `protobuf:"bytes,1,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"`
	TableName  string `protobuf:"bytes,2,opt,name=table_name,json=tableName,proto3" json:"table_name,omitempty"`
	// contains filtered or unexported fields
}

func (*CardinalityRequest) Descriptor deprecated added in v0.15.0 

func (*CardinalityRequest) Descriptor() ([]byte, []int)

Deprecated: Use CardinalityRequest.ProtoReflect.Descriptor instead.

func (*CardinalityRequest) GetInstanceId added in v0.15.0 

func (x *CardinalityRequest) GetInstanceId() string

func (*CardinalityRequest) GetTableName added in v0.15.0 

func (x *CardinalityRequest) GetTableName() string

func (*CardinalityRequest) ProtoMessage added in v0.15.0 

func (*CardinalityRequest) ProtoMessage()

func (*CardinalityRequest) ProtoReflect added in v0.15.0 

func (x *CardinalityRequest) ProtoReflect() protoreflect.Message

func (*CardinalityRequest) Reset added in v0.15.0 

func (x *CardinalityRequest) Reset()

func (*CardinalityRequest) String added in v0.15.0 

func (x *CardinalityRequest) String() string

type CardinalityResponse added in v0.15.0 

type CardinalityResponse struct {
	Cardinality int64 `protobuf:"varint,1,opt,name=cardinality,proto3" json:"cardinality,omitempty"`
	// contains filtered or unexported fields
}

func (*CardinalityResponse) Descriptor deprecated added in v0.15.0 

func (*CardinalityResponse) Descriptor() ([]byte, []int)

Deprecated: Use CardinalityResponse.ProtoReflect.Descriptor instead.

func (*CardinalityResponse) GetCardinality added in v0.15.0 

func (x *CardinalityResponse) GetCardinality() int64

func (*CardinalityResponse) ProtoMessage added in v0.15.0 

func (*CardinalityResponse) ProtoMessage()

func (*CardinalityResponse) ProtoReflect added in v0.15.0 

func (x *CardinalityResponse) ProtoReflect() protoreflect.Message

func (*CardinalityResponse) Reset added in v0.15.0 

func (x *CardinalityResponse) Reset()

func (*CardinalityResponse) String added in v0.15.0 

func (x *CardinalityResponse) String() string

type CatalogObject 

type CatalogObject struct {
	Type        CatalogObject_Type     `protobuf:"varint,1,opt,name=type,proto3,enum=rill.runtime.v1.CatalogObject_Type" json:"type,omitempty"`
	Table       *Table                 `protobuf:"bytes,2,opt,name=table,proto3" json:"table,omitempty"`
	Source      *Source                `protobuf:"bytes,3,opt,name=source,proto3" json:"source,omitempty"`
	Model       *Model                 `protobuf:"bytes,4,opt,name=model,proto3" json:"model,omitempty"`
	MetricsView *MetricsView           `protobuf:"bytes,5,opt,name=metrics_view,json=metricsView,proto3" json:"metrics_view,omitempty"`
	Name        string                 `protobuf:"bytes,6,opt,name=name,proto3" json:"name,omitempty"`
	Path        string                 `protobuf:"bytes,7,opt,name=path,proto3" json:"path,omitempty"`
	CreatedOn   *timestamppb.Timestamp `protobuf:"bytes,8,opt,name=created_on,json=createdOn,proto3" json:"created_on,omitempty"`
	UpdatedOn   *timestamppb.Timestamp `protobuf:"bytes,9,opt,name=updated_on,json=updatedOn,proto3" json:"updated_on,omitempty"`
	RefreshedOn *timestamppb.Timestamp `protobuf:"bytes,10,opt,name=refreshed_on,json=refreshedOn,proto3" json:"refreshed_on,omitempty"`
	// contains filtered or unexported fields
}

CatalogObject represents an object stored in the catalog

func (*CatalogObject) Descriptor deprecated 

func (*CatalogObject) Descriptor() ([]byte, []int)

Deprecated: Use CatalogObject.ProtoReflect.Descriptor instead.

func (*CatalogObject) GetCreatedOn added in v0.15.0 

func (x *CatalogObject) GetCreatedOn() *timestamppb.Timestamp

func (*CatalogObject) GetMetricsView 

func (x *CatalogObject) GetMetricsView() *MetricsView

func (*CatalogObject) GetModel added in v0.15.0 

func (x *CatalogObject) GetModel() *Model

func (*CatalogObject) GetName added in v0.15.0 

func (x *CatalogObject) GetName() string

func (*CatalogObject) GetPath added in v0.15.0 

func (x *CatalogObject) GetPath() string

func (*CatalogObject) GetRefreshedOn added in v0.13.0 

func (x *CatalogObject) GetRefreshedOn() *timestamppb.Timestamp

func (*CatalogObject) GetSource 

func (x *CatalogObject) GetSource() *Source

func (*CatalogObject) GetTable added in v0.15.0 

func (x *CatalogObject) GetTable() *Table

func (*CatalogObject) GetType 

func (x *CatalogObject) GetType() CatalogObject_Type

func (*CatalogObject) GetUpdatedOn added in v0.15.0 

func (x *CatalogObject) GetUpdatedOn() *timestamppb.Timestamp

func (*CatalogObject) ProtoMessage 

func (*CatalogObject) ProtoMessage()

func (*CatalogObject) ProtoReflect 

func (x *CatalogObject) ProtoReflect() protoreflect.Message

func (*CatalogObject) Reset 

func (x *CatalogObject) Reset()

func (*CatalogObject) String 

func (x *CatalogObject) String() string

type CatalogObject_Type added in v0.15.0 

type CatalogObject_Type int32
const (
	CatalogObject_TYPE_UNSPECIFIED  CatalogObject_Type = 0
	CatalogObject_TYPE_TABLE        CatalogObject_Type = 1
	CatalogObject_TYPE_SOURCE       CatalogObject_Type = 2
	CatalogObject_TYPE_MODEL        CatalogObject_Type = 3
	CatalogObject_TYPE_METRICS_VIEW CatalogObject_Type = 4
)

func (CatalogObject_Type) Descriptor added in v0.15.0 

func (CatalogObject_Type) Descriptor() protoreflect.EnumDescriptor

func (CatalogObject_Type) Enum added in v0.15.0 

func (x CatalogObject_Type) Enum() *CatalogObject_Type

func (CatalogObject_Type) EnumDescriptor deprecated added in v0.15.0 

func (CatalogObject_Type) EnumDescriptor() ([]byte, []int)

Deprecated: Use CatalogObject_Type.Descriptor instead.

func (CatalogObject_Type) Number added in v0.15.0 

func (x CatalogObject_Type) Number() protoreflect.EnumNumber

func (CatalogObject_Type) String added in v0.15.0 

func (x CatalogObject_Type) String() string

func (CatalogObject_Type) Type added in v0.15.0 

func (CatalogObject_Type) Type() protoreflect.EnumType

type CategoricalSummary added in v0.15.0 

type CategoricalSummary struct {
	TopKResponse *TopKResponse `protobuf:"bytes,1,opt,name=topKResponse,proto3,oneof" json:"topKResponse,omitempty"`
	Cardinality  *int64        `protobuf:"varint,2,opt,name=cardinality,proto3,oneof" json:"cardinality,omitempty"`
	// contains filtered or unexported fields
}

Response for RuntimeService.GetTopK and RuntimeService.GetCardinalityOfColumn. Message will have either topK or cardinality set.

func (*CategoricalSummary) Descriptor deprecated added in v0.15.0 

func (*CategoricalSummary) Descriptor() ([]byte, []int)

Deprecated: Use CategoricalSummary.ProtoReflect.Descriptor instead.

func (*CategoricalSummary) GetCardinality added in v0.15.0 

func (x *CategoricalSummary) GetCardinality() int64

func (*CategoricalSummary) GetTopKResponse added in v0.15.0 

func (x *CategoricalSummary) GetTopKResponse() *TopKResponse

func (*CategoricalSummary) ProtoMessage added in v0.15.0 

func (*CategoricalSummary) ProtoMessage()

func (*CategoricalSummary) ProtoReflect added in v0.15.0 

func (x *CategoricalSummary) ProtoReflect() protoreflect.Message

func (*CategoricalSummary) Reset added in v0.15.0 

func (x *CategoricalSummary) Reset()

func (*CategoricalSummary) String added in v0.15.0 

func (x *CategoricalSummary) String() string

type Connector 

type Connector struct {

	// Name is the name of the connector (e.g. "CREATE SOURCE foo WITH connector = 'name'")
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Pretty display name for use in UIs
	DisplayName string `protobuf:"bytes,2,opt,name=display_name,json=displayName,proto3" json:"display_name,omitempty"`
	// Human readable description of the connector
	Description string `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	// Properties accepted by the connector
	Properties []*Connector_Property `protobuf:"bytes,4,rep,name=properties,proto3" json:"properties,omitempty"`
	// contains filtered or unexported fields
}

Connector represents a connector available in the runtime. It should not be confused with a source.

func (*Connector) Descriptor deprecated 

func (*Connector) Descriptor() ([]byte, []int)

Deprecated: Use Connector.ProtoReflect.Descriptor instead.

func (*Connector) GetDescription 

func (x *Connector) GetDescription() string

func (*Connector) GetDisplayName 

func (x *Connector) GetDisplayName() string

func (*Connector) GetName 

func (x *Connector) GetName() string

func (*Connector) GetProperties 

func (x *Connector) GetProperties() []*Connector_Property

func (*Connector) ProtoMessage 

func (*Connector) ProtoMessage()

func (*Connector) ProtoReflect 

func (x *Connector) ProtoReflect() protoreflect.Message

func (*Connector) Reset 

func (x *Connector) Reset()

func (*Connector) String 

func (x *Connector) String() string

type Connector_Property 

type Connector_Property struct {

	// The property key
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// Pretty name for the property
	DisplayName string `protobuf:"bytes,2,opt,name=display_name,json=displayName,proto3" json:"display_name,omitempty"`
	// Human readable description of the field
	Description string `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	// Placeholder value for use in UIs
	Placeholder string `protobuf:"bytes,4,opt,name=placeholder,proto3" json:"placeholder,omitempty"`
	// The type expected for this property
	Type Connector_Property_Type `protobuf:"varint,5,opt,name=type,proto3,enum=rill.runtime.v1.Connector_Property_Type" json:"type,omitempty"`
	// Nullable is true if the field is optional
	Nullable bool `protobuf:"varint,6,opt,name=nullable,proto3" json:"nullable,omitempty"`
	// Additional textual explanation for use in UIs
	Hint string `protobuf:"bytes,7,opt,name=hint,proto3" json:"hint,omitempty"`
	// Link to documentation for this property
	Href string `protobuf:"bytes,8,opt,name=href,proto3" json:"href,omitempty"`
	// contains filtered or unexported fields
}

Property represents one of the connector's config properties

func (*Connector_Property) Descriptor deprecated 

func (*Connector_Property) Descriptor() ([]byte, []int)

Deprecated: Use Connector_Property.ProtoReflect.Descriptor instead.

func (*Connector_Property) GetDescription 

func (x *Connector_Property) GetDescription() string

func (*Connector_Property) GetDisplayName 

func (x *Connector_Property) GetDisplayName() string

func (*Connector_Property) GetHint added in v0.13.0 

func (x *Connector_Property) GetHint() string

func (*Connector_Property) GetHref added in v0.13.0 

func (x *Connector_Property) GetHref() string

func (*Connector_Property) GetKey 

func (x *Connector_Property) GetKey() string

func (*Connector_Property) GetNullable 

func (x *Connector_Property) GetNullable() bool

func (*Connector_Property) GetPlaceholder 

func (x *Connector_Property) GetPlaceholder() string

func (*Connector_Property) GetType 

func (x *Connector_Property) GetType() Connector_Property_Type

func (*Connector_Property) ProtoMessage 

func (*Connector_Property) ProtoMessage()

func (*Connector_Property) ProtoReflect 

func (x *Connector_Property) ProtoReflect() protoreflect.Message

func (*Connector_Property) Reset 

func (x *Connector_Property) Reset()

func (*Connector_Property) String 

func (x *Connector_Property) String() string

type Connector_Property_Type 

type Connector_Property_Type int32

Type represents the field type 

const (
	Connector_Property_TYPE_UNSPECIFIED   Connector_Property_Type = 0
	Connector_Property_TYPE_STRING        Connector_Property_Type = 1
	Connector_Property_TYPE_NUMBER        Connector_Property_Type = 2
	Connector_Property_TYPE_BOOLEAN       Connector_Property_Type = 3
	Connector_Property_TYPE_INFORMATIONAL Connector_Property_Type = 4
)

func (Connector_Property_Type) Descriptor 

func (Connector_Property_Type) Descriptor() protoreflect.EnumDescriptor

func (Connector_Property_Type) Enum 

func (x Connector_Property_Type) Enum() *Connector_Property_Type

func (Connector_Property_Type) EnumDescriptor deprecated 

func (Connector_Property_Type) EnumDescriptor() ([]byte, []int)

Deprecated: Use Connector_Property_Type.Descriptor instead.

func (Connector_Property_Type) Number 

func (x Connector_Property_Type) Number() protoreflect.EnumNumber

func (Connector_Property_Type) String 

func (x Connector_Property_Type) String() string

func (Connector_Property_Type) Type 

func (Connector_Property_Type) Type() protoreflect.EnumType

type CreateInstanceRequest 

type CreateInstanceRequest struct {

	// See message Instance for field descriptions
	InstanceId   string `protobuf:"bytes,1,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"`
	Driver       string `protobuf:"bytes,2,opt,name=driver,proto3" json:"driver,omitempty"`
	Dsn          string `protobuf:"bytes,3,opt,name=dsn,proto3" json:"dsn,omitempty"`
	ObjectPrefix string `protobuf:"bytes,4,opt,name=object_prefix,json=objectPrefix,proto3" json:"object_prefix,omitempty"`
	Exposed      bool   `protobuf:"varint,5,opt,name=exposed,proto3" json:"exposed,omitempty"`
	EmbedCatalog bool   `protobuf:"varint,6,opt,name=embed_catalog,json=embedCatalog,proto3" json:"embed_catalog,omitempty"`
	// contains filtered or unexported fields
}

Request message for RuntimeService.CreateInstance

func (*CreateInstanceRequest) Descriptor deprecated 

func (*CreateInstanceRequest) Descriptor() ([]byte, []int)

Deprecated: Use CreateInstanceRequest.ProtoReflect.Descriptor instead.

func (*CreateInstanceRequest) GetDriver 

func (x *CreateInstanceRequest) GetDriver() string

func (*CreateInstanceRequest) GetDsn 

func (x *CreateInstanceRequest) GetDsn() string

func (*CreateInstanceRequest) GetEmbedCatalog 

func (x *CreateInstanceRequest) GetEmbedCatalog() bool

func (*CreateInstanceRequest) GetExposed 

func (x *CreateInstanceRequest) GetExposed() bool

func (*CreateInstanceRequest) GetInstanceId added in v0.15.0 

func (x *CreateInstanceRequest) GetInstanceId() string

func (*CreateInstanceRequest) GetObjectPrefix 

func (x *CreateInstanceRequest) GetObjectPrefix() string

func (*CreateInstanceRequest) ProtoMessage 

func (*CreateInstanceRequest) ProtoMessage()

func (*CreateInstanceRequest) ProtoReflect 

func (x *CreateInstanceRequest) ProtoReflect() protoreflect.Message

func (*CreateInstanceRequest) Reset 

func (x *CreateInstanceRequest) Reset()

func (*CreateInstanceRequest) String 

func (x *CreateInstanceRequest) String() string

type CreateInstanceResponse 

type CreateInstanceResponse struct {
	InstanceId string    `protobuf:"bytes,1,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"` // Temporary, for compatibility with local frontend
	Instance   *Instance `protobuf:"bytes,2,opt,name=instance,proto3" json:"instance,omitempty"`
	// contains filtered or unexported fields
}

Response message for RuntimeService.CreateInstance

func (*CreateInstanceResponse) Descriptor deprecated 

func (*CreateInstanceResponse) Descriptor() ([]byte, []int)

Deprecated: Use CreateInstanceResponse.ProtoReflect.Descriptor instead.

func (*CreateInstanceResponse) GetInstance 

func (x *CreateInstanceResponse) GetInstance() *Instance

func (*CreateInstanceResponse) GetInstanceId 

func (x *CreateInstanceResponse) GetInstanceId() string

func (*CreateInstanceResponse) ProtoMessage 

func (*CreateInstanceResponse) ProtoMessage()

func (*CreateInstanceResponse) ProtoReflect 

func (x *CreateInstanceResponse) ProtoReflect() protoreflect.Message

func (*CreateInstanceResponse) Reset 

func (x *CreateInstanceResponse) Reset()

func (*CreateInstanceResponse) String 

func (x *CreateInstanceResponse) String() string

type CreateRepoRequest 

type CreateRepoRequest struct {
	RepoId string `protobuf:"bytes,1,opt,name=repo_id,json=repoId,proto3" json:"repo_id,omitempty"`
	Driver string `protobuf:"bytes,2,opt,name=driver,proto3" json:"driver,omitempty"`
	Dsn    string `protobuf:"bytes,3,opt,name=dsn,proto3" json:"dsn,omitempty"`
	// contains filtered or unexported fields
}

Request message for RuntimeService.CreateRepo

func (*CreateRepoRequest) Descriptor deprecated 

func (*CreateRepoRequest) Descriptor() ([]byte, []int)

Deprecated: Use CreateRepoRequest.ProtoReflect.Descriptor instead.

func (*CreateRepoRequest) GetDriver 

func (x *CreateRepoRequest) GetDriver() string

func (*CreateRepoRequest) GetDsn 

func (x *CreateRepoRequest) GetDsn() string

func (*CreateRepoRequest) GetRepoId added in v0.15.0 

func (x *CreateRepoRequest) GetRepoId() string

func (*CreateRepoRequest) ProtoMessage 

func (*CreateRepoRequest) ProtoMessage()

func (*CreateRepoRequest) ProtoReflect 

func (x *CreateRepoRequest) ProtoReflect() protoreflect.Message

func (*CreateRepoRequest) Reset 

func (x *CreateRepoRequest) Reset()

func (*CreateRepoRequest) String 

func (x *CreateRepoRequest) String() string

type CreateRepoResponse 

type CreateRepoResponse struct {
	Repo *Repo `protobuf:"bytes,1,opt,name=repo,proto3" json:"repo,omitempty"`
	// contains filtered or unexported fields
}

Response message for RuntimeService.CreateRepo

func (*CreateRepoResponse) Descriptor deprecated 

func (*CreateRepoResponse) Descriptor() ([]byte, []int)

Deprecated: Use CreateRepoResponse.ProtoReflect.Descriptor instead.

func (*CreateRepoResponse) GetRepo 

func (x *CreateRepoResponse) GetRepo() *Repo

func (*CreateRepoResponse) ProtoMessage 

func (*CreateRepoResponse) ProtoMessage()

func (*CreateRepoResponse) ProtoReflect 

func (x *CreateRepoResponse) ProtoReflect() protoreflect.Message

func (*CreateRepoResponse) Reset 

func (x *CreateRepoResponse) Reset()

func (*CreateRepoResponse) String 

func (x *CreateRepoResponse) String() string

type DatabaseObjectType added in v0.15.0 

type DatabaseObjectType int32
const (
	DatabaseObjectType_TABLE    DatabaseObjectType = 0
	DatabaseObjectType_VIEW     DatabaseObjectType = 1
	DatabaseObjectType_FUNCTION DatabaseObjectType = 2
)

func (DatabaseObjectType) Descriptor added in v0.15.0 

func (DatabaseObjectType) Descriptor() protoreflect.EnumDescriptor

func (DatabaseObjectType) Enum added in v0.15.0 

func (x DatabaseObjectType) Enum() *DatabaseObjectType

func (DatabaseObjectType) EnumDescriptor deprecated added in v0.15.0 

func (DatabaseObjectType) EnumDescriptor() ([]byte, []int)

Deprecated: Use DatabaseObjectType.Descriptor instead.

func (DatabaseObjectType) Number added in v0.15.0 

func (x DatabaseObjectType) Number() protoreflect.EnumNumber

func (DatabaseObjectType) String added in v0.15.0 

func (x DatabaseObjectType) String() string

func (DatabaseObjectType) Type added in v0.15.0 

func (DatabaseObjectType) Type() protoreflect.EnumType

type DeleteFileAndMigrateRequest added in v0.15.0 

type DeleteFileAndMigrateRequest struct {

	// Repo to store the file in
	RepoId string `protobuf:"bytes,1,opt,name=repo_id,json=repoId,proto3" json:"repo_id,omitempty"`
	// Instance to apply the migrations to
	InstanceId string `protobuf:"bytes,2,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"`
	// Path to store the file at
	Path string `protobuf:"bytes,3,opt,name=path,proto3" json:"path,omitempty"`
	// If true, will save the file and validate it and related file artifacts, but not actually execute any migrations.
	Dry bool `protobuf:"varint,4,opt,name=dry,proto3" json:"dry,omitempty"`
	// If true, will not execute any migrations if any artifact fails to validate.
	// Otherwise, it will execute a best-effort migration (including dropping objects with artifacts
	// that fail to validate.)
	Strict bool `protobuf:"varint,5,opt,name=strict,proto3" json:"strict,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteFileAndMigrateRequest) Descriptor deprecated added in v0.15.0 

func (*DeleteFileAndMigrateRequest) Descriptor() ([]byte, []int)

Deprecated: Use DeleteFileAndMigrateRequest.ProtoReflect.Descriptor instead.

func (*DeleteFileAndMigrateRequest) GetDry added in v0.15.0 

func (x *DeleteFileAndMigrateRequest) GetDry() bool

func (*DeleteFileAndMigrateRequest) GetInstanceId added in v0.15.0 

func (x *DeleteFileAndMigrateRequest) GetInstanceId() string

func (*DeleteFileAndMigrateRequest) GetPath added in v0.15.0 

func (x *DeleteFileAndMigrateRequest) GetPath() string

func (*DeleteFileAndMigrateRequest) GetRepoId added in v0.15.0 

func (x *DeleteFileAndMigrateRequest) GetRepoId() string

func (*DeleteFileAndMigrateRequest) GetStrict added in v0.15.0 

func (x *DeleteFileAndMigrateRequest) GetStrict() bool

func (*DeleteFileAndMigrateRequest) ProtoMessage added in v0.15.0 

func (*DeleteFileAndMigrateRequest) ProtoMessage()

func (*DeleteFileAndMigrateRequest) ProtoReflect added in v0.15.0 

func (x *DeleteFileAndMigrateRequest) ProtoReflect() protoreflect.Message

func (*DeleteFileAndMigrateRequest) Reset added in v0.15.0 

func (x *DeleteFileAndMigrateRequest) Reset()

func (*DeleteFileAndMigrateRequest) String added in v0.15.0 

func (x *DeleteFileAndMigrateRequest) String() string

type DeleteFileAndMigrateResponse added in v0.15.0 

type DeleteFileAndMigrateResponse struct {

	// Errors encountered during the migration. If strict = false, any path in
	// affected_paths without an error can be assumed to have been migrated succesfully.
	Errors []*MigrationError `protobuf:"bytes,1,rep,name=errors,proto3" json:"errors,omitempty"`
	// affected_paths lists all the file paths that were considered while
	// executing the migration. For a PutFileAndMigrate, this includes the put file
	// as well as any file artifacts that rely on objects declared in it.
	AffectedPaths []string `protobuf:"bytes,2,rep,name=affected_paths,json=affectedPaths,proto3" json:"affected_paths,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteFileAndMigrateResponse) Descriptor deprecated added in v0.15.0 

func (*DeleteFileAndMigrateResponse) Descriptor() ([]byte, []int)

Deprecated: Use DeleteFileAndMigrateResponse.ProtoReflect.Descriptor instead.

func (*DeleteFileAndMigrateResponse) GetAffectedPaths added in v0.15.0 

func (x *DeleteFileAndMigrateResponse) GetAffectedPaths() []string

func (*DeleteFileAndMigrateResponse) GetErrors added in v0.15.0 

func (x *DeleteFileAndMigrateResponse) GetErrors() []*MigrationError

func (*DeleteFileAndMigrateResponse) ProtoMessage added in v0.15.0 

func (*DeleteFileAndMigrateResponse) ProtoMessage()

func (*DeleteFileAndMigrateResponse) ProtoReflect added in v0.15.0 

func (x *DeleteFileAndMigrateResponse) ProtoReflect() protoreflect.Message

func (*DeleteFileAndMigrateResponse) Reset added in v0.15.0 

func (x *DeleteFileAndMigrateResponse) Reset()

func (*DeleteFileAndMigrateResponse) String added in v0.15.0 

func (x *DeleteFileAndMigrateResponse) String() string

type DeleteFileRequest added in v0.15.0 

type DeleteFileRequest struct {
	RepoId string `protobuf:"bytes,1,opt,name=repo_id,json=repoId,proto3" json:"repo_id,omitempty"`
	Path   string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	// contains filtered or unexported fields
}

Request message for RuntimeService.DeleteFile

func (*DeleteFileRequest) Descriptor deprecated added in v0.15.0 

func (*DeleteFileRequest) Descriptor() ([]byte, []int)

Deprecated: Use DeleteFileRequest.ProtoReflect.Descriptor instead.

func (*DeleteFileRequest) GetPath added in v0.15.0 

func (x *DeleteFileRequest) GetPath() string

func (*DeleteFileRequest) GetRepoId added in v0.15.0 

func (x *DeleteFileRequest) GetRepoId() string

func (*DeleteFileRequest) ProtoMessage added in v0.15.0 

func (*DeleteFileRequest) ProtoMessage()

func (*DeleteFileRequest) ProtoReflect added in v0.15.0 

func (x *DeleteFileRequest) ProtoReflect() protoreflect.Message

func (*DeleteFileRequest) Reset added in v0.15.0 

func (x *DeleteFileRequest) Reset()

func (*DeleteFileRequest) String added in v0.15.0 

func (x *DeleteFileRequest) String() string

type DeleteFileResponse added in v0.15.0 

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

Response message for RuntimeService.DeleteFile

func (*DeleteFileResponse) Descriptor deprecated added in v0.15.0 

func (*DeleteFileResponse) Descriptor() ([]byte, []int)

Deprecated: Use DeleteFileResponse.ProtoReflect.Descriptor instead.

func (*DeleteFileResponse) ProtoMessage added in v0.15.0 

func (*DeleteFileResponse) ProtoMessage()

func (*DeleteFileResponse) ProtoReflect added in v0.15.0 

func (x *DeleteFileResponse) ProtoReflect() protoreflect.Message

func (*DeleteFileResponse) Reset added in v0.15.0 

func (x *DeleteFileResponse) Reset()

func (*DeleteFileResponse) String added in v0.15.0 

func (x *DeleteFileResponse) String() string

type DeleteInstanceRequest 

type DeleteInstanceRequest struct {
	InstanceId string `protobuf:"bytes,1,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"`
	// contains filtered or unexported fields
}

Request message for RuntimeService.DeleteInstance

func (*DeleteInstanceRequest) Descriptor deprecated 

func (*DeleteInstanceRequest) Descriptor() ([]byte, []int)

Deprecated: Use DeleteInstanceRequest.ProtoReflect.Descriptor instead.

func (*DeleteInstanceRequest) GetInstanceId 

func (x *DeleteInstanceRequest) GetInstanceId() string

func (*DeleteInstanceRequest) ProtoMessage 

func (*DeleteInstanceRequest) ProtoMessage()

func (*DeleteInstanceRequest) ProtoReflect 

func (x *DeleteInstanceRequest) ProtoReflect() protoreflect.Message

func (*DeleteInstanceRequest) Reset 

func (x *DeleteInstanceRequest) Reset()

func (*DeleteInstanceRequest) String 

func (x *DeleteInstanceRequest) String() string

type DeleteInstanceResponse 

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

Response message for RuntimeService.DeleteInstance

func (*DeleteInstanceResponse) Descriptor deprecated 

func (*DeleteInstanceResponse) Descriptor() ([]byte, []int)

Deprecated: Use DeleteInstanceResponse.ProtoReflect.Descriptor instead.

func (*DeleteInstanceResponse) ProtoMessage 

func (*DeleteInstanceResponse) ProtoMessage()

func (*DeleteInstanceResponse) ProtoReflect 

func (x *DeleteInstanceResponse) ProtoReflect() protoreflect.Message

func (*DeleteInstanceResponse) Reset 

func (x *DeleteInstanceResponse) Reset()

func (*DeleteInstanceResponse) String 

func (x *DeleteInstanceResponse) String() string

type DeleteRepoRequest 

type DeleteRepoRequest struct {
	RepoId string `protobuf:"bytes,1,opt,name=repo_id,json=repoId,proto3" json:"repo_id,omitempty"`
	// contains filtered or unexported fields
}

Request message for RuntimeService.DeleteRepo

func (*DeleteRepoRequest) Descriptor deprecated 

func (*DeleteRepoRequest) Descriptor() ([]byte, []int)

Deprecated: Use DeleteRepoRequest.ProtoReflect.Descriptor instead.

func (*DeleteRepoRequest) GetRepoId 

func (x *DeleteRepoRequest) GetRepoId() string

func (*DeleteRepoRequest) ProtoMessage 

func (*DeleteRepoRequest) ProtoMessage()

func (*DeleteRepoRequest) ProtoReflect 

func (x *DeleteRepoRequest) ProtoReflect() protoreflect.Message

func (*DeleteRepoRequest) Reset 

func (x *DeleteRepoRequest) Reset()

func (*DeleteRepoRequest) String 

func (x *DeleteRepoRequest) String() string

type DeleteRepoResponse 

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

Response message for RuntimeService.DeleteRepo

func (*DeleteRepoResponse) Descriptor deprecated 

func (*DeleteRepoResponse) Descriptor() ([]byte, []int)

Deprecated: Use DeleteRepoResponse.ProtoReflect.Descriptor instead.

func (*DeleteRepoResponse) ProtoMessage 

func (*DeleteRepoResponse) ProtoMessage()

func (*DeleteRepoResponse) ProtoReflect 

func (x *DeleteRepoResponse) ProtoReflect() protoreflect.Message

func (*DeleteRepoResponse) Reset 

func (x *DeleteRepoResponse) Reset()

func (*DeleteRepoResponse) String 

func (x *DeleteRepoResponse) String() string

type DescriptiveStatisticsRequest added in v0.15.0 

type DescriptiveStatisticsRequest struct {
	InstanceId string `protobuf:"bytes,1,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"`
	TableName  string `protobuf:"bytes,2,opt,name=table_name,json=tableName,proto3" json:"table_name,omitempty"`
	ColumnName string `protobuf:"bytes,3,opt,name=column_name,json=columnName,proto3" json:"column_name,omitempty"`
	// contains filtered or unexported fields
}

Request for RuntimeService.GetDescriptiveStatisticsRequest. Returns the stats for a given column for table table_name

func (*DescriptiveStatisticsRequest) Descriptor deprecated added in v0.15.0 

func (*DescriptiveStatisticsRequest) Descriptor() ([]byte, []int)

Deprecated: Use DescriptiveStatisticsRequest.ProtoReflect.Descriptor instead.

func (*DescriptiveStatisticsRequest) GetColumnName added in v0.15.0 

func (x *DescriptiveStatisticsRequest) GetColumnName() string

func (*DescriptiveStatisticsRequest) GetInstanceId added in v0.15.0 

func (x *DescriptiveStatisticsRequest) GetInstanceId() string

func (*DescriptiveStatisticsRequest) GetTableName added in v0.15.0 

func (x *DescriptiveStatisticsRequest) GetTableName() string

func (*DescriptiveStatisticsRequest) ProtoMessage added in v0.15.0 

func (*DescriptiveStatisticsRequest) ProtoMessage()

func (*DescriptiveStatisticsRequest) ProtoReflect added in v0.15.0 

func (x *DescriptiveStatisticsRequest) ProtoReflect() protoreflect.Message

func (*DescriptiveStatisticsRequest) Reset added in v0.15.0 

func (x *DescriptiveStatisticsRequest) Reset()

func (*DescriptiveStatisticsRequest) String added in v0.15.0 

func (x *DescriptiveStatisticsRequest) String() string

type EstimateRollupIntervalRequest added in v0.15.0 

type EstimateRollupIntervalRequest struct {
	InstanceId string `protobuf:"bytes,1,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"`
	TableName  string `protobuf:"bytes,2,opt,name=table_name,json=tableName,proto3" json:"table_name,omitempty"`
	ColumnName string `protobuf:"bytes,3,opt,name=column_name,json=columnName,proto3" json:"column_name,omitempty"`
	// contains filtered or unexported fields
}

func (*EstimateRollupIntervalRequest) Descriptor deprecated added in v0.15.0 

func (*EstimateRollupIntervalRequest) Descriptor() ([]byte, []int)

Deprecated: Use EstimateRollupIntervalRequest.ProtoReflect.Descriptor instead.

func (*EstimateRollupIntervalRequest) GetColumnName added in v0.15.0 

func (x *EstimateRollupIntervalRequest) GetColumnName() string

func (*EstimateRollupIntervalRequest) GetInstanceId added in v0.15.0 

func (x *EstimateRollupIntervalRequest) GetInstanceId() string

func (*EstimateRollupIntervalRequest) GetTableName added in v0.15.0 

func (x *EstimateRollupIntervalRequest) GetTableName() string

func (*EstimateRollupIntervalRequest) ProtoMessage added in v0.15.0 

func (*EstimateRollupIntervalRequest) ProtoMessage()

func (*EstimateRollupIntervalRequest) ProtoReflect added in v0.15.0 

func (x *EstimateRollupIntervalRequest) ProtoReflect() protoreflect.Message

func (*EstimateRollupIntervalRequest) Reset added in v0.15.0 

func (x *EstimateRollupIntervalRequest) Reset()

func (*EstimateRollupIntervalRequest) String added in v0.15.0 

func (x *EstimateRollupIntervalRequest) String() string

type EstimateRollupIntervalResponse added in v0.15.0 

type EstimateRollupIntervalResponse struct {
	Interval int64   `protobuf:"varint,1,opt,name=interval,proto3" json:"interval,omitempty"`
	Min      *Scalar `protobuf:"bytes,2,opt,name=min,proto3" json:"min,omitempty"`
	Max      *Scalar `protobuf:"bytes,3,opt,name=max,proto3" json:"max,omitempty"`
	// contains filtered or unexported fields
}

func (*EstimateRollupIntervalResponse) Descriptor deprecated added in v0.15.0 

func (*EstimateRollupIntervalResponse) Descriptor() ([]byte, []int)

Deprecated: Use EstimateRollupIntervalResponse.ProtoReflect.Descriptor instead.

func (*EstimateRollupIntervalResponse) GetInterval added in v0.15.0 

func (x *EstimateRollupIntervalResponse) GetInterval() int64

func (*EstimateRollupIntervalResponse) GetMax added in v0.15.0 

func (x *EstimateRollupIntervalResponse) GetMax() *Scalar

func (*EstimateRollupIntervalResponse) GetMin added in v0.15.0 

func (x *EstimateRollupIntervalResponse) GetMin() *Scalar

func (*EstimateRollupIntervalResponse) ProtoMessage added in v0.15.0 

func (*EstimateRollupIntervalResponse) ProtoMessage()

func (*EstimateRollupIntervalResponse) ProtoReflect added in v0.15.0 

func (x *EstimateRollupIntervalResponse) ProtoReflect() protoreflect.Message

func (*EstimateRollupIntervalResponse) Reset added in v0.15.0 

func (x *EstimateRollupIntervalResponse) Reset()

func (*EstimateRollupIntervalResponse) String added in v0.15.0 

func (x *EstimateRollupIntervalResponse) String() string

type EstimateSmallestTimeGrainRequest added in v0.15.0 

type EstimateSmallestTimeGrainRequest struct {
	InstanceId string `protobuf:"bytes,1,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"`
	TableName  string `protobuf:"bytes,2,opt,name=table_name,json=tableName,proto3" json:"table_name,omitempty"`
	ColumnName string `protobuf:"bytes,3,opt,name=column_name,json=columnName,proto3" json:"column_name,omitempty"`
	// contains filtered or unexported fields
}

Request for RuntimeService.GetEstimateSmallestTimeGrainRequest

func (*EstimateSmallestTimeGrainRequest) Descriptor deprecated added in v0.15.0 

func (*EstimateSmallestTimeGrainRequest) Descriptor() ([]byte, []int)

Deprecated: Use EstimateSmallestTimeGrainRequest.ProtoReflect.Descriptor instead.

func (*EstimateSmallestTimeGrainRequest) GetColumnName added in v0.15.0 

func (x *EstimateSmallestTimeGrainRequest) GetColumnName() string

func (*EstimateSmallestTimeGrainRequest) GetInstanceId added in v0.15.0 

func (x *EstimateSmallestTimeGrainRequest) GetInstanceId() string

func (*EstimateSmallestTimeGrainRequest) GetTableName added in v0.15.0 

func (x *EstimateSmallestTimeGrainRequest) GetTableName() string

func (*EstimateSmallestTimeGrainRequest) ProtoMessage added in v0.15.0 

func (*EstimateSmallestTimeGrainRequest) ProtoMessage()

func (*EstimateSmallestTimeGrainRequest) ProtoReflect added in v0.15.0 

func (x *EstimateSmallestTimeGrainRequest) ProtoReflect() protoreflect.Message

func (*EstimateSmallestTimeGrainRequest) Reset added in v0.15.0 

func (x *EstimateSmallestTimeGrainRequest) Reset()

func (*EstimateSmallestTimeGrainRequest) String added in v0.15.0 

func (x *EstimateSmallestTimeGrainRequest) String() string

type EstimateSmallestTimeGrainResponse added in v0.15.0 

type EstimateSmallestTimeGrainResponse struct {
	TimeGrain TimeGrain `protobuf:"varint,1,opt,name=time_grain,json=timeGrain,proto3,enum=rill.runtime.v1.TimeGrain" json:"time_grain,omitempty"`
	// contains filtered or unexported fields
}

Response for RuntimeService.EstimateSmallestTimeGrain

func (*EstimateSmallestTimeGrainResponse) Descriptor deprecated added in v0.15.0 

func (*EstimateSmallestTimeGrainResponse) Descriptor() ([]byte, []int)

Deprecated: Use EstimateSmallestTimeGrainResponse.ProtoReflect.Descriptor instead.

func (*EstimateSmallestTimeGrainResponse) GetTimeGrain added in v0.15.0 

func (x *EstimateSmallestTimeGrainResponse) GetTimeGrain() TimeGrain

func (*EstimateSmallestTimeGrainResponse) ProtoMessage added in v0.15.0 

func (*EstimateSmallestTimeGrainResponse) ProtoMessage()

func (*EstimateSmallestTimeGrainResponse) ProtoReflect added in v0.15.0 

func (x *EstimateSmallestTimeGrainResponse) ProtoReflect() protoreflect.Message

func (*EstimateSmallestTimeGrainResponse) Reset added in v0.15.0 

func (x *EstimateSmallestTimeGrainResponse) Reset()

func (*EstimateSmallestTimeGrainResponse) String added in v0.15.0 

func (x *EstimateSmallestTimeGrainResponse) String() string

type GenerateTimeSeriesRequest added in v0.15.0 

type GenerateTimeSeriesRequest struct {
	InstanceId          string                                   `protobuf:"bytes,1,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"`
	TableName           string                                   `protobuf:"bytes,2,opt,name=table_name,json=tableName,proto3" json:"table_name,omitempty"`
	Measures            *GenerateTimeSeriesRequest_BasicMeasures `protobuf:"bytes,3,opt,name=measures,proto3,oneof" json:"measures,omitempty"`
	TimestampColumnName string                                   `protobuf:"bytes,4,opt,name=timestamp_column_name,json=timestampColumnName,proto3" json:"timestamp_column_name,omitempty"`
	TimeRange           *TimeSeriesTimeRange                     `protobuf:"bytes,5,opt,name=time_range,json=timeRange,proto3,oneof" json:"time_range,omitempty"`
	Filters             *MetricsViewRequestFilter                `protobuf:"bytes,6,opt,name=filters,proto3,oneof" json:"filters,omitempty"`
	Pixels              *int64                                   `protobuf:"varint,7,opt,name=pixels,proto3,oneof" json:"pixels,omitempty"`
	SampleSize          *int32                                   `protobuf:"varint,8,opt,name=sample_size,json=sampleSize,proto3,oneof" json:"sample_size,omitempty"`
	// contains filtered or unexported fields
}

func (*GenerateTimeSeriesRequest) Descriptor deprecated added in v0.15.0 

func (*GenerateTimeSeriesRequest) Descriptor() ([]byte, []int)

Deprecated: Use GenerateTimeSeriesRequest.ProtoReflect.Descriptor instead.

func (*GenerateTimeSeriesRequest) GetFilters added in v0.15.0 

func (x *GenerateTimeSeriesRequest) GetFilters() *MetricsViewRequestFilter

func (*GenerateTimeSeriesRequest) GetInstanceId added in v0.15.0 

func (x *GenerateTimeSeriesRequest) GetInstanceId() string

func (*GenerateTimeSeriesRequest) GetMeasures added in v0.15.0 

func (x *GenerateTimeSeriesRequest) GetMeasures() *GenerateTimeSeriesRequest_BasicMeasures

func (*GenerateTimeSeriesRequest) GetPixels added in v0.15.0 

func (x *GenerateTimeSeriesRequest) GetPixels() int64

func (*GenerateTimeSeriesRequest) GetSampleSize added in v0.15.0 

func (x *GenerateTimeSeriesRequest) GetSampleSize() int32

func (*GenerateTimeSeriesRequest) GetTableName added in v0.15.0 

func (x *GenerateTimeSeriesRequest) GetTableName() string

func (*GenerateTimeSeriesRequest) GetTimeRange added in v0.15.0 

func (x *GenerateTimeSeriesRequest) GetTimeRange() *TimeSeriesTimeRange

func (*GenerateTimeSeriesRequest) GetTimestampColumnName added in v0.15.0 

func (x *GenerateTimeSeriesRequest) GetTimestampColumnName() string

func (*GenerateTimeSeriesRequest) ProtoMessage added in v0.15.0 

func (*GenerateTimeSeriesRequest) ProtoMessage()

func (*GenerateTimeSeriesRequest) ProtoReflect added in v0.15.0 

func (x *GenerateTimeSeriesRequest) ProtoReflect() protoreflect.Message

func (*GenerateTimeSeriesRequest) Reset added in v0.15.0 

func (x *GenerateTimeSeriesRequest) Reset()

func (*GenerateTimeSeriesRequest) String added in v0.15.0 

func (x *GenerateTimeSeriesRequest) String() string

type GenerateTimeSeriesRequest_BasicMeasures added in v0.15.0 

type GenerateTimeSeriesRequest_BasicMeasures struct {
	BasicMeasures []*BasicMeasureDefinition `protobuf:"bytes,1,rep,name=basicMeasures,proto3" json:"basicMeasures,omitempty"`
	// contains filtered or unexported fields
}

func (*GenerateTimeSeriesRequest_BasicMeasures) Descriptor deprecated added in v0.15.0 

func (*GenerateTimeSeriesRequest_BasicMeasures) Descriptor() ([]byte, []int)

Deprecated: Use GenerateTimeSeriesRequest_BasicMeasures.ProtoReflect.Descriptor instead.

func (*GenerateTimeSeriesRequest_BasicMeasures) GetBasicMeasures added in v0.15.0 

func (x *GenerateTimeSeriesRequest_BasicMeasures) GetBasicMeasures() []*BasicMeasureDefinition

func (*GenerateTimeSeriesRequest_BasicMeasures) ProtoMessage added in v0.15.0 

func (*GenerateTimeSeriesRequest_BasicMeasures) ProtoMessage()

func (*GenerateTimeSeriesRequest_BasicMeasures) ProtoReflect added in v0.15.0 

func (x *GenerateTimeSeriesRequest_BasicMeasures) ProtoReflect() protoreflect.Message

func (*GenerateTimeSeriesRequest_BasicMeasures) Reset added in v0.15.0 

func (x *GenerateTimeSeriesRequest_BasicMeasures) Reset()

func (*GenerateTimeSeriesRequest_BasicMeasures) String added in v0.15.0 

func (x *GenerateTimeSeriesRequest_BasicMeasures) String() string

type GetCatalogObjectRequest 

type GetCatalogObjectRequest struct {
	InstanceId string `protobuf:"bytes,1,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"`
	Name       string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

Request message for RuntimeService.GetCatalogObject

func (*GetCatalogObjectRequest) Descriptor deprecated 

func (*GetCatalogObjectRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetCatalogObjectRequest.ProtoReflect.Descriptor instead.

func (*GetCatalogObjectRequest) GetInstanceId 

func (x *GetCatalogObjectRequest) GetInstanceId() string

func (*GetCatalogObjectRequest) GetName 

func (x *GetCatalogObjectRequest) GetName() string

func (*GetCatalogObjectRequest) ProtoMessage 

func (*GetCatalogObjectRequest) ProtoMessage()

func (*GetCatalogObjectRequest) ProtoReflect 

func (x *GetCatalogObjectRequest) ProtoReflect() protoreflect.Message

func (*GetCatalogObjectRequest) Reset 

func (x *GetCatalogObjectRequest) Reset()

func (*GetCatalogObjectRequest) String 

func (x *GetCatalogObjectRequest) String() string

type GetCatalogObjectResponse 

type GetCatalogObjectResponse struct {
	Object *CatalogObject `protobuf:"bytes,1,opt,name=object,proto3" json:"object,omitempty"`
	// contains filtered or unexported fields
}

Response message for RuntimeService.GetCatalogObject

func (*GetCatalogObjectResponse) Descriptor deprecated 

func (*GetCatalogObjectResponse) Descriptor() ([]byte, []int)

Deprecated: Use GetCatalogObjectResponse.ProtoReflect.Descriptor instead.

func (*GetCatalogObjectResponse) GetObject 

func (x *GetCatalogObjectResponse) GetObject() *CatalogObject

func (*GetCatalogObjectResponse) ProtoMessage 

func (*GetCatalogObjectResponse) ProtoMessage()

func (*GetCatalogObjectResponse) ProtoReflect 

func (x *GetCatalogObjectResponse) ProtoReflect() protoreflect.Message

func (*GetCatalogObjectResponse) Reset 

func (x *GetCatalogObjectResponse) Reset()

func (*GetCatalogObjectResponse) String 

func (x *GetCatalogObjectResponse) String() string

type GetFileRequest added in v0.15.0 

type GetFileRequest struct {
	RepoId string `protobuf:"bytes,1,opt,name=repo_id,json=repoId,proto3" json:"repo_id,omitempty"`
	Path   string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	// contains filtered or unexported fields
}

Request message for RuntimeService.GetFile

func (*GetFileRequest) Descriptor deprecated added in v0.15.0 

func (*GetFileRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetFileRequest.ProtoReflect.Descriptor instead.

func (*GetFileRequest) GetPath added in v0.15.0 

func (x *GetFileRequest) GetPath() string

func (*GetFileRequest) GetRepoId added in v0.15.0 

func (x *GetFileRequest) GetRepoId() string

func (*GetFileRequest) ProtoMessage added in v0.15.0 

func (*GetFileRequest) ProtoMessage()

func (*GetFileRequest) ProtoReflect added in v0.15.0 

func (x *GetFileRequest) ProtoReflect() protoreflect.Message

func (*GetFileRequest) Reset added in v0.15.0 

func (x *GetFileRequest) Reset()

func (*GetFileRequest) String added in v0.15.0 

func (x *GetFileRequest) String() string

type GetFileResponse added in v0.15.0 

type GetFileResponse struct {
	Blob      string                 `protobuf:"bytes,1,opt,name=blob,proto3" json:"blob,omitempty"`
	UpdatedOn *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=updated_on,json=updatedOn,proto3" json:"updated_on,omitempty"`
	// contains filtered or unexported fields
}

Reponse message for RuntimeService.GetFile

func (*GetFileResponse) Descriptor deprecated added in v0.15.0 

func (*GetFileResponse) Descriptor() ([]byte, []int)

Deprecated: Use GetFileResponse.ProtoReflect.Descriptor instead.

func (*GetFileResponse) GetBlob added in v0.15.0 

func (x *GetFileResponse) GetBlob() string

func (*GetFileResponse) GetUpdatedOn added in v0.15.0 

func (x *GetFileResponse) GetUpdatedOn() *timestamppb.Timestamp

func (*GetFileResponse) ProtoMessage added in v0.15.0 

func (*GetFileResponse) ProtoMessage()

func (*GetFileResponse) ProtoReflect added in v0.15.0 

func (x *GetFileResponse) ProtoReflect() protoreflect.Message

func (*GetFileResponse) Reset added in v0.15.0 

func (x *GetFileResponse) Reset()

func (*GetFileResponse) String added in v0.15.0 

func (x *GetFileResponse) String() string

type GetInstanceRequest 

type GetInstanceRequest struct {
	InstanceId string `protobuf:"bytes,1,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"`
	// contains filtered or unexported fields
}

Request message for RuntimeService.GetInstance

func (*GetInstanceRequest) Descriptor deprecated 

func (*GetInstanceRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetInstanceRequest.ProtoReflect.Descriptor instead.

func (*GetInstanceRequest) GetInstanceId 

func (x *GetInstanceRequest) GetInstanceId() string

func (*GetInstanceRequest) ProtoMessage 

func (*GetInstanceRequest) ProtoMessage()

func (*GetInstanceRequest) ProtoReflect 

func (x *GetInstanceRequest) ProtoReflect() protoreflect.Message

func (*GetInstanceRequest) Reset 

func (x *GetInstanceRequest) Reset()

func (*GetInstanceRequest) String 

func (x *GetInstanceRequest) String() string

type GetInstanceResponse 

type GetInstanceResponse struct {
	Instance *Instance `protobuf:"bytes,1,opt,name=instance,proto3" json:"instance,omitempty"`
	// contains filtered or unexported fields
}

Response message for RuntimeService.GetInstance

func (*GetInstanceResponse) Descriptor deprecated 

func (*GetInstanceResponse) Descriptor() ([]byte, []int)

Deprecated: Use GetInstanceResponse.ProtoReflect.Descriptor instead.

func (*GetInstanceResponse) GetInstance 

func (x *GetInstanceResponse) GetInstance() *Instance

func (*GetInstanceResponse) ProtoMessage 

func (*GetInstanceResponse) ProtoMessage()

func (*GetInstanceResponse) ProtoReflect 

func (x *GetInstanceResponse) ProtoReflect() protoreflect.Message

func (*GetInstanceResponse) Reset 

func (x *GetInstanceResponse) Reset()

func (*GetInstanceResponse) String 

func (x *GetInstanceResponse) String() string

type GetRepoRequest 

type GetRepoRequest struct {
	RepoId string `protobuf:"bytes,1,opt,name=repo_id,json=repoId,proto3" json:"repo_id,omitempty"`
	// contains filtered or unexported fields
}

Request message for RuntimeService.GetRepo

func (*GetRepoRequest) Descriptor deprecated 

func (*GetRepoRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetRepoRequest.ProtoReflect.Descriptor instead.

func (*GetRepoRequest) GetRepoId 

func (x *GetRepoRequest) GetRepoId() string

func (*GetRepoRequest) ProtoMessage 

func (*GetRepoRequest) ProtoMessage()

func (*GetRepoRequest) ProtoReflect 

func (x *GetRepoRequest) ProtoReflect() protoreflect.Message

func (*GetRepoRequest) Reset 

func (x *GetRepoRequest) Reset()

func (*GetRepoRequest) String 

func (x *GetRepoRequest) String() string

type GetRepoResponse 

type GetRepoResponse struct {
	Repo *Repo `protobuf:"bytes,1,opt,name=repo,proto3" json:"repo,omitempty"`
	// contains filtered or unexported fields
}

Response message for RuntimeService.GetRepo

func (*GetRepoResponse) Descriptor deprecated 

func (*GetRepoResponse) Descriptor() ([]byte, []int)

Deprecated: Use GetRepoResponse.ProtoReflect.Descriptor instead.

func (*GetRepoResponse) GetRepo 

func (x *GetRepoResponse) GetRepo() *Repo

func (*GetRepoResponse) ProtoMessage 

func (*GetRepoResponse) ProtoMessage()

func (*GetRepoResponse) ProtoReflect 

func (x *GetRepoResponse) ProtoReflect() protoreflect.Message

func (*GetRepoResponse) Reset 

func (x *GetRepoResponse) Reset()

func (*GetRepoResponse) String 

func (x *GetRepoResponse) String() string

type Instance 

type Instance struct {

	// Identifier (UUID)
	InstanceId string `protobuf:"bytes,1,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"`
	// Name of OLAP infra driver ("druid" or "duckdb")
	Driver string `protobuf:"bytes,2,opt,name=driver,proto3" json:"driver,omitempty"`
	// DSN for connection to the OLAP infra
	Dsn string `protobuf:"bytes,3,opt,name=dsn,proto3" json:"dsn,omitempty"`
	// Prefix to add to all table names created through Rill SQL (such as sources, models, etc.)
	// Use it as an alternative to database schemas.
	ObjectPrefix string `protobuf:"bytes,4,opt,name=object_prefix,json=objectPrefix,proto3" json:"object_prefix,omitempty"`
	// Indicates that the underlying infra may be manipulated directly by users.
	// If true, the runtime will continuously poll the infra's information schema
	// to discover tables not created through the runtime. They will be added to the
	// catalog as UnmanagedTables.
	Exposed bool `protobuf:"varint,5,opt,name=exposed,proto3" json:"exposed,omitempty"`
	// If true, the runtime will store the instance's catalog data (such as sources and metrics views)
	// in the instance's OLAP datastore instead of in the runtime's metadata store. This is currently
	// only supported for the duckdb driver.
	EmbedCatalog bool `protobuf:"varint,6,opt,name=embed_catalog,json=embedCatalog,proto3" json:"embed_catalog,omitempty"`
	// contains filtered or unexported fields
}

Instance represents one connection to an OLAP datastore (such as DuckDB or Druid). Migrations and queries are issued against a specific instance. The concept of instances enables multiple data projects to be served by one runtime.

func (*Instance) Descriptor deprecated 

func (*Instance) Descriptor() ([]byte, []int)

Deprecated: Use Instance.ProtoReflect.Descriptor instead.

func (*Instance) GetDriver 

func (x *Instance) GetDriver() string

func (*Instance) GetDsn 

func (x *Instance) GetDsn() string

func (*Instance) GetEmbedCatalog 

func (x *Instance) GetEmbedCatalog() bool

func (*Instance) GetExposed 

func (x *Instance) GetExposed() bool

func (*Instance) GetInstanceId 

func (x *Instance) GetInstanceId() string

func (*Instance) GetObjectPrefix 

func (x *Instance) GetObjectPrefix() string

func (*Instance) ProtoMessage 

func (*Instance) ProtoMessage()

func (*Instance) ProtoReflect 

func (x *Instance) ProtoReflect() protoreflect.Message

func (*Instance) Reset 

func (x *Instance) Reset()

func (*Instance) String 

func (x *Instance) String() string

type ListCatalogObjectsRequest 

type ListCatalogObjectsRequest struct {
	InstanceId string             `protobuf:"bytes,1,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"`
	Type       CatalogObject_Type `protobuf:"varint,2,opt,name=type,proto3,enum=rill.runtime.v1.CatalogObject_Type" json:"type,omitempty"`
	// contains filtered or unexported fields
}

Request message for RuntimeService.ListCatalogObjects

func (*ListCatalogObjectsRequest) Descriptor deprecated 

func (*ListCatalogObjectsRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListCatalogObjectsRequest.ProtoReflect.Descriptor instead.

func (*ListCatalogObjectsRequest) GetInstanceId 

func (x *ListCatalogObjectsRequest) GetInstanceId() string

func (*ListCatalogObjectsRequest) GetType added in v0.15.0 

func (x *ListCatalogObjectsRequest) GetType() CatalogObject_Type

func (*ListCatalogObjectsRequest) ProtoMessage 

func (*ListCatalogObjectsRequest) ProtoMessage()

func (*ListCatalogObjectsRequest) ProtoReflect 

func (x *ListCatalogObjectsRequest) ProtoReflect() protoreflect.Message

func (*ListCatalogObjectsRequest) Reset 

func (x *ListCatalogObjectsRequest) Reset()

func (*ListCatalogObjectsRequest) String 

func (x *ListCatalogObjectsRequest) String() string

type ListCatalogObjectsResponse 

type ListCatalogObjectsResponse struct {
	Objects []*CatalogObject `protobuf:"bytes,1,rep,name=objects,proto3" json:"objects,omitempty"`
	// contains filtered or unexported fields
}

Response message for RuntimeService.ListCatalogObjects

func (*ListCatalogObjectsResponse) Descriptor deprecated 

func (*ListCatalogObjectsResponse) Descriptor() ([]byte, []int)

Deprecated: Use ListCatalogObjectsResponse.ProtoReflect.Descriptor instead.

func (*ListCatalogObjectsResponse) GetObjects 

func (x *ListCatalogObjectsResponse) GetObjects() []*CatalogObject

func (*ListCatalogObjectsResponse) ProtoMessage 

func (*ListCatalogObjectsResponse) ProtoMessage()

func (*ListCatalogObjectsResponse) ProtoReflect 

func (x *ListCatalogObjectsResponse) ProtoReflect() protoreflect.Message

func (*ListCatalogObjectsResponse) Reset 

func (x *ListCatalogObjectsResponse) Reset()

func (*ListCatalogObjectsResponse) String 

func (x *ListCatalogObjectsResponse) String() string

type ListConnectorsRequest 

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

Request message for RuntimeService.ListConnectors

func (*ListConnectorsRequest) Descriptor deprecated 

func (*ListConnectorsRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListConnectorsRequest.ProtoReflect.Descriptor instead.

func (*ListConnectorsRequest) ProtoMessage 

func (*ListConnectorsRequest) ProtoMessage()

func (*ListConnectorsRequest) ProtoReflect 

func (x *ListConnectorsRequest) ProtoReflect() protoreflect.Message

func (*ListConnectorsRequest) Reset 

func (x *ListConnectorsRequest) Reset()

func (*ListConnectorsRequest) String 

func (x *ListConnectorsRequest) String() string

type ListConnectorsResponse 

type ListConnectorsResponse struct {
	Connectors []*Connector `protobuf:"bytes,1,rep,name=connectors,proto3" json:"connectors,omitempty"`
	// contains filtered or unexported fields
}

Response message for RuntimeService.ListConnectors

func (*ListConnectorsResponse) Descriptor deprecated 

func (*ListConnectorsResponse) Descriptor() ([]byte, []int)

Deprecated: Use ListConnectorsResponse.ProtoReflect.Descriptor instead.

func (*ListConnectorsResponse) GetConnectors 

func (x *ListConnectorsResponse) GetConnectors() []*Connector

func (*ListConnectorsResponse) ProtoMessage 

func (*ListConnectorsResponse) ProtoMessage()

func (*ListConnectorsResponse) ProtoReflect 

func (x *ListConnectorsResponse) ProtoReflect() protoreflect.Message

func (*ListConnectorsResponse) Reset 

func (x *ListConnectorsResponse) Reset()

func (*ListConnectorsResponse) String 

func (x *ListConnectorsResponse) String() string

type ListFilesRequest added in v0.15.0 

type ListFilesRequest struct {
	RepoId string `protobuf:"bytes,1,opt,name=repo_id,json=repoId,proto3" json:"repo_id,omitempty"`
	Glob   string `protobuf:"bytes,2,opt,name=glob,proto3" json:"glob,omitempty"`
	// contains filtered or unexported fields
}

Request message for RuntimeService.ListFiles

func (*ListFilesRequest) Descriptor deprecated added in v0.15.0 

func (*ListFilesRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListFilesRequest.ProtoReflect.Descriptor instead.

func (*ListFilesRequest) GetGlob added in v0.15.0 

func (x *ListFilesRequest) GetGlob() string

func (*ListFilesRequest) GetRepoId added in v0.15.0 

func (x *ListFilesRequest) GetRepoId() string

func (*ListFilesRequest) ProtoMessage added in v0.15.0 

func (*ListFilesRequest) ProtoMessage()

func (*ListFilesRequest) ProtoReflect added in v0.15.0 

func (x *ListFilesRequest) ProtoReflect() protoreflect.Message

func (*ListFilesRequest) Reset added in v0.15.0 

func (x *ListFilesRequest) Reset()

func (*ListFilesRequest) String added in v0.15.0 

func (x *ListFilesRequest) String() string

type ListFilesResponse added in v0.15.0 

type ListFilesResponse struct {
	Paths []string `protobuf:"bytes,1,rep,name=paths,proto3" json:"paths,omitempty"`
	// contains filtered or unexported fields
}

Response message for RuntimeService.ListFiles

func (*ListFilesResponse) Descriptor deprecated added in v0.15.0 

func (*ListFilesResponse) Descriptor() ([]byte, []int)

Deprecated: Use ListFilesResponse.ProtoReflect.Descriptor instead.

func (*ListFilesResponse) GetPaths added in v0.15.0 

func (x *ListFilesResponse) GetPaths() []string

func (*ListFilesResponse) ProtoMessage added in v0.15.0 

func (*ListFilesResponse) ProtoMessage()

func (*ListFilesResponse) ProtoReflect added in v0.15.0 

func (x *ListFilesResponse) ProtoReflect() protoreflect.Message

func (*ListFilesResponse) Reset added in v0.15.0 

func (x *ListFilesResponse) Reset()

func (*ListFilesResponse) String added in v0.15.0 

func (x *ListFilesResponse) String() string

type ListInstancesRequest 

type ListInstancesRequest struct {
	PageSize  int32  `protobuf:"varint,1,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	PageToken string `protobuf:"bytes,2,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// contains filtered or unexported fields
}

Request message for RuntimeService.ListInstances

func (*ListInstancesRequest) Descriptor deprecated 

func (*ListInstancesRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListInstancesRequest.ProtoReflect.Descriptor instead.

func (*ListInstancesRequest) GetPageSize 

func (x *ListInstancesRequest) GetPageSize() int32

func (*ListInstancesRequest) GetPageToken 

func (x *ListInstancesRequest) GetPageToken() string

func (*ListInstancesRequest) ProtoMessage 

func (*ListInstancesRequest) ProtoMessage()

func (*ListInstancesRequest) ProtoReflect 

func (x *ListInstancesRequest) ProtoReflect() protoreflect.Message

func (*ListInstancesRequest) Reset 

func (x *ListInstancesRequest) Reset()

func (*ListInstancesRequest) String 

func (x *ListInstancesRequest) String() string

type ListInstancesResponse 

type ListInstancesResponse struct {
	Instances     []*Instance `protobuf:"bytes,1,rep,name=instances,proto3" json:"instances,omitempty"`
	NextPageToken string      `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// contains filtered or unexported fields
}

Response message for RuntimeService.ListInstances

func (*ListInstancesResponse) Descriptor deprecated 

func (*ListInstancesResponse) Descriptor() ([]byte, []int)

Deprecated: Use ListInstancesResponse.ProtoReflect.Descriptor instead.

func (*ListInstancesResponse) GetInstances 

func (x *ListInstancesResponse) GetInstances() []*Instance

func (*ListInstancesResponse) GetNextPageToken 

func (x *ListInstancesResponse) GetNextPageToken() string

func (*ListInstancesResponse) ProtoMessage 

func (*ListInstancesResponse) ProtoMessage()

func (*ListInstancesResponse) ProtoReflect 

func (x *ListInstancesResponse) ProtoReflect() protoreflect.Message

func (*ListInstancesResponse) Reset 

func (x *ListInstancesResponse) Reset()

func (*ListInstancesResponse) String 

func (x *ListInstancesResponse) String() string

type ListReposRequest 

type ListReposRequest struct {
	PageSize  int32  `protobuf:"varint,1,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	PageToken string `protobuf:"bytes,2,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// contains filtered or unexported fields
}

Request message for RuntimeService.ListRepos

func (*ListReposRequest) Descriptor deprecated 

func (*ListReposRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListReposRequest.ProtoReflect.Descriptor instead.

func (*ListReposRequest) GetPageSize 

func (x *ListReposRequest) GetPageSize() int32

func (*ListReposRequest) GetPageToken 

func (x *ListReposRequest) GetPageToken() string

func (*ListReposRequest) ProtoMessage 

func (*ListReposRequest) ProtoMessage()

func (*ListReposRequest) ProtoReflect 

func (x *ListReposRequest) ProtoReflect() protoreflect.Message

func (*ListReposRequest) Reset 

func (x *ListReposRequest) Reset()

func (*ListReposRequest) String 

func (x *ListReposRequest) String() string

type ListReposResponse 

type ListReposResponse struct {
	Repos         []*Repo `protobuf:"bytes,1,rep,name=repos,proto3" json:"repos,omitempty"`
	NextPageToken string  `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// contains filtered or unexported fields
}

Response message for RuntimeService.ListRepos

func (*ListReposResponse) Descriptor deprecated 

func (*ListReposResponse) Descriptor() ([]byte, []int)

Deprecated: Use ListReposResponse.ProtoReflect.Descriptor instead.

func (*ListReposResponse) GetNextPageToken 

func (x *ListReposResponse) GetNextPageToken() string

func (*ListReposResponse) GetRepos 

func (x *ListReposResponse) GetRepos() []*Repo

func (*ListReposResponse) ProtoMessage 

func (*ListReposResponse) ProtoMessage()

func (*ListReposResponse) ProtoReflect 

func (x *ListReposResponse) ProtoReflect() protoreflect.Message

func (*ListReposResponse) Reset 

func (x *ListReposResponse) Reset()

func (*ListReposResponse) String 

func (x *ListReposResponse) String() string

type MapType added in v0.15.0 

type MapType struct {
	KeyType   *Type `protobuf:"bytes,1,opt,name=key_type,json=keyType,proto3" json:"key_type,omitempty"`
	ValueType *Type `protobuf:"bytes,2,opt,name=value_type,json=valueType,proto3" json:"value_type,omitempty"`
	// contains filtered or unexported fields
}

MapType is a complex type for mapping keys to values

func (*MapType) Descriptor deprecated added in v0.15.0 

func (*MapType) Descriptor() ([]byte, []int)

Deprecated: Use MapType.ProtoReflect.Descriptor instead.

func (*MapType) GetKeyType added in v0.15.0 

func (x *MapType) GetKeyType() *Type

func (*MapType) GetValueType added in v0.15.0 

func (x *MapType) GetValueType() *Type

func (*MapType) ProtoMessage added in v0.15.0 

func (*MapType) ProtoMessage()

func (*MapType) ProtoReflect added in v0.15.0 

func (x *MapType) ProtoReflect() protoreflect.Message

func (*MapType) Reset added in v0.15.0 

func (x *MapType) Reset()

func (*MapType) String added in v0.15.0 

func (x *MapType) String() string

type MetricsView 

type MetricsView struct {

	// Name of the metrics view
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Name of the source or model that the metrics view is based on
	From string `protobuf:"bytes,2,opt,name=from,proto3" json:"from,omitempty"`
	// Name of the primary time dimension, used for rendering time series
	TimeDimension string `protobuf:"bytes,3,opt,name=time_dimension,json=timeDimension,proto3" json:"time_dimension,omitempty"`
	// Recommended granularities for rolling up the time dimension.
	// Should be a valid SQL INTERVAL value.
	TimeGrains []string `protobuf:"bytes,4,rep,name=time_grains,json=timeGrains,proto3" json:"time_grains,omitempty"`
	// Dimensions in the metrics view
	Dimensions []*MetricsView_Dimension `protobuf:"bytes,5,rep,name=dimensions,proto3" json:"dimensions,omitempty"`
	// Measures in the metrics view
	Measures []*MetricsView_Measure `protobuf:"bytes,6,rep,name=measures,proto3" json:"measures,omitempty"`
	// contains filtered or unexported fields
}

Metrics view is the internal representation of a metrics view definition

func (*MetricsView) Descriptor deprecated 

func (*MetricsView) Descriptor() ([]byte, []int)

Deprecated: Use MetricsView.ProtoReflect.Descriptor instead.

func (*MetricsView) GetDimensions 

func (x *MetricsView) GetDimensions() []*MetricsView_Dimension

func (*MetricsView) GetFrom added in v0.15.0 

func (x *MetricsView) GetFrom() string

func (*MetricsView) GetMeasures 

func (x *MetricsView) GetMeasures() []*MetricsView_Measure

func (*MetricsView) GetName 

func (x *MetricsView) GetName() string

func (*MetricsView) GetTimeDimension added in v0.15.0 

func (x *MetricsView) GetTimeDimension() string

func (*MetricsView) GetTimeGrains added in v0.15.0 

func (x *MetricsView) GetTimeGrains() []string

func (*MetricsView) ProtoMessage 

func (*MetricsView) ProtoMessage()

func (*MetricsView) ProtoReflect 

func (x *MetricsView) ProtoReflect() protoreflect.Message

func (*MetricsView) Reset 

func (x *MetricsView) Reset()

func (*MetricsView) String 

func (x *MetricsView) String() string

type MetricsViewColumn added in v0.15.0 

type MetricsViewColumn struct {
	Name     string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Type     string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	Nullable bool   `protobuf:"varint,3,opt,name=nullable,proto3" json:"nullable,omitempty"`
	// contains filtered or unexported fields
}

MetricsViewColumn represents a column in a metrics view

func (*MetricsViewColumn) Descriptor deprecated added in v0.15.0 

func (*MetricsViewColumn) Descriptor() ([]byte, []int)

Deprecated: Use MetricsViewColumn.ProtoReflect.Descriptor instead.

func (*MetricsViewColumn) GetName added in v0.15.0 

func (x *MetricsViewColumn) GetName() string

func (*MetricsViewColumn) GetNullable added in v0.15.0 

func (x *MetricsViewColumn) GetNullable() bool

func (*MetricsViewColumn) GetType added in v0.15.0 

func (x *MetricsViewColumn) GetType() string

func (*MetricsViewColumn) ProtoMessage added in v0.15.0 

func (*MetricsViewColumn) ProtoMessage()

func (*MetricsViewColumn) ProtoReflect added in v0.15.0 

func (x *MetricsViewColumn) ProtoReflect() protoreflect.Message

func (*MetricsViewColumn) Reset added in v0.15.0 

func (x *MetricsViewColumn) Reset()

func (*MetricsViewColumn) String added in v0.15.0 

func (x *MetricsViewColumn) String() string

type MetricsViewDimensionValue added in v0.15.0 

type MetricsViewDimensionValue struct {
	Name string                            `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	In   []*structpb.Value                 `protobuf:"bytes,2,rep,name=in,proto3" json:"in,omitempty"`
	Like *MetricsViewDimensionValue_Values `protobuf:"bytes,3,opt,name=like,proto3,oneof" json:"like,omitempty"`
	// contains filtered or unexported fields
}

func (*MetricsViewDimensionValue) Descriptor deprecated added in v0.15.0 

func (*MetricsViewDimensionValue) Descriptor() ([]byte, []int)

Deprecated: Use MetricsViewDimensionValue.ProtoReflect.Descriptor instead.

func (*MetricsViewDimensionValue) GetIn added in v0.15.0 

func (x *MetricsViewDimensionValue) GetIn() []*structpb.Value

func (*MetricsViewDimensionValue) GetLike added in v0.15.0 

func (x *MetricsViewDimensionValue) GetLike() *MetricsViewDimensionValue_Values

func (*MetricsViewDimensionValue) GetName added in v0.15.0 

func (x *MetricsViewDimensionValue) GetName() string

func (*MetricsViewDimensionValue) ProtoMessage added in v0.15.0 

func (*MetricsViewDimensionValue) ProtoMessage()

func (*MetricsViewDimensionValue) ProtoReflect added in v0.15.0 

func (x *MetricsViewDimensionValue) ProtoReflect() protoreflect.Message

func (*MetricsViewDimensionValue) Reset added in v0.15.0 

func (x *MetricsViewDimensionValue) Reset()

func (*MetricsViewDimensionValue) String added in v0.15.0 

func (x *MetricsViewDimensionValue) String() string

type MetricsViewDimensionValue_Values added in v0.15.0 

type MetricsViewDimensionValue_Values struct {
	Values []*structpb.Value `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

func (*MetricsViewDimensionValue_Values) Descriptor deprecated added in v0.15.0 

func (*MetricsViewDimensionValue_Values) Descriptor() ([]byte, []int)

Deprecated: Use MetricsViewDimensionValue_Values.ProtoReflect.Descriptor instead.

func (*MetricsViewDimensionValue_Values) GetValues added in v0.15.0 

func (x *MetricsViewDimensionValue_Values) GetValues() []*structpb.Value

func (*MetricsViewDimensionValue_Values) ProtoMessage added in v0.15.0 

func (*MetricsViewDimensionValue_Values) ProtoMessage()

func (*MetricsViewDimensionValue_Values) ProtoReflect added in v0.15.0 

func (x *MetricsViewDimensionValue_Values) ProtoReflect() protoreflect.Message

func (*MetricsViewDimensionValue_Values) Reset added in v0.15.0 

func (x *MetricsViewDimensionValue_Values) Reset()

func (*MetricsViewDimensionValue_Values) String added in v0.15.0 

func (x *MetricsViewDimensionValue_Values) String() string

type MetricsViewFilter 

type MetricsViewFilter struct {
	Match   []string                  `protobuf:"bytes,1,rep,name=match,proto3" json:"match,omitempty"`
	Include []*MetricsViewFilter_Cond `protobuf:"bytes,2,rep,name=include,proto3" json:"include,omitempty"`
	Exclude []*MetricsViewFilter_Cond `protobuf:"bytes,3,rep,name=exclude,proto3" json:"exclude,omitempty"`
	// contains filtered or unexported fields
}

Filter clause for metrics view requests

func (*MetricsViewFilter) Descriptor deprecated 

func (*MetricsViewFilter) Descriptor() ([]byte, []int)

Deprecated: Use MetricsViewFilter.ProtoReflect.Descriptor instead.

func (*MetricsViewFilter) GetExclude 

func (x *MetricsViewFilter) GetExclude() []*MetricsViewFilter_Cond

func (*MetricsViewFilter) GetInclude 

func (x *MetricsViewFilter) GetInclude() []*MetricsViewFilter_Cond

func (*MetricsViewFilter) GetMatch 

func (x *MetricsViewFilter) GetMatch() []string

func (*MetricsViewFilter) ProtoMessage 

func (*MetricsViewFilter) ProtoMessage()

func (*MetricsViewFilter) ProtoReflect 

func (x *MetricsViewFilter) ProtoReflect() protoreflect.Message

func (*MetricsViewFilter) Reset 

func (x *MetricsViewFilter) Reset()

func (*MetricsViewFilter) String 

func (x *MetricsViewFilter) String() string

type MetricsViewFilter_Cond 

type MetricsViewFilter_Cond struct {
	Name string            `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	In   []*structpb.Value `protobuf:"bytes,2,rep,name=in,proto3" json:"in,omitempty"`
	Like []*structpb.Value `protobuf:"bytes,3,rep,name=like,proto3" json:"like,omitempty"`
	// contains filtered or unexported fields
}

func (*MetricsViewFilter_Cond) Descriptor deprecated 

func (*MetricsViewFilter_Cond) Descriptor() ([]byte, []int)

Deprecated: Use MetricsViewFilter_Cond.ProtoReflect.Descriptor instead.

func (*MetricsViewFilter_Cond) GetIn 

func (x *MetricsViewFilter_Cond) GetIn() []*structpb.Value

func (*MetricsViewFilter_Cond) GetLike 

func (x *MetricsViewFilter_Cond) GetLike() []*structpb.Value

func (*MetricsViewFilter_Cond) GetName 

func (x *MetricsViewFilter_Cond) GetName() string

func (*MetricsViewFilter_Cond) ProtoMessage 

func (*MetricsViewFilter_Cond) ProtoMessage()

func (*MetricsViewFilter_Cond) ProtoReflect 

func (x *MetricsViewFilter_Cond) ProtoReflect() protoreflect.Message

func (*MetricsViewFilter_Cond) Reset 

func (x *MetricsViewFilter_Cond) Reset()

func (*MetricsViewFilter_Cond) String 

func (x *MetricsViewFilter_Cond) String() string

type MetricsViewMetaRequest 

type MetricsViewMetaRequest struct {
	InstanceId      string `protobuf:"bytes,1,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"`
	MetricsViewName string `protobuf:"bytes,2,opt,name=metrics_view_name,json=metricsViewName,proto3" json:"metrics_view_name,omitempty"`
	// contains filtered or unexported fields
}

Request message for RuntimeService.MetricsViewMeta

func (*MetricsViewMetaRequest) Descriptor deprecated 

func (*MetricsViewMetaRequest) Descriptor() ([]byte, []int)

Deprecated: Use MetricsViewMetaRequest.ProtoReflect.Descriptor instead.

func (*MetricsViewMetaRequest) GetInstanceId 

func (x *MetricsViewMetaRequest) GetInstanceId() string

func (*MetricsViewMetaRequest) GetMetricsViewName 

func (x *MetricsViewMetaRequest) GetMetricsViewName() string

func (*MetricsViewMetaRequest) ProtoMessage 

func (*MetricsViewMetaRequest) ProtoMessage()

func (*MetricsViewMetaRequest) ProtoReflect 

func (x *MetricsViewMetaRequest) ProtoReflect() protoreflect.Message

func (*MetricsViewMetaRequest) Reset 

func (x *MetricsViewMetaRequest) Reset()

func (*MetricsViewMetaRequest) String 

func (x *MetricsViewMetaRequest) String() string

type MetricsViewMetaResponse 

type MetricsViewMetaResponse struct {
	MetricsViewName string                   `protobuf:"bytes,1,opt,name=metrics_view_name,json=metricsViewName,proto3" json:"metrics_view_name,omitempty"`
	FromObject      string                   `protobuf:"bytes,2,opt,name=from_object,json=fromObject,proto3" json:"from_object,omitempty"`
	Dimensions      []*MetricsView_Dimension `protobuf:"bytes,3,rep,name=dimensions,proto3" json:"dimensions,omitempty"`
	Measures        []*MetricsView_Measure   `protobuf:"bytes,4,rep,name=measures,proto3" json:"measures,omitempty"`
	// contains filtered or unexported fields
}

Response message for RuntimeService.MetricsViewMeta

func (*MetricsViewMetaResponse) Descriptor deprecated 

func (*MetricsViewMetaResponse) Descriptor() ([]byte, []int)

Deprecated: Use MetricsViewMetaResponse.ProtoReflect.Descriptor instead.

func (*MetricsViewMetaResponse) GetDimensions 

func (x *MetricsViewMetaResponse) GetDimensions() []*MetricsView_Dimension

func (*MetricsViewMetaResponse) GetFromObject 

func (x *MetricsViewMetaResponse) GetFromObject() string

func (*MetricsViewMetaResponse) GetMeasures 

func (x *MetricsViewMetaResponse) GetMeasures() []*MetricsView_Measure

func (*MetricsViewMetaResponse) GetMetricsViewName 

func (x *MetricsViewMetaResponse) GetMetricsViewName() string

func (*MetricsViewMetaResponse) ProtoMessage 

func (*MetricsViewMetaResponse) ProtoMessage()

func (*MetricsViewMetaResponse) ProtoReflect 

func (x *MetricsViewMetaResponse) ProtoReflect() protoreflect.Message

func (*MetricsViewMetaResponse) Reset 

func (x *MetricsViewMetaResponse) Reset()

func (*MetricsViewMetaResponse) String 

func (x *MetricsViewMetaResponse) String() string

type MetricsViewRequestFilter added in v0.15.0 

type MetricsViewRequestFilter struct {
	Include []*MetricsViewDimensionValue `protobuf:"bytes,1,rep,name=include,proto3" json:"include,omitempty"`
	Exclude []*MetricsViewDimensionValue `protobuf:"bytes,2,rep,name=exclude,proto3" json:"exclude,omitempty"`
	// contains filtered or unexported fields
}

func (*MetricsViewRequestFilter) Descriptor deprecated added in v0.15.0 

func (*MetricsViewRequestFilter) Descriptor() ([]byte, []int)

Deprecated: Use MetricsViewRequestFilter.ProtoReflect.Descriptor instead.

func (*MetricsViewRequestFilter) GetExclude added in v0.15.0 

func (x *MetricsViewRequestFilter) GetExclude() []*MetricsViewDimensionValue

func (*MetricsViewRequestFilter) GetInclude added in v0.15.0 

func (x *MetricsViewRequestFilter) GetInclude() []*MetricsViewDimensionValue

func (*MetricsViewRequestFilter) ProtoMessage added in v0.15.0 

func (*MetricsViewRequestFilter) ProtoMessage()

func (*MetricsViewRequestFilter) ProtoReflect added in v0.15.0 

func (x *MetricsViewRequestFilter) ProtoReflect() protoreflect.Message

func (*MetricsViewRequestFilter) Reset added in v0.15.0 

func (x *MetricsViewRequestFilter) Reset()

func (*MetricsViewRequestFilter) String added in v0.15.0 

func (x *MetricsViewRequestFilter) String() string

type MetricsViewSort 

type MetricsViewSort struct {
	Name      string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Ascending bool   `protobuf:"varint,2,opt,name=ascending,proto3" json:"ascending,omitempty"`
	// contains filtered or unexported fields
}

Sort clause for metrics view requests

func (*MetricsViewSort) Descriptor deprecated 

func (*MetricsViewSort) Descriptor() ([]byte, []int)

Deprecated: Use MetricsViewSort.ProtoReflect.Descriptor instead.

func (*MetricsViewSort) GetAscending 

func (x *MetricsViewSort) GetAscending() bool

func (*MetricsViewSort) GetName 

func (x *MetricsViewSort) GetName() string

func (*MetricsViewSort) ProtoMessage 

func (*MetricsViewSort) ProtoMessage()

func (*MetricsViewSort) ProtoReflect 

func (x *MetricsViewSort) ProtoReflect() protoreflect.Message

func (*MetricsViewSort) Reset 

func (x *MetricsViewSort) Reset()

func (*MetricsViewSort) String 

func (x *MetricsViewSort) String() string

type MetricsViewTimeSeriesRequest 

type MetricsViewTimeSeriesRequest struct {
	InstanceId      string                 `protobuf:"bytes,1,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"`
	MetricsViewName string                 `protobuf:"bytes,2,opt,name=metrics_view_name,json=metricsViewName,proto3" json:"metrics_view_name,omitempty"`
	MeasureNames    []string               `protobuf:"bytes,3,rep,name=measure_names,json=measureNames,proto3" json:"measure_names,omitempty"`
	TimeStart       *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=time_start,json=timeStart,proto3" json:"time_start,omitempty"`
	TimeEnd         *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=time_end,json=timeEnd,proto3" json:"time_end,omitempty"`
	TimeGranularity string                 `protobuf:"bytes,6,opt,name=time_granularity,json=timeGranularity,proto3" json:"time_granularity,omitempty"`
	Filter          *MetricsViewFilter     `protobuf:"bytes,7,opt,name=filter,proto3" json:"filter,omitempty"`
	// contains filtered or unexported fields
}

Request message for RuntimeService.MetricsViewTimeSeries

func (*MetricsViewTimeSeriesRequest) Descriptor deprecated 

func (*MetricsViewTimeSeriesRequest) Descriptor() ([]byte, []int)

Deprecated: Use MetricsViewTimeSeriesRequest.ProtoReflect.Descriptor instead.

func (*MetricsViewTimeSeriesRequest) GetFilter 

func (x *MetricsViewTimeSeriesRequest) GetFilter() *MetricsViewFilter

func (*MetricsViewTimeSeriesRequest) GetInstanceId 

func (x *MetricsViewTimeSeriesRequest) GetInstanceId() string

func (*MetricsViewTimeSeriesRequest) GetMeasureNames 

func (x *MetricsViewTimeSeriesRequest) GetMeasureNames() []string

func (*MetricsViewTimeSeriesRequest) GetMetricsViewName 

func (x *MetricsViewTimeSeriesRequest) GetMetricsViewName() string

func (*MetricsViewTimeSeriesRequest) GetTimeEnd 

func (x *MetricsViewTimeSeriesRequest) GetTimeEnd() *timestamppb.Timestamp

func (*MetricsViewTimeSeriesRequest) GetTimeGranularity 

func (x *MetricsViewTimeSeriesRequest) GetTimeGranularity() string

func (*MetricsViewTimeSeriesRequest) GetTimeStart 

func (x *MetricsViewTimeSeriesRequest) GetTimeStart() *timestamppb.Timestamp

func (*MetricsViewTimeSeriesRequest) ProtoMessage 

func (*MetricsViewTimeSeriesRequest) ProtoMessage()

func (*MetricsViewTimeSeriesRequest) ProtoReflect 

func (x *MetricsViewTimeSeriesRequest) ProtoReflect() protoreflect.Message

func (*MetricsViewTimeSeriesRequest) Reset 

func (x *MetricsViewTimeSeriesRequest) Reset()

func (*MetricsViewTimeSeriesRequest) String 

func (x *MetricsViewTimeSeriesRequest) String() string

type MetricsViewTimeSeriesResponse 

type MetricsViewTimeSeriesResponse struct {
	Meta []*MetricsViewColumn `protobuf:"bytes,1,rep,name=meta,proto3" json:"meta,omitempty"`
	Data []*structpb.Struct   `protobuf:"bytes,2,rep,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

Response message for RuntimeService.MetricsViewTimeSeries

func (*MetricsViewTimeSeriesResponse) Descriptor deprecated 

func (*MetricsViewTimeSeriesResponse) Descriptor() ([]byte, []int)

Deprecated: Use MetricsViewTimeSeriesResponse.ProtoReflect.Descriptor instead.

func (*MetricsViewTimeSeriesResponse) GetData 

func (x *MetricsViewTimeSeriesResponse) GetData() []*structpb.Struct

func (*MetricsViewTimeSeriesResponse) GetMeta 

func (x *MetricsViewTimeSeriesResponse) GetMeta() []*MetricsViewColumn

func (*MetricsViewTimeSeriesResponse) ProtoMessage 

func (*MetricsViewTimeSeriesResponse) ProtoMessage()

func (*MetricsViewTimeSeriesResponse) ProtoReflect 

func (x *MetricsViewTimeSeriesResponse) ProtoReflect() protoreflect.Message

func (*MetricsViewTimeSeriesResponse) Reset 

func (x *MetricsViewTimeSeriesResponse) Reset()

func (*MetricsViewTimeSeriesResponse) String 

func (x *MetricsViewTimeSeriesResponse) String() string

type MetricsViewToplistRequest 

type MetricsViewToplistRequest struct {
	InstanceId      string                 `protobuf:"bytes,1,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"`
	MetricsViewName string                 `protobuf:"bytes,2,opt,name=metrics_view_name,json=metricsViewName,proto3" json:"metrics_view_name,omitempty"`
	DimensionName   string                 `protobuf:"bytes,3,opt,name=dimension_name,json=dimensionName,proto3" json:"dimension_name,omitempty"`
	MeasureNames    []string               `protobuf:"bytes,4,rep,name=measure_names,json=measureNames,proto3" json:"measure_names,omitempty"`
	TimeStart       *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=time_start,json=timeStart,proto3" json:"time_start,omitempty"`
	TimeEnd         *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=time_end,json=timeEnd,proto3" json:"time_end,omitempty"`
	Limit           int64                  `protobuf:"varint,7,opt,name=limit,proto3" json:"limit,omitempty"`
	Offset          int64                  `protobuf:"varint,8,opt,name=offset,proto3" json:"offset,omitempty"`
	Sort            []*MetricsViewSort     `protobuf:"bytes,9,rep,name=sort,proto3" json:"sort,omitempty"`
	Filter          *MetricsViewFilter     `protobuf:"bytes,10,opt,name=filter,proto3" json:"filter,omitempty"`
	// contains filtered or unexported fields
}

Request message for RuntimeService.MetricsViewToplist

func (*MetricsViewToplistRequest) Descriptor deprecated 

func (*MetricsViewToplistRequest) Descriptor() ([]byte, []int)

Deprecated: Use MetricsViewToplistRequest.ProtoReflect.Descriptor instead.

func (*MetricsViewToplistRequest) GetDimensionName 

func (x *MetricsViewToplistRequest) GetDimensionName() string

func (*MetricsViewToplistRequest) GetFilter 

func (x *MetricsViewToplistRequest) GetFilter() *MetricsViewFilter

func (*MetricsViewToplistRequest) GetInstanceId 

func (x *MetricsViewToplistRequest) GetInstanceId() string

func (*MetricsViewToplistRequest) GetLimit 

func (x *MetricsViewToplistRequest) GetLimit() int64

func (*MetricsViewToplistRequest) GetMeasureNames 

func (x *MetricsViewToplistRequest) GetMeasureNames() []string

func (*MetricsViewToplistRequest) GetMetricsViewName 

func (x *MetricsViewToplistRequest) GetMetricsViewName() string

func (*MetricsViewToplistRequest) GetOffset 

func (x *MetricsViewToplistRequest) GetOffset() int64

func (*MetricsViewToplistRequest) GetSort 

func (x *MetricsViewToplistRequest) GetSort() []*MetricsViewSort

func (*MetricsViewToplistRequest) GetTimeEnd 

func (x *MetricsViewToplistRequest) GetTimeEnd() *timestamppb.Timestamp

func (*MetricsViewToplistRequest) GetTimeStart 

func (x *MetricsViewToplistRequest) GetTimeStart() *timestamppb.Timestamp

func (*MetricsViewToplistRequest) ProtoMessage 

func (*MetricsViewToplistRequest) ProtoMessage()

func (*MetricsViewToplistRequest) ProtoReflect 

func (x *MetricsViewToplistRequest) ProtoReflect() protoreflect.Message

func (*MetricsViewToplistRequest) Reset 

func (x *MetricsViewToplistRequest) Reset()

func (*MetricsViewToplistRequest) String 

func (x *MetricsViewToplistRequest) String() string

type MetricsViewToplistResponse 

type MetricsViewToplistResponse struct {
	Meta []*MetricsViewColumn `protobuf:"bytes,1,rep,name=meta,proto3" json:"meta,omitempty"`
	Data []*structpb.Struct   `protobuf:"bytes,2,rep,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

Response message for RuntimeService.MetricsViewToplist

func (*MetricsViewToplistResponse) Descriptor deprecated 

func (*MetricsViewToplistResponse) Descriptor() ([]byte, []int)

Deprecated: Use MetricsViewToplistResponse.ProtoReflect.Descriptor instead.

func (*MetricsViewToplistResponse) GetData 

func (x *MetricsViewToplistResponse) GetData() []*structpb.Struct

func (*MetricsViewToplistResponse) GetMeta 

func (x *MetricsViewToplistResponse) GetMeta() []*MetricsViewColumn

func (*MetricsViewToplistResponse) ProtoMessage 

func (*MetricsViewToplistResponse) ProtoMessage()

func (*MetricsViewToplistResponse) ProtoReflect 

func (x *MetricsViewToplistResponse) ProtoReflect() protoreflect.Message

func (*MetricsViewToplistResponse) Reset 

func (x *MetricsViewToplistResponse) Reset()

func (*MetricsViewToplistResponse) String 

func (x *MetricsViewToplistResponse) String() string

type MetricsViewTotalsRequest 

type MetricsViewTotalsRequest struct {
	InstanceId      string                 `protobuf:"bytes,1,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"`
	MetricsViewName string                 `protobuf:"bytes,2,opt,name=metrics_view_name,json=metricsViewName,proto3" json:"metrics_view_name,omitempty"`
	MeasureNames    []string               `protobuf:"bytes,3,rep,name=measure_names,json=measureNames,proto3" json:"measure_names,omitempty"`
	TimeStart       *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=time_start,json=timeStart,proto3" json:"time_start,omitempty"`
	TimeEnd         *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=time_end,json=timeEnd,proto3" json:"time_end,omitempty"`
	Filter          *MetricsViewFilter     `protobuf:"bytes,7,opt,name=filter,proto3" json:"filter,omitempty"`
	// contains filtered or unexported fields
}

Request message for RuntimeService.MetricsViewTotals

func (*MetricsViewTotalsRequest) Descriptor deprecated 

func (*MetricsViewTotalsRequest) Descriptor() ([]byte, []int)

Deprecated: Use MetricsViewTotalsRequest.ProtoReflect.Descriptor instead.

func (*MetricsViewTotalsRequest) GetFilter 

func (x *MetricsViewTotalsRequest) GetFilter() *MetricsViewFilter

func (*MetricsViewTotalsRequest) GetInstanceId 

func (x *MetricsViewTotalsRequest) GetInstanceId() string

func (*MetricsViewTotalsRequest) GetMeasureNames 

func (x *MetricsViewTotalsRequest) GetMeasureNames() []string

func (*MetricsViewTotalsRequest) GetMetricsViewName 

func (x *MetricsViewTotalsRequest) GetMetricsViewName() string

func (*MetricsViewTotalsRequest) GetTimeEnd 

func (x *MetricsViewTotalsRequest) GetTimeEnd() *timestamppb.Timestamp

func (*MetricsViewTotalsRequest) GetTimeStart 

func (x *MetricsViewTotalsRequest) GetTimeStart() *timestamppb.Timestamp

func (*MetricsViewTotalsRequest) ProtoMessage 

func (*MetricsViewTotalsRequest) ProtoMessage()

func (*MetricsViewTotalsRequest) ProtoReflect 

func (x *MetricsViewTotalsRequest) ProtoReflect() protoreflect.Message

func (*MetricsViewTotalsRequest) Reset 

func (x *MetricsViewTotalsRequest) Reset()

func (*MetricsViewTotalsRequest) String 

func (x *MetricsViewTotalsRequest) String() string

type MetricsViewTotalsResponse 

type MetricsViewTotalsResponse struct {
	Meta []*MetricsViewColumn `protobuf:"bytes,1,rep,name=meta,proto3" json:"meta,omitempty"`
	Data *structpb.Struct     `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

Response message for RuntimeService.MetricsViewTotals

func (*MetricsViewTotalsResponse) Descriptor deprecated 

func (*MetricsViewTotalsResponse) Descriptor() ([]byte, []int)

Deprecated: Use MetricsViewTotalsResponse.ProtoReflect.Descriptor instead.

func (*MetricsViewTotalsResponse) GetData 

func (x *MetricsViewTotalsResponse) GetData() *structpb.Struct

func (*MetricsViewTotalsResponse) GetMeta 

func (x *MetricsViewTotalsResponse) GetMeta() []*MetricsViewColumn

func (*MetricsViewTotalsResponse) ProtoMessage 

func (*MetricsViewTotalsResponse) ProtoMessage()

func (*MetricsViewTotalsResponse) ProtoReflect 

func (x *MetricsViewTotalsResponse) ProtoReflect() protoreflect.Message

func (*MetricsViewTotalsResponse) Reset 

func (x *MetricsViewTotalsResponse) Reset()

func (*MetricsViewTotalsResponse) String 

func (x *MetricsViewTotalsResponse) String() string

type MetricsView_Dimension 

type MetricsView_Dimension struct {
	Name        string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Label       string `protobuf:"bytes,2,opt,name=label,proto3" json:"label,omitempty"`
	Description string `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	Enabled     string `protobuf:"bytes,4,opt,name=enabled,proto3" json:"enabled,omitempty"`
	// contains filtered or unexported fields
}

Dimensions are columns to filter and group by

func (*MetricsView_Dimension) Descriptor deprecated 

func (*MetricsView_Dimension) Descriptor() ([]byte, []int)

Deprecated: Use MetricsView_Dimension.ProtoReflect.Descriptor instead.

func (*MetricsView_Dimension) GetDescription 

func (x *MetricsView_Dimension) GetDescription() string

func (*MetricsView_Dimension) GetEnabled added in v0.15.0 

func (x *MetricsView_Dimension) GetEnabled() string

func (*MetricsView_Dimension) GetLabel added in v0.15.0 

func (x *MetricsView_Dimension) GetLabel() string

func (*MetricsView_Dimension) GetName 

func (x *MetricsView_Dimension) GetName() string

func (*MetricsView_Dimension) ProtoMessage 

func (*MetricsView_Dimension) ProtoMessage()

func (*MetricsView_Dimension) ProtoReflect 

func (x *MetricsView_Dimension) ProtoReflect() protoreflect.Message

func (*MetricsView_Dimension) Reset 

func (x *MetricsView_Dimension) Reset()

func (*MetricsView_Dimension) String 

func (x *MetricsView_Dimension) String() string

type MetricsView_Measure 

type MetricsView_Measure struct {
	Name        string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Label       string `protobuf:"bytes,2,opt,name=label,proto3" json:"label,omitempty"`
	Expression  string `protobuf:"bytes,3,opt,name=expression,proto3" json:"expression,omitempty"`
	Description string `protobuf:"bytes,4,opt,name=description,proto3" json:"description,omitempty"`
	Format      string `protobuf:"bytes,5,opt,name=format,proto3" json:"format,omitempty"`
	Enabled     string `protobuf:"bytes,6,opt,name=enabled,proto3" json:"enabled,omitempty"`
	// contains filtered or unexported fields
}

Measures are aggregated computed values

func (*MetricsView_Measure) Descriptor deprecated 

func (*MetricsView_Measure) Descriptor() ([]byte, []int)

Deprecated: Use MetricsView_Measure.ProtoReflect.Descriptor instead.

func (*MetricsView_Measure) GetDescription 

func (x *MetricsView_Measure) GetDescription() string

func (*MetricsView_Measure) GetEnabled added in v0.15.0 

func (x *MetricsView_Measure) GetEnabled() string

func (*MetricsView_Measure) GetExpression added in v0.15.0 

func (x *MetricsView_Measure) GetExpression() string

func (*MetricsView_Measure) GetFormat added in v0.15.0 

func (x *MetricsView_Measure) GetFormat() string

func (*MetricsView_Measure) GetLabel added in v0.15.0 

func (x *MetricsView_Measure) GetLabel() string

func (*MetricsView_Measure) GetName 

func (x *MetricsView_Measure) GetName() string

func (*MetricsView_Measure) ProtoMessage 

func (*MetricsView_Measure) ProtoMessage()

func (*MetricsView_Measure) ProtoReflect 

func (x *MetricsView_Measure) ProtoReflect() protoreflect.Message

func (*MetricsView_Measure) Reset 

func (x *MetricsView_Measure) Reset()

func (*MetricsView_Measure) String 

func (x *MetricsView_Measure) String() string

type MigrateDeleteRequest 

type MigrateDeleteRequest struct {

	// Instance to migrate
	InstanceId string `protobuf:"bytes,1,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"`
	// Name of object to drop
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

Request message for RuntimeService.MigrateDelete

func (*MigrateDeleteRequest) Descriptor deprecated 

func (*MigrateDeleteRequest) Descriptor() ([]byte, []int)

Deprecated: Use MigrateDeleteRequest.ProtoReflect.Descriptor instead.

func (*MigrateDeleteRequest) GetInstanceId 

func (x *MigrateDeleteRequest) GetInstanceId() string

func (*MigrateDeleteRequest) GetName 

func (x *MigrateDeleteRequest) GetName() string

func (*MigrateDeleteRequest) ProtoMessage 

func (*MigrateDeleteRequest) ProtoMessage()

func (*MigrateDeleteRequest) ProtoReflect 

func (x *MigrateDeleteRequest) ProtoReflect() protoreflect.Message

func (*MigrateDeleteRequest) Reset 

func (x *MigrateDeleteRequest) Reset()

func (*MigrateDeleteRequest) String 

func (x *MigrateDeleteRequest) String() string

type MigrateDeleteResponse 

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

Response message for RuntimeService.MigrateDelete

func (*MigrateDeleteResponse) Descriptor deprecated 

func (*MigrateDeleteResponse) Descriptor() ([]byte, []int)

Deprecated: Use MigrateDeleteResponse.ProtoReflect.Descriptor instead.

func (*MigrateDeleteResponse) ProtoMessage 

func (*MigrateDeleteResponse) ProtoMessage()

func (*MigrateDeleteResponse) ProtoReflect 

func (x *MigrateDeleteResponse) ProtoReflect() protoreflect.Message

func (*MigrateDeleteResponse) Reset 

func (x *MigrateDeleteResponse) Reset()

func (*MigrateDeleteResponse) String 

func (x *MigrateDeleteResponse) String() string

type MigrateRequest 

type MigrateRequest struct {

	// Instance to migrate
	InstanceId string `protobuf:"bytes,1,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"`
	// Contents of files containing one or more SQL DDL statements
	RepoId string `protobuf:"bytes,2,opt,name=repo_id,json=repoId,proto3" json:"repo_id,omitempty"`
	// Changed paths provides a way to "hint" what files have changed in the repo, enabling
	// migrations to execute faster by not scanning all code artifacts for changes.
	ChangedPaths []string `protobuf:"bytes,3,rep,name=changed_paths,json=changedPaths,proto3" json:"changed_paths,omitempty"`
	// If true, will validate the file artifacts, but not actually execute any migrations
	Dry bool `protobuf:"varint,4,opt,name=dry,proto3" json:"dry,omitempty"`
	// If true, will not execute any migrations if any artifact fails to validate.
	// Otherwise, it will execute a best-effort migration (including dropping objects with artifacts
	// that fail to validate.)
	Strict bool `protobuf:"varint,5,opt,name=strict,proto3" json:"strict,omitempty"`
	// contains filtered or unexported fields
}

Request message for RuntimeService.Migrate

func (*MigrateRequest) Descriptor deprecated 

func (*MigrateRequest) Descriptor() ([]byte, []int)

Deprecated: Use MigrateRequest.ProtoReflect.Descriptor instead.

func (*MigrateRequest) GetChangedPaths added in v0.15.0 

func (x *MigrateRequest) GetChangedPaths() []string

func (*MigrateRequest) GetDry added in v0.15.0 

func (x *MigrateRequest) GetDry() bool

func (*MigrateRequest) GetInstanceId 

func (x *MigrateRequest) GetInstanceId() string

func (*MigrateRequest) GetRepoId added in v0.15.0 

func (x *MigrateRequest) GetRepoId() string

func (*MigrateRequest) GetStrict added in v0.15.0 

func (x *MigrateRequest) GetStrict() bool

func (*MigrateRequest) ProtoMessage 

func (*MigrateRequest) ProtoMessage()

func (*MigrateRequest) ProtoReflect 

func (x *MigrateRequest) ProtoReflect() protoreflect.Message

func (*MigrateRequest) Reset 

func (x *MigrateRequest) Reset()

func (*MigrateRequest) String 

func (x *MigrateRequest) String() string

type MigrateResponse 

type MigrateResponse struct {

	// Errors encountered during the migration. If strict = false, any path in
	// affected_paths without an error can be assumed to have been migrated succesfully.
	Errors []*MigrationError `protobuf:"bytes,1,rep,name=errors,proto3" json:"errors,omitempty"`
	// affected_paths lists all the file artifact paths that were considered while
	// executing the migration. If changed_paths was empty, this will include all
	// code artifacts in the repo.
	AffectedPaths []string `protobuf:"bytes,2,rep,name=affected_paths,json=affectedPaths,proto3" json:"affected_paths,omitempty"`
	// contains filtered or unexported fields
}

Response message for RuntimeService.Migrate

func (*MigrateResponse) Descriptor deprecated 

func (*MigrateResponse) Descriptor() ([]byte, []int)

Deprecated: Use MigrateResponse.ProtoReflect.Descriptor instead.

func (*MigrateResponse) GetAffectedPaths added in v0.15.0 

func (x *MigrateResponse) GetAffectedPaths() []string

func (*MigrateResponse) GetErrors added in v0.15.0 

func (x *MigrateResponse) GetErrors() []*MigrationError

func (*MigrateResponse) ProtoMessage 

func (*MigrateResponse) ProtoMessage()

func (*MigrateResponse) ProtoReflect 

func (x *MigrateResponse) ProtoReflect() protoreflect.Message

func (*MigrateResponse) Reset 

func (x *MigrateResponse) Reset()

func (*MigrateResponse) String 

func (x *MigrateResponse) String() string

type MigrateSingleRequest 

type MigrateSingleRequest struct {

	// Instance to migrate
	InstanceId string `protobuf:"bytes,1,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"`
	// A CREATE statement
	Sql string `protobuf:"bytes,2,opt,name=sql,proto3" json:"sql,omitempty"`
	// If true, will validate the SQL, but not actually execute the migrations
	DryRun bool `protobuf:"varint,3,opt,name=dry_run,json=dryRun,proto3" json:"dry_run,omitempty"`
	// If true, will replace existing definitions with the same name
	CreateOrReplace bool `protobuf:"varint,4,opt,name=create_or_replace,json=createOrReplace,proto3" json:"create_or_replace,omitempty"`
	// If provided, will attempt to rename an existing object and only recompute if necessary.
	// NOTE: very questionable semantics here.
	RenameFrom string `protobuf:"bytes,5,opt,name=rename_from,json=renameFrom,proto3" json:"rename_from,omitempty"`
	// contains filtered or unexported fields
}

Request message for RuntimeService.MigrateSingle

func (*MigrateSingleRequest) Descriptor deprecated 

func (*MigrateSingleRequest) Descriptor() ([]byte, []int)

Deprecated: Use MigrateSingleRequest.ProtoReflect.Descriptor instead.

func (*MigrateSingleRequest) GetCreateOrReplace 

func (x *MigrateSingleRequest) GetCreateOrReplace() bool

func (*MigrateSingleRequest) GetDryRun 

func (x *MigrateSingleRequest) GetDryRun() bool

func (*MigrateSingleRequest) GetInstanceId 

func (x *MigrateSingleRequest) GetInstanceId() string

func (*MigrateSingleRequest) GetRenameFrom added in v0.13.0 

func (x *MigrateSingleRequest) GetRenameFrom() string

func (*MigrateSingleRequest) GetSql 

func (x *MigrateSingleRequest) GetSql() string

func (*MigrateSingleRequest) ProtoMessage 

func (*MigrateSingleRequest) ProtoMessage()

func (*MigrateSingleRequest) ProtoReflect 

func (x *MigrateSingleRequest) ProtoReflect() protoreflect.Message

func (*MigrateSingleRequest) Reset 

func (x *MigrateSingleRequest) Reset()

func (*MigrateSingleRequest) String 

func (x *MigrateSingleRequest) String() string

type MigrateSingleResponse 

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

Response message for RuntimeService.MigrateSingle

func (*MigrateSingleResponse) Descriptor deprecated 

func (*MigrateSingleResponse) Descriptor() ([]byte, []int)

Deprecated: Use MigrateSingleResponse.ProtoReflect.Descriptor instead.

func (*MigrateSingleResponse) ProtoMessage 

func (*MigrateSingleResponse) ProtoMessage()

func (*MigrateSingleResponse) ProtoReflect 

func (x *MigrateSingleResponse) ProtoReflect() protoreflect.Message

func (*MigrateSingleResponse) Reset 

func (x *MigrateSingleResponse) Reset()

func (*MigrateSingleResponse) String 

func (x *MigrateSingleResponse) String() string

type MigrationError added in v0.15.0 

type MigrationError struct {

	// Code denotes the category of error
	Code MigrationError_Code `protobuf:"varint,1,opt,name=code,proto3,enum=rill.runtime.v1.MigrationError_Code" json:"code,omitempty"`
	// Message is a developer-friendly error message
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// File path of the code artifact that this error relates to (if any)
	FilePath string `protobuf:"bytes,3,opt,name=file_path,json=filePath,proto3" json:"file_path,omitempty"`
	// Property path of the error in the code artifact (if any).
	// It's represented as a JS-style property path, e.g. "key0.key1[index2].key3".
	// It only applies to structured code artifacts (i.e. YAML).
	// Only applicable if file_path is set.
	PropertyPath string `protobuf:"bytes,4,opt,name=property_path,json=propertyPath,proto3" json:"property_path,omitempty"`
	// Start location of the error in the code artifact (if any).
	// Only applicable if file_path is set.
	StartLocation *MigrationError_CharLocation `protobuf:"bytes,5,opt,name=start_location,json=startLocation,proto3" json:"start_location,omitempty"`
	// End location of the error in the code artifact (if any).
	// Only applicable if file_path and start_location is set.
	EndLocation *MigrationError_CharLocation `protobuf:"bytes,6,opt,name=end_location,json=endLocation,proto3" json:"end_location,omitempty"`
	// contains filtered or unexported fields
}

MigrationError represents an error encountered while running Migrate.

func (*MigrationError) Descriptor deprecated added in v0.15.0 

func (*MigrationError) Descriptor() ([]byte, []int)

Deprecated: Use MigrationError.ProtoReflect.Descriptor instead.

func (*MigrationError) GetCode added in v0.15.0 

func (x *MigrationError) GetCode() MigrationError_Code

func (*MigrationError) GetEndLocation added in v0.15.0 

func (x *MigrationError) GetEndLocation() *MigrationError_CharLocation

func (*MigrationError) GetFilePath added in v0.15.0 

func (x *MigrationError) GetFilePath() string

func (*MigrationError) GetMessage added in v0.15.0 

func (x *MigrationError) GetMessage() string

func (*MigrationError) GetPropertyPath added in v0.15.0 

func (x *MigrationError) GetPropertyPath() string

func (*MigrationError) GetStartLocation added in v0.15.0 

func (x *MigrationError) GetStartLocation() *MigrationError_CharLocation

func (*MigrationError) ProtoMessage added in v0.15.0 

func (*MigrationError) ProtoMessage()

func (*MigrationError) ProtoReflect added in v0.15.0 

func (x *MigrationError) ProtoReflect() protoreflect.Message

func (*MigrationError) Reset added in v0.15.0 

func (x *MigrationError) Reset()

func (*MigrationError) String added in v0.15.0 

func (x *MigrationError) String() string

type MigrationError_CharLocation added in v0.15.0 

type MigrationError_CharLocation struct {
	Line   uint32 `protobuf:"varint,1,opt,name=line,proto3" json:"line,omitempty"`
	Column uint32 `protobuf:"varint,2,opt,name=column,proto3" json:"column,omitempty"`
	// contains filtered or unexported fields
}

CharLocation is a line and column in a code artifact

func (*MigrationError_CharLocation) Descriptor deprecated added in v0.15.0 

func (*MigrationError_CharLocation) Descriptor() ([]byte, []int)

Deprecated: Use MigrationError_CharLocation.ProtoReflect.Descriptor instead.

func (*MigrationError_CharLocation) GetColumn added in v0.15.0 

func (x *MigrationError_CharLocation) GetColumn() uint32

func (*MigrationError_CharLocation) GetLine added in v0.15.0 

func (x *MigrationError_CharLocation) GetLine() uint32

func (*MigrationError_CharLocation) ProtoMessage added in v0.15.0 

func (*MigrationError_CharLocation) ProtoMessage()

func (*MigrationError_CharLocation) ProtoReflect added in v0.15.0 

func (x *MigrationError_CharLocation) ProtoReflect() protoreflect.Message

func (*MigrationError_CharLocation) Reset added in v0.15.0 

func (x *MigrationError_CharLocation) Reset()

func (*MigrationError_CharLocation) String added in v0.15.0 

func (x *MigrationError_CharLocation) String() string

type MigrationError_Code added in v0.15.0 

type MigrationError_Code int32

Code represents different categories of migration errors 

const (
	// Unspecified error
	MigrationError_CODE_UNSPECIFIED MigrationError_Code = 0
	// Code artifact failed to parse
	MigrationError_CODE_SYNTAX MigrationError_Code = 1
	// Code artifact has internal validation errors
	MigrationError_CODE_VALIDATION MigrationError_Code = 2
	// Code artifact is valid, but has invalid dependencies
	MigrationError_CODE_DEPENDENCY MigrationError_Code = 3
	// Error returned from the OLAP database
	MigrationError_CODE_OLAP MigrationError_Code = 4
	// Error encountered during source inspection or ingestion
	MigrationError_CODE_SOURCE MigrationError_Code = 5
)

func (MigrationError_Code) Descriptor added in v0.15.0 

func (MigrationError_Code) Descriptor() protoreflect.EnumDescriptor

func (MigrationError_Code) Enum added in v0.15.0 

func (x MigrationError_Code) Enum() *MigrationError_Code

func (MigrationError_Code) EnumDescriptor deprecated added in v0.15.0 

func (MigrationError_Code) EnumDescriptor() ([]byte, []int)

Deprecated: Use MigrationError_Code.Descriptor instead.

func (MigrationError_Code) Number added in v0.15.0 

func (x MigrationError_Code) Number() protoreflect.EnumNumber

func (MigrationError_Code) String added in v0.15.0 

func (x MigrationError_Code) String() string

func (MigrationError_Code) Type added in v0.15.0 

func (MigrationError_Code) Type() protoreflect.EnumType

type Model added in v0.15.0 

type Model struct {

	// Name of the model
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// SQL is a SELECT statement representing the model
	Sql string `protobuf:"bytes,2,opt,name=sql,proto3" json:"sql,omitempty"`
	// Dialect of the SQL statement
	Dialect Model_Dialect `protobuf:"varint,3,opt,name=dialect,proto3,enum=rill.runtime.v1.Model_Dialect" json:"dialect,omitempty"`
	// Detected schema of the model
	Schema *StructType `protobuf:"bytes,4,opt,name=schema,proto3" json:"schema,omitempty"`
	// contains filtered or unexported fields
}

Model is the internal representation of a model definition

func (*Model) Descriptor deprecated added in v0.15.0 

func (*Model) Descriptor() ([]byte, []int)

Deprecated: Use Model.ProtoReflect.Descriptor instead.

func (*Model) GetDialect added in v0.15.0 

func (x *Model) GetDialect() Model_Dialect

func (*Model) GetName added in v0.15.0 

func (x *Model) GetName() string

func (*Model) GetSchema added in v0.15.0 

func (x *Model) GetSchema() *StructType

func (*Model) GetSql added in v0.15.0 

func (x *Model) GetSql() string

func (*Model) ProtoMessage added in v0.15.0 

func (*Model) ProtoMessage()

func (*Model) ProtoReflect added in v0.15.0 

func (x *Model) ProtoReflect() protoreflect.Message

func (*Model) Reset added in v0.15.0 

func (x *Model) Reset()

func (*Model) String added in v0.15.0 

func (x *Model) String() string

type Model_Dialect added in v0.15.0 

type Model_Dialect int32

Dialects supported for models 

const (
	Model_DIALECT_UNSPECIFIED Model_Dialect = 0
	Model_DIALECT_DUCKDB      Model_Dialect = 1
)

func (Model_Dialect) Descriptor added in v0.15.0 

func (Model_Dialect) Descriptor() protoreflect.EnumDescriptor

func (Model_Dialect) Enum added in v0.15.0 

func (x Model_Dialect) Enum() *Model_Dialect

func (Model_Dialect) EnumDescriptor deprecated added in v0.15.0 

func (Model_Dialect) EnumDescriptor() ([]byte, []int)

Deprecated: Use Model_Dialect.Descriptor instead.

func (Model_Dialect) Number added in v0.15.0 

func (x Model_Dialect) Number() protoreflect.EnumNumber

func (Model_Dialect) String added in v0.15.0 

func (x Model_Dialect) String() string

func (Model_Dialect) Type added in v0.15.0 

func (Model_Dialect) Type() protoreflect.EnumType

type NullCountRequest added in v0.15.0 

type NullCountRequest struct {
	InstanceId string `protobuf:"bytes,1,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"`
	TableName  string `protobuf:"bytes,2,opt,name=table_name,json=tableName,proto3" json:"table_name,omitempty"`
	ColumnName string `protobuf:"bytes,3,opt,name=column_name,json=columnName,proto3" json:"column_name,omitempty"`
	// contains filtered or unexported fields
}

Request for RuntimeService.GetNullCount. Returns the null count for a given column for table table_name

func (*NullCountRequest) Descriptor deprecated added in v0.15.0 

func (*NullCountRequest) Descriptor() ([]byte, []int)

Deprecated: Use NullCountRequest.ProtoReflect.Descriptor instead.

func (*NullCountRequest) GetColumnName added in v0.15.0 

func (x *NullCountRequest) GetColumnName() string

func (*NullCountRequest) GetInstanceId added in v0.15.0 

func (x *NullCountRequest) GetInstanceId() string

func (*NullCountRequest) GetTableName added in v0.15.0 

func (x *NullCountRequest) GetTableName() string

func (*NullCountRequest) ProtoMessage added in v0.15.0 

func (*NullCountRequest) ProtoMessage()

func (*NullCountRequest) ProtoReflect added in v0.15.0 

func (x *NullCountRequest) ProtoReflect() protoreflect.Message

func (*NullCountRequest) Reset added in v0.15.0 

func (x *NullCountRequest) Reset()

func (*NullCountRequest) String added in v0.15.0 

func (x *NullCountRequest) String() string

type NullCountResponse added in v0.15.0 

type NullCountResponse struct {
	Count int64 `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"`
	// contains filtered or unexported fields
}

Response for RuntimeService.GetNullCount

func (*NullCountResponse) Descriptor deprecated added in v0.15.0 

func (*NullCountResponse) Descriptor() ([]byte, []int)

Deprecated: Use NullCountResponse.ProtoReflect.Descriptor instead.

func (*NullCountResponse) GetCount added in v0.15.0 

func (x *NullCountResponse) GetCount() int64

func (*NullCountResponse) ProtoMessage added in v0.15.0 

func (*NullCountResponse) ProtoMessage()

func (*NullCountResponse) ProtoReflect added in v0.15.0 

func (x *NullCountResponse) ProtoReflect() protoreflect.Message

func (*NullCountResponse) Reset added in v0.15.0 

func (x *NullCountResponse) Reset()

func (*NullCountResponse) String added in v0.15.0 

func (x *NullCountResponse) String() string

type NumericHistogramBins added in v0.15.0 

type NumericHistogramBins struct {
	Bins []*NumericHistogramBins_Bin `protobuf:"bytes,1,rep,name=bins,proto3" json:"bins,omitempty"`
	// contains filtered or unexported fields
}

Response for RuntimeService.GetNumericHistogram

func (*NumericHistogramBins) Descriptor deprecated added in v0.15.0 

func (*NumericHistogramBins) Descriptor() ([]byte, []int)

Deprecated: Use NumericHistogramBins.ProtoReflect.Descriptor instead.

func (*NumericHistogramBins) GetBins added in v0.15.0 

func (x *NumericHistogramBins) GetBins() []*NumericHistogramBins_Bin

func (*NumericHistogramBins) ProtoMessage added in v0.15.0 

func (*NumericHistogramBins) ProtoMessage()

func (*NumericHistogramBins) ProtoReflect added in v0.15.0 

func (x *NumericHistogramBins) ProtoReflect() protoreflect.Message

func (*NumericHistogramBins) Reset added in v0.15.0 

func (x *NumericHistogramBins) Reset()

func (*NumericHistogramBins) String added in v0.15.0 

func (x *NumericHistogramBins) String() string

type NumericHistogramBins_Bin added in v0.15.0 

type NumericHistogramBins_Bin struct {
	Bucket int64   `protobuf:"varint,1,opt,name=bucket,proto3" json:"bucket,omitempty"`
	Low    float64 `protobuf:"fixed64,2,opt,name=low,proto3" json:"low,omitempty"`
	High   float64 `protobuf:"fixed64,3,opt,name=high,proto3" json:"high,omitempty"`
	Count  int64   `protobuf:"varint,4,opt,name=count,proto3" json:"count,omitempty"`
	// contains filtered or unexported fields
}

func (*NumericHistogramBins_Bin) Descriptor deprecated added in v0.15.0 

func (*NumericHistogramBins_Bin) Descriptor() ([]byte, []int)

Deprecated: Use NumericHistogramBins_Bin.ProtoReflect.Descriptor instead.

func (*NumericHistogramBins_Bin) GetBucket added in v0.15.0 

func (x *NumericHistogramBins_Bin) GetBucket() int64

func (*NumericHistogramBins_Bin) GetCount added in v0.15.0 

func (x *NumericHistogramBins_Bin) GetCount() int64

func (*NumericHistogramBins_Bin) GetHigh added in v0.15.0 

func (x *NumericHistogramBins_Bin) GetHigh() float64

func (*NumericHistogramBins_Bin) GetLow added in v0.15.0 

func (x *NumericHistogramBins_Bin) GetLow() float64

func (*NumericHistogramBins_Bin) ProtoMessage added in v0.15.0 

func (*NumericHistogramBins_Bin) ProtoMessage()

func (*NumericHistogramBins_Bin) ProtoReflect added in v0.15.0 

func (x *NumericHistogramBins_Bin) ProtoReflect() protoreflect.Message

func (*NumericHistogramBins_Bin) Reset added in v0.15.0 

func (x *NumericHistogramBins_Bin) Reset()

func (*NumericHistogramBins_Bin) String added in v0.15.0 

func (x *NumericHistogramBins_Bin) String() string

type NumericHistogramRequest added in v0.15.0 

type NumericHistogramRequest struct {
	InstanceId string `protobuf:"bytes,1,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"`
	TableName  string `protobuf:"bytes,2,opt,name=table_name,json=tableName,proto3" json:"table_name,omitempty"`
	ColumnName string `protobuf:"bytes,3,opt,name=column_name,json=columnName,proto3" json:"column_name,omitempty"`
	// contains filtered or unexported fields
}

Request for RuntimeService.GetNumericHistogram. Returns the histogram for a given column for table table_name

func (*NumericHistogramRequest) Descriptor deprecated added in v0.15.0 

func (*NumericHistogramRequest) Descriptor() ([]byte, []int)

Deprecated: Use NumericHistogramRequest.ProtoReflect.Descriptor instead.

func (*NumericHistogramRequest) GetColumnName added in v0.15.0 

func (x *NumericHistogramRequest) GetColumnName() string

func (*NumericHistogramRequest) GetInstanceId added in v0.15.0 

func (x *NumericHistogramRequest) GetInstanceId() string

func (*NumericHistogramRequest) GetTableName added in v0.15.0 

func (x *NumericHistogramRequest) GetTableName() string

func (*NumericHistogramRequest) ProtoMessage added in v0.15.0 

func (*NumericHistogramRequest) ProtoMessage()

func (*NumericHistogramRequest) ProtoReflect added in v0.15.0 

func (x *NumericHistogramRequest) ProtoReflect() protoreflect.Message

func (*NumericHistogramRequest) Reset added in v0.15.0 

func (x *NumericHistogramRequest) Reset()

func (*NumericHistogramRequest) String added in v0.15.0 

func (x *NumericHistogramRequest) String() string

type NumericOutliers added in v0.15.0 

type NumericOutliers struct {
	Outliers []*NumericOutliers_Outlier `protobuf:"bytes,1,rep,name=outliers,proto3" json:"outliers,omitempty"`
	// contains filtered or unexported fields
}

func (*NumericOutliers) Descriptor deprecated added in v0.15.0 

func (*NumericOutliers) Descriptor() ([]byte, []int)

Deprecated: Use NumericOutliers.ProtoReflect.Descriptor instead.

func (*NumericOutliers) GetOutliers added in v0.15.0 

func (x *NumericOutliers) GetOutliers() []*NumericOutliers_Outlier

func (*NumericOutliers) ProtoMessage added in v0.15.0 

func (*NumericOutliers) ProtoMessage()

func (*NumericOutliers) ProtoReflect added in v0.15.0 

func (x *NumericOutliers) ProtoReflect() protoreflect.Message

func (*NumericOutliers) Reset added in v0.15.0 

func (x *NumericOutliers) Reset()

func (*NumericOutliers) String added in v0.15.0 

func (x *NumericOutliers) String() string

type NumericOutliers_Outlier added in v0.15.0 

type NumericOutliers_Outlier struct {
	Bucket  int64   `protobuf:"varint,1,opt,name=bucket,proto3" json:"bucket,omitempty"`
	Low     float64 `protobuf:"fixed64,2,opt,name=low,proto3" json:"low,omitempty"`
	High    float64 `protobuf:"fixed64,3,opt,name=high,proto3" json:"high,omitempty"`
	Present bool    `protobuf:"varint,4,opt,name=present,proto3" json:"present,omitempty"`
	// contains filtered or unexported fields
}

func (*NumericOutliers_Outlier) Descriptor deprecated added in v0.15.0 

func (*NumericOutliers_Outlier) Descriptor() ([]byte, []int)

Deprecated: Use NumericOutliers_Outlier.ProtoReflect.Descriptor instead.

func (*NumericOutliers_Outlier) GetBucket added in v0.15.0 

func (x *NumericOutliers_Outlier) GetBucket() int64

func (*NumericOutliers_Outlier) GetHigh added in v0.15.0 

func (x *NumericOutliers_Outlier) GetHigh() float64

func (*NumericOutliers_Outlier) GetLow added in v0.15.0 

func (x *NumericOutliers_Outlier) GetLow() float64

func (*NumericOutliers_Outlier) GetPresent added in v0.15.0 

func (x *NumericOutliers_Outlier) GetPresent() bool

func (*NumericOutliers_Outlier) ProtoMessage added in v0.15.0 

func (*NumericOutliers_Outlier) ProtoMessage()

func (*NumericOutliers_Outlier) ProtoReflect added in v0.15.0 

func (x *NumericOutliers_Outlier) ProtoReflect() protoreflect.Message

func (*NumericOutliers_Outlier) Reset added in v0.15.0 

func (x *NumericOutliers_Outlier) Reset()

func (*NumericOutliers_Outlier) String added in v0.15.0 

func (x *NumericOutliers_Outlier) String() string

type NumericStatistics added in v0.15.0 

type NumericStatistics struct {
	Min  float64 `protobuf:"fixed64,1,opt,name=min,proto3" json:"min,omitempty"`
	Max  float64 `protobuf:"fixed64,2,opt,name=max,proto3" json:"max,omitempty"`
	Mean float64 `protobuf:"fixed64,3,opt,name=mean,proto3" json:"mean,omitempty"`
	Q25  float64 `protobuf:"fixed64,4,opt,name=q25,proto3" json:"q25,omitempty"`
	Q50  float64 `protobuf:"fixed64,5,opt,name=q50,proto3" json:"q50,omitempty"`
	Q75  float64 `protobuf:"fixed64,6,opt,name=q75,proto3" json:"q75,omitempty"`
	Sd   float64 `protobuf:"fixed64,7,opt,name=sd,proto3" json:"sd,omitempty"`
	// contains filtered or unexported fields
}

Response for RuntimeService.GetDescriptiveStatistics

func (*NumericStatistics) Descriptor deprecated added in v0.15.0 

func (*NumericStatistics) Descriptor() ([]byte, []int)

Deprecated: Use NumericStatistics.ProtoReflect.Descriptor instead.

func (*NumericStatistics) GetMax added in v0.15.0 

func (x *NumericStatistics) GetMax() float64

func (*NumericStatistics) GetMean added in v0.15.0 

func (x *NumericStatistics) GetMean() float64

func (*NumericStatistics) GetMin added in v0.15.0 

func (x *NumericStatistics) GetMin() float64

func (*NumericStatistics) GetQ25 added in v0.15.0 

func (x *NumericStatistics) GetQ25() float64

func (*NumericStatistics) GetQ50 added in v0.15.0 

func (x *NumericStatistics) GetQ50() float64

func (*NumericStatistics) GetQ75 added in v0.15.0 

func (x *NumericStatistics) GetQ75() float64

func (*NumericStatistics) GetSd added in v0.15.0 

func (x *NumericStatistics) GetSd() float64

func (*NumericStatistics) ProtoMessage added in v0.15.0 

func (*NumericStatistics) ProtoMessage()

func (*NumericStatistics) ProtoReflect added in v0.15.0 

func (x *NumericStatistics) ProtoReflect() protoreflect.Message

func (*NumericStatistics) Reset added in v0.15.0 

func (x *NumericStatistics) Reset()

func (*NumericStatistics) String added in v0.15.0 

func (x *NumericStatistics) String() string

type NumericSummary added in v0.15.0 

type NumericSummary struct {
	NumericHistogramBins *NumericHistogramBins `protobuf:"bytes,1,opt,name=numericHistogramBins,proto3,oneof" json:"numericHistogramBins,omitempty"`
	NumericStatistics    *NumericStatistics    `protobuf:"bytes,2,opt,name=numericStatistics,proto3,oneof" json:"numericStatistics,omitempty"`
	NumericOutliers      *NumericOutliers      `protobuf:"bytes,3,opt,name=numericOutliers,proto3,oneof" json:"numericOutliers,omitempty"`
	// contains filtered or unexported fields
}

Response for RuntimeService.GetNumericHistogram, RuntimeService.GetDescriptiveStatistics and RuntimeService.GetCardinalityOfColumn. Message will have either numericHistogramBins, numericStatistics or numericOutliers set.

func (*NumericSummary) Descriptor deprecated added in v0.15.0 

func (*NumericSummary) Descriptor() ([]byte, []int)

Deprecated: Use NumericSummary.ProtoReflect.Descriptor instead.

func (*NumericSummary) GetNumericHistogramBins added in v0.15.0 

func (x *NumericSummary) GetNumericHistogramBins() *NumericHistogramBins

func (*NumericSummary) GetNumericOutliers added in v0.15.0 

func (x *NumericSummary) GetNumericOutliers() *NumericOutliers

func (*NumericSummary) GetNumericStatistics added in v0.15.0 

func (x *NumericSummary) GetNumericStatistics() *NumericStatistics

func (*NumericSummary) ProtoMessage added in v0.15.0 

func (*NumericSummary) ProtoMessage()

func (*NumericSummary) ProtoReflect added in v0.15.0 

func (x *NumericSummary) ProtoReflect() protoreflect.Message

func (*NumericSummary) Reset added in v0.15.0 

func (x *NumericSummary) Reset()

func (*NumericSummary) String added in v0.15.0 

func (x *NumericSummary) String() string

type PingRequest 

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

Request message for RuntimeService.Ping

func (*PingRequest) Descriptor deprecated 

func (*PingRequest) Descriptor() ([]byte, []int)

Deprecated: Use PingRequest.ProtoReflect.Descriptor instead.

func (*PingRequest) ProtoMessage 

func (*PingRequest) ProtoMessage()

func (*PingRequest) ProtoReflect 

func (x *PingRequest) ProtoReflect() protoreflect.Message

func (*PingRequest) Reset 

func (x *PingRequest) Reset()

func (*PingRequest) String 

func (x *PingRequest) String() string

type PingResponse 

type PingResponse struct {

	// Runtime version
	Version string `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
	// Runtime server time
	Time *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

Response message for RuntimeService.Ping

func (*PingResponse) Descriptor deprecated 

func (*PingResponse) Descriptor() ([]byte, []int)

Deprecated: Use PingResponse.ProtoReflect.Descriptor instead.

func (*PingResponse) GetTime 

func (x *PingResponse) GetTime() *timestamppb.Timestamp

func (*PingResponse) GetVersion 

func (x *PingResponse) GetVersion() string

func (*PingResponse) ProtoMessage 

func (*PingResponse) ProtoMessage()

func (*PingResponse) ProtoReflect 

func (x *PingResponse) ProtoReflect() protoreflect.Message

func (*PingResponse) Reset 

func (x *PingResponse) Reset()

func (*PingResponse) String 

func (x *PingResponse) String() string

type ProfileColumn added in v0.15.0 

type ProfileColumn struct {
	Name                string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Type                string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	LargestStringLength int32  `protobuf:"varint,3,opt,name=largest_string_length,json=largestStringLength,proto3" json:"largest_string_length,omitempty"`
	// contains filtered or unexported fields
}

func (*ProfileColumn) Descriptor deprecated added in v0.15.0 

func (*ProfileColumn) Descriptor() ([]byte, []int)

Deprecated: Use ProfileColumn.ProtoReflect.Descriptor instead.

func (*ProfileColumn) GetLargestStringLength added in v0.15.0 

func (x *ProfileColumn) GetLargestStringLength() int32

func (*ProfileColumn) GetName added in v0.15.0 

func (x *ProfileColumn) GetName() string

func (*ProfileColumn) GetType added in v0.15.0 

func (x *ProfileColumn) GetType() string

func (*ProfileColumn) ProtoMessage added in v0.15.0 

func (*ProfileColumn) ProtoMessage()

func (*ProfileColumn) ProtoReflect added in v0.15.0 

func (x *ProfileColumn) ProtoReflect() protoreflect.Message

func (*ProfileColumn) Reset added in v0.15.0 

func (x *ProfileColumn) Reset()

func (*ProfileColumn) String added in v0.15.0 

func (x *ProfileColumn) String() string

type ProfileColumnSummary added in v0.15.0 

type ProfileColumnSummary struct {

	// Types that are assignable to Case:
	//
	//	*ProfileColumnSummary_CategoricalSummary
	//	*ProfileColumnSummary_NumericSummary
	//	*ProfileColumnSummary_TimeRangeSummary
	Case isProfileColumnSummary_Case `protobuf_oneof:"Case"`
	// contains filtered or unexported fields
}

func (*ProfileColumnSummary) Descriptor deprecated added in v0.15.0 

func (*ProfileColumnSummary) Descriptor() ([]byte, []int)

Deprecated: Use ProfileColumnSummary.ProtoReflect.Descriptor instead.

func (*ProfileColumnSummary) GetCase added in v0.15.0 

func (m *ProfileColumnSummary) GetCase() isProfileColumnSummary_Case

func (*ProfileColumnSummary) GetCategoricalSummary added in v0.15.0 

func (x *ProfileColumnSummary) GetCategoricalSummary() *CategoricalSummary

func (*ProfileColumnSummary) GetNumericSummary added in v0.15.0 

func (x *ProfileColumnSummary) GetNumericSummary() *NumericSummary

func (*ProfileColumnSummary) GetTimeRangeSummary added in v0.15.0 

func (x *ProfileColumnSummary) GetTimeRangeSummary() *TimeRangeSummary

func (*ProfileColumnSummary) ProtoMessage added in v0.15.0 

func (*ProfileColumnSummary) ProtoMessage()

func (*ProfileColumnSummary) ProtoReflect added in v0.15.0 

func (x *ProfileColumnSummary) ProtoReflect() protoreflect.Message

func (*ProfileColumnSummary) Reset added in v0.15.0 

func (x *ProfileColumnSummary) Reset()

func (*ProfileColumnSummary) String added in v0.15.0 

func (x *ProfileColumnSummary) String() string

type ProfileColumnSummary_CategoricalSummary added in v0.15.0 

type ProfileColumnSummary_CategoricalSummary struct {
	CategoricalSummary *CategoricalSummary `protobuf:"bytes,1,opt,name=categoricalSummary,proto3,oneof"`
}

type ProfileColumnSummary_NumericSummary added in v0.15.0 

type ProfileColumnSummary_NumericSummary struct {
	NumericSummary *NumericSummary `protobuf:"bytes,2,opt,name=numericSummary,proto3,oneof"`
}

type ProfileColumnSummary_TimeRangeSummary added in v0.15.0 

type ProfileColumnSummary_TimeRangeSummary struct {
	TimeRangeSummary *TimeRangeSummary `protobuf:"bytes,3,opt,name=timeRangeSummary,proto3,oneof"`
}

type ProfileColumnsRequest added in v0.15.0 

type ProfileColumnsRequest struct {
	InstanceId string `protobuf:"bytes,1,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"`
	TableName  string `protobuf:"bytes,2,opt,name=table_name,json=tableName,proto3" json:"table_name,omitempty"`
	// contains filtered or unexported fields
}

func (*ProfileColumnsRequest) Descriptor deprecated added in v0.15.0 

func (*ProfileColumnsRequest) Descriptor() ([]byte, []int)

Deprecated: Use ProfileColumnsRequest.ProtoReflect.Descriptor instead.

func (*ProfileColumnsRequest) GetInstanceId added in v0.15.0 

func (x *ProfileColumnsRequest) GetInstanceId() string

func (*ProfileColumnsRequest) GetTableName added in v0.15.0 

func (x *ProfileColumnsRequest) GetTableName() string

func (*ProfileColumnsRequest) ProtoMessage added in v0.15.0 

func (*ProfileColumnsRequest) ProtoMessage()

func (*ProfileColumnsRequest) ProtoReflect added in v0.15.0 

func (x *ProfileColumnsRequest) ProtoReflect() protoreflect.Message

func (*ProfileColumnsRequest) Reset added in v0.15.0 

func (x *ProfileColumnsRequest) Reset()

func (*ProfileColumnsRequest) String added in v0.15.0 

func (x *ProfileColumnsRequest) String() string

type ProfileColumnsResponse added in v0.15.0 

type ProfileColumnsResponse struct {
	ProfileColumns []*ProfileColumn `protobuf:"bytes,1,rep,name=profile_columns,json=profileColumns,proto3" json:"profile_columns,omitempty"`
	// contains filtered or unexported fields
}

func (*ProfileColumnsResponse) Descriptor deprecated added in v0.15.0 

func (*ProfileColumnsResponse) Descriptor() ([]byte, []int)

Deprecated: Use ProfileColumnsResponse.ProtoReflect.Descriptor instead.

func (*ProfileColumnsResponse) GetProfileColumns added in v0.15.0 

func (x *ProfileColumnsResponse) GetProfileColumns() []*ProfileColumn

func (*ProfileColumnsResponse) ProtoMessage added in v0.15.0 

func (*ProfileColumnsResponse) ProtoMessage()

func (*ProfileColumnsResponse) ProtoReflect added in v0.15.0 

func (x *ProfileColumnsResponse) ProtoReflect() protoreflect.Message

func (*ProfileColumnsResponse) Reset added in v0.15.0 

func (x *ProfileColumnsResponse) Reset()

func (*ProfileColumnsResponse) String added in v0.15.0 

func (x *ProfileColumnsResponse) String() string

type PutFileAndMigrateRequest added in v0.15.0 

type PutFileAndMigrateRequest struct {

	// Repo to store the file in
	RepoId string `protobuf:"bytes,1,opt,name=repo_id,json=repoId,proto3" json:"repo_id,omitempty"`
	// Instance to apply the migrations to
	InstanceId string `protobuf:"bytes,2,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"`
	// Path to store the file at
	Path string `protobuf:"bytes,3,opt,name=path,proto3" json:"path,omitempty"`
	// Contents to save to the file
	Blob string `protobuf:"bytes,4,opt,name=blob,proto3" json:"blob,omitempty"`
	// Create indicates whether to create the file if it doesn't already exist
	Create bool `protobuf:"varint,5,opt,name=create,proto3" json:"create,omitempty"`
	// create_only will cause the operation to fail if a file already exists at path.
	// It should only be set when create = true.
	CreateOnly bool `protobuf:"varint,6,opt,name=create_only,json=createOnly,proto3" json:"create_only,omitempty"`
	// If true, will save the file and validate it and related file artifacts, but not actually execute any migrations.
	Dry bool `protobuf:"varint,8,opt,name=dry,proto3" json:"dry,omitempty"`
	// If true, will not execute any migrations if any artifact fails to validate.
	// Otherwise, it will execute a best-effort migration (including dropping objects with artifacts
	// that fail to validate.)
	Strict bool `protobuf:"varint,9,opt,name=strict,proto3" json:"strict,omitempty"`
	// contains filtered or unexported fields
}

func (*PutFileAndMigrateRequest) Descriptor deprecated added in v0.15.0 

func (*PutFileAndMigrateRequest) Descriptor() ([]byte, []int)

Deprecated: Use PutFileAndMigrateRequest.ProtoReflect.Descriptor instead.

func (*PutFileAndMigrateRequest) GetBlob added in v0.15.0 

func (x *PutFileAndMigrateRequest) GetBlob() string

func (*PutFileAndMigrateRequest) GetCreate added in v0.15.0 

func (x *PutFileAndMigrateRequest) GetCreate() bool

func (*PutFileAndMigrateRequest) GetCreateOnly added in v0.15.0 

func (x *PutFileAndMigrateRequest) GetCreateOnly() bool

func (*PutFileAndMigrateRequest) GetDry added in v0.15.0 

func (x *PutFileAndMigrateRequest) GetDry() bool

func (*PutFileAndMigrateRequest) GetInstanceId added in v0.15.0 

func (x *PutFileAndMigrateRequest) GetInstanceId() string

func (*PutFileAndMigrateRequest) GetPath added in v0.15.0 

func (x *PutFileAndMigrateRequest) GetPath() string

func (*PutFileAndMigrateRequest) GetRepoId added in v0.15.0 

func (x *PutFileAndMigrateRequest) GetRepoId() string

func (*PutFileAndMigrateRequest) GetStrict added in v0.15.0 

func (x *PutFileAndMigrateRequest) GetStrict() bool

func (*PutFileAndMigrateRequest) ProtoMessage added in v0.15.0 

func (*PutFileAndMigrateRequest) ProtoMessage()

func (*PutFileAndMigrateRequest) ProtoReflect added in v0.15.0 

func (x *PutFileAndMigrateRequest) ProtoReflect() protoreflect.Message

func (*PutFileAndMigrateRequest) Reset added in v0.15.0 

func (x *PutFileAndMigrateRequest) Reset()

func (*PutFileAndMigrateRequest) String added in v0.15.0 

func (x *PutFileAndMigrateRequest) String() string

type PutFileAndMigrateResponse added in v0.15.0 

type PutFileAndMigrateResponse struct {

	// Errors encountered during the migration. If strict = false, any path in
	// affected_paths without an error can be assumed to have been migrated succesfully.
	Errors []*MigrationError `protobuf:"bytes,1,rep,name=errors,proto3" json:"errors,omitempty"`
	// affected_paths lists all the file paths that were considered while
	// executing the migration. For a PutFileAndMigrate, this includes the put file
	// as well as any file artifacts that rely on objects declared in it.
	AffectedPaths []string `protobuf:"bytes,2,rep,name=affected_paths,json=affectedPaths,proto3" json:"affected_paths,omitempty"`
	// contains filtered or unexported fields
}

func (*PutFileAndMigrateResponse) Descriptor deprecated added in v0.15.0 

func (*PutFileAndMigrateResponse) Descriptor() ([]byte, []int)

Deprecated: Use PutFileAndMigrateResponse.ProtoReflect.Descriptor instead.

func (*PutFileAndMigrateResponse) GetAffectedPaths added in v0.15.0 

func (x *PutFileAndMigrateResponse) GetAffectedPaths() []string

func (*PutFileAndMigrateResponse) GetErrors added in v0.15.0 

func (x *PutFileAndMigrateResponse) GetErrors() []*MigrationError

func (*PutFileAndMigrateResponse) ProtoMessage added in v0.15.0 

func (*PutFileAndMigrateResponse) ProtoMessage()

func (*PutFileAndMigrateResponse) ProtoReflect added in v0.15.0 

func (x *PutFileAndMigrateResponse) ProtoReflect() protoreflect.Message

func (*PutFileAndMigrateResponse) Reset added in v0.15.0 

func (x *PutFileAndMigrateResponse) Reset()

func (*PutFileAndMigrateResponse) String added in v0.15.0 

func (x *PutFileAndMigrateResponse) String() string

type PutFileRequest added in v0.15.0 

type PutFileRequest struct {
	RepoId string `protobuf:"bytes,1,opt,name=repo_id,json=repoId,proto3" json:"repo_id,omitempty"`
	Path   string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	Blob   string `protobuf:"bytes,3,opt,name=blob,proto3" json:"blob,omitempty"`
	// Create indicates whether to create the file if it doesn't already exist
	Create bool `protobuf:"varint,4,opt,name=create,proto3" json:"create,omitempty"`
	// Will cause the operation to fail if the file already exists.
	// It should only be set when create = true.
	CreateOnly bool `protobuf:"varint,5,opt,name=create_only,json=createOnly,proto3" json:"create_only,omitempty"`
	// contains filtered or unexported fields
}

Request message for RuntimeService.PutFile

func (*PutFileRequest) Descriptor deprecated added in v0.15.0 

func (*PutFileRequest) Descriptor() ([]byte, []int)

Deprecated: Use PutFileRequest.ProtoReflect.Descriptor instead.

func (*PutFileRequest) GetBlob added in v0.15.0 

func (x *PutFileRequest) GetBlob() string

func (*PutFileRequest) GetCreate added in v0.15.0 

func (x *PutFileRequest) GetCreate() bool

func (*PutFileRequest) GetCreateOnly added in v0.15.0 

func (x *PutFileRequest) GetCreateOnly() bool

func (*PutFileRequest) GetPath added in v0.15.0 

func (x *PutFileRequest) GetPath() string

func (*PutFileRequest) GetRepoId added in v0.15.0 

func (x *PutFileRequest) GetRepoId() string

func (*PutFileRequest) ProtoMessage added in v0.15.0 

func (*PutFileRequest) ProtoMessage()

func (*PutFileRequest) ProtoReflect added in v0.15.0 

func (x *PutFileRequest) ProtoReflect() protoreflect.Message

func (*PutFileRequest) Reset added in v0.15.0 

func (x *PutFileRequest) Reset()

func (*PutFileRequest) String added in v0.15.0 

func (x *PutFileRequest) String() string

type PutFileResponse added in v0.15.0 

type PutFileResponse struct {
	FilePath string `protobuf:"bytes,1,opt,name=file_path,json=filePath,proto3" json:"file_path,omitempty"` // TODO: Redundant, should be removed (but frontend currently uses it)
	// contains filtered or unexported fields
}

Response message for RuntimeService.PutFile

func (*PutFileResponse) Descriptor deprecated added in v0.15.0 

func (*PutFileResponse) Descriptor() ([]byte, []int)

Deprecated: Use PutFileResponse.ProtoReflect.Descriptor instead.

func (*PutFileResponse) GetFilePath added in v0.15.0 

func (x *PutFileResponse) GetFilePath() string

func (*PutFileResponse) ProtoMessage added in v0.15.0 

func (*PutFileResponse) ProtoMessage()

func (*PutFileResponse) ProtoReflect added in v0.15.0 

func (x *PutFileResponse) ProtoReflect() protoreflect.Message

func (*PutFileResponse) Reset added in v0.15.0 

func (x *PutFileResponse) Reset()

func (*PutFileResponse) String added in v0.15.0 

func (x *PutFileResponse) String() string

type QueryDirectRequest 

type QueryDirectRequest struct {

	// Instance to query
	InstanceId string `protobuf:"bytes,1,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"`
	// SELECT statement
	Sql string `protobuf:"bytes,2,opt,name=sql,proto3" json:"sql,omitempty"`
	// Args to interpolate into the statement
	Args []*structpb.Value `protobuf:"bytes,3,rep,name=args,proto3" json:"args,omitempty"`
	// Query priority (not supported by all backends)
	Priority int64 `protobuf:"varint,4,opt,name=priority,proto3" json:"priority,omitempty"`
	// If true, will only validate the query, not execute it
	DryRun bool `protobuf:"varint,5,opt,name=dry_run,json=dryRun,proto3" json:"dry_run,omitempty"`
	// contains filtered or unexported fields
}

Request message for RuntimeService.QueryDirect

func (*QueryDirectRequest) Descriptor deprecated 

func (*QueryDirectRequest) Descriptor() ([]byte, []int)

Deprecated: Use QueryDirectRequest.ProtoReflect.Descriptor instead.

func (*QueryDirectRequest) GetArgs 

func (x *QueryDirectRequest) GetArgs() []*structpb.Value

func (*QueryDirectRequest) GetDryRun 

func (x *QueryDirectRequest) GetDryRun() bool

func (*QueryDirectRequest) GetInstanceId 

func (x *QueryDirectRequest) GetInstanceId() string

func (*QueryDirectRequest) GetPriority 

func (x *QueryDirectRequest) GetPriority() int64

func (*QueryDirectRequest) GetSql 

func (x *QueryDirectRequest) GetSql() string

func (*QueryDirectRequest) ProtoMessage 

func (*QueryDirectRequest) ProtoMessage()

func (*QueryDirectRequest) ProtoReflect 

func (x *QueryDirectRequest) ProtoReflect() protoreflect.Message

func (*QueryDirectRequest) Reset 

func (x *QueryDirectRequest) Reset()

func (*QueryDirectRequest) String 

func (x *QueryDirectRequest) String() string

type QueryDirectResponse 

type QueryDirectResponse struct {

	// Schema of result data
	Meta *StructType `protobuf:"bytes,1,opt,name=meta,proto3" json:"meta,omitempty"`
	// Result data
	Data []*structpb.Struct `protobuf:"bytes,2,rep,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

Response message for RuntimeService.QueryDirect

func (*QueryDirectResponse) Descriptor deprecated 

func (*QueryDirectResponse) Descriptor() ([]byte, []int)

Deprecated: Use QueryDirectResponse.ProtoReflect.Descriptor instead.

func (*QueryDirectResponse) GetData 

func (x *QueryDirectResponse) GetData() []*structpb.Struct

func (*QueryDirectResponse) GetMeta 

func (x *QueryDirectResponse) GetMeta() *StructType

func (*QueryDirectResponse) ProtoMessage 

func (*QueryDirectResponse) ProtoMessage()

func (*QueryDirectResponse) ProtoReflect 

func (x *QueryDirectResponse) ProtoReflect() protoreflect.Message

func (*QueryDirectResponse) Reset 

func (x *QueryDirectResponse) Reset()

func (*QueryDirectResponse) String 

func (x *QueryDirectResponse) String() string

type QueryRequest 

type QueryRequest struct {

	// Instance to query
	InstanceId string `protobuf:"bytes,1,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"`
	// SELECT statement
	Sql string `protobuf:"bytes,2,opt,name=sql,proto3" json:"sql,omitempty"`
	// Args to interpolate into the statement
	Args []*structpb.Value `protobuf:"bytes,3,rep,name=args,proto3" json:"args,omitempty"`
	// Query priority (not supported by all backends)
	Priority int64 `protobuf:"varint,4,opt,name=priority,proto3" json:"priority,omitempty"`
	// If true, will only validate the query, not execute it
	DryRun bool `protobuf:"varint,5,opt,name=dry_run,json=dryRun,proto3" json:"dry_run,omitempty"`
	// contains filtered or unexported fields
}

Request message for RuntimeService.Query

func (*QueryRequest) Descriptor deprecated 

func (*QueryRequest) Descriptor() ([]byte, []int)

Deprecated: Use QueryRequest.ProtoReflect.Descriptor instead.

func (*QueryRequest) GetArgs 

func (x *QueryRequest) GetArgs() []*structpb.Value

func (*QueryRequest) GetDryRun 

func (x *QueryRequest) GetDryRun() bool

func (*QueryRequest) GetInstanceId 

func (x *QueryRequest) GetInstanceId() string

func (*QueryRequest) GetPriority 

func (x *QueryRequest) GetPriority() int64

func (*QueryRequest) GetSql 

func (x *QueryRequest) GetSql() string

func (*QueryRequest) ProtoMessage 

func (*QueryRequest) ProtoMessage()

func (*QueryRequest) ProtoReflect 

func (x *QueryRequest) ProtoReflect() protoreflect.Message

func (*QueryRequest) Reset 

func (x *QueryRequest) Reset()

func (*QueryRequest) String 

func (x *QueryRequest) String() string

type QueryResponse 

type QueryResponse struct {

	// Schema of result data
	Meta *StructType `protobuf:"bytes,1,opt,name=meta,proto3" json:"meta,omitempty"`
	// Result data
	Data []*structpb.Struct `protobuf:"bytes,2,rep,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

Response message for RuntimeService.Query

func (*QueryResponse) Descriptor deprecated 

func (*QueryResponse) Descriptor() ([]byte, []int)

Deprecated: Use QueryResponse.ProtoReflect.Descriptor instead.

func (*QueryResponse) GetData 

func (x *QueryResponse) GetData() []*structpb.Struct

func (*QueryResponse) GetMeta 

func (x *QueryResponse) GetMeta() *StructType

func (*QueryResponse) ProtoMessage 

func (*QueryResponse) ProtoMessage()

func (*QueryResponse) ProtoReflect 

func (x *QueryResponse) ProtoReflect() protoreflect.Message

func (*QueryResponse) Reset 

func (x *QueryResponse) Reset()

func (*QueryResponse) String 

func (x *QueryResponse) String() string

type RenameDatabaseObjectRequest added in v0.15.0 

type RenameDatabaseObjectRequest struct {
	InstanceId string              `protobuf:"bytes,1,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"`
	Name       string              `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Newname    string              `protobuf:"bytes,3,opt,name=newname,proto3" json:"newname,omitempty"`
	Type       *DatabaseObjectType `protobuf:"varint,4,opt,name=type,proto3,enum=rill.runtime.v1.DatabaseObjectType,oneof" json:"type,omitempty"`
	// contains filtered or unexported fields
}

func (*RenameDatabaseObjectRequest) Descriptor deprecated added in v0.15.0 

func (*RenameDatabaseObjectRequest) Descriptor() ([]byte, []int)

Deprecated: Use RenameDatabaseObjectRequest.ProtoReflect.Descriptor instead.

func (*RenameDatabaseObjectRequest) GetInstanceId added in v0.15.0 

func (x *RenameDatabaseObjectRequest) GetInstanceId() string

func (*RenameDatabaseObjectRequest) GetName added in v0.15.0 

func (x *RenameDatabaseObjectRequest) GetName() string

func (*RenameDatabaseObjectRequest) GetNewname added in v0.15.0 

func (x *RenameDatabaseObjectRequest) GetNewname() string

func (*RenameDatabaseObjectRequest) GetType added in v0.15.0 

func (x *RenameDatabaseObjectRequest) GetType() DatabaseObjectType

func (*RenameDatabaseObjectRequest) ProtoMessage added in v0.15.0 

func (*RenameDatabaseObjectRequest) ProtoMessage()

func (*RenameDatabaseObjectRequest) ProtoReflect added in v0.15.0 

func (x *RenameDatabaseObjectRequest) ProtoReflect() protoreflect.Message

func (*RenameDatabaseObjectRequest) Reset added in v0.15.0 

func (x *RenameDatabaseObjectRequest) Reset()

func (*RenameDatabaseObjectRequest) String added in v0.15.0 

func (x *RenameDatabaseObjectRequest) String() string

type RenameDatabaseObjectResponse added in v0.15.0 

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

func (*RenameDatabaseObjectResponse) Descriptor deprecated added in v0.15.0 

func (*RenameDatabaseObjectResponse) Descriptor() ([]byte, []int)

Deprecated: Use RenameDatabaseObjectResponse.ProtoReflect.Descriptor instead.

func (*RenameDatabaseObjectResponse) ProtoMessage added in v0.15.0 

func (*RenameDatabaseObjectResponse) ProtoMessage()

func (*RenameDatabaseObjectResponse) ProtoReflect added in v0.15.0 

func (x *RenameDatabaseObjectResponse) ProtoReflect() protoreflect.Message

func (*RenameDatabaseObjectResponse) Reset added in v0.15.0 

func (x *RenameDatabaseObjectResponse) Reset()

func (*RenameDatabaseObjectResponse) String added in v0.15.0 

func (x *RenameDatabaseObjectResponse) String() string

type RenameFileAndMigrateRequest added in v0.15.0 

type RenameFileAndMigrateRequest struct {

	// Repo to store the file in
	RepoId string `protobuf:"bytes,1,opt,name=repo_id,json=repoId,proto3" json:"repo_id,omitempty"`
	// Instance to apply the migrations to
	InstanceId string `protobuf:"bytes,2,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"`
	// Current path of the file
	FromPath string `protobuf:"bytes,3,opt,name=from_path,json=fromPath,proto3" json:"from_path,omitempty"`
	// New path of the file
	ToPath string `protobuf:"bytes,4,opt,name=to_path,json=toPath,proto3" json:"to_path,omitempty"`
	// If true, will save the file and validate it and related file artifacts, but not actually execute any migrations.
	Dry bool `protobuf:"varint,5,opt,name=dry,proto3" json:"dry,omitempty"`
	// If true, will not execute any migrations if any artifact fails to validate.
	// Otherwise, it will execute a best-effort migration (including dropping objects with artifacts
	// that fail to validate.)
	Strict bool `protobuf:"varint,6,opt,name=strict,proto3" json:"strict,omitempty"`
	// contains filtered or unexported fields
}

func (*RenameFileAndMigrateRequest) Descriptor deprecated added in v0.15.0 

func (*RenameFileAndMigrateRequest) Descriptor() ([]byte, []int)

Deprecated: Use RenameFileAndMigrateRequest.ProtoReflect.Descriptor instead.

func (*RenameFileAndMigrateRequest) GetDry added in v0.15.0 

func (x *RenameFileAndMigrateRequest) GetDry() bool

func (*RenameFileAndMigrateRequest) GetFromPath added in v0.15.0 

func (x *RenameFileAndMigrateRequest) GetFromPath() string

func (*RenameFileAndMigrateRequest) GetInstanceId added in v0.15.0 

func (x *RenameFileAndMigrateRequest) GetInstanceId() string

func (*RenameFileAndMigrateRequest) GetRepoId added in v0.15.0 

func (x *RenameFileAndMigrateRequest) GetRepoId() string

func (*RenameFileAndMigrateRequest) GetStrict added in v0.15.0 

func (x *RenameFileAndMigrateRequest) GetStrict() bool

func (*RenameFileAndMigrateRequest) GetToPath added in v0.15.0 

func (x *RenameFileAndMigrateRequest) GetToPath() string

func (*RenameFileAndMigrateRequest) ProtoMessage added in v0.15.0 

func (*RenameFileAndMigrateRequest) ProtoMessage()

func (*RenameFileAndMigrateRequest) ProtoReflect added in v0.15.0 

func (x *RenameFileAndMigrateRequest) ProtoReflect() protoreflect.Message

func (*RenameFileAndMigrateRequest) Reset added in v0.15.0 

func (x *RenameFileAndMigrateRequest) Reset()

func (*RenameFileAndMigrateRequest) String added in v0.15.0 

func (x *RenameFileAndMigrateRequest) String() string

type RenameFileAndMigrateResponse added in v0.15.0 

type RenameFileAndMigrateResponse struct {

	// Errors encountered during the migration. If strict = false, any path in
	// affected_paths without an error can be assumed to have been migrated succesfully.
	Errors []*MigrationError `protobuf:"bytes,1,rep,name=errors,proto3" json:"errors,omitempty"`
	// affected_paths lists all the file paths that were considered while
	// executing the migration. For a PutFileAndMigrate, this includes the put file
	// as well as any file artifacts that rely on objects declared in it.
	AffectedPaths []string `protobuf:"bytes,2,rep,name=affected_paths,json=affectedPaths,proto3" json:"affected_paths,omitempty"`
	// contains filtered or unexported fields
}

func (*RenameFileAndMigrateResponse) Descriptor deprecated added in v0.15.0 

func (*RenameFileAndMigrateResponse) Descriptor() ([]byte, []int)

Deprecated: Use RenameFileAndMigrateResponse.ProtoReflect.Descriptor instead.

func (*RenameFileAndMigrateResponse) GetAffectedPaths added in v0.15.0 

func (x *RenameFileAndMigrateResponse) GetAffectedPaths() []string

func (*RenameFileAndMigrateResponse) GetErrors added in v0.15.0 

func (x *RenameFileAndMigrateResponse) GetErrors() []*MigrationError

func (*RenameFileAndMigrateResponse) ProtoMessage added in v0.15.0 

func (*RenameFileAndMigrateResponse) ProtoMessage()

func (*RenameFileAndMigrateResponse) ProtoReflect added in v0.15.0 

func (x *RenameFileAndMigrateResponse) ProtoReflect() protoreflect.Message

func (*RenameFileAndMigrateResponse) Reset added in v0.15.0 

func (x *RenameFileAndMigrateResponse) Reset()

func (*RenameFileAndMigrateResponse) String added in v0.15.0 

func (x *RenameFileAndMigrateResponse) String() string

type RenameFileRequest added in v0.15.0 

type RenameFileRequest struct {
	RepoId   string `protobuf:"bytes,1,opt,name=repo_id,json=repoId,proto3" json:"repo_id,omitempty"`
	FromPath string `protobuf:"bytes,2,opt,name=from_path,json=fromPath,proto3" json:"from_path,omitempty"`
	ToPath   string `protobuf:"bytes,3,opt,name=to_path,json=toPath,proto3" json:"to_path,omitempty"`
	// contains filtered or unexported fields
}

Request message for RuntimeService.RenameFile

func (*RenameFileRequest) Descriptor deprecated added in v0.15.0 

func (*RenameFileRequest) Descriptor() ([]byte, []int)

Deprecated: Use RenameFileRequest.ProtoReflect.Descriptor instead.

func (*RenameFileRequest) GetFromPath added in v0.15.0 

func (x *RenameFileRequest) GetFromPath() string

func (*RenameFileRequest) GetRepoId added in v0.15.0 

func (x *RenameFileRequest) GetRepoId() string

func (*RenameFileRequest) GetToPath added in v0.15.0 

func (x *RenameFileRequest) GetToPath() string

func (*RenameFileRequest) ProtoMessage added in v0.15.0 

func (*RenameFileRequest) ProtoMessage()

func (*RenameFileRequest) ProtoReflect added in v0.15.0 

func (x *RenameFileRequest) ProtoReflect() protoreflect.Message

func (*RenameFileRequest) Reset added in v0.15.0 

func (x *RenameFileRequest) Reset()

func (*RenameFileRequest) String added in v0.15.0 

func (x *RenameFileRequest) String() string

type RenameFileResponse added in v0.15.0 

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

Response message for RuntimeService.RenameFile

func (*RenameFileResponse) Descriptor deprecated added in v0.15.0 

func (*RenameFileResponse) Descriptor() ([]byte, []int)

Deprecated: Use RenameFileResponse.ProtoReflect.Descriptor instead.

func (*RenameFileResponse) ProtoMessage added in v0.15.0 

func (*RenameFileResponse) ProtoMessage()

func (*RenameFileResponse) ProtoReflect added in v0.15.0 

func (x *RenameFileResponse) ProtoReflect() protoreflect.Message

func (*RenameFileResponse) Reset added in v0.15.0 

func (x *RenameFileResponse) Reset()

func (*RenameFileResponse) String added in v0.15.0 

func (x *RenameFileResponse) String() string

type Repo 

type Repo struct {

	// UUID identifier
	RepoId string `protobuf:"bytes,1,opt,name=repo_id,json=repoId,proto3" json:"repo_id,omitempty"`
	// Driver for persisting artifacts. Supports "file" and "postgres".
	Driver string `protobuf:"bytes,2,opt,name=driver,proto3" json:"driver,omitempty"`
	// DSN for driver. If the driver is "file", this should be the path to the root directory.
	Dsn string `protobuf:"bytes,3,opt,name=dsn,proto3" json:"dsn,omitempty"`
	// contains filtered or unexported fields
}

Repo represents a collection of file artifacts containing SQL statements. It will usually by represented as a folder on disk, but may also be backed by a database (for modelling in the cloud where no persistant file system is available).

func (*Repo) Descriptor deprecated 

func (*Repo) Descriptor() ([]byte, []int)

Deprecated: Use Repo.ProtoReflect.Descriptor instead.

func (*Repo) GetDriver 

func (x *Repo) GetDriver() string

func (*Repo) GetDsn 

func (x *Repo) GetDsn() string

func (*Repo) GetRepoId 

func (x *Repo) GetRepoId() string

func (*Repo) ProtoMessage 

func (*Repo) ProtoMessage()

func (*Repo) ProtoReflect 

func (x *Repo) ProtoReflect() protoreflect.Message

func (*Repo) Reset 

func (x *Repo) Reset()

func (*Repo) String 

func (x *Repo) String() string

type RowsRequest added in v0.15.0 

type RowsRequest struct {
	InstanceId string `protobuf:"bytes,1,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"`
	TableName  string `protobuf:"bytes,2,opt,name=table_name,json=tableName,proto3" json:"table_name,omitempty"`
	Limit      int32  `protobuf:"varint,3,opt,name=limit,proto3" json:"limit,omitempty"`
	// contains filtered or unexported fields
}

func (*RowsRequest) Descriptor deprecated added in v0.15.0 

func (*RowsRequest) Descriptor() ([]byte, []int)

Deprecated: Use RowsRequest.ProtoReflect.Descriptor instead.

func (*RowsRequest) GetInstanceId added in v0.15.0 

func (x *RowsRequest) GetInstanceId() string

func (*RowsRequest) GetLimit added in v0.15.0 

func (x *RowsRequest) GetLimit() int32

func (*RowsRequest) GetTableName added in v0.15.0 

func (x *RowsRequest) GetTableName() string

func (*RowsRequest) ProtoMessage added in v0.15.0 

func (*RowsRequest) ProtoMessage()

func (*RowsRequest) ProtoReflect added in v0.15.0 

func (x *RowsRequest) ProtoReflect() protoreflect.Message

func (*RowsRequest) Reset added in v0.15.0 

func (x *RowsRequest) Reset()

func (*RowsRequest) String added in v0.15.0 

func (x *RowsRequest) String() string

type RowsResponse added in v0.15.0 

type RowsResponse struct {
	Data []*structpb.Struct `protobuf:"bytes,1,rep,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*RowsResponse) Descriptor deprecated added in v0.15.0 

func (*RowsResponse) Descriptor() ([]byte, []int)

Deprecated: Use RowsResponse.ProtoReflect.Descriptor instead.

func (*RowsResponse) GetData added in v0.15.0 

func (x *RowsResponse) GetData() []*structpb.Struct

func (*RowsResponse) ProtoMessage added in v0.15.0 

func (*RowsResponse) ProtoMessage()

func (*RowsResponse) ProtoReflect added in v0.15.0 

func (x *RowsResponse) ProtoReflect() protoreflect.Message

func (*RowsResponse) Reset added in v0.15.0 

func (x *RowsResponse) Reset()

func (*RowsResponse) String added in v0.15.0 

func (x *RowsResponse) String() string

type RugHistogramRequest added in v0.15.0 

type RugHistogramRequest struct {
	InstanceId string `protobuf:"bytes,1,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"`
	TableName  string `protobuf:"bytes,2,opt,name=table_name,json=tableName,proto3" json:"table_name,omitempty"`
	ColumnName string `protobuf:"bytes,3,opt,name=column_name,json=columnName,proto3" json:"column_name,omitempty"`
	// contains filtered or unexported fields
}

Request for RuntimeService.GetRugHistogram

func (*RugHistogramRequest) Descriptor deprecated added in v0.15.0 

func (*RugHistogramRequest) Descriptor() ([]byte, []int)

Deprecated: Use RugHistogramRequest.ProtoReflect.Descriptor instead.

func (*RugHistogramRequest) GetColumnName added in v0.15.0 

func (x *RugHistogramRequest) GetColumnName() string

func (*RugHistogramRequest) GetInstanceId added in v0.15.0 

func (x *RugHistogramRequest) GetInstanceId() string

func (*RugHistogramRequest) GetTableName added in v0.15.0 

func (x *RugHistogramRequest) GetTableName() string

func (*RugHistogramRequest) ProtoMessage added in v0.15.0 

func (*RugHistogramRequest) ProtoMessage()

func (*RugHistogramRequest) ProtoReflect added in v0.15.0 

func (x *RugHistogramRequest) ProtoReflect() protoreflect.Message

func (*RugHistogramRequest) Reset added in v0.15.0 

func (x *RugHistogramRequest) Reset()

func (*RugHistogramRequest) String added in v0.15.0 

func (x *RugHistogramRequest) String() string

type RuntimeServiceClient 

type RuntimeServiceClient interface {
	// Ping returns information about the runtime
	Ping(ctx context.Context, in *PingRequest, opts ...grpc.CallOption) (*PingResponse, error)
	// ListRepos lists all the repos currently managed by the runtime
	ListRepos(ctx context.Context, in *ListReposRequest, opts ...grpc.CallOption) (*ListReposResponse, error)
	// GetRepo returns info about a specific repo
	GetRepo(ctx context.Context, in *GetRepoRequest, opts ...grpc.CallOption) (*GetRepoResponse, error)
	// CreateRepo creates a new repo. See the Repo message for an explanation of repos.
	CreateRepo(ctx context.Context, in *CreateRepoRequest, opts ...grpc.CallOption) (*CreateRepoResponse, error)
	// DeleteRepo deletes a repo
	DeleteRepo(ctx context.Context, in *DeleteRepoRequest, opts ...grpc.CallOption) (*DeleteRepoResponse, error)
	// ListFiles lists all the files matching a glob in a repo.
	// The files are sorted by their full path.
	ListFiles(ctx context.Context, in *ListFilesRequest, opts ...grpc.CallOption) (*ListFilesResponse, error)
	// GetFile returns the contents of a specific file in a repo.
	GetFile(ctx context.Context, in *GetFileRequest, opts ...grpc.CallOption) (*GetFileResponse, error)
	// PutFile creates or updates a file in a repo
	PutFile(ctx context.Context, in *PutFileRequest, opts ...grpc.CallOption) (*PutFileResponse, error)
	// DeleteFile deletes a file from a repo
	DeleteFile(ctx context.Context, in *DeleteFileRequest, opts ...grpc.CallOption) (*DeleteFileResponse, error)
	// RenameFile renames a file in a repo
	RenameFile(ctx context.Context, in *RenameFileRequest, opts ...grpc.CallOption) (*RenameFileResponse, error)
	// ListInstances lists all the instances currently managed by the runtime
	ListInstances(ctx context.Context, in *ListInstancesRequest, opts ...grpc.CallOption) (*ListInstancesResponse, error)
	// GetInstance returns information about a specific instance
	GetInstance(ctx context.Context, in *GetInstanceRequest, opts ...grpc.CallOption) (*GetInstanceResponse, error)
	// CreateInstance creates a new instance
	CreateInstance(ctx context.Context, in *CreateInstanceRequest, opts ...grpc.CallOption) (*CreateInstanceResponse, error)
	// DeleteInstance deletes an instance
	DeleteInstance(ctx context.Context, in *DeleteInstanceRequest, opts ...grpc.CallOption) (*DeleteInstanceResponse, error)
	// ListCatalogObjects lists all the objects (like tables, sources or metrics views) registered in an instance's catalog
	ListCatalogObjects(ctx context.Context, in *ListCatalogObjectsRequest, opts ...grpc.CallOption) (*ListCatalogObjectsResponse, error)
	// GetCatalogObject returns information about a specific object in the catalog
	GetCatalogObject(ctx context.Context, in *GetCatalogObjectRequest, opts ...grpc.CallOption) (*GetCatalogObjectResponse, error)
	// TriggerRefresh triggers a refresh of a refreshable catalog object.
	// It currently only supports sources (which will be re-ingested), but will also support materialized models in the future.
	// It does not respond until the refresh has completed (will move to async jobs when the task scheduler is in place).
	TriggerRefresh(ctx context.Context, in *TriggerRefreshRequest, opts ...grpc.CallOption) (*TriggerRefreshResponse, error)
	// TriggerSync syncronizes the instance's catalog with the underlying OLAP's information schema.
	// If the instance has exposed=true, tables found in the information schema will be added to the catalog.
	TriggerSync(ctx context.Context, in *TriggerSyncRequest, opts ...grpc.CallOption) (*TriggerSyncResponse, error)
	// Migrate applies a full set of artifacts from a repo to the catalog and infra.
	// It attempts to infer a minimal number of migrations to apply to reconcile the current state with
	// the desired state expressed in the artifacts. Any existing objects not described in the submitted
	// artifacts will be deleted.
	Migrate(ctx context.Context, in *MigrateRequest, opts ...grpc.CallOption) (*MigrateResponse, error)
	// PutFileAndMigrate combines PutFile and Migrate in a single endpoint to reduce latency.
	// It is equivalent to calling the two RPCs sequentially.
	PutFileAndMigrate(ctx context.Context, in *PutFileAndMigrateRequest, opts ...grpc.CallOption) (*PutFileAndMigrateResponse, error)
	// DeleteFileAndMigrate combines RenameFile and Migrate in a single endpoint to reduce latency.
	DeleteFileAndMigrate(ctx context.Context, in *DeleteFileAndMigrateRequest, opts ...grpc.CallOption) (*DeleteFileAndMigrateResponse, error)
	// RenameFileAndMigrate combines RenameFile and Migrate in a single endpoint to reduce latency.
	RenameFileAndMigrate(ctx context.Context, in *RenameFileAndMigrateRequest, opts ...grpc.CallOption) (*RenameFileAndMigrateResponse, error)
	// DEPRECATED: MigrateSingle applies a single `CREATE` statement.
	// It bypasses the reconciling migrations described in Migrate.
	// We aim to deprecate this function once reconciling migrations are mature and adopted in the modeller.
	MigrateSingle(ctx context.Context, in *MigrateSingleRequest, opts ...grpc.CallOption) (*MigrateSingleResponse, error)
	// DEPRECATED: MigrateDelete deletes a single object.
	// It bypasses the reconciling migrations described in Migrate.
	// We aim to deprecate this function once reconciling migrations are mature and adopted in the modeller.
	MigrateDelete(ctx context.Context, in *MigrateDeleteRequest, opts ...grpc.CallOption) (*MigrateDeleteResponse, error)
	// Query runs a SQL query against the instance's OLAP datastore.
	Query(ctx context.Context, in *QueryRequest, opts ...grpc.CallOption) (*QueryResponse, error)
	// DEPRECATED: QueryDirect runs a SQL query by directly executing it against the instance's OLAP datastore.
	QueryDirect(ctx context.Context, in *QueryDirectRequest, opts ...grpc.CallOption) (*QueryDirectResponse, error)
	// MetricsViewMeta returns metadata about a metrics view.
	// It's comparable to calling GetCatalogObject and will be deprecated in the future.
	MetricsViewMeta(ctx context.Context, in *MetricsViewMetaRequest, opts ...grpc.CallOption) (*MetricsViewMetaResponse, error)
	// MetricsViewToplist returns the top dimension values of a metrics view sorted by one or more measures.
	// It's a convenience API for querying a metrics view.
	MetricsViewToplist(ctx context.Context, in *MetricsViewToplistRequest, opts ...grpc.CallOption) (*MetricsViewToplistResponse, error)
	// MetricsViewTimeSeries returns time series for the measures in the metrics view.
	// It's a convenience API for querying a metrics view.
	MetricsViewTimeSeries(ctx context.Context, in *MetricsViewTimeSeriesRequest, opts ...grpc.CallOption) (*MetricsViewTimeSeriesResponse, error)
	// MetricsViewTotals returns totals over a time period for the measures in a metrics view.
	// It's a convenience API for querying a metrics view.
	MetricsViewTotals(ctx context.Context, in *MetricsViewTotalsRequest, opts ...grpc.CallOption) (*MetricsViewTotalsResponse, error)
	// EstimateRollupInterval (TODO: add description)
	EstimateRollupInterval(ctx context.Context, in *EstimateRollupIntervalRequest, opts ...grpc.CallOption) (*EstimateRollupIntervalResponse, error)
	// Get TopK elements from a table for a column given an agg function
	// agg function and k are optional, defaults are count(*) and 50 respectively
	GetTopK(ctx context.Context, in *TopKRequest, opts ...grpc.CallOption) (*CategoricalSummary, error)
	// Get the number of nulls in a column
	GetNullCount(ctx context.Context, in *NullCountRequest, opts ...grpc.CallOption) (*NullCountResponse, error)
	// Get basic stats for a numeric column like min, max, mean, stddev, etc
	GetDescriptiveStatistics(ctx context.Context, in *DescriptiveStatisticsRequest, opts ...grpc.CallOption) (*NumericSummary, error)
	// Estimates the smallest time grain present in the column
	EstimateSmallestTimeGrain(ctx context.Context, in *EstimateSmallestTimeGrainRequest, opts ...grpc.CallOption) (*EstimateSmallestTimeGrainResponse, error)
	// Get the histogram for values in a column
	GetNumericHistogram(ctx context.Context, in *NumericHistogramRequest, opts ...grpc.CallOption) (*NumericSummary, error)
	// Get outliers for a numeric column
	GetRugHistogram(ctx context.Context, in *RugHistogramRequest, opts ...grpc.CallOption) (*NumericSummary, error)
	// Get the time range summaries (min, max) for a column
	GetTimeRangeSummary(ctx context.Context, in *TimeRangeSummaryRequest, opts ...grpc.CallOption) (*TimeRangeSummary, error)
	// Get cardinality for a column
	GetCardinalityOfColumn(ctx context.Context, in *CardinalityOfColumnRequest, opts ...grpc.CallOption) (*CategoricalSummary, error)
	// Generate time series
	GenerateTimeSeries(ctx context.Context, in *GenerateTimeSeriesRequest, opts ...grpc.CallOption) (*TimeSeriesRollup, error)
	// Tablewide profiling APIs
	RenameDatabaseObject(ctx context.Context, in *RenameDatabaseObjectRequest, opts ...grpc.CallOption) (*RenameDatabaseObjectResponse, error)
	// TableCardinality (TODO: add description)
	TableCardinality(ctx context.Context, in *CardinalityRequest, opts ...grpc.CallOption) (*CardinalityResponse, error)
	// ProfileColumns (TODO: add description)
	ProfileColumns(ctx context.Context, in *ProfileColumnsRequest, opts ...grpc.CallOption) (*ProfileColumnsResponse, error)
	// TableRows (TODO: add description)
	TableRows(ctx context.Context, in *RowsRequest, opts ...grpc.CallOption) (*RowsResponse, error)
	// ListConnectors returns a description of all the connectors implemented in the runtime,
	// including their schema and validation rules
	ListConnectors(ctx context.Context, in *ListConnectorsRequest, opts ...grpc.CallOption) (*ListConnectorsResponse, error)
}

RuntimeServiceClient is the client API for RuntimeService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewRuntimeServiceClient 

func NewRuntimeServiceClient(cc grpc.ClientConnInterface) RuntimeServiceClient

type RuntimeServiceServer 

type RuntimeServiceServer interface {
	// Ping returns information about the runtime
	Ping(context.Context, *PingRequest) (*PingResponse, error)
	// ListRepos lists all the repos currently managed by the runtime
	ListRepos(context.Context, *ListReposRequest) (*ListReposResponse, error)
	// GetRepo returns info about a specific repo
	GetRepo(context.Context, *GetRepoRequest) (*GetRepoResponse, error)
	// CreateRepo creates a new repo. See the Repo message for an explanation of repos.
	CreateRepo(context.Context, *CreateRepoRequest) (*CreateRepoResponse, error)
	// DeleteRepo deletes a repo
	DeleteRepo(context.Context, *DeleteRepoRequest) (*DeleteRepoResponse, error)
	// ListFiles lists all the files matching a glob in a repo.
	// The files are sorted by their full path.
	ListFiles(context.Context, *ListFilesRequest) (*ListFilesResponse, error)
	// GetFile returns the contents of a specific file in a repo.
	GetFile(context.Context, *GetFileRequest) (*GetFileResponse, error)
	// PutFile creates or updates a file in a repo
	PutFile(context.Context, *PutFileRequest) (*PutFileResponse, error)
	// DeleteFile deletes a file from a repo
	DeleteFile(context.Context, *DeleteFileRequest) (*DeleteFileResponse, error)
	// RenameFile renames a file in a repo
	RenameFile(context.Context, *RenameFileRequest) (*RenameFileResponse, error)
	// ListInstances lists all the instances currently managed by the runtime
	ListInstances(context.Context, *ListInstancesRequest) (*ListInstancesResponse, error)
	// GetInstance returns information about a specific instance
	GetInstance(context.Context, *GetInstanceRequest) (*GetInstanceResponse, error)
	// CreateInstance creates a new instance
	CreateInstance(context.Context, *CreateInstanceRequest) (*CreateInstanceResponse, error)
	// DeleteInstance deletes an instance
	DeleteInstance(context.Context, *DeleteInstanceRequest) (*DeleteInstanceResponse, error)
	// ListCatalogObjects lists all the objects (like tables, sources or metrics views) registered in an instance's catalog
	ListCatalogObjects(context.Context, *ListCatalogObjectsRequest) (*ListCatalogObjectsResponse, error)
	// GetCatalogObject returns information about a specific object in the catalog
	GetCatalogObject(context.Context, *GetCatalogObjectRequest) (*GetCatalogObjectResponse, error)
	// TriggerRefresh triggers a refresh of a refreshable catalog object.
	// It currently only supports sources (which will be re-ingested), but will also support materialized models in the future.
	// It does not respond until the refresh has completed (will move to async jobs when the task scheduler is in place).
	TriggerRefresh(context.Context, *TriggerRefreshRequest) (*TriggerRefreshResponse, error)
	// TriggerSync syncronizes the instance's catalog with the underlying OLAP's information schema.
	// If the instance has exposed=true, tables found in the information schema will be added to the catalog.
	TriggerSync(context.Context, *TriggerSyncRequest) (*TriggerSyncResponse, error)
	// Migrate applies a full set of artifacts from a repo to the catalog and infra.
	// It attempts to infer a minimal number of migrations to apply to reconcile the current state with
	// the desired state expressed in the artifacts. Any existing objects not described in the submitted
	// artifacts will be deleted.
	Migrate(context.Context, *MigrateRequest) (*MigrateResponse, error)
	// PutFileAndMigrate combines PutFile and Migrate in a single endpoint to reduce latency.
	// It is equivalent to calling the two RPCs sequentially.
	PutFileAndMigrate(context.Context, *PutFileAndMigrateRequest) (*PutFileAndMigrateResponse, error)
	// DeleteFileAndMigrate combines RenameFile and Migrate in a single endpoint to reduce latency.
	DeleteFileAndMigrate(context.Context, *DeleteFileAndMigrateRequest) (*DeleteFileAndMigrateResponse, error)
	// RenameFileAndMigrate combines RenameFile and Migrate in a single endpoint to reduce latency.
	RenameFileAndMigrate(context.Context, *RenameFileAndMigrateRequest) (*RenameFileAndMigrateResponse, error)
	// DEPRECATED: MigrateSingle applies a single `CREATE` statement.
	// It bypasses the reconciling migrations described in Migrate.
	// We aim to deprecate this function once reconciling migrations are mature and adopted in the modeller.
	MigrateSingle(context.Context, *MigrateSingleRequest) (*MigrateSingleResponse, error)
	// DEPRECATED: MigrateDelete deletes a single object.
	// It bypasses the reconciling migrations described in Migrate.
	// We aim to deprecate this function once reconciling migrations are mature and adopted in the modeller.
	MigrateDelete(context.Context, *MigrateDeleteRequest) (*MigrateDeleteResponse, error)
	// Query runs a SQL query against the instance's OLAP datastore.
	Query(context.Context, *QueryRequest) (*QueryResponse, error)
	// DEPRECATED: QueryDirect runs a SQL query by directly executing it against the instance's OLAP datastore.
	QueryDirect(context.Context, *QueryDirectRequest) (*QueryDirectResponse, error)
	// MetricsViewMeta returns metadata about a metrics view.
	// It's comparable to calling GetCatalogObject and will be deprecated in the future.
	MetricsViewMeta(context.Context, *MetricsViewMetaRequest) (*MetricsViewMetaResponse, error)
	// MetricsViewToplist returns the top dimension values of a metrics view sorted by one or more measures.
	// It's a convenience API for querying a metrics view.
	MetricsViewToplist(context.Context, *MetricsViewToplistRequest) (*MetricsViewToplistResponse, error)
	// MetricsViewTimeSeries returns time series for the measures in the metrics view.
	// It's a convenience API for querying a metrics view.
	MetricsViewTimeSeries(context.Context, *MetricsViewTimeSeriesRequest) (*MetricsViewTimeSeriesResponse, error)
	// MetricsViewTotals returns totals over a time period for the measures in a metrics view.
	// It's a convenience API for querying a metrics view.
	MetricsViewTotals(context.Context, *MetricsViewTotalsRequest) (*MetricsViewTotalsResponse, error)
	// EstimateRollupInterval (TODO: add description)
	EstimateRollupInterval(context.Context, *EstimateRollupIntervalRequest) (*EstimateRollupIntervalResponse, error)
	// Get TopK elements from a table for a column given an agg function
	// agg function and k are optional, defaults are count(*) and 50 respectively
	GetTopK(context.Context, *TopKRequest) (*CategoricalSummary, error)
	// Get the number of nulls in a column
	GetNullCount(context.Context, *NullCountRequest) (*NullCountResponse, error)
	// Get basic stats for a numeric column like min, max, mean, stddev, etc
	GetDescriptiveStatistics(context.Context, *DescriptiveStatisticsRequest) (*NumericSummary, error)
	// Estimates the smallest time grain present in the column
	EstimateSmallestTimeGrain(context.Context, *EstimateSmallestTimeGrainRequest) (*EstimateSmallestTimeGrainResponse, error)
	// Get the histogram for values in a column
	GetNumericHistogram(context.Context, *NumericHistogramRequest) (*NumericSummary, error)
	// Get outliers for a numeric column
	GetRugHistogram(context.Context, *RugHistogramRequest) (*NumericSummary, error)
	// Get the time range summaries (min, max) for a column
	GetTimeRangeSummary(context.Context, *TimeRangeSummaryRequest) (*TimeRangeSummary, error)
	// Get cardinality for a column
	GetCardinalityOfColumn(context.Context, *CardinalityOfColumnRequest) (*CategoricalSummary, error)
	// Generate time series
	GenerateTimeSeries(context.Context, *GenerateTimeSeriesRequest) (*TimeSeriesRollup, error)
	// Tablewide profiling APIs
	RenameDatabaseObject(context.Context, *RenameDatabaseObjectRequest) (*RenameDatabaseObjectResponse, error)
	// TableCardinality (TODO: add description)
	TableCardinality(context.Context, *CardinalityRequest) (*CardinalityResponse, error)
	// ProfileColumns (TODO: add description)
	ProfileColumns(context.Context, *ProfileColumnsRequest) (*ProfileColumnsResponse, error)
	// TableRows (TODO: add description)
	TableRows(context.Context, *RowsRequest) (*RowsResponse, error)
	// ListConnectors returns a description of all the connectors implemented in the runtime,
	// including their schema and validation rules
	ListConnectors(context.Context, *ListConnectorsRequest) (*ListConnectorsResponse, error)
	// contains filtered or unexported methods
}

RuntimeServiceServer is the server API for RuntimeService service. All implementations must embed UnimplementedRuntimeServiceServer for forward compatibility

type Scalar added in v0.15.0 

type Scalar struct {

	// Types that are assignable to Value:
	//
	//	*Scalar_Int64
	//	*Scalar_Double
	//	*Scalar_Timestamp
	Value isScalar_Value `protobuf_oneof:"value"`
	// contains filtered or unexported fields
}

func (*Scalar) Descriptor deprecated added in v0.15.0 

func (*Scalar) Descriptor() ([]byte, []int)

Deprecated: Use Scalar.ProtoReflect.Descriptor instead.

func (*Scalar) GetDouble added in v0.15.0 

func (x *Scalar) GetDouble() float64

func (*Scalar) GetInt64 added in v0.15.0 

func (x *Scalar) GetInt64() int64

func (*Scalar) GetTimestamp added in v0.15.0 

func (x *Scalar) GetTimestamp() *timestamppb.Timestamp

func (*Scalar) GetValue added in v0.15.0 

func (m *Scalar) GetValue() isScalar_Value

func (*Scalar) ProtoMessage added in v0.15.0 

func (*Scalar) ProtoMessage()

func (*Scalar) ProtoReflect added in v0.15.0 

func (x *Scalar) ProtoReflect() protoreflect.Message

func (*Scalar) Reset added in v0.15.0 

func (x *Scalar) Reset()

func (*Scalar) String added in v0.15.0 

func (x *Scalar) String() string

type Scalar_Double added in v0.15.0 

type Scalar_Double struct {
	Double float64 `protobuf:"fixed64,2,opt,name=double,proto3,oneof"`
}

type Scalar_Int64 added in v0.15.0 

type Scalar_Int64 struct {
	Int64 int64 `protobuf:"varint,1,opt,name=int64,proto3,oneof"`
}

type Scalar_Timestamp added in v0.15.0 

type Scalar_Timestamp struct {
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=timestamp,proto3,oneof"`
}

type Source 

type Source struct {

	// Name of the source
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Connector used by the source
	Connector string `protobuf:"bytes,2,opt,name=connector,proto3" json:"connector,omitempty"`
	// Connector properties assigned in the source
	Properties *structpb.Struct `protobuf:"bytes,3,opt,name=properties,proto3" json:"properties,omitempty"`
	// Detected schema of the source
	Schema *StructType `protobuf:"bytes,5,opt,name=schema,proto3" json:"schema,omitempty"`
	// Used for the SQL statement for sources
	// TODO: Remove when frontend sources code has been refactored
	Sql string `protobuf:"bytes,20,opt,name=sql,proto3" json:"sql,omitempty"`
	// contains filtered or unexported fields
}

Source is the internal representation of a source definition

func (*Source) Descriptor deprecated 

func (*Source) Descriptor() ([]byte, []int)

Deprecated: Use Source.ProtoReflect.Descriptor instead.

func (*Source) GetConnector 

func (x *Source) GetConnector() string

func (*Source) GetName 

func (x *Source) GetName() string

func (*Source) GetProperties 

func (x *Source) GetProperties() *structpb.Struct

func (*Source) GetSchema added in v0.15.0 

func (x *Source) GetSchema() *StructType

func (*Source) GetSql 

func (x *Source) GetSql() string

func (*Source) ProtoMessage 

func (*Source) ProtoMessage()

func (*Source) ProtoReflect 

func (x *Source) ProtoReflect() protoreflect.Message

func (*Source) Reset 

func (x *Source) Reset()

func (*Source) String 

func (x *Source) String() string

type StructType added in v0.15.0 

type StructType struct {
	Fields []*StructType_Field `protobuf:"bytes,1,rep,name=fields,proto3" json:"fields,omitempty"`
	// contains filtered or unexported fields
}

StructType is a type composed of ordered, named and typed sub-fields

func (*StructType) Descriptor deprecated added in v0.15.0 

func (*StructType) Descriptor() ([]byte, []int)

Deprecated: Use StructType.ProtoReflect.Descriptor instead.

func (*StructType) GetFields added in v0.15.0 

func (x *StructType) GetFields() []*StructType_Field

func (*StructType) ProtoMessage added in v0.15.0 

func (*StructType) ProtoMessage()

func (*StructType) ProtoReflect added in v0.15.0 

func (x *StructType) ProtoReflect() protoreflect.Message

func (*StructType) Reset added in v0.15.0 

func (x *StructType) Reset()

func (*StructType) String added in v0.15.0 

func (x *StructType) String() string

type StructType_Field added in v0.15.0 

type StructType_Field struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Type *Type  `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	// contains filtered or unexported fields
}

func (*StructType_Field) Descriptor deprecated added in v0.15.0 

func (*StructType_Field) Descriptor() ([]byte, []int)

Deprecated: Use StructType_Field.ProtoReflect.Descriptor instead.

func (*StructType_Field) GetName added in v0.15.0 

func (x *StructType_Field) GetName() string

func (*StructType_Field) GetType added in v0.15.0 

func (x *StructType_Field) GetType() *Type

func (*StructType_Field) ProtoMessage added in v0.15.0 

func (*StructType_Field) ProtoMessage()

func (*StructType_Field) ProtoReflect added in v0.15.0 

func (x *StructType_Field) ProtoReflect() protoreflect.Message

func (*StructType_Field) Reset added in v0.15.0 

func (x *StructType_Field) Reset()

func (*StructType_Field) String added in v0.15.0 

func (x *StructType_Field) String() string

type Table added in v0.15.0 

type Table struct {

	// Table name
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Table schema
	Schema *StructType `protobuf:"bytes,2,opt,name=schema,proto3" json:"schema,omitempty"`
	// Managed is true if the table was created through a runtime migration, false if it was discovered in by
	// scanning the database's information schema.
	Managed bool `protobuf:"varint,3,opt,name=managed,proto3" json:"managed,omitempty"`
	// contains filtered or unexported fields
}

Table represents a table in the OLAP database. These include pre-existing tables discovered by periodically scanning the database's information schema when the instance is created with exposed=true. Pre-existing tables have managed = false.

func (*Table) Descriptor deprecated added in v0.15.0 

func (*Table) Descriptor() ([]byte, []int)

Deprecated: Use Table.ProtoReflect.Descriptor instead.

func (*Table) GetManaged added in v0.15.0 

func (x *Table) GetManaged() bool

func (*Table) GetName added in v0.15.0 

func (x *Table) GetName() string

func (*Table) GetSchema added in v0.15.0 

func (x *Table) GetSchema() *StructType

func (*Table) ProtoMessage added in v0.15.0 

func (*Table) ProtoMessage()

func (*Table) ProtoReflect added in v0.15.0 

func (x *Table) ProtoReflect() protoreflect.Message

func (*Table) Reset added in v0.15.0 

func (x *Table) Reset()

func (*Table) String added in v0.15.0 

func (x *Table) String() string

type TimeGrain added in v0.15.0 

type TimeGrain int32
const (
	TimeGrain_MILLISECOND TimeGrain = 0
	TimeGrain_SECOND      TimeGrain = 1
	TimeGrain_MINUTE      TimeGrain = 2
	TimeGrain_HOUR        TimeGrain = 3
	TimeGrain_DAY         TimeGrain = 4
	TimeGrain_WEEK        TimeGrain = 5
	TimeGrain_MONTH       TimeGrain = 6
	TimeGrain_YEAR        TimeGrain = 7
	TimeGrain_UNSPECIFIED TimeGrain = 8
)

func (TimeGrain) Descriptor added in v0.15.0 

func (TimeGrain) Descriptor() protoreflect.EnumDescriptor

func (TimeGrain) Enum added in v0.15.0 

func (x TimeGrain) Enum() *TimeGrain

func (TimeGrain) EnumDescriptor deprecated added in v0.15.0 

func (TimeGrain) EnumDescriptor() ([]byte, []int)

Deprecated: Use TimeGrain.Descriptor instead.

func (TimeGrain) Number added in v0.15.0 

func (x TimeGrain) Number() protoreflect.EnumNumber

func (TimeGrain) String added in v0.15.0 

func (x TimeGrain) String() string

func (TimeGrain) Type added in v0.15.0 

func (TimeGrain) Type() protoreflect.EnumType

type TimeRangeName added in v0.15.0 

type TimeRangeName int32
const (
	TimeRangeName_LastHour   TimeRangeName = 0
	TimeRangeName_Last6Hours TimeRangeName = 1
	TimeRangeName_LastDay    TimeRangeName = 2
	TimeRangeName_Last2Days  TimeRangeName = 3
	TimeRangeName_Last5Days  TimeRangeName = 4
	TimeRangeName_LastWeek   TimeRangeName = 5
	TimeRangeName_Last2Weeks TimeRangeName = 6
	TimeRangeName_Last30Days TimeRangeName = 7
	TimeRangeName_Last60Days TimeRangeName = 8
	TimeRangeName_AllTime    TimeRangeName = 9
)

func (TimeRangeName) Descriptor added in v0.15.0 

func (TimeRangeName) Descriptor() protoreflect.EnumDescriptor

func (TimeRangeName) Enum added in v0.15.0 

func (x TimeRangeName) Enum() *TimeRangeName

func (TimeRangeName) EnumDescriptor deprecated added in v0.15.0 

func (TimeRangeName) EnumDescriptor() ([]byte, []int)

Deprecated: Use TimeRangeName.Descriptor instead.

func (TimeRangeName) Number added in v0.15.0 

func (x TimeRangeName) Number() protoreflect.EnumNumber

func (TimeRangeName) String added in v0.15.0 

func (x TimeRangeName) String() string

func (TimeRangeName) Type added in v0.15.0 

func (TimeRangeName) Type() protoreflect.EnumType

type TimeRangeSummary added in v0.15.0 

type TimeRangeSummary struct {
	Min      string                     `protobuf:"bytes,1,opt,name=min,proto3" json:"min,omitempty"`
	Max      string                     `protobuf:"bytes,2,opt,name=max,proto3" json:"max,omitempty"`
	Interval *TimeRangeSummary_Interval `protobuf:"bytes,3,opt,name=interval,proto3" json:"interval,omitempty"`
	// contains filtered or unexported fields
}

func (*TimeRangeSummary) Descriptor deprecated added in v0.15.0 

func (*TimeRangeSummary) Descriptor() ([]byte, []int)

Deprecated: Use TimeRangeSummary.ProtoReflect.Descriptor instead.

func (*TimeRangeSummary) GetInterval added in v0.15.0 

func (x *TimeRangeSummary) GetInterval() *TimeRangeSummary_Interval

func (*TimeRangeSummary) GetMax added in v0.15.0 

func (x *TimeRangeSummary) GetMax() string

func (*TimeRangeSummary) GetMin added in v0.15.0 

func (x *TimeRangeSummary) GetMin() string

func (*TimeRangeSummary) ProtoMessage added in v0.15.0 

func (*TimeRangeSummary) ProtoMessage()

func (*TimeRangeSummary) ProtoReflect added in v0.15.0 

func (x *TimeRangeSummary) ProtoReflect() protoreflect.Message

func (*TimeRangeSummary) Reset added in v0.15.0 

func (x *TimeRangeSummary) Reset()

func (*TimeRangeSummary) String added in v0.15.0 

func (x *TimeRangeSummary) String() string

type TimeRangeSummaryRequest added in v0.15.0 

type TimeRangeSummaryRequest struct {
	InstanceId string `protobuf:"bytes,1,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"`
	TableName  string `protobuf:"bytes,2,opt,name=table_name,json=tableName,proto3" json:"table_name,omitempty"`
	ColumnName string `protobuf:"bytes,3,opt,name=column_name,json=columnName,proto3" json:"column_name,omitempty"`
	// contains filtered or unexported fields
}

Request for RuntimeService.GetTimeRangeSummary

func (*TimeRangeSummaryRequest) Descriptor deprecated added in v0.15.0 

func (*TimeRangeSummaryRequest) Descriptor() ([]byte, []int)

Deprecated: Use TimeRangeSummaryRequest.ProtoReflect.Descriptor instead.

func (*TimeRangeSummaryRequest) GetColumnName added in v0.15.0 

func (x *TimeRangeSummaryRequest) GetColumnName() string

func (*TimeRangeSummaryRequest) GetInstanceId added in v0.15.0 

func (x *TimeRangeSummaryRequest) GetInstanceId() string

func (*TimeRangeSummaryRequest) GetTableName added in v0.15.0 

func (x *TimeRangeSummaryRequest) GetTableName() string

func (*TimeRangeSummaryRequest) ProtoMessage added in v0.15.0 

func (*TimeRangeSummaryRequest) ProtoMessage()

func (*TimeRangeSummaryRequest) ProtoReflect added in v0.15.0 

func (x *TimeRangeSummaryRequest) ProtoReflect() protoreflect.Message

func (*TimeRangeSummaryRequest) Reset added in v0.15.0 

func (x *TimeRangeSummaryRequest) Reset()

func (*TimeRangeSummaryRequest) String added in v0.15.0 

func (x *TimeRangeSummaryRequest) String() string

type TimeRangeSummary_Interval added in v0.15.0 

type TimeRangeSummary_Interval struct {
	Months int32 `protobuf:"varint,1,opt,name=months,proto3" json:"months,omitempty"`
	Days   int32 `protobuf:"varint,2,opt,name=days,proto3" json:"days,omitempty"`
	Micros int64 `protobuf:"varint,3,opt,name=micros,proto3" json:"micros,omitempty"`
	// contains filtered or unexported fields
}

func (*TimeRangeSummary_Interval) Descriptor deprecated added in v0.15.0 

func (*TimeRangeSummary_Interval) Descriptor() ([]byte, []int)

Deprecated: Use TimeRangeSummary_Interval.ProtoReflect.Descriptor instead.

func (*TimeRangeSummary_Interval) GetDays added in v0.15.0 

func (x *TimeRangeSummary_Interval) GetDays() int32

func (*TimeRangeSummary_Interval) GetMicros added in v0.15.0 

func (x *TimeRangeSummary_Interval) GetMicros() int64

func (*TimeRangeSummary_Interval) GetMonths added in v0.15.0 

func (x *TimeRangeSummary_Interval) GetMonths() int32

func (*TimeRangeSummary_Interval) ProtoMessage added in v0.15.0 

func (*TimeRangeSummary_Interval) ProtoMessage()

func (*TimeRangeSummary_Interval) ProtoReflect added in v0.15.0 

func (x *TimeRangeSummary_Interval) ProtoReflect() protoreflect.Message

func (*TimeRangeSummary_Interval) Reset added in v0.15.0 

func (x *TimeRangeSummary_Interval) Reset()

func (*TimeRangeSummary_Interval) String added in v0.15.0 

func (x *TimeRangeSummary_Interval) String() string

type TimeSeriesResponse added in v0.15.0 

type TimeSeriesResponse struct {
	Id         *string                              `protobuf:"bytes,1,opt,name=id,proto3,oneof" json:"id,omitempty"`
	Results    []*TimeSeriesValue                   `protobuf:"bytes,2,rep,name=results,proto3" json:"results,omitempty"`
	Spark      *TimeSeriesResponse_TimeSeriesValues `protobuf:"bytes,3,opt,name=spark,proto3,oneof" json:"spark,omitempty"`
	TimeRange  *TimeSeriesTimeRange                 `protobuf:"bytes,4,opt,name=time_range,json=timeRange,proto3,oneof" json:"time_range,omitempty"`
	SampleSize int32                                `protobuf:"varint,5,opt,name=sample_size,json=sampleSize,proto3" json:"sample_size,omitempty"`
	Error      *string                              `protobuf:"bytes,6,opt,name=error,proto3,oneof" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*TimeSeriesResponse) Descriptor deprecated added in v0.15.0 

func (*TimeSeriesResponse) Descriptor() ([]byte, []int)

Deprecated: Use TimeSeriesResponse.ProtoReflect.Descriptor instead.

func (*TimeSeriesResponse) GetError added in v0.15.0 

func (x *TimeSeriesResponse) GetError() string

func (*TimeSeriesResponse) GetId added in v0.15.0 

func (x *TimeSeriesResponse) GetId() string

func (*TimeSeriesResponse) GetResults added in v0.15.0 

func (x *TimeSeriesResponse) GetResults() []*TimeSeriesValue

func (*TimeSeriesResponse) GetSampleSize added in v0.15.0 

func (x *TimeSeriesResponse) GetSampleSize() int32

func (*TimeSeriesResponse) GetSpark added in v0.15.0 

func (x *TimeSeriesResponse) GetSpark() *TimeSeriesResponse_TimeSeriesValues

func (*TimeSeriesResponse) GetTimeRange added in v0.15.0 

func (x *TimeSeriesResponse) GetTimeRange() *TimeSeriesTimeRange

func (*TimeSeriesResponse) ProtoMessage added in v0.15.0 

func (*TimeSeriesResponse) ProtoMessage()

func (*TimeSeriesResponse) ProtoReflect added in v0.15.0 

func (x *TimeSeriesResponse) ProtoReflect() protoreflect.Message

func (*TimeSeriesResponse) Reset added in v0.15.0 

func (x *TimeSeriesResponse) Reset()

func (*TimeSeriesResponse) String added in v0.15.0 

func (x *TimeSeriesResponse) String() string

type TimeSeriesResponse_TimeSeriesValues added in v0.15.0 

type TimeSeriesResponse_TimeSeriesValues struct {
	Values []*TimeSeriesValue `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

func (*TimeSeriesResponse_TimeSeriesValues) Descriptor deprecated added in v0.15.0 

func (*TimeSeriesResponse_TimeSeriesValues) Descriptor() ([]byte, []int)

Deprecated: Use TimeSeriesResponse_TimeSeriesValues.ProtoReflect.Descriptor instead.

func (*TimeSeriesResponse_TimeSeriesValues) GetValues added in v0.15.0 

func (x *TimeSeriesResponse_TimeSeriesValues) GetValues() []*TimeSeriesValue

func (*TimeSeriesResponse_TimeSeriesValues) ProtoMessage added in v0.15.0 

func (*TimeSeriesResponse_TimeSeriesValues) ProtoMessage()

func (*TimeSeriesResponse_TimeSeriesValues) ProtoReflect added in v0.15.0 

func (x *TimeSeriesResponse_TimeSeriesValues) ProtoReflect() protoreflect.Message

func (*TimeSeriesResponse_TimeSeriesValues) Reset added in v0.15.0 

func (x *TimeSeriesResponse_TimeSeriesValues) Reset()

func (*TimeSeriesResponse_TimeSeriesValues) String added in v0.15.0 

func (x *TimeSeriesResponse_TimeSeriesValues) String() string

type TimeSeriesRollup added in v0.15.0 

type TimeSeriesRollup struct {
	Rollup *TimeSeriesResponse `protobuf:"bytes,1,opt,name=rollup,proto3" json:"rollup,omitempty"`
	// contains filtered or unexported fields
}

func (*TimeSeriesRollup) Descriptor deprecated added in v0.15.0 

func (*TimeSeriesRollup) Descriptor() ([]byte, []int)

Deprecated: Use TimeSeriesRollup.ProtoReflect.Descriptor instead.

func (*TimeSeriesRollup) GetRollup added in v0.15.0 

func (x *TimeSeriesRollup) GetRollup() *TimeSeriesResponse

func (*TimeSeriesRollup) ProtoMessage added in v0.15.0 

func (*TimeSeriesRollup) ProtoMessage()

func (*TimeSeriesRollup) ProtoReflect added in v0.15.0 

func (x *TimeSeriesRollup) ProtoReflect() protoreflect.Message

func (*TimeSeriesRollup) Reset added in v0.15.0 

func (x *TimeSeriesRollup) Reset()

func (*TimeSeriesRollup) String added in v0.15.0 

func (x *TimeSeriesRollup) String() string

type TimeSeriesTimeRange added in v0.15.0 

type TimeSeriesTimeRange struct {
	Name     TimeRangeName `protobuf:"varint,1,opt,name=name,proto3,enum=rill.runtime.v1.TimeRangeName" json:"name,omitempty"`
	Start    string        `protobuf:"bytes,2,opt,name=start,proto3" json:"start,omitempty"`
	End      string        `protobuf:"bytes,3,opt,name=end,proto3" json:"end,omitempty"`
	Interval TimeGrain     `protobuf:"varint,4,opt,name=interval,proto3,enum=rill.runtime.v1.TimeGrain" json:"interval,omitempty"`
	// contains filtered or unexported fields
}

func (*TimeSeriesTimeRange) Descriptor deprecated added in v0.15.0 

func (*TimeSeriesTimeRange) Descriptor() ([]byte, []int)

Deprecated: Use TimeSeriesTimeRange.ProtoReflect.Descriptor instead.

func (*TimeSeriesTimeRange) GetEnd added in v0.15.0 

func (x *TimeSeriesTimeRange) GetEnd() string

func (*TimeSeriesTimeRange) GetInterval added in v0.15.0 

func (x *TimeSeriesTimeRange) GetInterval() TimeGrain

func (*TimeSeriesTimeRange) GetName added in v0.15.0 

func (x *TimeSeriesTimeRange) GetName() TimeRangeName

func (*TimeSeriesTimeRange) GetStart added in v0.15.0 

func (x *TimeSeriesTimeRange) GetStart() string

func (*TimeSeriesTimeRange) ProtoMessage added in v0.15.0 

func (*TimeSeriesTimeRange) ProtoMessage()

func (*TimeSeriesTimeRange) ProtoReflect added in v0.15.0 

func (x *TimeSeriesTimeRange) ProtoReflect() protoreflect.Message

func (*TimeSeriesTimeRange) Reset added in v0.15.0 

func (x *TimeSeriesTimeRange) Reset()

func (*TimeSeriesTimeRange) String added in v0.15.0 

func (x *TimeSeriesTimeRange) String() string

type TimeSeriesValue added in v0.15.0 

type TimeSeriesValue struct {
	Ts      string             `protobuf:"bytes,1,opt,name=ts,proto3" json:"ts,omitempty"`
	Bin     *float64           `protobuf:"fixed64,2,opt,name=bin,proto3,oneof" json:"bin,omitempty"`
	Records map[string]float64 `` /* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*TimeSeriesValue) Descriptor deprecated added in v0.15.0 

func (*TimeSeriesValue) Descriptor() ([]byte, []int)

Deprecated: Use TimeSeriesValue.ProtoReflect.Descriptor instead.

func (*TimeSeriesValue) GetBin added in v0.15.0 

func (x *TimeSeriesValue) GetBin() float64

func (*TimeSeriesValue) GetRecords added in v0.15.0 

func (x *TimeSeriesValue) GetRecords() map[string]float64

func (*TimeSeriesValue) GetTs added in v0.15.0 

func (x *TimeSeriesValue) GetTs() string

func (*TimeSeriesValue) ProtoMessage added in v0.15.0 

func (*TimeSeriesValue) ProtoMessage()

func (*TimeSeriesValue) ProtoReflect added in v0.15.0 

func (x *TimeSeriesValue) ProtoReflect() protoreflect.Message

func (*TimeSeriesValue) Reset added in v0.15.0 

func (x *TimeSeriesValue) Reset()

func (*TimeSeriesValue) String added in v0.15.0 

func (x *TimeSeriesValue) String() string

type TopKRequest added in v0.14.0 

type TopKRequest struct {
	InstanceId string  `protobuf:"bytes,1,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"`
	TableName  string  `protobuf:"bytes,2,opt,name=table_name,json=tableName,proto3" json:"table_name,omitempty"`
	ColumnName string  `protobuf:"bytes,3,opt,name=column_name,json=columnName,proto3" json:"column_name,omitempty"`
	Agg        *string `protobuf:"bytes,4,opt,name=agg,proto3,oneof" json:"agg,omitempty"` // default is count(*)
	K          *int32  `protobuf:"varint,5,opt,name=k,proto3,oneof" json:"k,omitempty"`    // default is 50
	// contains filtered or unexported fields
}

Request for RuntimeService.GetTopK. Returns the top K values for a given column using agg function for table table_name.

func (*TopKRequest) Descriptor deprecated added in v0.14.0 

func (*TopKRequest) Descriptor() ([]byte, []int)

Deprecated: Use TopKRequest.ProtoReflect.Descriptor instead.

func (*TopKRequest) GetAgg added in v0.14.0 

func (x *TopKRequest) GetAgg() string

func (*TopKRequest) GetColumnName added in v0.14.0 

func (x *TopKRequest) GetColumnName() string

func (*TopKRequest) GetInstanceId added in v0.14.0 

func (x *TopKRequest) GetInstanceId() string

func (*TopKRequest) GetK added in v0.14.0 

func (x *TopKRequest) GetK() int32

func (*TopKRequest) GetTableName added in v0.14.0 

func (x *TopKRequest) GetTableName() string

func (*TopKRequest) ProtoMessage added in v0.14.0 

func (*TopKRequest) ProtoMessage()

func (*TopKRequest) ProtoReflect added in v0.14.0 

func (x *TopKRequest) ProtoReflect() protoreflect.Message

func (*TopKRequest) Reset added in v0.14.0 

func (x *TopKRequest) Reset()

func (*TopKRequest) String added in v0.14.0 

func (x *TopKRequest) String() string

type TopKResponse added in v0.14.0 

type TopKResponse struct {
	Entries []*TopKResponse_TopKEntry `protobuf:"bytes,1,rep,name=entries,proto3" json:"entries,omitempty"`
	// contains filtered or unexported fields
}

Response for RuntimeService.GetTopK.

func (*TopKResponse) Descriptor deprecated added in v0.14.0 

func (*TopKResponse) Descriptor() ([]byte, []int)

Deprecated: Use TopKResponse.ProtoReflect.Descriptor instead.

func (*TopKResponse) GetEntries added in v0.15.0 

func (x *TopKResponse) GetEntries() []*TopKResponse_TopKEntry

func (*TopKResponse) ProtoMessage added in v0.14.0 

func (*TopKResponse) ProtoMessage()

func (*TopKResponse) ProtoReflect added in v0.14.0 

func (x *TopKResponse) ProtoReflect() protoreflect.Message

func (*TopKResponse) Reset added in v0.14.0 

func (x *TopKResponse) Reset()

func (*TopKResponse) String added in v0.14.0 

func (x *TopKResponse) String() string

type TopKResponse_TopKEntry added in v0.15.0 

type TopKResponse_TopKEntry struct {

	// value is optional so that null values from the database can be represented.
	Value *string `protobuf:"bytes,1,opt,name=value,proto3,oneof" json:"value,omitempty"`
	Count float64 `protobuf:"fixed64,2,opt,name=count,proto3" json:"count,omitempty"`
	// contains filtered or unexported fields
}

func (*TopKResponse_TopKEntry) Descriptor deprecated added in v0.15.0 

func (*TopKResponse_TopKEntry) Descriptor() ([]byte, []int)

Deprecated: Use TopKResponse_TopKEntry.ProtoReflect.Descriptor instead.

func (*TopKResponse_TopKEntry) GetCount added in v0.15.0 

func (x *TopKResponse_TopKEntry) GetCount() float64

func (*TopKResponse_TopKEntry) GetValue added in v0.15.0 

func (x *TopKResponse_TopKEntry) GetValue() string

func (*TopKResponse_TopKEntry) ProtoMessage added in v0.15.0 

func (*TopKResponse_TopKEntry) ProtoMessage()

func (*TopKResponse_TopKEntry) ProtoReflect added in v0.15.0 

func (x *TopKResponse_TopKEntry) ProtoReflect() protoreflect.Message

func (*TopKResponse_TopKEntry) Reset added in v0.15.0 

func (x *TopKResponse_TopKEntry) Reset()

func (*TopKResponse_TopKEntry) String added in v0.15.0 

func (x *TopKResponse_TopKEntry) String() string

type TriggerRefreshRequest 

type TriggerRefreshRequest struct {
	InstanceId string `protobuf:"bytes,1,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"`
	Name       string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

Request message for RuntimeService.TriggerRefresh

func (*TriggerRefreshRequest) Descriptor deprecated 

func (*TriggerRefreshRequest) Descriptor() ([]byte, []int)

Deprecated: Use TriggerRefreshRequest.ProtoReflect.Descriptor instead.

func (*TriggerRefreshRequest) GetInstanceId 

func (x *TriggerRefreshRequest) GetInstanceId() string

func (*TriggerRefreshRequest) GetName 

func (x *TriggerRefreshRequest) GetName() string

func (*TriggerRefreshRequest) ProtoMessage 

func (*TriggerRefreshRequest) ProtoMessage()

func (*TriggerRefreshRequest) ProtoReflect 

func (x *TriggerRefreshRequest) ProtoReflect() protoreflect.Message

func (*TriggerRefreshRequest) Reset 

func (x *TriggerRefreshRequest) Reset()

func (*TriggerRefreshRequest) String 

func (x *TriggerRefreshRequest) String() string

type TriggerRefreshResponse 

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

Response message for RuntimeService.TriggerRefresh

func (*TriggerRefreshResponse) Descriptor deprecated 

func (*TriggerRefreshResponse) Descriptor() ([]byte, []int)

Deprecated: Use TriggerRefreshResponse.ProtoReflect.Descriptor instead.

func (*TriggerRefreshResponse) ProtoMessage 

func (*TriggerRefreshResponse) ProtoMessage()

func (*TriggerRefreshResponse) ProtoReflect 

func (x *TriggerRefreshResponse) ProtoReflect() protoreflect.Message

func (*TriggerRefreshResponse) Reset 

func (x *TriggerRefreshResponse) Reset()

func (*TriggerRefreshResponse) String 

func (x *TriggerRefreshResponse) String() string

type TriggerSyncRequest added in v0.15.0 

type TriggerSyncRequest struct {
	InstanceId string `protobuf:"bytes,1,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"`
	// contains filtered or unexported fields
}

Request message for RuntimeService.TriggerSync

func (*TriggerSyncRequest) Descriptor deprecated added in v0.15.0 

func (*TriggerSyncRequest) Descriptor() ([]byte, []int)

Deprecated: Use TriggerSyncRequest.ProtoReflect.Descriptor instead.

func (*TriggerSyncRequest) GetInstanceId added in v0.15.0 

func (x *TriggerSyncRequest) GetInstanceId() string

func (*TriggerSyncRequest) ProtoMessage added in v0.15.0 

func (*TriggerSyncRequest) ProtoMessage()

func (*TriggerSyncRequest) ProtoReflect added in v0.15.0 

func (x *TriggerSyncRequest) ProtoReflect() protoreflect.Message

func (*TriggerSyncRequest) Reset added in v0.15.0 

func (x *TriggerSyncRequest) Reset()

func (*TriggerSyncRequest) String added in v0.15.0 

func (x *TriggerSyncRequest) String() string

type TriggerSyncResponse added in v0.15.0 

type TriggerSyncResponse struct {
	ObjectsCount        uint32 `protobuf:"varint,1,opt,name=objects_count,json=objectsCount,proto3" json:"objects_count,omitempty"`
	ObjectsAddedCount   uint32 `protobuf:"varint,2,opt,name=objects_added_count,json=objectsAddedCount,proto3" json:"objects_added_count,omitempty"`
	ObjectsUpdatedCount uint32 `protobuf:"varint,3,opt,name=objects_updated_count,json=objectsUpdatedCount,proto3" json:"objects_updated_count,omitempty"`
	ObjectsRemovedCount uint32 `protobuf:"varint,4,opt,name=objects_removed_count,json=objectsRemovedCount,proto3" json:"objects_removed_count,omitempty"`
	// contains filtered or unexported fields
}

Response message for RuntimeService.TriggerSync

func (*TriggerSyncResponse) Descriptor deprecated added in v0.15.0 

func (*TriggerSyncResponse) Descriptor() ([]byte, []int)

Deprecated: Use TriggerSyncResponse.ProtoReflect.Descriptor instead.

func (*TriggerSyncResponse) GetObjectsAddedCount added in v0.15.0 

func (x *TriggerSyncResponse) GetObjectsAddedCount() uint32

func (*TriggerSyncResponse) GetObjectsCount added in v0.15.0 

func (x *TriggerSyncResponse) GetObjectsCount() uint32

func (*TriggerSyncResponse) GetObjectsRemovedCount added in v0.15.0 

func (x *TriggerSyncResponse) GetObjectsRemovedCount() uint32

func (*TriggerSyncResponse) GetObjectsUpdatedCount added in v0.15.0 

func (x *TriggerSyncResponse) GetObjectsUpdatedCount() uint32

func (*TriggerSyncResponse) ProtoMessage added in v0.15.0 

func (*TriggerSyncResponse) ProtoMessage()

func (*TriggerSyncResponse) ProtoReflect added in v0.15.0 

func (x *TriggerSyncResponse) ProtoReflect() protoreflect.Message

func (*TriggerSyncResponse) Reset added in v0.15.0 

func (x *TriggerSyncResponse) Reset()

func (*TriggerSyncResponse) String added in v0.15.0 

func (x *TriggerSyncResponse) String() string

type Type added in v0.15.0 

type Type struct {

	// Code designates the type
	Code Type_Code `protobuf:"varint,1,opt,name=code,proto3,enum=rill.runtime.v1.Type_Code" json:"code,omitempty"`
	// Nullable indicates whether null values are possible
	Nullable bool `protobuf:"varint,2,opt,name=nullable,proto3" json:"nullable,omitempty"`
	// If code is CODE_ARRAY, array_element_type specifies the type of the array elements
	ArrayElementType *Type `protobuf:"bytes,3,opt,name=array_element_type,json=arrayElementType,proto3" json:"array_element_type,omitempty"`
	// If code is CODE_STRUCT, struct_type specifies the type of the struct's fields
	StructType *StructType `protobuf:"bytes,4,opt,name=struct_type,json=structType,proto3" json:"struct_type,omitempty"`
	// If code is CODE_MAP, map_type specifies the map's key and value types
	MapType *MapType `protobuf:"bytes,5,opt,name=map_type,json=mapType,proto3" json:"map_type,omitempty"`
	// contains filtered or unexported fields
}

Type represents a data type in a schema

func (*Type) Descriptor deprecated added in v0.15.0 

func (*Type) Descriptor() ([]byte, []int)

Deprecated: Use Type.ProtoReflect.Descriptor instead.

func (*Type) GetArrayElementType added in v0.15.0 

func (x *Type) GetArrayElementType() *Type

func (*Type) GetCode added in v0.15.0 

func (x *Type) GetCode() Type_Code

func (*Type) GetMapType added in v0.15.0 

func (x *Type) GetMapType() *MapType

func (*Type) GetNullable added in v0.15.0 

func (x *Type) GetNullable() bool

func (*Type) GetStructType added in v0.15.0 

func (x *Type) GetStructType() *StructType

func (*Type) ProtoMessage added in v0.15.0 

func (*Type) ProtoMessage()

func (*Type) ProtoReflect added in v0.15.0 

func (x *Type) ProtoReflect() protoreflect.Message

func (*Type) Reset added in v0.15.0 

func (x *Type) Reset()

func (*Type) String added in v0.15.0 

func (x *Type) String() string

type Type_Code added in v0.15.0 

type Type_Code int32

Code enumerates all the types that can be represented in a schema 

const (
	Type_CODE_UNSPECIFIED Type_Code = 0
	Type_CODE_BOOL        Type_Code = 1
	Type_CODE_INT8        Type_Code = 2
	Type_CODE_INT16       Type_Code = 3
	Type_CODE_INT32       Type_Code = 4
	Type_CODE_INT64       Type_Code = 5
	Type_CODE_INT128      Type_Code = 6
	Type_CODE_UINT8       Type_Code = 7
	Type_CODE_UINT16      Type_Code = 8
	Type_CODE_UINT32      Type_Code = 9
	Type_CODE_UINT64      Type_Code = 10
	Type_CODE_UINT128     Type_Code = 11
	Type_CODE_FLOAT32     Type_Code = 12
	Type_CODE_FLOAT64     Type_Code = 13
	Type_CODE_TIMESTAMP   Type_Code = 14
	Type_CODE_DATE        Type_Code = 15
	Type_CODE_TIME        Type_Code = 16
	Type_CODE_STRING      Type_Code = 17
	Type_CODE_BYTES       Type_Code = 18
	Type_CODE_ARRAY       Type_Code = 19
	Type_CODE_STRUCT      Type_Code = 20
	Type_CODE_MAP         Type_Code = 21
	Type_CODE_DECIMAL     Type_Code = 22
	Type_CODE_JSON        Type_Code = 23
	Type_CODE_UUID        Type_Code = 24
)

func (Type_Code) Descriptor added in v0.15.0 

func (Type_Code) Descriptor() protoreflect.EnumDescriptor

func (Type_Code) Enum added in v0.15.0 

func (x Type_Code) Enum() *Type_Code

func (Type_Code) EnumDescriptor deprecated added in v0.15.0 

func (Type_Code) EnumDescriptor() ([]byte, []int)

Deprecated: Use Type_Code.Descriptor instead.

func (Type_Code) Number added in v0.15.0 

func (x Type_Code) Number() protoreflect.EnumNumber

func (Type_Code) String added in v0.15.0 

func (x Type_Code) String() string

func (Type_Code) Type added in v0.15.0 

func (Type_Code) Type() protoreflect.EnumType

type UnimplementedRuntimeServiceServer 

type UnimplementedRuntimeServiceServer struct {
}

UnimplementedRuntimeServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedRuntimeServiceServer) CreateInstance 

func (UnimplementedRuntimeServiceServer) CreateInstance(context.Context, *CreateInstanceRequest) (*CreateInstanceResponse, error)

func (UnimplementedRuntimeServiceServer) CreateRepo 

func (UnimplementedRuntimeServiceServer) CreateRepo(context.Context, *CreateRepoRequest) (*CreateRepoResponse, error)

func (UnimplementedRuntimeServiceServer) DeleteFile added in v0.15.0 

func (UnimplementedRuntimeServiceServer) DeleteFile(context.Context, *DeleteFileRequest) (*DeleteFileResponse, error)

func (UnimplementedRuntimeServiceServer) DeleteFileAndMigrate added in v0.15.0 

func (UnimplementedRuntimeServiceServer) DeleteFileAndMigrate(context.Context, *DeleteFileAndMigrateRequest) (*DeleteFileAndMigrateResponse, error)

func (UnimplementedRuntimeServiceServer) DeleteInstance 

func (UnimplementedRuntimeServiceServer) DeleteInstance(context.Context, *DeleteInstanceRequest) (*DeleteInstanceResponse, error)

func (UnimplementedRuntimeServiceServer) DeleteRepo 

func (UnimplementedRuntimeServiceServer) DeleteRepo(context.Context, *DeleteRepoRequest) (*DeleteRepoResponse, error)

func (UnimplementedRuntimeServiceServer) EstimateRollupInterval added in v0.15.0 

func (UnimplementedRuntimeServiceServer) EstimateRollupInterval(context.Context, *EstimateRollupIntervalRequest) (*EstimateRollupIntervalResponse, error)

func (UnimplementedRuntimeServiceServer) EstimateSmallestTimeGrain added in v0.15.0 

func (UnimplementedRuntimeServiceServer) EstimateSmallestTimeGrain(context.Context, *EstimateSmallestTimeGrainRequest) (*EstimateSmallestTimeGrainResponse, error)

func (UnimplementedRuntimeServiceServer) GenerateTimeSeries added in v0.15.0 

func (UnimplementedRuntimeServiceServer) GenerateTimeSeries(context.Context, *GenerateTimeSeriesRequest) (*TimeSeriesRollup, error)

func (UnimplementedRuntimeServiceServer) GetCardinalityOfColumn added in v0.15.0 

func (UnimplementedRuntimeServiceServer) GetCardinalityOfColumn(context.Context, *CardinalityOfColumnRequest) (*CategoricalSummary, error)

func (UnimplementedRuntimeServiceServer) GetCatalogObject 

func (UnimplementedRuntimeServiceServer) GetCatalogObject(context.Context, *GetCatalogObjectRequest) (*GetCatalogObjectResponse, error)

func (UnimplementedRuntimeServiceServer) GetDescriptiveStatistics added in v0.15.0 

func (UnimplementedRuntimeServiceServer) GetDescriptiveStatistics(context.Context, *DescriptiveStatisticsRequest) (*NumericSummary, error)

func (UnimplementedRuntimeServiceServer) GetFile added in v0.15.0 

func (UnimplementedRuntimeServiceServer) GetFile(context.Context, *GetFileRequest) (*GetFileResponse, error)

func (UnimplementedRuntimeServiceServer) GetInstance 

func (UnimplementedRuntimeServiceServer) GetInstance(context.Context, *GetInstanceRequest) (*GetInstanceResponse, error)

func (UnimplementedRuntimeServiceServer) GetNullCount added in v0.15.0 

func (UnimplementedRuntimeServiceServer) GetNullCount(context.Context, *NullCountRequest) (*NullCountResponse, error)

func (UnimplementedRuntimeServiceServer) GetNumericHistogram added in v0.15.0 

func (UnimplementedRuntimeServiceServer) GetNumericHistogram(context.Context, *NumericHistogramRequest) (*NumericSummary, error)

func (UnimplementedRuntimeServiceServer) GetRepo 

func (UnimplementedRuntimeServiceServer) GetRepo(context.Context, *GetRepoRequest) (*GetRepoResponse, error)

func (UnimplementedRuntimeServiceServer) GetRugHistogram added in v0.15.0 

func (UnimplementedRuntimeServiceServer) GetRugHistogram(context.Context, *RugHistogramRequest) (*NumericSummary, error)

func (UnimplementedRuntimeServiceServer) GetTimeRangeSummary added in v0.15.0 

func (UnimplementedRuntimeServiceServer) GetTimeRangeSummary(context.Context, *TimeRangeSummaryRequest) (*TimeRangeSummary, error)

func (UnimplementedRuntimeServiceServer) GetTopK added in v0.14.0 

func (UnimplementedRuntimeServiceServer) GetTopK(context.Context, *TopKRequest) (*CategoricalSummary, error)

func (UnimplementedRuntimeServiceServer) ListCatalogObjects 

func (UnimplementedRuntimeServiceServer) ListCatalogObjects(context.Context, *ListCatalogObjectsRequest) (*ListCatalogObjectsResponse, error)

func (UnimplementedRuntimeServiceServer) ListConnectors 

func (UnimplementedRuntimeServiceServer) ListConnectors(context.Context, *ListConnectorsRequest) (*ListConnectorsResponse, error)

func (UnimplementedRuntimeServiceServer) ListFiles added in v0.15.0 

func (UnimplementedRuntimeServiceServer) ListFiles(context.Context, *ListFilesRequest) (*ListFilesResponse, error)

func (UnimplementedRuntimeServiceServer) ListInstances 

func (UnimplementedRuntimeServiceServer) ListInstances(context.Context, *ListInstancesRequest) (*ListInstancesResponse, error)

func (UnimplementedRuntimeServiceServer) ListRepos 

func (UnimplementedRuntimeServiceServer) ListRepos(context.Context, *ListReposRequest) (*ListReposResponse, error)

func (UnimplementedRuntimeServiceServer) MetricsViewMeta 

func (UnimplementedRuntimeServiceServer) MetricsViewMeta(context.Context, *MetricsViewMetaRequest) (*MetricsViewMetaResponse, error)

func (UnimplementedRuntimeServiceServer) MetricsViewTimeSeries 

func (UnimplementedRuntimeServiceServer) MetricsViewTimeSeries(context.Context, *MetricsViewTimeSeriesRequest) (*MetricsViewTimeSeriesResponse, error)

func (UnimplementedRuntimeServiceServer) MetricsViewToplist 

func (UnimplementedRuntimeServiceServer) MetricsViewToplist(context.Context, *MetricsViewToplistRequest) (*MetricsViewToplistResponse, error)

func (UnimplementedRuntimeServiceServer) MetricsViewTotals 

func (UnimplementedRuntimeServiceServer) MetricsViewTotals(context.Context, *MetricsViewTotalsRequest) (*MetricsViewTotalsResponse, error)

func (UnimplementedRuntimeServiceServer) Migrate 

func (UnimplementedRuntimeServiceServer) Migrate(context.Context, *MigrateRequest) (*MigrateResponse, error)

func (UnimplementedRuntimeServiceServer) MigrateDelete 

func (UnimplementedRuntimeServiceServer) MigrateDelete(context.Context, *MigrateDeleteRequest) (*MigrateDeleteResponse, error)

func (UnimplementedRuntimeServiceServer) MigrateSingle 

func (UnimplementedRuntimeServiceServer) MigrateSingle(context.Context, *MigrateSingleRequest) (*MigrateSingleResponse, error)

func (UnimplementedRuntimeServiceServer) Ping 

func (UnimplementedRuntimeServiceServer) Ping(context.Context, *PingRequest) (*PingResponse, error)

func (UnimplementedRuntimeServiceServer) ProfileColumns added in v0.15.0 

func (UnimplementedRuntimeServiceServer) ProfileColumns(context.Context, *ProfileColumnsRequest) (*ProfileColumnsResponse, error)

func (UnimplementedRuntimeServiceServer) PutFile added in v0.15.0 

func (UnimplementedRuntimeServiceServer) PutFile(context.Context, *PutFileRequest) (*PutFileResponse, error)

func (UnimplementedRuntimeServiceServer) PutFileAndMigrate added in v0.15.0 

func (UnimplementedRuntimeServiceServer) PutFileAndMigrate(context.Context, *PutFileAndMigrateRequest) (*PutFileAndMigrateResponse, error)

func (UnimplementedRuntimeServiceServer) Query 

func (UnimplementedRuntimeServiceServer) Query(context.Context, *QueryRequest) (*QueryResponse, error)

func (UnimplementedRuntimeServiceServer) QueryDirect 

func (UnimplementedRuntimeServiceServer) QueryDirect(context.Context, *QueryDirectRequest) (*QueryDirectResponse, error)

func (UnimplementedRuntimeServiceServer) RenameDatabaseObject added in v0.15.0 

func (UnimplementedRuntimeServiceServer) RenameDatabaseObject(context.Context, *RenameDatabaseObjectRequest) (*RenameDatabaseObjectResponse, error)

func (UnimplementedRuntimeServiceServer) RenameFile added in v0.15.0 

func (UnimplementedRuntimeServiceServer) RenameFile(context.Context, *RenameFileRequest) (*RenameFileResponse, error)

func (UnimplementedRuntimeServiceServer) RenameFileAndMigrate added in v0.15.0 

func (UnimplementedRuntimeServiceServer) RenameFileAndMigrate(context.Context, *RenameFileAndMigrateRequest) (*RenameFileAndMigrateResponse, error)

func (UnimplementedRuntimeServiceServer) TableCardinality added in v0.15.0 

func (UnimplementedRuntimeServiceServer) TableCardinality(context.Context, *CardinalityRequest) (*CardinalityResponse, error)

func (UnimplementedRuntimeServiceServer) TableRows added in v0.15.0 

func (UnimplementedRuntimeServiceServer) TableRows(context.Context, *RowsRequest) (*RowsResponse, error)

func (UnimplementedRuntimeServiceServer) TriggerRefresh 

func (UnimplementedRuntimeServiceServer) TriggerRefresh(context.Context, *TriggerRefreshRequest) (*TriggerRefreshResponse, error)

func (UnimplementedRuntimeServiceServer) TriggerSync added in v0.15.0 

func (UnimplementedRuntimeServiceServer) TriggerSync(context.Context, *TriggerSyncRequest) (*TriggerSyncResponse, error)

type UnsafeRuntimeServiceServer 

type UnsafeRuntimeServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeRuntimeServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to RuntimeServiceServer will result in compilation errors.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.