runtimev1

package
v0.16.0-rc8 Latest Latest
Warning

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

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

Documentation

Overview

Package runtimev1 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: "TIME_GRAIN_UNSPECIFIED",
		1: "TIME_GRAIN_MILLISECOND",
		2: "TIME_GRAIN_SECOND",
		3: "TIME_GRAIN_MINUTE",
		4: "TIME_GRAIN_HOUR",
		5: "TIME_GRAIN_DAY",
		6: "TIME_GRAIN_WEEK",
		7: "TIME_GRAIN_MONTH",
		8: "TIME_GRAIN_YEAR",
	}
	TimeGrain_value = map[string]int32{
		"TIME_GRAIN_UNSPECIFIED": 0,
		"TIME_GRAIN_MILLISECOND": 1,
		"TIME_GRAIN_SECOND":      2,
		"TIME_GRAIN_MINUTE":      3,
		"TIME_GRAIN_HOUR":        4,
		"TIME_GRAIN_DAY":         5,
		"TIME_GRAIN_WEEK":        6,
		"TIME_GRAIN_MONTH":       7,
		"TIME_GRAIN_YEAR":        8,
	}
)

Enum value maps for TimeGrain.

View Source
var (
	TimeRangeName_name = map[int32]string{
		0:  "TIME_RANGE_NAME_UNSPECIFIED",
		1:  "TIME_RANGE_NAME_LAST_HOUR",
		2:  "TIME_RANGE_NAME_LAST_6_HOUR",
		3:  "TIME_RANGE_NAME_LAST_DAY",
		4:  "TIME_RANGE_NAME_LAST_2_DAYS",
		5:  "TIME_RANGE_NAME_LAST_5_DAYS",
		6:  "TIME_RANGE_NAME_LAST_WEEK",
		7:  "TIME_RANGE_NAME_LAST_2_WEEKS",
		8:  "TIME_RANGE_NAME_LAST_30_DAYS",
		9:  "TIME_RANGE_NAME_LAST_60_DAYS",
		10: "TIME_RANGE_NAME_ALL_TIME",
	}
	TimeRangeName_value = map[string]int32{
		"TIME_RANGE_NAME_UNSPECIFIED":  0,
		"TIME_RANGE_NAME_LAST_HOUR":    1,
		"TIME_RANGE_NAME_LAST_6_HOUR":  2,
		"TIME_RANGE_NAME_LAST_DAY":     3,
		"TIME_RANGE_NAME_LAST_2_DAYS":  4,
		"TIME_RANGE_NAME_LAST_5_DAYS":  5,
		"TIME_RANGE_NAME_LAST_WEEK":    6,
		"TIME_RANGE_NAME_LAST_2_WEEKS": 7,
		"TIME_RANGE_NAME_LAST_30_DAYS": 8,
		"TIME_RANGE_NAME_LAST_60_DAYS": 9,
		"TIME_RANGE_NAME_ALL_TIME":     10,
	}
)

Enum value maps for TimeRangeName.

View Source
var (
	DatabaseObjectType_name = map[int32]string{
		0: "DATABASE_OBJECT_TYPE_UNSPECIFIED",
		1: "DATABASE_OBJECT_TYPE_TABLE",
		2: "DATABASE_OBJECT_TYPE_VIEW",
		3: "DATABASE_OBJECT_TYPE_FUNCTION",
	}
	DatabaseObjectType_value = map[string]int32{
		"DATABASE_OBJECT_TYPE_UNSPECIFIED": 0,
		"DATABASE_OBJECT_TYPE_TABLE":       1,
		"DATABASE_OBJECT_TYPE_VIEW":        2,
		"DATABASE_OBJECT_TYPE_FUNCTION":    3,
	}
)

Enum value maps for DatabaseObjectType.

