runtimev1

package
v0.18.0 Latest Latest
Warning

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

 Go to latest Published: Jan 6, 2023 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 (x *Connector_Property) GetType() Connector_Property_Type

func (*Connector_Property) ProtoMessage 

func (*Connector_Property) ProtoMessage()

func (*Connector_Property) ProtoReflect 

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

func (*Connector_Property) Reset 

func (x *Connector_Property) Reset()

func (*Connector_Property) String 

func (x *Connector_Property) String() string

type Connector_Property_Type 

type Connector_Property_Type int32

Type represents the field type 

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

func (Connector_Property_Type) Descriptor 

func (Connector_Property_Type) Descriptor() protoreflect.EnumDescriptor

func (Connector_Property_Type) Enum 

func (x Connector_Property_Type) Enum() *Connector_Property_Type

func (Connector_Property_Type) EnumDescriptor deprecated 

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

Deprecated: Use Connector_Property_Type.Descriptor instead.

func (Connector_Property_Type) Number 

func (x Connector_Property_Type) Number() protoreflect.EnumNumber

func (Connector_Property_Type) String 

func (x Connector_Property_Type) String() string

func (Connector_Property_Type) Type 

func (Connector_Property_Type) Type() protoreflect.EnumType

type CreateInstanceRequest 

type CreateInstanceRequest struct {
	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) Descriptor() protoreflect.EnumDescriptor

func (DatabaseObjectType) Enum 

func (x DatabaseObjectType) Enum() *DatabaseObjectType

func (DatabaseObjectType) EnumDescriptor deprecated 

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

Deprecated: Use DatabaseObjectType.Descriptor instead.

func (DatabaseObjectType) Number 

func (x DatabaseObjectType) Number() protoreflect.EnumNumber

func (DatabaseObjectType) String 

func (x DatabaseObjectType) String() string

func (DatabaseObjectType) Type 

func (DatabaseObjectType) Type() protoreflect.EnumType

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 (x *DeleteFileAndReconcileRequest) GetPath() string

func (*DeleteFileAndReconcileRequest) GetStrict 

func (x *DeleteFileAndReconcileRequest) GetStrict() bool

func (*DeleteFileAndReconcileRequest) ProtoMessage 

func (*DeleteFileAndReconcileRequest) ProtoMessage()

func (*DeleteFileAndReconcileRequest) ProtoReflect 

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

func (*DeleteFileAndReconcileRequest) Reset 

func (x *DeleteFileAndReconcileRequest) Reset()

func (*DeleteFileAndReconcileRequest) String 

func (x *DeleteFileAndReconcileRequest) String() 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 (x *DeleteFileAndReconcileResponse) GetErrors() []*ReconcileError

func (*DeleteFileAndReconcileResponse) ProtoMessage 

func (*DeleteFileAndReconcileResponse) ProtoMessage()

func (*DeleteFileAndReconcileResponse) ProtoReflect 

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

func (*DeleteFileAndReconcileResponse) Reset 

func (x *DeleteFileAndReconcileResponse) Reset()

func (*DeleteFileAndReconcileResponse) String 

func (x *DeleteFileAndReconcileResponse) String() 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 (x *EstimateRollupIntervalRequest) ProtoReflect() protoreflect.Message

func (*EstimateRollupIntervalRequest) Reset 

func (x *EstimateRollupIntervalRequest) Reset()

func (*EstimateRollupIntervalRequest) String 

func (x *EstimateRollupIntervalRequest) String() 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 (x *EstimateRollupIntervalResponse) GetEnd() *timestamppb.Timestamp

func (*EstimateRollupIntervalResponse) GetInterval 

func (x *EstimateRollupIntervalResponse) GetInterval() TimeGrain

func (*EstimateRollupIntervalResponse) GetStart 

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

func (*EstimateRollupIntervalResponse) ProtoMessage 

func (*EstimateRollupIntervalResponse) ProtoMessage()