View Source
var (
	ReconcileError_Code_name = map[int32]string{
		0: "CODE_UNSPECIFIED",
		1: "CODE_SYNTAX",
		2: "CODE_VALIDATION",
		3: "CODE_DEPENDENCY",
		4: "CODE_OLAP",
		5: "CODE_SOURCE",
	}
	ReconcileError_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 ReconcileError_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 (
	ObjectType_name = map[int32]string{
		0: "OBJECT_TYPE_UNSPECIFIED",
		1: "OBJECT_TYPE_TABLE",
		2: "OBJECT_TYPE_SOURCE",
		3: "OBJECT_TYPE_MODEL",
		4: "OBJECT_TYPE_METRICS_VIEW",
	}
	ObjectType_value = map[string]int32{
		"OBJECT_TYPE_UNSPECIFIED":  0,
		"OBJECT_TYPE_TABLE":        1,
		"OBJECT_TYPE_SOURCE":       2,
		"OBJECT_TYPE_MODEL":        3,
		"OBJECT_TYPE_METRICS_VIEW": 4,
	}
)

Enum value maps for ObjectType.

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 (
	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_rill_runtime_v1_api_proto protoreflect.FileDescriptor
View Source
var File_rill_runtime_v1_catalog_proto protoreflect.FileDescriptor
View Source
var File_rill_runtime_v1_schema_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: "ListInstances",
			Handler:    _RuntimeService_ListInstances_Handler,
		},
		{
			MethodName: "GetInstance",
			Handler:    _RuntimeService_GetInstance_Handler,
		},
		{
			MethodName: "CreateInstance",
			Handler:    _RuntimeService_CreateInstance_Handler,
		},
		{
			MethodName: "DeleteInstance",
			Handler:    _RuntimeService_DeleteInstance_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: "ListCatalogEntries",
			Handler:    _RuntimeService_ListCatalogEntries_Handler,
		},
		{
			MethodName: "GetCatalogEntry",
			Handler:    _RuntimeService_GetCatalogEntry_Handler,
		},
		{
			MethodName: "TriggerRefresh",
			Handler:    _RuntimeService_TriggerRefresh_Handler,
		},
		{
			MethodName: "TriggerSync",
			Handler:    _RuntimeService_TriggerSync_Handler,
		},
		{
			MethodName: "Reconcile",
			Handler:    _RuntimeService_Reconcile_Handler,
		},
		{
			MethodName: "PutFileAndReconcile",
			Handler:    _RuntimeService_PutFileAndReconcile_Handler,
		},
		{
			MethodName: "DeleteFileAndReconcile",
			Handler:    _RuntimeService_DeleteFileAndReconcile_Handler,
		},
		{
			MethodName: "RenameFileAndReconcile",
			Handler:    _RuntimeService_RenameFileAndReconcile_Handler,
		},
		{
			MethodName: "RefreshAndReconcile",
			Handler:    _RuntimeService_RefreshAndReconcile_Handler,
		},
		{
			MethodName: "Query",
			Handler:    _RuntimeService_Query_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: "GetTableCardinality",
			Handler:    _RuntimeService_GetTableCardinality_Handler,
		},
		{
			MethodName: "ProfileColumns",
			Handler:    _RuntimeService_ProfileColumns_Handler,
		},
		{
			MethodName: "GetTableRows",
			Handler:    _RuntimeService_GetTableRows_Handler,
		},
		{
			MethodName: "ListConnectors",
			Handler:    _RuntimeService_ListConnectors_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "rill/runtime/v1/api.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 CatalogEntry

type CatalogEntry struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Types that are assignable to Object:
	//	*CatalogEntry_Table
	//	*CatalogEntry_Source
	//	*CatalogEntry_Model
	//	*CatalogEntry_MetricsView
	Object      isCatalogEntry_Object  `protobuf_oneof:"object"`
	Path        string                 `protobuf:"bytes,6,opt,name=path,proto3" json:"path,omitempty"`
	CreatedOn   *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=created_on,json=createdOn,proto3" json:"created_on,omitempty"`
	UpdatedOn   *timestamppb.Timestamp `protobuf:"bytes,8,opt,name=updated_on,json=updatedOn,proto3" json:"updated_on,omitempty"`
	RefreshedOn *timestamppb.Timestamp `protobuf:"bytes,9,opt,name=refreshed_on,json=refreshedOn,proto3" json:"refreshed_on,omitempty"`
	// contains filtered or unexported fields
}

CatalogEntry contains information about an object in the catalog

func (*CatalogEntry) Descriptor deprecated

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

Deprecated: Use CatalogEntry.ProtoReflect.Descriptor instead.

func (*CatalogEntry) GetCreatedOn

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

func (*CatalogEntry) GetMetricsView

func (x *CatalogEntry) GetMetricsView() *MetricsView

func (*CatalogEntry) GetModel

func (x *CatalogEntry) GetModel() *Model

func (*CatalogEntry) GetName

func (x *CatalogEntry) GetName() string

func (*CatalogEntry) GetObject

func (m *CatalogEntry) GetObject() isCatalogEntry_Object

func (*CatalogEntry) GetPath

func (x *CatalogEntry) GetPath() string

func (*CatalogEntry) GetRefreshedOn

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

func (*CatalogEntry) GetSource

func (x *CatalogEntry) GetSource() *Source

func (*CatalogEntry) GetTable

func (x *CatalogEntry) GetTable() *Table

func (*CatalogEntry) GetUpdatedOn

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

func (*CatalogEntry) ProtoMessage

func (*CatalogEntry) ProtoMessage()

func (*CatalogEntry) ProtoReflect

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

func (*CatalogEntry) Reset

func (x *CatalogEntry) Reset()

func (*CatalogEntry) String

func (x *CatalogEntry) String() string

type CatalogEntry_MetricsView

type CatalogEntry_MetricsView struct {
	MetricsView *MetricsView `protobuf:"bytes,5,opt,name=metrics_view,json=metricsView,proto3,oneof"`
}

type CatalogEntry_Model

type CatalogEntry_Model struct {
	Model *Model `protobuf:"bytes,4,opt,name=model,proto3,oneof"`
}

type CatalogEntry_Source

type CatalogEntry_Source struct {
	Source *Source `protobuf:"bytes,3,opt,name=source,proto3,oneof"`
}

type CatalogEntry_Table

type CatalogEntry_Table struct {
	Table *Table `protobuf:"bytes,2,opt,name=table,proto3,oneof"`
}

type CategoricalSummary

type CategoricalSummary struct {

	// Types that are assignable to Case:
	//	*CategoricalSummary_TopK
	//	*CategoricalSummary_Cardinality
	Case isCategoricalSummary_Case `protobuf_oneof:"case"`
	// contains filtered or unexported fields
}

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

func (*CategoricalSummary) Descriptor deprecated

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

Deprecated: Use CategoricalSummary.ProtoReflect.Descriptor instead.

func (*CategoricalSummary) GetCardinality

func (x *CategoricalSummary) GetCardinality() float64

func (*CategoricalSummary) GetCase

func (m *CategoricalSummary) GetCase() isCategoricalSummary_Case

func (*CategoricalSummary) GetTopK

func (x *CategoricalSummary) GetTopK() *TopK

func (*CategoricalSummary) ProtoMessage

func (*CategoricalSummary) ProtoMessage()

func (*CategoricalSummary) ProtoReflect

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

func (*CategoricalSummary) Reset

func (x *CategoricalSummary) Reset()

func (*CategoricalSummary) String

func (x *CategoricalSummary) String() string

type CategoricalSummary_Cardinality

type CategoricalSummary_Cardinality struct {
	Cardinality float64 `protobuf:"fixed64,2,opt,name=cardinality,proto3,oneof"`
}

type CategoricalSummary_TopK

type CategoricalSummary_TopK struct {
	TopK *TopK `protobuf:"bytes,1,opt,name=top_k,json=topK,proto3,oneof"`
}

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

func (x *Connector_Property) GetHint() string

func (*Connector_Property) GetHref

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 (*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) Enum

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 (Connector_Property_Type) String

func (x Connector_Property_Type) String() string

func (Connector_Property_Type) Type

type CreateInstanceRequest

type CreateInstanceRequest struct {
	InstanceId   string `protobuf:"bytes,1,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"`
	OlapDriver   string `protobuf:"bytes,2,opt,name=olap_driver,json=olapDriver,proto3" json:"olap_driver,omitempty"`
	OlapDsn      string `protobuf:"bytes,3,opt,name=olap_dsn,json=olapDsn,proto3" json:"olap_dsn,omitempty"`
	RepoDriver   string `protobuf:"bytes,4,opt,name=repo_driver,json=repoDriver,proto3" json:"repo_driver,omitempty"`
	RepoDsn      string `protobuf:"bytes,5,opt,name=repo_dsn,json=repoDsn,proto3" json:"repo_dsn,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. See message Instance for field descriptions.

func (*CreateInstanceRequest) Descriptor deprecated

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

Deprecated: Use CreateInstanceRequest.ProtoReflect.Descriptor instead.

func (*CreateInstanceRequest) GetEmbedCatalog

func (x *CreateInstanceRequest) GetEmbedCatalog() bool

func (*CreateInstanceRequest) GetInstanceId

func (x *CreateInstanceRequest) GetInstanceId() string

func (*CreateInstanceRequest) GetOlapDriver

func (x *CreateInstanceRequest) GetOlapDriver() string

func (*CreateInstanceRequest) GetOlapDsn

func (x *CreateInstanceRequest) GetOlapDsn() string

func (*CreateInstanceRequest) GetRepoDriver

func (x *CreateInstanceRequest) GetRepoDriver() string

func (*CreateInstanceRequest) GetRepoDsn

func (x *CreateInstanceRequest) GetRepoDsn() 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 {
	Instance *Instance `protobuf:"bytes,1,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) 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 DatabaseObjectType

type DatabaseObjectType int32
const (
	DatabaseObjectType_DATABASE_OBJECT_TYPE_UNSPECIFIED DatabaseObjectType = 0
	DatabaseObjectType_DATABASE_OBJECT_TYPE_TABLE       DatabaseObjectType = 1
	DatabaseObjectType_DATABASE_OBJECT_TYPE_VIEW        DatabaseObjectType = 2
	DatabaseObjectType_DATABASE_OBJECT_TYPE_FUNCTION    DatabaseObjectType = 3
)

func (DatabaseObjectType) Descriptor

func (DatabaseObjectType) Enum

func (DatabaseObjectType) EnumDescriptor deprecated

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

Deprecated: Use DatabaseObjectType.Descriptor instead.

func (DatabaseObjectType) Number

func (DatabaseObjectType) String

func (x DatabaseObjectType) String() string

func (DatabaseObjectType) Type

type DeleteFileAndReconcileRequest

type DeleteFileAndReconcileRequest struct {

	// Instance to store file in and reconcile
	InstanceId string `protobuf:"bytes,1,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"`
	// Path to store the file at
	Path string `protobuf:"bytes,2,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,3,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 reconciliation (including dropping objects with
	// artifacts that fail to validate.)
	Strict bool `protobuf:"varint,4,opt,name=strict,proto3" json:"strict,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteFileAndReconcileRequest) Descriptor deprecated

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

Deprecated: Use DeleteFileAndReconcileRequest.ProtoReflect.Descriptor instead.

func (*DeleteFileAndReconcileRequest) GetDry

func (x *DeleteFileAndReconcileRequest) GetDry() bool

func (*DeleteFileAndReconcileRequest) GetInstanceId

func (x *DeleteFileAndReconcileRequest) GetInstanceId() string

func (*DeleteFileAndReconcileRequest) GetPath

func (*DeleteFileAndReconcileRequest) GetStrict

func (x *DeleteFileAndReconcileRequest) GetStrict() bool

func (*DeleteFileAndReconcileRequest) ProtoMessage

func (*DeleteFileAndReconcileRequest) ProtoMessage()

func (*DeleteFileAndReconcileRequest) ProtoReflect

func (*DeleteFileAndReconcileRequest) Reset

func (x *DeleteFileAndReconcileRequest) Reset()

func (*DeleteFileAndReconcileRequest) String

type DeleteFileAndReconcileResponse

type DeleteFileAndReconcileResponse struct {

	// Errors encountered during reconciliation. If strict = false, any path in
	// affected_paths without an error can be assumed to have been reconciled succesfully.
	Errors []*ReconcileError `protobuf:"bytes,1,rep,name=errors,proto3" json:"errors,omitempty"`
	// affected_paths lists all the file artifact paths that were considered while
	// executing the reconciliation. 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
}

func (*DeleteFileAndReconcileResponse) Descriptor deprecated

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

Deprecated: Use DeleteFileAndReconcileResponse.ProtoReflect.Descriptor instead.

func (*DeleteFileAndReconcileResponse) GetAffectedPaths

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

func (*DeleteFileAndReconcileResponse) GetErrors

func (*DeleteFileAndReconcileResponse) ProtoMessage

func (*DeleteFileAndReconcileResponse) ProtoMessage()

func (*DeleteFileAndReconcileResponse) ProtoReflect

func (*DeleteFileAndReconcileResponse) Reset

func (x *DeleteFileAndReconcileResponse) Reset()

func (*DeleteFileAndReconcileResponse) String

type DeleteFileRequest

type DeleteFileRequest struct {
	InstanceId string `protobuf:"bytes,1,opt,name=instance_id,json=instanceId,proto3" json:"instance_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

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

Deprecated: Use DeleteFileRequest.ProtoReflect.Descriptor instead.

func (*DeleteFileRequest) GetInstanceId

func (x *DeleteFileRequest) GetInstanceId() string

func (*DeleteFileRequest) GetPath

func (x *DeleteFileRequest) GetPath() string

func (*DeleteFileRequest) ProtoMessage

func (*DeleteFileRequest) ProtoMessage()

func (*DeleteFileRequest) ProtoReflect

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

func (*DeleteFileRequest) Reset

func (x *DeleteFileRequest) Reset()

func (*DeleteFileRequest) String

func (x *DeleteFileRequest) String() string

type DeleteFileResponse

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

Response message for RuntimeService.DeleteFile

func (*DeleteFileResponse) Descriptor deprecated

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

Deprecated: Use DeleteFileResponse.ProtoReflect.Descriptor instead.

func (*DeleteFileResponse) ProtoMessage

func (*DeleteFileResponse) ProtoMessage()

func (*DeleteFileResponse) ProtoReflect

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

func (*DeleteFileResponse) Reset

func (x *DeleteFileResponse) Reset()

func (*DeleteFileResponse) String

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 EstimateRollupIntervalRequest

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"`
	Priority   int32  `protobuf:"varint,4,opt,name=priority,proto3" json:"priority,omitempty"`
	// contains filtered or unexported fields
}

func (*EstimateRollupIntervalRequest) Descriptor deprecated

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

Deprecated: Use EstimateRollupIntervalRequest.ProtoReflect.Descriptor instead.

func (*EstimateRollupIntervalRequest) GetColumnName

func (x *EstimateRollupIntervalRequest) GetColumnName() string

func (*EstimateRollupIntervalRequest) GetInstanceId

func (x *EstimateRollupIntervalRequest) GetInstanceId() string

func (*EstimateRollupIntervalRequest) GetPriority

func (x *EstimateRollupIntervalRequest) GetPriority() int32

func (*EstimateRollupIntervalRequest) GetTableName

func (x *EstimateRollupIntervalRequest) GetTableName() string

func (*EstimateRollupIntervalRequest) ProtoMessage

func (*EstimateRollupIntervalRequest) ProtoMessage()

func (*EstimateRollupIntervalRequest) ProtoReflect

func (*EstimateRollupIntervalRequest) Reset

func (x *EstimateRollupIntervalRequest) Reset()

func (*EstimateRollupIntervalRequest) String

type EstimateRollupIntervalResponse

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

func (*EstimateRollupIntervalResponse) Descriptor deprecated

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

Deprecated: Use EstimateRollupIntervalResponse.ProtoReflect.Descriptor instead.

func (*EstimateRollupIntervalResponse) GetEnd

func (*EstimateRollupIntervalResponse) GetInterval

func (x *EstimateRollupIntervalResponse) GetInterval() TimeGrain

func (*EstimateRollupIntervalResponse) GetStart

func (*EstimateRollupIntervalResponse) ProtoMessage

func (*EstimateRollupIntervalResponse) ProtoMessage()

func (*EstimateRollupIntervalResponse) ProtoReflect

func (*EstimateRollupIntervalResponse) Reset

func (x *EstimateRollupIntervalResponse) Reset()

func (*EstimateRollupIntervalResponse) String

type EstimateSmallestTimeGrainRequest

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"`
	Priority   int32  `protobuf:"varint,4,opt,name=priority,proto3" json:"priority,omitempty"`
	// contains filtered or unexported fields
}

Request for RuntimeService.EstimateSmallestTimeGrainRequest

func (*EstimateSmallestTimeGrainRequest) Descriptor deprecated

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

Deprecated: Use EstimateSmallestTimeGrainRequest.ProtoReflect.Descriptor instead.

func (*EstimateSmallestTimeGrainRequest) GetColumnName

func (x *EstimateSmallestTimeGrainRequest) GetColumnName() string

func (*EstimateSmallestTimeGrainRequest) GetInstanceId

func (x *EstimateSmallestTimeGrainRequest) GetInstanceId() string

func (*EstimateSmallestTimeGrainRequest) GetPriority

func (x *EstimateSmallestTimeGrainRequest) GetPriority() int32

func (*EstimateSmallestTimeGrainRequest) GetTableName

func (x *EstimateSmallestTimeGrainRequest) GetTableName() string

func (*EstimateSmallestTimeGrainRequest) ProtoMessage

func (*EstimateSmallestTimeGrainRequest) ProtoMessage()

func (*EstimateSmallestTimeGrainRequest) ProtoReflect

func (*EstimateSmallestTimeGrainRequest) Reset

func (*EstimateSmallestTimeGrainRequest) String

type EstimateSmallestTimeGrainResponse

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

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

Deprecated: Use EstimateSmallestTimeGrainResponse.ProtoReflect.Descriptor instead.

func (*EstimateSmallestTimeGrainResponse) GetTimeGrain

func (x *EstimateSmallestTimeGrainResponse) GetTimeGrain() TimeGrain

func (*EstimateSmallestTimeGrainResponse) ProtoMessage

func (*EstimateSmallestTimeGrainResponse) ProtoMessage()

func (*EstimateSmallestTimeGrainResponse) ProtoReflect

func (*EstimateSmallestTimeGrainResponse) Reset

func (*EstimateSmallestTimeGrainResponse) String

type GenerateTimeSeriesRequest

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_BasicMeasure `protobuf:"bytes,3,rep,name=measures,proto3" 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" json:"time_range,omitempty"`
	Filters             *MetricsViewRequestFilter                 `protobuf:"bytes,6,opt,name=filters,proto3" json:"filters,omitempty"`
	Pixels              int32                                     `protobuf:"varint,7,opt,name=pixels,proto3" json:"pixels,omitempty"`
	SampleSize          int32                                     `protobuf:"varint,8,opt,name=sample_size,json=sampleSize,proto3" json:"sample_size,omitempty"`
	Priority            int32                                     `protobuf:"varint,9,opt,name=priority,proto3" json:"priority,omitempty"`
	// contains filtered or unexported fields
}

func (*GenerateTimeSeriesRequest) Descriptor deprecated

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

Deprecated: Use GenerateTimeSeriesRequest.ProtoReflect.Descriptor instead.

func (*GenerateTimeSeriesRequest) GetFilters

func (*GenerateTimeSeriesRequest) GetInstanceId

func (x *GenerateTimeSeriesRequest) GetInstanceId() string

func (*GenerateTimeSeriesRequest) GetMeasures

func (*GenerateTimeSeriesRequest) GetPixels

func (x *GenerateTimeSeriesRequest) GetPixels() int32

func (*GenerateTimeSeriesRequest) GetPriority

func (x *GenerateTimeSeriesRequest) GetPriority() int32

func (*GenerateTimeSeriesRequest) GetSampleSize

func (x *GenerateTimeSeriesRequest) GetSampleSize() int32

func (*GenerateTimeSeriesRequest) GetTableName

func (x *GenerateTimeSeriesRequest) GetTableName() string

func (*GenerateTimeSeriesRequest) GetTimeRange

func (*GenerateTimeSeriesRequest) GetTimestampColumnName

func (x *GenerateTimeSeriesRequest) GetTimestampColumnName() string

func (*GenerateTimeSeriesRequest) ProtoMessage

func (*GenerateTimeSeriesRequest) ProtoMessage()

func (*GenerateTimeSeriesRequest) ProtoReflect

func (*GenerateTimeSeriesRequest) Reset

func (x *GenerateTimeSeriesRequest) Reset()

func (*GenerateTimeSeriesRequest) String

func (x *GenerateTimeSeriesRequest) String() string

type GenerateTimeSeriesRequest_BasicMeasure

type GenerateTimeSeriesRequest_BasicMeasure 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" json:"sql_name,omitempty"`
	// contains filtered or unexported fields
}

func (*GenerateTimeSeriesRequest_BasicMeasure) Descriptor deprecated

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

Deprecated: Use GenerateTimeSeriesRequest_BasicMeasure.ProtoReflect.Descriptor instead.

func (*GenerateTimeSeriesRequest_BasicMeasure) GetExpression

func (*GenerateTimeSeriesRequest_BasicMeasure) GetId

func (*GenerateTimeSeriesRequest_BasicMeasure) GetSqlName

func (*GenerateTimeSeriesRequest_BasicMeasure) ProtoMessage

func (*GenerateTimeSeriesRequest_BasicMeasure) ProtoReflect

func (*GenerateTimeSeriesRequest_BasicMeasure) Reset

func (*GenerateTimeSeriesRequest_BasicMeasure) String

type GenerateTimeSeriesResponse

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

func (*GenerateTimeSeriesResponse) Descriptor deprecated

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

Deprecated: Use GenerateTimeSeriesResponse.ProtoReflect.Descriptor instead.

func (*GenerateTimeSeriesResponse) GetRollup

func (*GenerateTimeSeriesResponse) ProtoMessage

func (*GenerateTimeSeriesResponse) ProtoMessage()

func (*GenerateTimeSeriesResponse) ProtoReflect

func (*GenerateTimeSeriesResponse) Reset

func (x *GenerateTimeSeriesResponse) Reset()

func (*GenerateTimeSeriesResponse) String

func (x *GenerateTimeSeriesResponse) String() string

type GetCardinalityOfColumnRequest

type GetCardinalityOfColumnRequest 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"`
	Priority   int32  `protobuf:"varint,4,opt,name=priority,proto3" json:"priority,omitempty"`
	// contains filtered or unexported fields
}

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

func (*GetCardinalityOfColumnRequest) Descriptor deprecated

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

Deprecated: Use GetCardinalityOfColumnRequest.ProtoReflect.Descriptor instead.

func (*GetCardinalityOfColumnRequest) GetColumnName

func (x *GetCardinalityOfColumnRequest) GetColumnName() string

func (*GetCardinalityOfColumnRequest) GetInstanceId

func (x *GetCardinalityOfColumnRequest) GetInstanceId() string

func (*GetCardinalityOfColumnRequest) GetPriority

func (x *GetCardinalityOfColumnRequest) GetPriority() int32

func (*GetCardinalityOfColumnRequest) GetTableName

func (x *GetCardinalityOfColumnRequest) GetTableName() string

func (*GetCardinalityOfColumnRequest) ProtoMessage

func (*GetCardinalityOfColumnRequest) ProtoMessage()

func (*GetCardinalityOfColumnRequest) ProtoReflect

func (*GetCardinalityOfColumnRequest) Reset

func (x *GetCardinalityOfColumnRequest) Reset()

func (*GetCardinalityOfColumnRequest) String

type GetCardinalityOfColumnResponse

type GetCardinalityOfColumnResponse struct {
	CategoricalSummary *CategoricalSummary `protobuf:"bytes,1,opt,name=categorical_summary,json=categoricalSummary,proto3" json:"categorical_summary,omitempty"`
	// contains filtered or unexported fields
}

func (*GetCardinalityOfColumnResponse) Descriptor deprecated

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

Deprecated: Use GetCardinalityOfColumnResponse.ProtoReflect.Descriptor instead.

func (*GetCardinalityOfColumnResponse) GetCategoricalSummary

func (x *GetCardinalityOfColumnResponse) GetCategoricalSummary() *CategoricalSummary

func (*GetCardinalityOfColumnResponse) ProtoMessage

func (*GetCardinalityOfColumnResponse) ProtoMessage()

func (*GetCardinalityOfColumnResponse) ProtoReflect

func (*GetCardinalityOfColumnResponse) Reset

func (x *GetCardinalityOfColumnResponse) Reset()

func (*GetCardinalityOfColumnResponse) String

type GetCatalogEntryRequest

type GetCatalogEntryRequest 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.GetCatalogEntry

func (*GetCatalogEntryRequest) Descriptor deprecated

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

Deprecated: Use GetCatalogEntryRequest.ProtoReflect.Descriptor instead.

func (*GetCatalogEntryRequest) GetInstanceId

func (x *GetCatalogEntryRequest) GetInstanceId() string

func (*GetCatalogEntryRequest) GetName

func (x *GetCatalogEntryRequest) GetName() string

func (*GetCatalogEntryRequest) ProtoMessage

func (*GetCatalogEntryRequest) ProtoMessage()

func (*GetCatalogEntryRequest) ProtoReflect

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

func (*GetCatalogEntryRequest) Reset

func (x *GetCatalogEntryRequest) Reset()

func (*GetCatalogEntryRequest) String

func (x *GetCatalogEntryRequest) String() string

type GetCatalogEntryResponse

type GetCatalogEntryResponse struct {
	Entry *CatalogEntry `protobuf:"bytes,1,opt,name=entry,proto3" json:"entry,omitempty"`
	// contains filtered or unexported fields
}

Response message for RuntimeService.GetCatalogEntry

func (*GetCatalogEntryResponse) Descriptor deprecated

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

Deprecated: Use GetCatalogEntryResponse.ProtoReflect.Descriptor instead.

func (*GetCatalogEntryResponse) GetEntry

func (x *GetCatalogEntryResponse) GetEntry() *CatalogEntry

func (*GetCatalogEntryResponse) ProtoMessage

func (*GetCatalogEntryResponse) ProtoMessage()

func (*GetCatalogEntryResponse) ProtoReflect

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

func (*GetCatalogEntryResponse) Reset

func (x *GetCatalogEntryResponse) Reset()

func (*GetCatalogEntryResponse) String

func (x *GetCatalogEntryResponse) String() string

type GetDescriptiveStatisticsRequest

type GetDescriptiveStatisticsRequest 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"`
	Priority   int32  `protobuf:"varint,4,opt,name=priority,proto3" json:"priority,omitempty"`
	// contains filtered or unexported fields
}

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

func (*GetDescriptiveStatisticsRequest) Descriptor deprecated

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

Deprecated: Use GetDescriptiveStatisticsRequest.ProtoReflect.Descriptor instead.

func (*GetDescriptiveStatisticsRequest) GetColumnName

func (x *GetDescriptiveStatisticsRequest) GetColumnName() string

func (*GetDescriptiveStatisticsRequest) GetInstanceId

func (x *GetDescriptiveStatisticsRequest) GetInstanceId() string

func (*GetDescriptiveStatisticsRequest) GetPriority

func (x *GetDescriptiveStatisticsRequest) GetPriority() int32

func (*GetDescriptiveStatisticsRequest) GetTableName

func (x *GetDescriptiveStatisticsRequest) GetTableName() string

func (*GetDescriptiveStatisticsRequest) ProtoMessage

func (*GetDescriptiveStatisticsRequest) ProtoMessage()

func (*GetDescriptiveStatisticsRequest) ProtoReflect

func (*GetDescriptiveStatisticsRequest) Reset

func (*GetDescriptiveStatisticsRequest) String

type GetDescriptiveStatisticsResponse

type GetDescriptiveStatisticsResponse struct {
	NumericSummary *NumericSummary `protobuf:"bytes,1,opt,name=numeric_summary,json=numericSummary,proto3" json:"numeric_summary,omitempty"`
	// contains filtered or unexported fields
}

func (*GetDescriptiveStatisticsResponse) Descriptor deprecated

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

Deprecated: Use GetDescriptiveStatisticsResponse.ProtoReflect.Descriptor instead.

func (*GetDescriptiveStatisticsResponse) GetNumericSummary

func (x *GetDescriptiveStatisticsResponse) GetNumericSummary() *NumericSummary

func (*GetDescriptiveStatisticsResponse) ProtoMessage

func (*GetDescriptiveStatisticsResponse) ProtoMessage()

func (*GetDescriptiveStatisticsResponse) ProtoReflect

func (*GetDescriptiveStatisticsResponse) Reset

func (*GetDescriptiveStatisticsResponse) String

type GetFileRequest

type GetFileRequest struct {
	InstanceId string `protobuf:"bytes,1,opt,name=instance_id,json=instanceId,proto3" json:"instance_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

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

Deprecated: Use GetFileRequest.ProtoReflect.Descriptor instead.

func (*GetFileRequest) GetInstanceId

func (x *GetFileRequest) GetInstanceId() string

func (*GetFileRequest) GetPath

func (x *GetFileRequest) GetPath() string

func (*GetFileRequest) ProtoMessage

func (*GetFileRequest) ProtoMessage()

func (*GetFileRequest) ProtoReflect

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

func (*GetFileRequest) Reset

func (x *GetFileRequest) Reset()

func (*GetFileRequest) String

func (x *GetFileRequest) String() string

type GetFileResponse

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

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

Deprecated: Use GetFileResponse.ProtoReflect.Descriptor instead.

func (*GetFileResponse) GetBlob

func (x *GetFileResponse) GetBlob() string

func (*GetFileResponse) GetUpdatedOn

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

func (*GetFileResponse) ProtoMessage

func (*GetFileResponse) ProtoMessage()

func (*GetFileResponse) ProtoReflect

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

func (*GetFileResponse) Reset

func (x *GetFileResponse) Reset()

func (*GetFileResponse) String

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 GetNullCountRequest

type GetNullCountRequest 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"`
	Priority   int32  `protobuf:"varint,4,opt,name=priority,proto3" json:"priority,omitempty"`
	// contains filtered or unexported fields
}

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

func (*GetNullCountRequest) Descriptor deprecated

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

Deprecated: Use GetNullCountRequest.ProtoReflect.Descriptor instead.

func (*GetNullCountRequest) GetColumnName

func (x *GetNullCountRequest) GetColumnName() string

func (*GetNullCountRequest) GetInstanceId

func (x *GetNullCountRequest) GetInstanceId() string

func (*GetNullCountRequest) GetPriority

func (x *GetNullCountRequest) GetPriority() int32

func (*GetNullCountRequest) GetTableName

func (x *GetNullCountRequest) GetTableName() string

func (*GetNullCountRequest) ProtoMessage

func (*GetNullCountRequest) ProtoMessage()

func (*GetNullCountRequest) ProtoReflect

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

func (*GetNullCountRequest) Reset

func (x *GetNullCountRequest) Reset()

func (*GetNullCountRequest) String

func (x *GetNullCountRequest) String() string

type GetNullCountResponse

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

Response for RuntimeService.GetNullCount

func (*GetNullCountResponse) Descriptor deprecated

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

Deprecated: Use GetNullCountResponse.ProtoReflect.Descriptor instead.

func (*GetNullCountResponse) GetCount

func (x *GetNullCountResponse) GetCount() float64

func (*GetNullCountResponse) ProtoMessage

func (*GetNullCountResponse) ProtoMessage()

func (*GetNullCountResponse) ProtoReflect

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

func (*GetNullCountResponse) Reset

func (x *GetNullCountResponse) Reset()

func (*GetNullCountResponse) String

func (x *GetNullCountResponse) String() string

type GetNumericHistogramRequest

type GetNumericHistogramRequest 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"`
	Priority   int32  `protobuf:"varint,4,opt,name=priority,proto3" json:"priority,omitempty"`
	// contains filtered or unexported fields
}

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

func (*GetNumericHistogramRequest) Descriptor deprecated

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

Deprecated: Use GetNumericHistogramRequest.ProtoReflect.Descriptor instead.

func (*GetNumericHistogramRequest) GetColumnName

func (x *GetNumericHistogramRequest) GetColumnName() string

func (*GetNumericHistogramRequest) GetInstanceId

func (x *GetNumericHistogramRequest) GetInstanceId() string

func (*GetNumericHistogramRequest) GetPriority

func (x *GetNumericHistogramRequest) GetPriority() int32

func (*GetNumericHistogramRequest) GetTableName

func (x *GetNumericHistogramRequest) GetTableName() string

func (*GetNumericHistogramRequest) ProtoMessage

func (*GetNumericHistogramRequest) ProtoMessage()

func (*GetNumericHistogramRequest) ProtoReflect

func (*GetNumericHistogramRequest) Reset

func (x *GetNumericHistogramRequest) Reset()

func (*GetNumericHistogramRequest) String

func (x *GetNumericHistogramRequest) String() string

type GetNumericHistogramResponse

type GetNumericHistogramResponse struct {
	NumericSummary *NumericSummary `protobuf:"bytes,1,opt,name=numeric_summary,json=numericSummary,proto3" json:"numeric_summary,omitempty"`
	// contains filtered or unexported fields
}

func (*GetNumericHistogramResponse) Descriptor deprecated

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

Deprecated: Use GetNumericHistogramResponse.ProtoReflect.Descriptor instead.

func (*GetNumericHistogramResponse) GetNumericSummary

func (x *GetNumericHistogramResponse) GetNumericSummary() *NumericSummary

func (*GetNumericHistogramResponse) ProtoMessage

func (*GetNumericHistogramResponse) ProtoMessage()

func (*GetNumericHistogramResponse) ProtoReflect

func (*GetNumericHistogramResponse) Reset

func (x *GetNumericHistogramResponse) Reset()

func (*GetNumericHistogramResponse) String

func (x *GetNumericHistogramResponse) String() string

type GetRugHistogramRequest

type GetRugHistogramRequest 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"`
	Priority   int32  `protobuf:"varint,4,opt,name=priority,proto3" json:"priority,omitempty"`
	// contains filtered or unexported fields
}

Request for RuntimeService.GetRugHistogram

func (*GetRugHistogramRequest) Descriptor deprecated

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

Deprecated: Use GetRugHistogramRequest.ProtoReflect.Descriptor instead.

func (*GetRugHistogramRequest) GetColumnName

func (x *GetRugHistogramRequest) GetColumnName() string

func (*GetRugHistogramRequest) GetInstanceId

func (x *GetRugHistogramRequest) GetInstanceId() string

func (*GetRugHistogramRequest) GetPriority

func (x *GetRugHistogramRequest) GetPriority() int32

func (*GetRugHistogramRequest) GetTableName

func (x *GetRugHistogramRequest) GetTableName() string

func (*GetRugHistogramRequest) ProtoMessage

func (*GetRugHistogramRequest) ProtoMessage()

func (*GetRugHistogramRequest) ProtoReflect

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

func (*GetRugHistogramRequest) Reset

func (x *GetRugHistogramRequest) Reset()

func (*GetRugHistogramRequest) String

func (x *GetRugHistogramRequest) String() string

type GetRugHistogramResponse

type GetRugHistogramResponse struct {
	NumericSummary *NumericSummary `protobuf:"bytes,1,opt,name=numeric_summary,json=numericSummary,proto3" json:"numeric_summary,omitempty"`
	// contains filtered or unexported fields
}

func (*GetRugHistogramResponse) Descriptor deprecated

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

Deprecated: Use GetRugHistogramResponse.ProtoReflect.Descriptor instead.

func (*GetRugHistogramResponse) GetNumericSummary

func (x *GetRugHistogramResponse) GetNumericSummary() *NumericSummary

func (*GetRugHistogramResponse) ProtoMessage

func (*GetRugHistogramResponse) ProtoMessage()

func (*GetRugHistogramResponse) ProtoReflect

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

func (*GetRugHistogramResponse) Reset

func (x *GetRugHistogramResponse) Reset()

func (*GetRugHistogramResponse) String

func (x *GetRugHistogramResponse) String() string

type GetTableCardinalityRequest

type GetTableCardinalityRequest 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"`
	Priority   int32  `protobuf:"varint,3,opt,name=priority,proto3" json:"priority,omitempty"`
	// contains filtered or unexported fields
}

func (*GetTableCardinalityRequest) Descriptor deprecated

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

Deprecated: Use GetTableCardinalityRequest.ProtoReflect.Descriptor instead.

func (*GetTableCardinalityRequest) GetInstanceId

func (x *GetTableCardinalityRequest) GetInstanceId() string

func (*GetTableCardinalityRequest) GetPriority

func (x *GetTableCardinalityRequest) GetPriority() int32

func (*GetTableCardinalityRequest) GetTableName

func (x *GetTableCardinalityRequest) GetTableName() string

func (*GetTableCardinalityRequest) ProtoMessage

func (*GetTableCardinalityRequest) ProtoMessage()

func (*GetTableCardinalityRequest) ProtoReflect

func (*GetTableCardinalityRequest) Reset

func (x *GetTableCardinalityRequest) Reset()

func (*GetTableCardinalityRequest) String

func (x *GetTableCardinalityRequest) String() string

type GetTableCardinalityResponse

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

func (*GetTableCardinalityResponse) Descriptor deprecated

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

Deprecated: Use GetTableCardinalityResponse.ProtoReflect.Descriptor instead.

func (*GetTableCardinalityResponse) GetCardinality

func (x *GetTableCardinalityResponse) GetCardinality() int64

func (*GetTableCardinalityResponse) ProtoMessage

func (*GetTableCardinalityResponse) ProtoMessage()

func (*GetTableCardinalityResponse) ProtoReflect

func (*GetTableCardinalityResponse) Reset

func (x *GetTableCardinalityResponse) Reset()