func (*EstimateRollupIntervalResponse) ProtoReflect 

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

func (*EstimateRollupIntervalResponse) Reset 

func (x *EstimateRollupIntervalResponse) Reset()

func (*EstimateRollupIntervalResponse) String 

func (x *EstimateRollupIntervalResponse) String() 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 (x *EstimateSmallestTimeGrainRequest) ProtoReflect() protoreflect.Message

func (*EstimateSmallestTimeGrainRequest) Reset 

func (x *EstimateSmallestTimeGrainRequest) Reset()

func (*EstimateSmallestTimeGrainRequest) String 

func (x *EstimateSmallestTimeGrainRequest) String() 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 (x *EstimateSmallestTimeGrainResponse) ProtoReflect() protoreflect.Message

func (*EstimateSmallestTimeGrainResponse) Reset 

func (x *EstimateSmallestTimeGrainResponse) Reset()

func (*EstimateSmallestTimeGrainResponse) String 

func (x *EstimateSmallestTimeGrainResponse) String() 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             *MetricsViewFilter                        `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 (x *GenerateTimeSeriesRequest) GetFilters() *MetricsViewFilter

func (*GenerateTimeSeriesRequest) GetInstanceId 

func (x *GenerateTimeSeriesRequest) GetInstanceId() string

func (*GenerateTimeSeriesRequest) GetMeasures 

func (x *GenerateTimeSeriesRequest) GetMeasures() []*GenerateTimeSeriesRequest_BasicMeasure

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 (x *GenerateTimeSeriesRequest) GetTimeRange() *TimeSeriesTimeRange

func (*GenerateTimeSeriesRequest) GetTimestampColumnName 

func (x *GenerateTimeSeriesRequest) GetTimestampColumnName() string

func (*GenerateTimeSeriesRequest) ProtoMessage 

func (*GenerateTimeSeriesRequest) ProtoMessage()

func (*GenerateTimeSeriesRequest) ProtoReflect 

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

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 (x *GenerateTimeSeriesRequest_BasicMeasure) GetExpression() string

func (*GenerateTimeSeriesRequest_BasicMeasure) GetId 

func (x *GenerateTimeSeriesRequest_BasicMeasure) GetId() string

func (*GenerateTimeSeriesRequest_BasicMeasure) GetSqlName 

func (x *GenerateTimeSeriesRequest_BasicMeasure) GetSqlName() string

func (*GenerateTimeSeriesRequest_BasicMeasure) ProtoMessage 

func (*GenerateTimeSeriesRequest_BasicMeasure) ProtoMessage()

func (*GenerateTimeSeriesRequest_BasicMeasure) ProtoReflect 

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

func (*GenerateTimeSeriesRequest_BasicMeasure) Reset 

func (x *GenerateTimeSeriesRequest_BasicMeasure) Reset()

func (*GenerateTimeSeriesRequest_BasicMeasure) String 

func (x *GenerateTimeSeriesRequest_BasicMeasure) String() 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 (x *GenerateTimeSeriesResponse) GetRollup() *TimeSeriesResponse

func (*GenerateTimeSeriesResponse) ProtoMessage 

func (*GenerateTimeSeriesResponse) ProtoMessage()

func (*GenerateTimeSeriesResponse) ProtoReflect 

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

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 (x *GetCardinalityOfColumnRequest) ProtoReflect() protoreflect.Message

func (*GetCardinalityOfColumnRequest) Reset 

func (x *GetCardinalityOfColumnRequest) Reset()

func (*GetCardinalityOfColumnRequest) String 

func (x *GetCardinalityOfColumnRequest) String() 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 (x *GetCardinalityOfColumnResponse) ProtoReflect() protoreflect.Message

func (*GetCardinalityOfColumnResponse) Reset 

func (x *GetCardinalityOfColumnResponse) Reset()

func (*GetCardinalityOfColumnResponse) String 

func (x *GetCardinalityOfColumnResponse) String() 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 (x *GetDescriptiveStatisticsRequest) ProtoReflect() protoreflect.Message

func (*GetDescriptiveStatisticsRequest) Reset 

func (x *GetDescriptiveStatisticsRequest) Reset()

func (*GetDescriptiveStatisticsRequest) String 

func (x *GetDescriptiveStatisticsRequest) String() 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 (x *GetDescriptiveStatisticsResponse) ProtoReflect() protoreflect.Message

func (*GetDescriptiveStatisticsResponse) Reset 

func (x *GetDescriptiveStatisticsResponse) Reset()

func (*GetDescriptiveStatisticsResponse) String 

func (x *GetDescriptiveStatisticsResponse) String() 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 (x *GetNumericHistogramRequest) ProtoReflect() protoreflect.Message

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 (x *GetNumericHistogramResponse) ProtoReflect() protoreflect.Message

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 (x *GetTableCardinalityRequest) ProtoReflect() protoreflect.Message

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 (x *GetTableCardinalityResponse) ProtoReflect() protoreflect.Message

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 (x *GetTimeRangeSummaryRequest) ProtoReflect() protoreflect.Message

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 (x *GetTimeRangeSummaryResponse) ProtoReflect() protoreflect.Message

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 (x *ListCatalogEntriesRequest) GetType() ObjectType

func (*ListCatalogEntriesRequest) ProtoMessage 

func (*ListCatalogEntriesRequest) ProtoMessage()

func (*ListCatalogEntriesRequest) ProtoReflect 

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

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 (x *ListCatalogEntriesResponse) ProtoReflect() protoreflect.Message

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 MetricsViewFilter 

type MetricsViewFilter struct {
	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) 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 []string          `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() []string

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 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 (x *MetricsViewTimeSeriesRequest) GetFilter() *MetricsViewFilter