func (*GetTableCardinalityResponse) String

func (x *GetTableCardinalityResponse) String() string

type GetTableRowsRequest

type GetTableRowsRequest 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"`
	Priority   int32  `protobuf:"varint,4,opt,name=priority,proto3" json:"priority,omitempty"`
	// contains filtered or unexported fields
}

func (*GetTableRowsRequest) Descriptor deprecated

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

Deprecated: Use GetTableRowsRequest.ProtoReflect.Descriptor instead.

func (*GetTableRowsRequest) GetInstanceId

func (x *GetTableRowsRequest) GetInstanceId() string

func (*GetTableRowsRequest) GetLimit

func (x *GetTableRowsRequest) GetLimit() int32

func (*GetTableRowsRequest) GetPriority

func (x *GetTableRowsRequest) GetPriority() int32

func (*GetTableRowsRequest) GetTableName

func (x *GetTableRowsRequest) GetTableName() string

func (*GetTableRowsRequest) ProtoMessage

func (*GetTableRowsRequest) ProtoMessage()

func (*GetTableRowsRequest) ProtoReflect

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

func (*GetTableRowsRequest) Reset

func (x *GetTableRowsRequest) Reset()

func (*GetTableRowsRequest) String

func (x *GetTableRowsRequest) String() string

type GetTableRowsResponse

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

func (*GetTableRowsResponse) Descriptor deprecated

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

Deprecated: Use GetTableRowsResponse.ProtoReflect.Descriptor instead.

func (*GetTableRowsResponse) GetData

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

func (*GetTableRowsResponse) ProtoMessage

func (*GetTableRowsResponse) ProtoMessage()

func (*GetTableRowsResponse) ProtoReflect

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

func (*GetTableRowsResponse) Reset

func (x *GetTableRowsResponse) Reset()

func (*GetTableRowsResponse) String

func (x *GetTableRowsResponse) String() string

type GetTimeRangeSummaryRequest

type GetTimeRangeSummaryRequest 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"`
	Priority   int32  `protobuf:"varint,4,opt,name=priority,proto3" json:"priority,omitempty"`
	// contains filtered or unexported fields
}

Request for RuntimeService.GetTimeRangeSummary

func (*GetTimeRangeSummaryRequest) Descriptor deprecated

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

Deprecated: Use GetTimeRangeSummaryRequest.ProtoReflect.Descriptor instead.

func (*GetTimeRangeSummaryRequest) GetColumnName

func (x *GetTimeRangeSummaryRequest) GetColumnName() string

func (*GetTimeRangeSummaryRequest) GetInstanceId

func (x *GetTimeRangeSummaryRequest) GetInstanceId() string

func (*GetTimeRangeSummaryRequest) GetPriority

func (x *GetTimeRangeSummaryRequest) GetPriority() int32

func (*GetTimeRangeSummaryRequest) GetTableName

func (x *GetTimeRangeSummaryRequest) GetTableName() string

func (*GetTimeRangeSummaryRequest) ProtoMessage

func (*GetTimeRangeSummaryRequest) ProtoMessage()

func (*GetTimeRangeSummaryRequest) ProtoReflect

func (*GetTimeRangeSummaryRequest) Reset

func (x *GetTimeRangeSummaryRequest) Reset()

func (*GetTimeRangeSummaryRequest) String

func (x *GetTimeRangeSummaryRequest) String() string

type GetTimeRangeSummaryResponse

type GetTimeRangeSummaryResponse struct {
	TimeRangeSummary *TimeRangeSummary `protobuf:"bytes,1,opt,name=time_range_summary,json=timeRangeSummary,proto3" json:"time_range_summary,omitempty"`
	// contains filtered or unexported fields
}

func (*GetTimeRangeSummaryResponse) Descriptor deprecated

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

Deprecated: Use GetTimeRangeSummaryResponse.ProtoReflect.Descriptor instead.

func (*GetTimeRangeSummaryResponse) GetTimeRangeSummary

func (x *GetTimeRangeSummaryResponse) GetTimeRangeSummary() *TimeRangeSummary

func (*GetTimeRangeSummaryResponse) ProtoMessage

func (*GetTimeRangeSummaryResponse) ProtoMessage()

func (*GetTimeRangeSummaryResponse) ProtoReflect

func (*GetTimeRangeSummaryResponse) Reset

func (x *GetTimeRangeSummaryResponse) Reset()

func (*GetTimeRangeSummaryResponse) String

func (x *GetTimeRangeSummaryResponse) String() string

type GetTopKRequest

type GetTopKRequest 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" json:"agg,omitempty"` // default is count(*)
	K          int32  `protobuf:"varint,5,opt,name=k,proto3" json:"k,omitempty"`    // default is 50
	Priority   int32  `protobuf:"varint,6,opt,name=priority,proto3" json:"priority,omitempty"`
	// 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 (*GetTopKRequest) Descriptor deprecated

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

Deprecated: Use GetTopKRequest.ProtoReflect.Descriptor instead.

func (*GetTopKRequest) GetAgg

func (x *GetTopKRequest) GetAgg() string

func (*GetTopKRequest) GetColumnName

func (x *GetTopKRequest) GetColumnName() string

func (*GetTopKRequest) GetInstanceId

func (x *GetTopKRequest) GetInstanceId() string

func (*GetTopKRequest) GetK

func (x *GetTopKRequest) GetK() int32

func (*GetTopKRequest) GetPriority

func (x *GetTopKRequest) GetPriority() int32

func (*GetTopKRequest) GetTableName

func (x *GetTopKRequest) GetTableName() string

func (*GetTopKRequest) ProtoMessage

func (*GetTopKRequest) ProtoMessage()

func (*GetTopKRequest) ProtoReflect

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

func (*GetTopKRequest) Reset

func (x *GetTopKRequest) Reset()

func (*GetTopKRequest) String

func (x *GetTopKRequest) String() string

type GetTopKResponse

type GetTopKResponse struct {
	CategoricalSummary *CategoricalSummary `protobuf:"bytes,1,opt,name=categorical_summary,json=categoricalSummary,proto3" json:"categorical_summary,omitempty"`
	// contains filtered or unexported fields
}

func (*GetTopKResponse) Descriptor deprecated

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

Deprecated: Use GetTopKResponse.ProtoReflect.Descriptor instead.

func (*GetTopKResponse) GetCategoricalSummary

func (x *GetTopKResponse) GetCategoricalSummary() *CategoricalSummary

func (*GetTopKResponse) ProtoMessage

func (*GetTopKResponse) ProtoMessage()

func (*GetTopKResponse) ProtoReflect

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

func (*GetTopKResponse) Reset

func (x *GetTopKResponse) Reset()

func (*GetTopKResponse) String

func (x *GetTopKResponse) 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"`
	// Driver to connect to for OLAP (options: duckdb, druid)
	OlapDriver string `protobuf:"bytes,2,opt,name=olap_driver,json=olapDriver,proto3" json:"olap_driver,omitempty"`
	// DSN for connection to OLAP
	OlapDsn string `protobuf:"bytes,3,opt,name=olap_dsn,json=olapDsn,proto3" json:"olap_dsn,omitempty"`
	// Driver for reading/editing code artifacts (options: file, metastore).
	// This enables virtualizing a file system in a cloud setting.
	RepoDriver string `protobuf:"bytes,4,opt,name=repo_driver,json=repoDriver,proto3" json:"repo_driver,omitempty"`
	// DSN for connecting to repo
	RepoDsn string `protobuf:"bytes,5,opt,name=repo_dsn,json=repoDsn,proto3" json:"repo_dsn,omitempty"`
	// If true, the runtime will store the instance's catalog in its OLAP store instead
	// of in the runtime's metadata store. 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 a single data project, meaning one set of code artifacts, one connection to an OLAP datastore (DuckDB, Druid), and one catalog of related metadata (such as reconciliation state). Instances are the unit of isolation within the runtime. They enable one runtime deployment to serve not only multiple data projects, but also multiple tenants. On local, the runtime will usually have just a single instance.

func (*Instance) Descriptor deprecated

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

Deprecated: Use Instance.ProtoReflect.Descriptor instead.

func (*Instance) GetEmbedCatalog

func (x *Instance) GetEmbedCatalog() bool

func (*Instance) GetInstanceId

func (x *Instance) GetInstanceId() string

func (*Instance) GetOlapDriver

func (x *Instance) GetOlapDriver() string

func (*Instance) GetOlapDsn

func (x *Instance) GetOlapDsn() string

func (*Instance) GetRepoDriver

func (x *Instance) GetRepoDriver() string

func (*Instance) GetRepoDsn

func (x *Instance) GetRepoDsn() 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 ListCatalogEntriesRequest

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

Request message for RuntimeService.ListCatalogEntries

func (*ListCatalogEntriesRequest) Descriptor deprecated

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

Deprecated: Use ListCatalogEntriesRequest.ProtoReflect.Descriptor instead.

func (*ListCatalogEntriesRequest) GetInstanceId

func (x *ListCatalogEntriesRequest) GetInstanceId() string

func (*ListCatalogEntriesRequest) GetType

func (*ListCatalogEntriesRequest) ProtoMessage

func (*ListCatalogEntriesRequest) ProtoMessage()

func (*ListCatalogEntriesRequest) ProtoReflect

func (*ListCatalogEntriesRequest) Reset

func (x *ListCatalogEntriesRequest) Reset()

func (*ListCatalogEntriesRequest) String

func (x *ListCatalogEntriesRequest) String() string

type ListCatalogEntriesResponse

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

Response message for RuntimeService.ListCatalogEntries

func (*ListCatalogEntriesResponse) Descriptor deprecated

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

Deprecated: Use ListCatalogEntriesResponse.ProtoReflect.Descriptor instead.

func (*ListCatalogEntriesResponse) GetEntries

func (x *ListCatalogEntriesResponse) GetEntries() []*CatalogEntry

func (*ListCatalogEntriesResponse) ProtoMessage

func (*ListCatalogEntriesResponse) ProtoMessage()

func (*ListCatalogEntriesResponse) ProtoReflect

func (*ListCatalogEntriesResponse) Reset

func (x *ListCatalogEntriesResponse) Reset()

func (*ListCatalogEntriesResponse) String

func (x *ListCatalogEntriesResponse) 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

type ListFilesRequest struct {
	InstanceId string `protobuf:"bytes,1,opt,name=instance_id,json=instanceId,proto3" json:"instance_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

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

Deprecated: Use ListFilesRequest.ProtoReflect.Descriptor instead.

func (*ListFilesRequest) GetGlob

func (x *ListFilesRequest) GetGlob() string

func (*ListFilesRequest) GetInstanceId

func (x *ListFilesRequest) GetInstanceId() string

func (*ListFilesRequest) ProtoMessage

func (*ListFilesRequest) ProtoMessage()

func (*ListFilesRequest) ProtoReflect

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

func (*ListFilesRequest) Reset

func (x *ListFilesRequest) Reset()

func (*ListFilesRequest) String

func (x *ListFilesRequest) String() string

type ListFilesResponse

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

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

Deprecated: Use ListFilesResponse.ProtoReflect.Descriptor instead.

func (*ListFilesResponse) GetPaths

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

func (*ListFilesResponse) ProtoMessage

func (*ListFilesResponse) ProtoMessage()

func (*ListFilesResponse) ProtoReflect

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

func (*ListFilesResponse) Reset

func (x *ListFilesResponse) Reset()

func (*ListFilesResponse) String

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 MapType

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

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

Deprecated: Use MapType.ProtoReflect.Descriptor instead.

func (*MapType) GetKeyType

func (x *MapType) GetKeyType() *Type

func (*MapType) GetValueType

func (x *MapType) GetValueType() *Type

func (*MapType) ProtoMessage

func (*MapType) ProtoMessage()

func (*MapType) ProtoReflect

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

func (*MapType) Reset

func (x *MapType) Reset()

func (*MapType) String

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
	Model string `protobuf:"bytes,2,opt,name=model,proto3" json:"model,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"`
	// User friendly label for the dashboard
	Label string `protobuf:"bytes,7,opt,name=label,proto3" json:"label,omitempty"`
	// Brief description of the dashboard
	Description string `protobuf:"bytes,8,opt,name=description,proto3" json:"description,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) GetDescription

func (x *MetricsView) GetDescription() string

func (*MetricsView) GetDimensions

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

func (*MetricsView) GetLabel

func (x *MetricsView) GetLabel() string

func (*MetricsView) GetMeasures

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

func (*MetricsView) GetModel

func (x *MetricsView) GetModel() string

func (*MetricsView) GetName

func (x *MetricsView) GetName() string

func (*MetricsView) GetTimeDimension

func (x *MetricsView) GetTimeDimension() string

func (*MetricsView) GetTimeGrains

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

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

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

Deprecated: Use MetricsViewColumn.ProtoReflect.Descriptor instead.

func (*MetricsViewColumn) GetName

func (x *MetricsViewColumn) GetName() string

func (*MetricsViewColumn) GetNullable

func (x *MetricsViewColumn) GetNullable() bool

func (*MetricsViewColumn) GetType

func (x *MetricsViewColumn) GetType() string

func (*MetricsViewColumn) ProtoMessage

func (*MetricsViewColumn) ProtoMessage()

func (*MetricsViewColumn) ProtoReflect

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

func (*MetricsViewColumn) Reset

func (x *MetricsViewColumn) Reset()

func (*MetricsViewColumn) String

func (x *MetricsViewColumn) String() string

type MetricsViewDimensionValue

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 []*structpb.Value `protobuf:"bytes,3,rep,name=like,proto3" json:"like,omitempty"`
	// contains filtered or unexported fields
}

func (*MetricsViewDimensionValue) Descriptor deprecated

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

Deprecated: Use MetricsViewDimensionValue.ProtoReflect.Descriptor instead.

func (*MetricsViewDimensionValue) GetIn

func (*MetricsViewDimensionValue) GetLike

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

func (*MetricsViewDimensionValue) GetName

func (x *MetricsViewDimensionValue) GetName() string

func (*MetricsViewDimensionValue) ProtoMessage

func (*MetricsViewDimensionValue) ProtoMessage()

func (*MetricsViewDimensionValue) ProtoReflect

func (*MetricsViewDimensionValue) Reset

func (x *MetricsViewDimensionValue) Reset()

func (*MetricsViewDimensionValue) String

func (x *MetricsViewDimensionValue) 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 MetricsViewRequestFilter

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

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

Deprecated: Use MetricsViewRequestFilter.ProtoReflect.Descriptor instead.

func (*MetricsViewRequestFilter) GetExclude

func (*MetricsViewRequestFilter) GetInclude

func (*MetricsViewRequestFilter) ProtoMessage

func (*MetricsViewRequestFilter) ProtoMessage()

func (*MetricsViewRequestFilter) ProtoReflect

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

func (*MetricsViewRequestFilter) Reset

func (x *MetricsViewRequestFilter) Reset()

func (*MetricsViewRequestFilter) String

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"`
	Priority        int32                  `protobuf:"varint,8,opt,name=priority,proto3" json:"priority,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 (*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) GetPriority

func (x *MetricsViewTimeSeriesRequest) GetPriority() int32

func (*MetricsViewTimeSeriesRequest) GetTimeEnd

func (*MetricsViewTimeSeriesRequest) GetTimeGranularity

func (x *MetricsViewTimeSeriesRequest) GetTimeGranularity() string

func (*MetricsViewTimeSeriesRequest) GetTimeStart

func (*MetricsViewTimeSeriesRequest) ProtoMessage

func (*MetricsViewTimeSeriesRequest) ProtoMessage()

func (*MetricsViewTimeSeriesRequest) ProtoReflect

func (*MetricsViewTimeSeriesRequest) Reset

func (x *MetricsViewTimeSeriesRequest) Reset()

func (*MetricsViewTimeSeriesRequest) 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 (*MetricsViewTimeSeriesResponse) GetMeta

func (*MetricsViewTimeSeriesResponse) ProtoMessage

func (*MetricsViewTimeSeriesResponse) ProtoMessage()

func (*MetricsViewTimeSeriesResponse) ProtoReflect

func (*MetricsViewTimeSeriesResponse) Reset

func (x *MetricsViewTimeSeriesResponse) Reset()

func (*MetricsViewTimeSeriesResponse) 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"`
	Priority        int32                  `protobuf:"varint,11,opt,name=priority,proto3" json:"priority,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 (*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) GetPriority

func (x *MetricsViewToplistRequest) GetPriority() int32

func (*MetricsViewToplistRequest) GetSort

func (*MetricsViewToplistRequest) GetTimeEnd

func (*MetricsViewToplistRequest) GetTimeStart

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

func (*MetricsViewToplistRequest) ProtoMessage

func (*MetricsViewToplistRequest) ProtoMessage()

func (*MetricsViewToplistRequest) ProtoReflect

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 (*MetricsViewToplistResponse) ProtoMessage

func (*MetricsViewToplistResponse) ProtoMessage()

func (*MetricsViewToplistResponse) ProtoReflect

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"`
	Priority        int32                  `protobuf:"varint,8,opt,name=priority,proto3" json:"priority,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 (*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) GetPriority

func (x *MetricsViewTotalsRequest) GetPriority() int32

func (*MetricsViewTotalsRequest) GetTimeEnd

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 (*MetricsViewTotalsResponse) GetMeta

func (*MetricsViewTotalsResponse) ProtoMessage

func (*MetricsViewTotalsResponse) ProtoMessage()

func (*MetricsViewTotalsResponse) ProtoReflect

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"`
	// 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) GetLabel

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"`
	// 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) GetExpression

func (x *MetricsView_Measure) GetExpression() string

func (*MetricsView_Measure) GetFormat

func (x *MetricsView_Measure) GetFormat() string

func (*MetricsView_Measure) GetLabel

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 Model

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

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

Deprecated: Use Model.ProtoReflect.Descriptor instead.

func (*Model) GetDialect

func (x *Model) GetDialect() Model_Dialect

func (*Model) GetName

func (x *Model) GetName() string

func (*Model) GetSchema

func (x *Model) GetSchema() *StructType

func (*Model) GetSql

func (x *Model) GetSql() string

func (*Model) ProtoMessage

func (*Model) ProtoMessage()

func (*Model) ProtoReflect

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

func (*Model) Reset

func (x *Model) Reset()

func (*Model) String

func (x *Model) String() string

type Model_Dialect

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

func (Model_Dialect) Enum

func (x Model_Dialect) Enum() *Model_Dialect

func (Model_Dialect) EnumDescriptor deprecated

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

Deprecated: Use Model_Dialect.Descriptor instead.

func (Model_Dialect) Number

func (Model_Dialect) String

func (x Model_Dialect) String() string

func (Model_Dialect) Type

type NumericHistogramBins

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

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

Deprecated: Use NumericHistogramBins.ProtoReflect.Descriptor instead.

func (*NumericHistogramBins) GetBins

func (*NumericHistogramBins) ProtoMessage

func (*NumericHistogramBins) ProtoMessage()

func (*NumericHistogramBins) ProtoReflect

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

func (*NumericHistogramBins) Reset

func (x *NumericHistogramBins) Reset()

func (*NumericHistogramBins) String

func (x *NumericHistogramBins) String() string

type NumericHistogramBins_Bin

type NumericHistogramBins_Bin struct {
	Bucket int32   `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  float64 `protobuf:"fixed64,4,opt,name=count,proto3" json:"count,omitempty"`
	// contains filtered or unexported fields
}

func (*NumericHistogramBins_Bin) Descriptor deprecated

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

Deprecated: Use NumericHistogramBins_Bin.ProtoReflect.Descriptor instead.

func (*NumericHistogramBins_Bin) GetBucket

func (x *NumericHistogramBins_Bin) GetBucket() int32

func (*NumericHistogramBins_Bin) GetCount

func (x *NumericHistogramBins_Bin) GetCount() float64

func (*NumericHistogramBins_Bin) GetHigh

func (x *NumericHistogramBins_Bin) GetHigh() float64

func (*NumericHistogramBins_Bin) GetLow

func (x *NumericHistogramBins_Bin) GetLow() float64

func (*NumericHistogramBins_Bin) ProtoMessage

func (*NumericHistogramBins_Bin) ProtoMessage()

func (*NumericHistogramBins_Bin) ProtoReflect

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

func (*NumericHistogramBins_Bin) Reset

func (x *NumericHistogramBins_Bin) Reset()

func (*NumericHistogramBins_Bin) String

func (x *NumericHistogramBins_Bin) String() string

type NumericOutliers

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

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

Deprecated: Use NumericOutliers.ProtoReflect.Descriptor instead.

func (*NumericOutliers) GetOutliers

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

func (*NumericOutliers) ProtoMessage

func (*NumericOutliers) ProtoMessage()

func (*NumericOutliers) ProtoReflect

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

func (*NumericOutliers) Reset

func (x *NumericOutliers) Reset()

func (*NumericOutliers) String

func (x *NumericOutliers) String() string

type NumericOutliers_Outlier

type NumericOutliers_Outlier struct {
	Bucket  int32   `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"`
	Count   int32   `protobuf:"varint,5,opt,name=count,proto3" json:"count,omitempty"`
	// contains filtered or unexported fields
}

func (*NumericOutliers_Outlier) Descriptor deprecated

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

Deprecated: Use NumericOutliers_Outlier.ProtoReflect.Descriptor instead.

func (*NumericOutliers_Outlier) GetBucket

func (x *NumericOutliers_Outlier) GetBucket() int32

func (*NumericOutliers_Outlier) GetCount

func (x *NumericOutliers_Outlier) GetCount() int32

func (*NumericOutliers_Outlier) GetHigh

func (x *NumericOutliers_Outlier) GetHigh() float64

func (*NumericOutliers_Outlier) GetLow

func (x *NumericOutliers_Outlier) GetLow() float64

func (*NumericOutliers_Outlier) GetPresent

func (x *NumericOutliers_Outlier) GetPresent() bool

func (*NumericOutliers_Outlier) ProtoMessage

func (*NumericOutliers_Outlier) ProtoMessage()

func (*NumericOutliers_Outlier) ProtoReflect

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

func (*NumericOutliers_Outlier) Reset

func (x *NumericOutliers_Outlier) Reset()

func (*NumericOutliers_Outlier) String

func (x *NumericOutliers_Outlier) String() string

type NumericStatistics

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

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

Deprecated: Use NumericStatistics.ProtoReflect.Descriptor instead.

func (*NumericStatistics) GetMax

func (x *NumericStatistics) GetMax() float64

func (*NumericStatistics) GetMean

func (x *NumericStatistics) GetMean() float64

func (*NumericStatistics) GetMin

func (x *NumericStatistics) GetMin() float64

func (*NumericStatistics) GetQ25

func (x *NumericStatistics) GetQ25() float64

func (*NumericStatistics) GetQ50

func (x *NumericStatistics) GetQ50() float64

func (*NumericStatistics) GetQ75

func (x *NumericStatistics) GetQ75() float64

func (*NumericStatistics) GetSd

func (x *NumericStatistics) GetSd() float64

func (*NumericStatistics) ProtoMessage

func (*NumericStatistics) ProtoMessage()

func (*NumericStatistics) ProtoReflect

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

func (*NumericStatistics) Reset

func (x *NumericStatistics) Reset()

func (*NumericStatistics) String

func (x *NumericStatistics) String() string

type NumericSummary

type NumericSummary struct {

	// Types that are assignable to Case:
	//	*NumericSummary_NumericHistogramBins
	//	*NumericSummary_NumericStatistics
	//	*NumericSummary_NumericOutliers
	Case isNumericSummary_Case `protobuf_oneof:"case"`
	// 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

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

Deprecated: Use NumericSummary.ProtoReflect.Descriptor instead.

func (*NumericSummary) GetCase

func (m *NumericSummary) GetCase() isNumericSummary_Case

func (*NumericSummary) GetNumericHistogramBins

func (x *NumericSummary) GetNumericHistogramBins() *NumericHistogramBins

func (*NumericSummary) GetNumericOutliers

func (x *NumericSummary) GetNumericOutliers() *NumericOutliers

func (*NumericSummary) GetNumericStatistics

func (x *NumericSummary) GetNumericStatistics() *NumericStatistics

func (*NumericSummary) ProtoMessage

func (*NumericSummary) ProtoMessage()

func (*NumericSummary) ProtoReflect

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

func (*NumericSummary) Reset

func (x *NumericSummary) Reset()

func (*NumericSummary) String

func (x *NumericSummary) String() string

type NumericSummary_NumericHistogramBins

type NumericSummary_NumericHistogramBins struct {
	NumericHistogramBins *NumericHistogramBins `protobuf:"bytes,1,opt,name=numeric_histogram_bins,json=numericHistogramBins,proto3,oneof"`
}

type NumericSummary_NumericOutliers

type NumericSummary_NumericOutliers struct {
	NumericOutliers *NumericOutliers `protobuf:"bytes,3,opt,name=numeric_outliers,json=numericOutliers,proto3,oneof"`
}

type NumericSummary_NumericStatistics

type NumericSummary_NumericStatistics struct {
	NumericStatistics *NumericStatistics `protobuf:"bytes,2,opt,name=numeric_statistics,json=numericStatistics,proto3,oneof"`
}

type ObjectType

type ObjectType int32

ObjectType represents the different kinds of catalog objects

const (
	ObjectType_OBJECT_TYPE_UNSPECIFIED  ObjectType = 0
	ObjectType_OBJECT_TYPE_TABLE        ObjectType = 1
	ObjectType_OBJECT_TYPE_SOURCE       ObjectType = 2
	ObjectType_OBJECT_TYPE_MODEL        ObjectType = 3
	ObjectType_OBJECT_TYPE_METRICS_VIEW ObjectType = 4
)

func (ObjectType) Descriptor

func (ObjectType) Descriptor() protoreflect.EnumDescriptor

func (ObjectType) Enum

func (x ObjectType) Enum() *ObjectType

func (ObjectType) EnumDescriptor deprecated

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

Deprecated: Use ObjectType.Descriptor instead.

func (ObjectType) Number

func (x ObjectType) Number() protoreflect.EnumNumber

func (ObjectType) String

func (x ObjectType) String() string

func (ObjectType) Type

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

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

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

Deprecated: Use ProfileColumn.ProtoReflect.Descriptor instead.

func (*ProfileColumn) GetLargestStringLength

func (x *ProfileColumn) GetLargestStringLength() int32

func (*ProfileColumn) GetName

func (x *ProfileColumn) GetName() string

func (*ProfileColumn) GetType

func (x *ProfileColumn) GetType() string

func (*ProfileColumn) ProtoMessage

func (*ProfileColumn) ProtoMessage()

func (*ProfileColumn) ProtoReflect

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

func (*ProfileColumn) Reset

func (x *ProfileColumn) Reset()

func (*ProfileColumn) String

func (x *ProfileColumn) String() string

type ProfileColumnSummary

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

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

Deprecated: Use ProfileColumnSummary.ProtoReflect.Descriptor instead.

func (*ProfileColumnSummary) GetCase

func (m *ProfileColumnSummary) GetCase() isProfileColumnSummary_Case

func (*ProfileColumnSummary) GetCategoricalSummary

func (x *ProfileColumnSummary) GetCategoricalSummary() *CategoricalSummary

func (*ProfileColumnSummary) GetNumericSummary

func (x *ProfileColumnSummary) GetNumericSummary() *NumericSummary

func (*ProfileColumnSummary) GetTimeRangeSummary

func (x *ProfileColumnSummary) GetTimeRangeSummary() *TimeRangeSummary

func (*ProfileColumnSummary) ProtoMessage

func (*ProfileColumnSummary) ProtoMessage()

func (*ProfileColumnSummary) ProtoReflect

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

func (*ProfileColumnSummary) Reset

func (x *ProfileColumnSummary) Reset()

func (*ProfileColumnSummary) String

func (x *ProfileColumnSummary) String() string

type ProfileColumnSummary_CategoricalSummary

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

type ProfileColumnSummary_NumericSummary

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

type ProfileColumnSummary_TimeRangeSummary

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

type ProfileColumnsRequest

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"`
	Priority   int32  `protobuf:"varint,3,opt,name=priority,proto3" json:"priority,omitempty"`
	// contains filtered or unexported fields
}