func (*MetricsViewTimeSeriesRequest) GetInstanceId 

func (x *MetricsViewTimeSeriesRequest) GetInstanceId() string

func (*MetricsViewTimeSeriesRequest) GetMeasureNames 

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

func (*MetricsViewTimeSeriesRequest) GetMetricsViewName 

func (x *MetricsViewTimeSeriesRequest) GetMetricsViewName() string

func (*MetricsViewTimeSeriesRequest) GetPriority 

func (x *MetricsViewTimeSeriesRequest) GetPriority() int32

func (*MetricsViewTimeSeriesRequest) GetTimeEnd 

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

func (*MetricsViewTimeSeriesRequest) GetTimeGranularity 

func (x *MetricsViewTimeSeriesRequest) GetTimeGranularity() string

func (*MetricsViewTimeSeriesRequest) GetTimeStart 

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

func (*MetricsViewTimeSeriesRequest) ProtoMessage 

func (*MetricsViewTimeSeriesRequest) ProtoMessage()

func (*MetricsViewTimeSeriesRequest) ProtoReflect 

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

func (*MetricsViewTimeSeriesRequest) Reset 

func (x *MetricsViewTimeSeriesRequest) Reset()

func (*MetricsViewTimeSeriesRequest) String 

func (x *MetricsViewTimeSeriesRequest) String() string

type MetricsViewTimeSeriesResponse 

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

Response message for RuntimeService.MetricsViewTimeSeries

func (*MetricsViewTimeSeriesResponse) Descriptor deprecated 

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

Deprecated: Use MetricsViewTimeSeriesResponse.ProtoReflect.Descriptor instead.

func (*MetricsViewTimeSeriesResponse) GetData 

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

func (*MetricsViewTimeSeriesResponse) GetMeta 

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

func (*MetricsViewTimeSeriesResponse) ProtoMessage 

func (*MetricsViewTimeSeriesResponse) ProtoMessage()

func (*MetricsViewTimeSeriesResponse) ProtoReflect 

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

func (*MetricsViewTimeSeriesResponse) Reset 