func (*ProfileColumnsRequest) Descriptor deprecated

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

Deprecated: Use ProfileColumnsRequest.ProtoReflect.Descriptor instead.

func (*ProfileColumnsRequest) GetInstanceId

func (x *ProfileColumnsRequest) GetInstanceId() string

func (*ProfileColumnsRequest) GetPriority

func (x *ProfileColumnsRequest) GetPriority() int32

func (*ProfileColumnsRequest) GetTableName

func (x *ProfileColumnsRequest) GetTableName() string

func (*ProfileColumnsRequest) ProtoMessage

func (*ProfileColumnsRequest) ProtoMessage()

func (*ProfileColumnsRequest) ProtoReflect

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

func (*ProfileColumnsRequest) Reset

func (x *ProfileColumnsRequest) Reset()

func (*ProfileColumnsRequest) String

func (x *ProfileColumnsRequest) String() string

type ProfileColumnsResponse

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

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

Deprecated: Use ProfileColumnsResponse.ProtoReflect.Descriptor instead.

func (*ProfileColumnsResponse) GetProfileColumns

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

func (*ProfileColumnsResponse) ProtoMessage

func (*ProfileColumnsResponse) ProtoMessage()

func (*ProfileColumnsResponse) ProtoReflect

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

func (*ProfileColumnsResponse) Reset

func (x *ProfileColumnsResponse) Reset()

func (*ProfileColumnsResponse) String

func (x *ProfileColumnsResponse) String() string

type PutFileAndReconcileRequest

type PutFileAndReconcileRequest struct {

	// Instance to store file in and reconcile
	InstanceId string `protobuf:"bytes,1,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"`
	// Path to store the file at
	Path string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	// Contents to save to the file
	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"`
	// 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,5,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,6,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 reconciliation (including dropping objects with
	// artifacts that fail to validate.)
	Strict bool `protobuf:"varint,7,opt,name=strict,proto3" json:"strict,omitempty"`
	// contains filtered or unexported fields
}

func (*PutFileAndReconcileRequest) Descriptor deprecated

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

Deprecated: Use PutFileAndReconcileRequest.ProtoReflect.Descriptor instead.

func (*PutFileAndReconcileRequest) GetBlob

func (x *PutFileAndReconcileRequest) GetBlob() string

func (*PutFileAndReconcileRequest) GetCreate

func (x *PutFileAndReconcileRequest) GetCreate() bool

func (*PutFileAndReconcileRequest) GetCreateOnly

func (x *PutFileAndReconcileRequest) GetCreateOnly() bool

func (*PutFileAndReconcileRequest) GetDry

func (x *PutFileAndReconcileRequest) GetDry() bool

func (*PutFileAndReconcileRequest) GetInstanceId

func (x *PutFileAndReconcileRequest) GetInstanceId() string

func (*PutFileAndReconcileRequest) GetPath

func (x *PutFileAndReconcileRequest) GetPath() string

func (*PutFileAndReconcileRequest) GetStrict

func (x *PutFileAndReconcileRequest) GetStrict() bool

func (*PutFileAndReconcileRequest) ProtoMessage

func (*PutFileAndReconcileRequest) ProtoMessage()

func (*PutFileAndReconcileRequest) ProtoReflect

func (*PutFileAndReconcileRequest) Reset

func (x *PutFileAndReconcileRequest) Reset()

func (*PutFileAndReconcileRequest) String

func (x *PutFileAndReconcileRequest) String() string

type PutFileAndReconcileResponse

type PutFileAndReconcileResponse struct {

	// Errors encountered during reconciliation. If strict = false, any path in
	// affected_paths without an error can be assumed to have been reconciled succesfully.
	Errors []*ReconcileError `protobuf:"bytes,1,rep,name=errors,proto3" json:"errors,omitempty"`
	// affected_paths lists all the file artifact paths that were considered while
	// executing the reconciliation. 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
}

func (*PutFileAndReconcileResponse) Descriptor deprecated

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

Deprecated: Use PutFileAndReconcileResponse.ProtoReflect.Descriptor instead.

func (*PutFileAndReconcileResponse) GetAffectedPaths

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

func (*PutFileAndReconcileResponse) GetErrors

func (x *PutFileAndReconcileResponse) GetErrors() []*ReconcileError

func (*PutFileAndReconcileResponse) ProtoMessage

func (*PutFileAndReconcileResponse) ProtoMessage()

func (*PutFileAndReconcileResponse) ProtoReflect

func (*PutFileAndReconcileResponse) Reset

func (x *PutFileAndReconcileResponse) Reset()

func (*PutFileAndReconcileResponse) String

func (x *PutFileAndReconcileResponse) String() string

type PutFileRequest