func (x *MetricsViewTimeSeriesResponse) Reset()

func (*MetricsViewTimeSeriesResponse) String 

func (x *MetricsViewTimeSeriesResponse) String() string

type MetricsViewToplistRequest 

type MetricsViewToplistRequest struct {
	InstanceId      string                 `protobuf:"bytes,1,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"`
	MetricsViewName string                 `protobuf:"bytes,2,opt,name=metrics_view_name,json=metricsViewName,proto3" json:"metrics_view_name,omitempty"`
	DimensionName   string                 `protobuf:"bytes,3,opt,name=dimension_name,json=dimensionName,proto3" json:"dimension_name,omitempty"`
	MeasureNames    []string               `protobuf:"bytes,4,rep,name=measure_names,json=measureNames,proto3" json:"measure_names,omitempty"`
	TimeStart       *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=time_start,json=timeStart,proto3" json:"time_start,omitempty"`
	TimeEnd         *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=time_end,json=timeEnd,proto3" json:"time_end,omitempty"`
	Limit           int64                  `protobuf:"varint,7,opt,name=limit,proto3" json:"limit,omitempty"`
	Offset          int64                  `protobuf:"varint,8,opt,name=offset,proto3" json:"offset,omitempty"`
	Sort            []*MetricsViewSort     `protobuf:"bytes,9,rep,name=sort,proto3" json:"sort,omitempty"`
	Filter          *MetricsViewFilter     `protobuf:"bytes,10,opt,name=filter,proto3" json:"filter,omitempty"`
	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 (x *MetricsViewToplistRequest) GetFilter() *MetricsViewFilter

func (*MetricsViewToplistRequest) GetInstanceId 

func (x *MetricsViewToplistRequest) GetInstanceId() string

func (*MetricsViewToplistRequest) GetLimit 

func (x *MetricsViewToplistRequest) GetLimit() int64

func (*MetricsViewToplistRequest) GetMeasureNames 

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

func (*MetricsViewToplistRequest) GetMetricsViewName 

func (x *MetricsViewToplistRequest) GetMetricsViewName() string

func (*MetricsViewToplistRequest) GetOffset 

func (x *MetricsViewToplistRequest) GetOffset() int64

func (*MetricsViewToplistRequest) GetPriority 

func (x *MetricsViewToplistRequest) GetPriority() int32

func (*MetricsViewToplistRequest) GetSort 

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

func (*MetricsViewToplistRequest) GetTimeEnd 

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

func (*MetricsViewToplistRequest) GetTimeStart 

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

func (*MetricsViewToplistRequest) ProtoMessage 

func (*MetricsViewToplistRequest) ProtoMessage()

func (*MetricsViewToplistRequest) ProtoReflect 

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

func (*MetricsViewToplistRequest) Reset 

func (x *MetricsViewToplistRequest) Reset()

func (*MetricsViewToplistRequest) String 

func (x *MetricsViewToplistRequest) String() string

type MetricsViewToplistResponse 

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

Response message for RuntimeService.MetricsViewToplist

func (*MetricsViewToplistResponse) Descriptor deprecated 

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

Deprecated: Use MetricsViewToplistResponse.ProtoReflect.Descriptor instead.

func (*MetricsViewToplistResponse) GetData 

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

func (*MetricsViewToplistResponse) GetMeta 

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

func (*MetricsViewToplistResponse) ProtoMessage 

func (*MetricsViewToplistResponse) ProtoMessage()

func (*MetricsViewToplistResponse) ProtoReflect 

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

func (*MetricsViewToplistResponse) Reset 

func (x *MetricsViewToplistResponse) Reset()

func (*MetricsViewToplistResponse) String 

func (x *MetricsViewToplistResponse) String() string

type MetricsViewTotalsRequest 

type MetricsViewTotalsRequest struct {
	InstanceId      string                 `protobuf:"bytes,1,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"`
	MetricsViewName string                 `protobuf:"bytes,2,opt,name=metrics_view_name,json=metricsViewName,proto3" json:"metrics_view_name,omitempty"`
	MeasureNames    []string               `protobuf:"bytes,3,rep,name=measure_names,json=measureNames,proto3" json:"measure_names,omitempty"`
	TimeStart       *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=time_start,json=timeStart,proto3" json:"time_start,omitempty"`
	TimeEnd         *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=time_end,json=timeEnd,proto3" json:"time_end,omitempty"`
	Filter          *MetricsViewFilter     `protobuf:"bytes,7,opt,name=filter,proto3" json:"filter,omitempty"`
	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 (x *MetricsViewTotalsRequest) GetFilter() *MetricsViewFilter

func (*MetricsViewTotalsRequest) GetInstanceId 

func (x *MetricsViewTotalsRequest) GetInstanceId() string

func (*MetricsViewTotalsRequest) GetMeasureNames 

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

func (*MetricsViewTotalsRequest) GetMetricsViewName 

func (x *MetricsViewTotalsRequest) GetMetricsViewName() string

func (*MetricsViewTotalsRequest) GetPriority 

func (x *MetricsViewTotalsRequest) GetPriority() int32

func (*MetricsViewTotalsRequest) GetTimeEnd 

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

func (*MetricsViewTotalsRequest) GetTimeStart 

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

func (*MetricsViewTotalsRequest) ProtoMessage 

func (*MetricsViewTotalsRequest) ProtoMessage()

func (*MetricsViewTotalsRequest) ProtoReflect 

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

func (*MetricsViewTotalsRequest) Reset 

func (x *MetricsViewTotalsRequest) Reset()

func (*MetricsViewTotalsRequest) String 

func (x *MetricsViewTotalsRequest) String() string

type MetricsViewTotalsResponse 

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

Response message for RuntimeService.MetricsViewTotals

func (*MetricsViewTotalsResponse) Descriptor deprecated 

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

Deprecated: Use MetricsViewTotalsResponse.ProtoReflect.Descriptor instead.

func (*MetricsViewTotalsResponse) GetData 

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

func (*MetricsViewTotalsResponse) GetMeta 

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

func (*MetricsViewTotalsResponse) ProtoMessage 

func (*MetricsViewTotalsResponse) ProtoMessage()

func (*MetricsViewTotalsResponse) ProtoReflect 

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

func (*MetricsViewTotalsResponse) Reset 

func (x *MetricsViewTotalsResponse) Reset()

func (*MetricsViewTotalsResponse) String 

func (x *MetricsViewTotalsResponse) String() string

type MetricsView_Dimension 

type MetricsView_Dimension struct {
	Name        string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Label       string `protobuf:"bytes,2,opt,name=label,proto3" json:"label,omitempty"`
	Description string `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	// 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) Descriptor() protoreflect.EnumDescriptor

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 (x Model_Dialect) Number() protoreflect.EnumNumber

func (Model_Dialect) String 

func (x Model_Dialect) String() string

func (Model_Dialect) Type 

func (Model_Dialect) Type() protoreflect.EnumType

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 (x *NumericHistogramBins) GetBins() []*NumericHistogramBins_Bin

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 

func (ObjectType) Type() protoreflect.EnumType

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 (x *PutFileAndReconcileRequest) ProtoReflect() protoreflect.Message

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 (x *PutFileAndReconcileResponse) ProtoReflect() protoreflect.Message

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 (x *ReconcileError_CharLocation) ProtoReflect() protoreflect.Message

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) Descriptor() protoreflect.EnumDescriptor

func (ReconcileError_Code) Enum 

func (x ReconcileError_Code) Enum() *ReconcileError_Code

func (ReconcileError_Code) EnumDescriptor deprecated 

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

Deprecated: Use ReconcileError_Code.Descriptor instead.

func (ReconcileError_Code) Number 

func (x ReconcileError_Code) Number() protoreflect.EnumNumber

func (ReconcileError_Code) String 

func (x ReconcileError_Code) String() string

func (ReconcileError_Code) Type 

func (ReconcileError_Code) Type() protoreflect.EnumType

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 (x *RefreshAndReconcileRequest) ProtoReflect() protoreflect.Message

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 (x *RefreshAndReconcileResponse) ProtoReflect() protoreflect.Message

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 (x *RenameFileAndReconcileRequest) ProtoReflect() protoreflect.Message

func (*RenameFileAndReconcileRequest) Reset 

func (x *RenameFileAndReconcileRequest) Reset()

func (*RenameFileAndReconcileRequest) String 

func (x *RenameFileAndReconcileRequest) String() 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 (x *RenameFileAndReconcileResponse) GetErrors() []*ReconcileError

func (*RenameFileAndReconcileResponse) ProtoMessage 

func (*RenameFileAndReconcileResponse) ProtoMessage()

func (*RenameFileAndReconcileResponse) ProtoReflect 

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

func (*RenameFileAndReconcileResponse) Reset 

func (x *RenameFileAndReconcileResponse) Reset()

func (*RenameFileAndReconcileResponse) String 

func (x *RenameFileAndReconcileResponse) String() 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.

func NewRuntimeServiceClient 

func NewRuntimeServiceClient(cc grpc.ClientConnInterface) RuntimeServiceClient

type RuntimeServiceServer 

type RuntimeServiceServer interface {
	// Ping returns information about the runtime
	Ping(context.Context, *PingRequest) (*PingResponse, error)
	// 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 

func (TimeGrain) Type() protoreflect.EnumType

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) Descriptor() protoreflect.EnumDescriptor

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 (x TimeRangeName) Number() protoreflect.EnumNumber

func (TimeRangeName) String 

func (x TimeRangeName) String() string

func (TimeRangeName) Type 

func (TimeRangeName) Type() protoreflect.EnumType

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 (x *TimeRangeSummary_Interval) ProtoReflect() protoreflect.Message

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 (x *TimeSeriesTimeRange) GetEnd() *timestamppb.Timestamp

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 

func (Type_Code) Type() protoreflect.EnumType

type UnimplementedRuntimeServiceServer 

type UnimplementedRuntimeServiceServer struct {
}

UnimplementedRuntimeServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedRuntimeServiceServer) CreateInstance 

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

func (UnimplementedRuntimeServiceServer) DeleteFile 

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

func (UnimplementedRuntimeServiceServer) DeleteFileAndReconcile 

func (UnimplementedRuntimeServiceServer) DeleteFileAndReconcile(context.Context, *DeleteFileAndReconcileRequest) (*DeleteFileAndReconcileResponse, error)

func (UnimplementedRuntimeServiceServer) DeleteInstance 

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

func (UnimplementedRuntimeServiceServer) EstimateRollupInterval 

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

func (UnimplementedRuntimeServiceServer) EstimateSmallestTimeGrain 

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

func (UnimplementedRuntimeServiceServer) GenerateTimeSeries 

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

func (UnimplementedRuntimeServiceServer) GetCardinalityOfColumn 

func (UnimplementedRuntimeServiceServer) GetCardinalityOfColumn(context.Context, *GetCardinalityOfColumnRequest) (*GetCardinalityOfColumnResponse, error)

func (UnimplementedRuntimeServiceServer) GetCatalogEntry 

func (UnimplementedRuntimeServiceServer) GetCatalogEntry(context.Context, *GetCatalogEntryRequest) (*GetCatalogEntryResponse, error)

func (UnimplementedRuntimeServiceServer) GetDescriptiveStatistics 

func (UnimplementedRuntimeServiceServer) GetDescriptiveStatistics(context.Context, *GetDescriptiveStatisticsRequest) (*GetDescriptiveStatisticsResponse, error)

func (UnimplementedRuntimeServiceServer) GetFile 

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

func (UnimplementedRuntimeServiceServer) GetInstance 

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

func (UnimplementedRuntimeServiceServer) GetNullCount 

func (UnimplementedRuntimeServiceServer) GetNullCount(context.Context, *GetNullCountRequest) (*GetNullCountResponse, error)

func (UnimplementedRuntimeServiceServer) GetNumericHistogram 

func (UnimplementedRuntimeServiceServer) GetNumericHistogram(context.Context, *GetNumericHistogramRequest) (*GetNumericHistogramResponse, error)

func (UnimplementedRuntimeServiceServer) GetRugHistogram 

func (UnimplementedRuntimeServiceServer) GetRugHistogram(context.Context, *GetRugHistogramRequest) (*GetRugHistogramResponse, error)

func (UnimplementedRuntimeServiceServer) GetTableCardinality 

func (UnimplementedRuntimeServiceServer) GetTableCardinality(context.Context, *GetTableCardinalityRequest) (*GetTableCardinalityResponse, error)

func (UnimplementedRuntimeServiceServer) GetTableRows 

func (UnimplementedRuntimeServiceServer) GetTableRows(context.Context, *GetTableRowsRequest) (*GetTableRowsResponse, error)

func (UnimplementedRuntimeServiceServer) GetTimeRangeSummary 

func (UnimplementedRuntimeServiceServer) GetTimeRangeSummary(context.Context, *GetTimeRangeSummaryRequest) (*GetTimeRangeSummaryResponse, error)

func (UnimplementedRuntimeServiceServer) GetTopK 

func (UnimplementedRuntimeServiceServer) GetTopK(context.Context, *GetTopKRequest) (*GetTopKResponse, error)

func (UnimplementedRuntimeServiceServer) ListCatalogEntries 

func (UnimplementedRuntimeServiceServer) ListCatalogEntries(context.Context, *ListCatalogEntriesRequest) (*ListCatalogEntriesResponse, error)

func (UnimplementedRuntimeServiceServer) ListConnectors 

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

func (UnimplementedRuntimeServiceServer) ListFiles 

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

func (UnimplementedRuntimeServiceServer) ListInstances 

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

func (UnimplementedRuntimeServiceServer) MetricsViewTimeSeries 

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

func (UnimplementedRuntimeServiceServer) MetricsViewToplist 

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

func (UnimplementedRuntimeServiceServer) MetricsViewTotals 

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

func (UnimplementedRuntimeServiceServer) Ping 

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

func (UnimplementedRuntimeServiceServer) ProfileColumns 

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

func (UnimplementedRuntimeServiceServer) PutFile 

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

func (UnimplementedRuntimeServiceServer) PutFileAndReconcile 

func (UnimplementedRuntimeServiceServer) PutFileAndReconcile(context.Context, *PutFileAndReconcileRequest) (*PutFileAndReconcileResponse, error)

func (UnimplementedRuntimeServiceServer) Query 

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

func (UnimplementedRuntimeServiceServer) Reconcile 

func (UnimplementedRuntimeServiceServer) Reconcile(context.Context, *ReconcileRequest) (*ReconcileResponse, error)

func (UnimplementedRuntimeServiceServer) RefreshAndReconcile 

func (UnimplementedRuntimeServiceServer) RefreshAndReconcile(context.Context, *RefreshAndReconcileRequest) (*RefreshAndReconcileResponse, error)

func (UnimplementedRuntimeServiceServer) RenameFile 

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

func (UnimplementedRuntimeServiceServer) RenameFileAndReconcile 

func (UnimplementedRuntimeServiceServer) RenameFileAndReconcile(context.Context, *RenameFileAndReconcileRequest) (*RenameFileAndReconcileResponse, error)

func (UnimplementedRuntimeServiceServer) TriggerRefresh 

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

func (UnimplementedRuntimeServiceServer) TriggerSync 

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

type UnsafeRuntimeServiceServer 

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

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

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