type PutFileRequest struct {
	InstanceId string `protobuf:"bytes,1,opt,name=instance_id,json=instanceId,proto3" json:"instance_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

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

Deprecated: Use PutFileRequest.ProtoReflect.Descriptor instead.

func (*PutFileRequest) GetBlob

func (x *PutFileRequest) GetBlob() string

func (*PutFileRequest) GetCreate

func (x *PutFileRequest) GetCreate() bool

func (*PutFileRequest) GetCreateOnly

func (x *PutFileRequest) GetCreateOnly() bool

func (*PutFileRequest) GetInstanceId

func (x *PutFileRequest) GetInstanceId() string

func (*PutFileRequest) GetPath

func (x *PutFileRequest) GetPath() string

func (*PutFileRequest) ProtoMessage

func (*PutFileRequest) ProtoMessage()

func (*PutFileRequest) ProtoReflect

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

func (*PutFileRequest) Reset

func (x *PutFileRequest) Reset()

func (*PutFileRequest) String

func (x *PutFileRequest) String() string

type PutFileResponse

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

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

Deprecated: Use PutFileResponse.ProtoReflect.Descriptor instead.

func (*PutFileResponse) GetFilePath

func (x *PutFileResponse) GetFilePath() string

func (*PutFileResponse) ProtoMessage

func (*PutFileResponse) ProtoMessage()

func (*PutFileResponse) ProtoReflect

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

func (*PutFileResponse) Reset

func (x *PutFileResponse) Reset()

func (*PutFileResponse) String

func (x *PutFileResponse) 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 int32 `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() int32

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 ReconcileError

type ReconcileError struct {

	// Code denotes the category of error
	Code ReconcileError_Code `protobuf:"varint,1,opt,name=code,proto3,enum=rill.runtime.v1.ReconcileError_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,rep,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 *ReconcileError_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 *ReconcileError_CharLocation `protobuf:"bytes,6,opt,name=end_location,json=endLocation,proto3" json:"end_location,omitempty"`
	// contains filtered or unexported fields
}

ReconcileError represents an error encountered while running Reconcile.

func (*ReconcileError) Descriptor deprecated

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

Deprecated: Use ReconcileError.ProtoReflect.Descriptor instead.

func (*ReconcileError) GetCode

func (x *ReconcileError) GetCode() ReconcileError_Code

func (*ReconcileError) GetEndLocation

func (x *ReconcileError) GetEndLocation() *ReconcileError_CharLocation

func (*ReconcileError) GetFilePath

func (x *ReconcileError) GetFilePath() string

func (*ReconcileError) GetMessage

func (x *ReconcileError) GetMessage() string

func (*ReconcileError) GetPropertyPath

func (x *ReconcileError) GetPropertyPath() []string

func (*ReconcileError) GetStartLocation

func (x *ReconcileError) GetStartLocation() *ReconcileError_CharLocation

func (*ReconcileError) ProtoMessage

func (*ReconcileError) ProtoMessage()

func (*ReconcileError) ProtoReflect

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

func (*ReconcileError) Reset

func (x *ReconcileError) Reset()

func (*ReconcileError) String

func (x *ReconcileError) String() string

type ReconcileError_CharLocation

type ReconcileError_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 (*ReconcileError_CharLocation) Descriptor deprecated

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

Deprecated: Use ReconcileError_CharLocation.ProtoReflect.Descriptor instead.

func (*ReconcileError_CharLocation) GetColumn

func (x *ReconcileError_CharLocation) GetColumn() uint32

func (*ReconcileError_CharLocation) GetLine

func (x *ReconcileError_CharLocation) GetLine() uint32

func (*ReconcileError_CharLocation) ProtoMessage

func (*ReconcileError_CharLocation) ProtoMessage()

func (*ReconcileError_CharLocation) ProtoReflect

func (*ReconcileError_CharLocation) Reset

func (x *ReconcileError_CharLocation) Reset()

func (*ReconcileError_CharLocation) String

func (x *ReconcileError_CharLocation) String() string

type ReconcileError_Code

type ReconcileError_Code int32

Code represents different categories of reconciliation errors

const (
	// Unspecified error
	ReconcileError_CODE_UNSPECIFIED ReconcileError_Code = 0
	// Code artifact failed to parse
	ReconcileError_CODE_SYNTAX ReconcileError_Code = 1
	// Code artifact has internal validation errors
	ReconcileError_CODE_VALIDATION ReconcileError_Code = 2
	// Code artifact is valid, but has invalid dependencies
	ReconcileError_CODE_DEPENDENCY ReconcileError_Code = 3
	// Error returned from the OLAP database
	ReconcileError_CODE_OLAP ReconcileError_Code = 4
	// Error encountered during source inspection or ingestion
	ReconcileError_CODE_SOURCE ReconcileError_Code = 5
)

func (ReconcileError_Code) Descriptor

func (ReconcileError_Code) Enum

func (ReconcileError_Code) EnumDescriptor deprecated

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

Deprecated: Use ReconcileError_Code.Descriptor instead.

func (ReconcileError_Code) Number

func (ReconcileError_Code) String

func (x ReconcileError_Code) String() string

func (ReconcileError_Code) Type

type ReconcileRequest

type ReconcileRequest struct {

	// Instance to reconcile
	InstanceId string `protobuf:"bytes,1,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"`
	// Changed paths provides a way to "hint" what files have changed in the repo, enabling
	// reconciliation to execute faster by not scanning all code artifacts for changes.
	ChangedPaths []string `protobuf:"bytes,2,rep,name=changed_paths,json=changedPaths,proto3" json:"changed_paths,omitempty"`
	// Forced paths is used to force run reconcile on certain files.
	// This is mainly used by UI to reconcile paths missing in catalog and get errors if any.
	ForcedPaths []string `protobuf:"bytes,3,rep,name=forced_paths,json=forcedPaths,proto3" json:"forced_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 reconciliation (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.Reconcile

func (*ReconcileRequest) Descriptor deprecated

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

Deprecated: Use ReconcileRequest.ProtoReflect.Descriptor instead.

func (*ReconcileRequest) GetChangedPaths

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

func (*ReconcileRequest) GetDry

func (x *ReconcileRequest) GetDry() bool

func (*ReconcileRequest) GetForcedPaths

func (x *ReconcileRequest) GetForcedPaths() []string

func (*ReconcileRequest) GetInstanceId

func (x *ReconcileRequest) GetInstanceId() string

func (*ReconcileRequest) GetStrict

func (x *ReconcileRequest) GetStrict() bool

func (*ReconcileRequest) ProtoMessage

func (*ReconcileRequest) ProtoMessage()

func (*ReconcileRequest) ProtoReflect

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

func (*ReconcileRequest) Reset

func (x *ReconcileRequest) Reset()

func (*ReconcileRequest) String

func (x *ReconcileRequest) String() string

type ReconcileResponse

type ReconcileResponse struct {

	// Errors encountered during reconciliation. If strict = false, any path in
	// affected_paths without an error can be assumed to have been reconciled succesfully.
	Errors []*ReconcileError `protobuf:"bytes,1,rep,name=errors,proto3" json:"errors,omitempty"`
	// affected_paths lists all the file artifact paths that were considered while
	// executing the reconciliation. 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.Reconcile

func (*ReconcileResponse) Descriptor deprecated

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

Deprecated: Use ReconcileResponse.ProtoReflect.Descriptor instead.

func (*ReconcileResponse) GetAffectedPaths

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

func (*ReconcileResponse) GetErrors

func (x *ReconcileResponse) GetErrors() []*ReconcileError

func (*ReconcileResponse) ProtoMessage

func (*ReconcileResponse) ProtoMessage()

func (*ReconcileResponse) ProtoReflect

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

func (*ReconcileResponse) Reset

func (x *ReconcileResponse) Reset()

func (*ReconcileResponse) String

func (x *ReconcileResponse) String() string

type RefreshAndReconcileRequest

type RefreshAndReconcileRequest struct {

	// Instance to store file in and reconcile
	InstanceId string `protobuf:"bytes,1,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"`
	// Current path of the file
	Path string `protobuf:"bytes,2,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,3,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 reconciliation (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 (*RefreshAndReconcileRequest) Descriptor deprecated

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

Deprecated: Use RefreshAndReconcileRequest.ProtoReflect.Descriptor instead.

func (*RefreshAndReconcileRequest) GetDry

func (x *RefreshAndReconcileRequest) GetDry() bool

func (*RefreshAndReconcileRequest) GetInstanceId

func (x *RefreshAndReconcileRequest) GetInstanceId() string

func (*RefreshAndReconcileRequest) GetPath

func (x *RefreshAndReconcileRequest) GetPath() string

func (*RefreshAndReconcileRequest) GetStrict

func (x *RefreshAndReconcileRequest) GetStrict() bool

func (*RefreshAndReconcileRequest) ProtoMessage

func (*RefreshAndReconcileRequest) ProtoMessage()

func (*RefreshAndReconcileRequest) ProtoReflect

func (*RefreshAndReconcileRequest) Reset

func (x *RefreshAndReconcileRequest) Reset()

func (*RefreshAndReconcileRequest) String

func (x *RefreshAndReconcileRequest) String() string

type RefreshAndReconcileResponse

type RefreshAndReconcileResponse struct {

	// Errors encountered during reconciliation. If strict = false, any path in
	// affected_paths without an error can be assumed to have been reconciled succesfully.
	Errors []*ReconcileError `protobuf:"bytes,1,rep,name=errors,proto3" json:"errors,omitempty"`
	// affected_paths lists all the file artifact paths that were considered while
	// executing the reconciliation. 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
}

func (*RefreshAndReconcileResponse) Descriptor deprecated

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

Deprecated: Use RefreshAndReconcileResponse.ProtoReflect.Descriptor instead.

func (*RefreshAndReconcileResponse) GetAffectedPaths

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

func (*RefreshAndReconcileResponse) GetErrors

func (x *RefreshAndReconcileResponse) GetErrors() []*ReconcileError

func (*RefreshAndReconcileResponse) ProtoMessage

func (*RefreshAndReconcileResponse) ProtoMessage()

func (*RefreshAndReconcileResponse) ProtoReflect

func (*RefreshAndReconcileResponse) Reset

func (x *RefreshAndReconcileResponse) Reset()

func (*RefreshAndReconcileResponse) String

func (x *RefreshAndReconcileResponse) String() string

type RenameFileAndReconcileRequest

type RenameFileAndReconcileRequest struct {

	// Instance to store file in and reconcile
	InstanceId string `protobuf:"bytes,1,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"`
	// Current path of the file
	FromPath string `protobuf:"bytes,2,opt,name=from_path,json=fromPath,proto3" json:"from_path,omitempty"`
	// New path of the file
	ToPath string `protobuf:"bytes,3,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,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 reconciliation (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 (*RenameFileAndReconcileRequest) Descriptor deprecated

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

Deprecated: Use RenameFileAndReconcileRequest.ProtoReflect.Descriptor instead.

func (*RenameFileAndReconcileRequest) GetDry

func (x *RenameFileAndReconcileRequest) GetDry() bool

func (*RenameFileAndReconcileRequest) GetFromPath

func (x *RenameFileAndReconcileRequest) GetFromPath() string

func (*RenameFileAndReconcileRequest) GetInstanceId

func (x *RenameFileAndReconcileRequest) GetInstanceId() string

func (*RenameFileAndReconcileRequest) GetStrict

func (x *RenameFileAndReconcileRequest) GetStrict() bool

func (*RenameFileAndReconcileRequest) GetToPath

func (x *RenameFileAndReconcileRequest) GetToPath() string

func (*RenameFileAndReconcileRequest) ProtoMessage

func (*RenameFileAndReconcileRequest) ProtoMessage()

func (*RenameFileAndReconcileRequest) ProtoReflect

func (*RenameFileAndReconcileRequest) Reset

func (x *RenameFileAndReconcileRequest) Reset()

func (*RenameFileAndReconcileRequest) String

type RenameFileAndReconcileResponse

type RenameFileAndReconcileResponse struct {

	// Errors encountered during reconciliation. If strict = false, any path in
	// affected_paths without an error can be assumed to have been reconciled succesfully.
	Errors []*ReconcileError `protobuf:"bytes,1,rep,name=errors,proto3" json:"errors,omitempty"`
	// affected_paths lists all the file artifact paths that were considered while
	// executing the reconciliation. 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
}

func (*RenameFileAndReconcileResponse) Descriptor deprecated

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

Deprecated: Use RenameFileAndReconcileResponse.ProtoReflect.Descriptor instead.

func (*RenameFileAndReconcileResponse) GetAffectedPaths

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

func (*RenameFileAndReconcileResponse) GetErrors

func (*RenameFileAndReconcileResponse) ProtoMessage

func (*RenameFileAndReconcileResponse) ProtoMessage()

func (*RenameFileAndReconcileResponse) ProtoReflect

func (*RenameFileAndReconcileResponse) Reset

func (x *RenameFileAndReconcileResponse) Reset()

func (*RenameFileAndReconcileResponse) String

type RenameFileRequest

type RenameFileRequest struct {
	InstanceId string `protobuf:"bytes,1,opt,name=instance_id,json=instanceId,proto3" json:"instance_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

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

Deprecated: Use RenameFileRequest.ProtoReflect.Descriptor instead.

func (*RenameFileRequest) GetFromPath

func (x *RenameFileRequest) GetFromPath() string

func (*RenameFileRequest) GetInstanceId

func (x *RenameFileRequest) GetInstanceId() string

func (*RenameFileRequest) GetToPath

func (x *RenameFileRequest) GetToPath() string

func (*RenameFileRequest) ProtoMessage

func (*RenameFileRequest) ProtoMessage()

func (*RenameFileRequest) ProtoReflect

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

func (*RenameFileRequest) Reset

func (x *RenameFileRequest) Reset()

func (*RenameFileRequest) String

func (x *RenameFileRequest) String() string

type RenameFileResponse

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

Response message for RuntimeService.RenameFile

func (*RenameFileResponse) Descriptor deprecated

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

Deprecated: Use RenameFileResponse.ProtoReflect.Descriptor instead.

func (*RenameFileResponse) ProtoMessage

func (*RenameFileResponse) ProtoMessage()

func (*RenameFileResponse) ProtoReflect

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

func (*RenameFileResponse) Reset

func (x *RenameFileResponse) Reset()

func (*RenameFileResponse) String

func (x *RenameFileResponse) String() string

type RuntimeServiceClient

type RuntimeServiceClient interface {
	// Ping returns information about the runtime
	Ping(ctx context.Context, in *PingRequest, opts ...grpc.CallOption) (*PingResponse, 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)
	// 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)
	// ListCatalogEntries lists all the entries registered in an instance's catalog (like tables, sources or metrics views)
	ListCatalogEntries(ctx context.Context, in *ListCatalogEntriesRequest, opts ...grpc.CallOption) (*ListCatalogEntriesResponse, error)
	// GetCatalogEntry returns information about a specific entry in the catalog
	GetCatalogEntry(ctx context.Context, in *GetCatalogEntryRequest, opts ...grpc.CallOption) (*GetCatalogEntryResponse, 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)
	// Reconcile 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.
	Reconcile(ctx context.Context, in *ReconcileRequest, opts ...grpc.CallOption) (*ReconcileResponse, error)
	// PutFileAndReconcile combines PutFile and Reconcile in a single endpoint to reduce latency.
	// It is equivalent to calling the two RPCs sequentially.
	PutFileAndReconcile(ctx context.Context, in *PutFileAndReconcileRequest, opts ...grpc.CallOption) (*PutFileAndReconcileResponse, error)
	// DeleteFileAndReconcile combines RenameFile and Reconcile in a single endpoint to reduce latency.
	DeleteFileAndReconcile(ctx context.Context, in *DeleteFileAndReconcileRequest, opts ...grpc.CallOption) (*DeleteFileAndReconcileResponse, error)
	// RenameFileAndReconcile combines RenameFile and Reconcile in a single endpoint to reduce latency.
	RenameFileAndReconcile(ctx context.Context, in *RenameFileAndReconcileRequest, opts ...grpc.CallOption) (*RenameFileAndReconcileResponse, error)
	RefreshAndReconcile(ctx context.Context, in *RefreshAndReconcileRequest, opts ...grpc.CallOption) (*RefreshAndReconcileResponse, error)
	// Query runs a SQL query against the instance's OLAP datastore.
	Query(ctx context.Context, in *QueryRequest, opts ...grpc.CallOption) (*QueryResponse, 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 *GetTopKRequest, opts ...grpc.CallOption) (*GetTopKResponse, error)
	// Get the number of nulls in a column
	GetNullCount(ctx context.Context, in *GetNullCountRequest, opts ...grpc.CallOption) (*GetNullCountResponse, error)
	// Get basic stats for a numeric column like min, max, mean, stddev, etc
	GetDescriptiveStatistics(ctx context.Context, in *GetDescriptiveStatisticsRequest, opts ...grpc.CallOption) (*GetDescriptiveStatisticsResponse, 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 *GetNumericHistogramRequest, opts ...grpc.CallOption) (*GetNumericHistogramResponse, error)
	// Get outliers for a numeric column
	GetRugHistogram(ctx context.Context, in *GetRugHistogramRequest, opts ...grpc.CallOption) (*GetRugHistogramResponse, error)
	// Get the time range summaries (min, max) for a column
	GetTimeRangeSummary(ctx context.Context, in *GetTimeRangeSummaryRequest, opts ...grpc.CallOption) (*GetTimeRangeSummaryResponse, error)
	// Get cardinality for a column
	GetCardinalityOfColumn(ctx context.Context, in *GetCardinalityOfColumnRequest, opts ...grpc.CallOption) (*GetCardinalityOfColumnResponse, error)
	// Generate time series
	GenerateTimeSeries(ctx context.Context, in *GenerateTimeSeriesRequest, opts ...grpc.CallOption) (*GenerateTimeSeriesResponse, error)
	// TableCardinality (TODO: add description)
	GetTableCardinality(ctx context.Context, in *GetTableCardinalityRequest, opts ...grpc.CallOption) (*GetTableCardinalityResponse, error)
	// ProfileColumns (TODO: add description)
	ProfileColumns(ctx context.Context, in *ProfileColumnsRequest, opts ...grpc.CallOption) (*ProfileColumnsResponse, error)
	// TableRows (TODO: add description)
	GetTableRows(ctx context.Context, in *GetTableRowsRequest, opts ...grpc.CallOption) (*GetTableRowsResponse, 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.

type RuntimeServiceServer

type RuntimeServiceServer interface {
	// Ping returns information about the runtime
	Ping(context.Context, *PingRequest) (*PingResponse, 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)
	// 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)
	// ListCatalogEntries lists all the entries registered in an instance's catalog (like tables, sources or metrics views)
	ListCatalogEntries(context.Context, *ListCatalogEntriesRequest) (*ListCatalogEntriesResponse, error)
	// GetCatalogEntry returns information about a specific entry in the catalog
	GetCatalogEntry(context.Context, *GetCatalogEntryRequest) (*GetCatalogEntryResponse, 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)
	// Reconcile 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.
	Reconcile(context.Context, *ReconcileRequest) (*ReconcileResponse, error)
	// PutFileAndReconcile combines PutFile and Reconcile in a single endpoint to reduce latency.
	// It is equivalent to calling the two RPCs sequentially.
	PutFileAndReconcile(context.Context, *PutFileAndReconcileRequest) (*PutFileAndReconcileResponse, error)
	// DeleteFileAndReconcile combines RenameFile and Reconcile in a single endpoint to reduce latency.
	DeleteFileAndReconcile(context.Context, *DeleteFileAndReconcileRequest) (*DeleteFileAndReconcileResponse, error)
	// RenameFileAndReconcile combines RenameFile and Reconcile in a single endpoint to reduce latency.
	RenameFileAndReconcile(context.Context, *RenameFileAndReconcileRequest) (*RenameFileAndReconcileResponse, error)
	RefreshAndReconcile(context.Context, *RefreshAndReconcileRequest) (*RefreshAndReconcileResponse, error)
	// Query runs a SQL query against the instance's OLAP datastore.
	Query(context.Context, *QueryRequest) (*QueryResponse, 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, *GetTopKRequest) (*GetTopKResponse, error)
	// Get the number of nulls in a column
	GetNullCount(context.Context, *GetNullCountRequest) (*GetNullCountResponse, error)
	// Get basic stats for a numeric column like min, max, mean, stddev, etc
	GetDescriptiveStatistics(context.Context, *GetDescriptiveStatisticsRequest) (*GetDescriptiveStatisticsResponse, 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, *GetNumericHistogramRequest) (*GetNumericHistogramResponse, error)
	// Get outliers for a numeric column
	GetRugHistogram(context.Context, *GetRugHistogramRequest) (*GetRugHistogramResponse, error)
	// Get the time range summaries (min, max) for a column
	GetTimeRangeSummary(context.Context, *GetTimeRangeSummaryRequest) (*GetTimeRangeSummaryResponse, error)
	// Get cardinality for a column
	GetCardinalityOfColumn(context.Context, *GetCardinalityOfColumnRequest) (*GetCardinalityOfColumnResponse, error)
	// Generate time series
	GenerateTimeSeries(context.Context, *GenerateTimeSeriesRequest) (*GenerateTimeSeriesResponse, error)
	// TableCardinality (TODO: add description)
	GetTableCardinality(context.Context, *GetTableCardinalityRequest) (*GetTableCardinalityResponse, error)
	// ProfileColumns (TODO: add description)
	ProfileColumns(context.Context, *ProfileColumnsRequest) (*ProfileColumnsResponse, error)
	// TableRows (TODO: add description)
	GetTableRows(context.Context, *GetTableRowsRequest) (*GetTableRowsResponse, 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 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"`
	// 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

func (x *Source) GetSchema() *StructType

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

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

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

Deprecated: Use StructType.ProtoReflect.Descriptor instead.

func (*StructType) GetFields

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

func (*StructType) ProtoMessage

func (*StructType) ProtoMessage()

func (*StructType) ProtoReflect

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

func (*StructType) Reset

func (x *StructType) Reset()

func (*StructType) String

func (x *StructType) String() string

type StructType_Field

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

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

Deprecated: Use StructType_Field.ProtoReflect.Descriptor instead.

func (*StructType_Field) GetName

func (x *StructType_Field) GetName() string

func (*StructType_Field) GetType

func (x *StructType_Field) GetType() *Type

func (*StructType_Field) ProtoMessage

func (*StructType_Field) ProtoMessage()

func (*StructType_Field) ProtoReflect

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

func (*StructType_Field) Reset

func (x *StructType_Field) Reset()

func (*StructType_Field) String

func (x *StructType_Field) String() string

type Table

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

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

Deprecated: Use Table.ProtoReflect.Descriptor instead.

func (*Table) GetManaged

func (x *Table) GetManaged() bool

func (*Table) GetName

func (x *Table) GetName() string

func (*Table) GetSchema

func (x *Table) GetSchema() *StructType

func (*Table) ProtoMessage

func (*Table) ProtoMessage()

func (*Table) ProtoReflect

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

func (*Table) Reset

func (x *Table) Reset()

func (*Table) String

func (x *Table) String() string

type TimeGrain

type TimeGrain int32
const (
	TimeGrain_TIME_GRAIN_UNSPECIFIED TimeGrain = 0
	TimeGrain_TIME_GRAIN_MILLISECOND TimeGrain = 1
	TimeGrain_TIME_GRAIN_SECOND      TimeGrain = 2
	TimeGrain_TIME_GRAIN_MINUTE      TimeGrain = 3
	TimeGrain_TIME_GRAIN_HOUR        TimeGrain = 4
	TimeGrain_TIME_GRAIN_DAY         TimeGrain = 5
	TimeGrain_TIME_GRAIN_WEEK        TimeGrain = 6
	TimeGrain_TIME_GRAIN_MONTH       TimeGrain = 7
	TimeGrain_TIME_GRAIN_YEAR        TimeGrain = 8
)

func (TimeGrain) Descriptor

func (TimeGrain) Descriptor() protoreflect.EnumDescriptor

func (TimeGrain) Enum

func (x TimeGrain) Enum() *TimeGrain

func (TimeGrain) EnumDescriptor deprecated

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

Deprecated: Use TimeGrain.Descriptor instead.

func (TimeGrain) Number

func (x TimeGrain) Number() protoreflect.EnumNumber

func (TimeGrain) String

func (x TimeGrain) String() string

func (TimeGrain) Type

type TimeRangeName

type TimeRangeName int32
const (
	TimeRangeName_TIME_RANGE_NAME_UNSPECIFIED  TimeRangeName = 0
	TimeRangeName_TIME_RANGE_NAME_LAST_HOUR    TimeRangeName = 1
	TimeRangeName_TIME_RANGE_NAME_LAST_6_HOUR  TimeRangeName = 2
	TimeRangeName_TIME_RANGE_NAME_LAST_DAY     TimeRangeName = 3
	TimeRangeName_TIME_RANGE_NAME_LAST_2_DAYS  TimeRangeName = 4
	TimeRangeName_TIME_RANGE_NAME_LAST_5_DAYS  TimeRangeName = 5
	TimeRangeName_TIME_RANGE_NAME_LAST_WEEK    TimeRangeName = 6
	TimeRangeName_TIME_RANGE_NAME_LAST_2_WEEKS TimeRangeName = 7
	TimeRangeName_TIME_RANGE_NAME_LAST_30_DAYS TimeRangeName = 8
	TimeRangeName_TIME_RANGE_NAME_LAST_60_DAYS TimeRangeName = 9
	TimeRangeName_TIME_RANGE_NAME_ALL_TIME     TimeRangeName = 10
)

func (TimeRangeName) Descriptor

func (TimeRangeName) Enum

func (x TimeRangeName) Enum() *TimeRangeName

func (TimeRangeName) EnumDescriptor deprecated

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

Deprecated: Use TimeRangeName.Descriptor instead.

func (TimeRangeName) Number

func (TimeRangeName) String

func (x TimeRangeName) String() string

func (TimeRangeName) Type

type TimeRangeSummary

type TimeRangeSummary struct {
	Min      *timestamppb.Timestamp     `protobuf:"bytes,1,opt,name=min,proto3" json:"min,omitempty"`
	Max      *timestamppb.Timestamp     `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

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

Deprecated: Use TimeRangeSummary.ProtoReflect.Descriptor instead.

func (*TimeRangeSummary) GetInterval

func (x *TimeRangeSummary) GetInterval() *TimeRangeSummary_Interval

func (*TimeRangeSummary) GetMax

func (x *TimeRangeSummary) GetMax() *timestamppb.Timestamp

func (*TimeRangeSummary) GetMin

func (x *TimeRangeSummary) GetMin() *timestamppb.Timestamp

func (*TimeRangeSummary) ProtoMessage

func (*TimeRangeSummary) ProtoMessage()

func (*TimeRangeSummary) ProtoReflect

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

func (*TimeRangeSummary) Reset

func (x *TimeRangeSummary) Reset()

func (*TimeRangeSummary) String

func (x *TimeRangeSummary) String() string

type TimeRangeSummary_Interval

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

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

Deprecated: Use TimeRangeSummary_Interval.ProtoReflect.Descriptor instead.

func (*TimeRangeSummary_Interval) GetDays

func (x *TimeRangeSummary_Interval) GetDays() int32

func (*TimeRangeSummary_Interval) GetMicros

func (x *TimeRangeSummary_Interval) GetMicros() int64

func (*TimeRangeSummary_Interval) GetMonths

func (x *TimeRangeSummary_Interval) GetMonths() int32

func (*TimeRangeSummary_Interval) ProtoMessage

func (*TimeRangeSummary_Interval) ProtoMessage()

func (*TimeRangeSummary_Interval) ProtoReflect

func (*TimeRangeSummary_Interval) Reset

func (x *TimeRangeSummary_Interval) Reset()

func (*TimeRangeSummary_Interval) String

func (x *TimeRangeSummary_Interval) String() string

type TimeSeriesResponse

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

func (*TimeSeriesResponse) Descriptor deprecated

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

Deprecated: Use TimeSeriesResponse.ProtoReflect.Descriptor instead.

func (*TimeSeriesResponse) GetResults

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

func (*TimeSeriesResponse) GetSampleSize

func (x *TimeSeriesResponse) GetSampleSize() int32

func (*TimeSeriesResponse) GetSpark

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

func (*TimeSeriesResponse) GetTimeRange

func (x *TimeSeriesResponse) GetTimeRange() *TimeSeriesTimeRange

func (*TimeSeriesResponse) ProtoMessage

func (*TimeSeriesResponse) ProtoMessage()

func (*TimeSeriesResponse) ProtoReflect

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

func (*TimeSeriesResponse) Reset

func (x *TimeSeriesResponse) Reset()

func (*TimeSeriesResponse) String

func (x *TimeSeriesResponse) String() string

type TimeSeriesTimeRange

type TimeSeriesTimeRange struct {
	Start    *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=start,proto3" json:"start,omitempty"`
	End      *timestamppb.Timestamp `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

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

Deprecated: Use TimeSeriesTimeRange.ProtoReflect.Descriptor instead.

func (*TimeSeriesTimeRange) GetEnd

func (*TimeSeriesTimeRange) GetInterval

func (x *TimeSeriesTimeRange) GetInterval() TimeGrain

func (*TimeSeriesTimeRange) GetStart

func (x *TimeSeriesTimeRange) GetStart() *timestamppb.Timestamp

func (*TimeSeriesTimeRange) ProtoMessage

func (*TimeSeriesTimeRange) ProtoMessage()

func (*TimeSeriesTimeRange) ProtoReflect

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

func (*TimeSeriesTimeRange) Reset

func (x *TimeSeriesTimeRange) Reset()

func (*TimeSeriesTimeRange) String

func (x *TimeSeriesTimeRange) String() string

type TimeSeriesValue

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

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

Deprecated: Use TimeSeriesValue.ProtoReflect.Descriptor instead.

func (*TimeSeriesValue) GetBin

func (x *TimeSeriesValue) GetBin() float64

func (*TimeSeriesValue) GetRecords

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

func (*TimeSeriesValue) GetTs

func (x *TimeSeriesValue) GetTs() string

func (*TimeSeriesValue) ProtoMessage

func (*TimeSeriesValue) ProtoMessage()

func (*TimeSeriesValue) ProtoReflect

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

func (*TimeSeriesValue) Reset

func (x *TimeSeriesValue) Reset()

func (*TimeSeriesValue) String

func (x *TimeSeriesValue) String() string

type TopK

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

func (*TopK) Descriptor deprecated

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

Deprecated: Use TopK.ProtoReflect.Descriptor instead.

func (*TopK) GetEntries

func (x *TopK) GetEntries() []*TopK_Entry

func (*TopK) ProtoMessage

func (*TopK) ProtoMessage()

func (*TopK) ProtoReflect

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

func (*TopK) Reset

func (x *TopK) Reset()

func (*TopK) String

func (x *TopK) String() string

type TopK_Entry

type TopK_Entry struct {
	Value *structpb.Value `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	Count float64         `protobuf:"fixed64,2,opt,name=count,proto3" json:"count,omitempty"`
	// contains filtered or unexported fields
}

func (*TopK_Entry) Descriptor deprecated

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

Deprecated: Use TopK_Entry.ProtoReflect.Descriptor instead.

func (*TopK_Entry) GetCount

func (x *TopK_Entry) GetCount() float64

func (*TopK_Entry) GetValue

func (x *TopK_Entry) GetValue() *structpb.Value

func (*TopK_Entry) ProtoMessage

func (*TopK_Entry) ProtoMessage()

func (*TopK_Entry) ProtoReflect

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

func (*TopK_Entry) Reset

func (x *TopK_Entry) Reset()

func (*TopK_Entry) String

func (x *TopK_Entry) 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

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

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

Deprecated: Use TriggerSyncRequest.ProtoReflect.Descriptor instead.

func (*TriggerSyncRequest) GetInstanceId

func (x *TriggerSyncRequest) GetInstanceId() string

func (*TriggerSyncRequest) ProtoMessage

func (*TriggerSyncRequest) ProtoMessage()

func (*TriggerSyncRequest) ProtoReflect

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

func (*TriggerSyncRequest) Reset

func (x *TriggerSyncRequest) Reset()

func (*TriggerSyncRequest) String

func (x *TriggerSyncRequest) String() string

type TriggerSyncResponse

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

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

Deprecated: Use TriggerSyncResponse.ProtoReflect.Descriptor instead.

func (*TriggerSyncResponse) GetObjectsAddedCount

func (x *TriggerSyncResponse) GetObjectsAddedCount() uint32

func (*TriggerSyncResponse) GetObjectsCount

func (x *TriggerSyncResponse) GetObjectsCount() uint32

func (*TriggerSyncResponse) GetObjectsRemovedCount

func (x *TriggerSyncResponse) GetObjectsRemovedCount() uint32

func (*TriggerSyncResponse) GetObjectsUpdatedCount

func (x *TriggerSyncResponse) GetObjectsUpdatedCount() uint32

func (*TriggerSyncResponse) ProtoMessage

func (*TriggerSyncResponse) ProtoMessage()

func (*TriggerSyncResponse) ProtoReflect

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

func (*TriggerSyncResponse) Reset

func (x *TriggerSyncResponse) Reset()

func (*TriggerSyncResponse) String

func (x *TriggerSyncResponse) String() string

type Type

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

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

Deprecated: Use Type.ProtoReflect.Descriptor instead.

func (*Type) GetArrayElementType

func (x *Type) GetArrayElementType() *Type

func (*Type) GetCode

func (x *Type) GetCode() Type_Code

func (*Type) GetMapType

func (x *Type) GetMapType() *MapType

func (*Type) GetNullable

func (x *Type) GetNullable() bool

func (*Type) GetStructType

func (x *Type) GetStructType() *StructType

func (*Type) ProtoMessage

func (*Type) ProtoMessage()

func (*Type) ProtoReflect

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

func (*Type) Reset

func (x *Type) Reset()

func (*Type) String

func (x *Type) String() string

type Type_Code

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

func (Type_Code) Descriptor() protoreflect.EnumDescriptor

func (Type_Code) Enum

func (x Type_Code) Enum() *Type_Code

func (Type_Code) EnumDescriptor deprecated

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

Deprecated: Use Type_Code.Descriptor instead.

func (Type_Code) Number

func (x Type_Code) Number() protoreflect.EnumNumber

func (Type_Code) String

func (x Type_Code) String() string

func (Type_Code) Type

type UnimplementedRuntimeServiceServer

type UnimplementedRuntimeServiceServer struct {
}

UnimplementedRuntimeServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedRuntimeServiceServer) CreateInstance

func (UnimplementedRuntimeServiceServer) DeleteFile

func (UnimplementedRuntimeServiceServer) DeleteInstance

func (UnimplementedRuntimeServiceServer) GenerateTimeSeries

func (UnimplementedRuntimeServiceServer) GetCatalogEntry

func (UnimplementedRuntimeServiceServer) GetFile

func (UnimplementedRuntimeServiceServer) GetInstance

func (UnimplementedRuntimeServiceServer) GetNullCount

func (UnimplementedRuntimeServiceServer) GetNumericHistogram

func (UnimplementedRuntimeServiceServer) GetRugHistogram

func (UnimplementedRuntimeServiceServer) GetTableCardinality

func (UnimplementedRuntimeServiceServer) GetTableRows

func (UnimplementedRuntimeServiceServer) GetTimeRangeSummary

func (UnimplementedRuntimeServiceServer) GetTopK

func (UnimplementedRuntimeServiceServer) ListCatalogEntries

func (UnimplementedRuntimeServiceServer) ListConnectors

func (UnimplementedRuntimeServiceServer) ListFiles

func (UnimplementedRuntimeServiceServer) ListInstances

func (UnimplementedRuntimeServiceServer) MetricsViewToplist

func (UnimplementedRuntimeServiceServer) MetricsViewTotals

func (UnimplementedRuntimeServiceServer) Ping

func (UnimplementedRuntimeServiceServer) ProfileColumns

func (UnimplementedRuntimeServiceServer) PutFile

func (UnimplementedRuntimeServiceServer) PutFileAndReconcile

func (UnimplementedRuntimeServiceServer) Query

func (UnimplementedRuntimeServiceServer) Reconcile

func (UnimplementedRuntimeServiceServer) RefreshAndReconcile

func (UnimplementedRuntimeServiceServer) RenameFile

func (UnimplementedRuntimeServiceServer) TriggerRefresh

func (UnimplementedRuntimeServiceServer) TriggerSync

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.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL