api

package
v0.14.1 Latest Latest
Warning

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

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

README

runtime/api/

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

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

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

Generating

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

go generate ./runtime/api

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

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

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

Documentation

Overview

Package api is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

View Source 
var (
	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 File_runtime_proto protoreflect.FileDescriptor
View Source 
var RuntimeService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "runtime.v1.RuntimeService",
	HandlerType: (*RuntimeServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Ping",
			Handler:    _RuntimeService_Ping_Handler,
		},
		{
			MethodName: "ListRepos",
			Handler:    _RuntimeService_ListRepos_Handler,
		},
		{
			MethodName: "GetRepo",
			Handler:    _RuntimeService_GetRepo_Handler,
		},
		{
			MethodName: "CreateRepo",
			Handler:    _RuntimeService_CreateRepo_Handler,
		},
		{
			MethodName: "DeleteRepo",
			Handler:    _RuntimeService_DeleteRepo_Handler,
		},
		{
			MethodName: "ListRepoObjects",
			Handler:    _RuntimeService_ListRepoObjects_Handler,
		},
		{
			MethodName: "GetRepoObject",
			Handler:    _RuntimeService_GetRepoObject_Handler,
		},
		{
			MethodName: "PutRepoObject",
			Handler:    _RuntimeService_PutRepoObject_Handler,
		},
		{
			MethodName: "ListInstances",
			Handler:    _RuntimeService_ListInstances_Handler,
		},
		{
			MethodName: "GetInstance",
			Handler:    _RuntimeService_GetInstance_Handler,
		},
		{
			MethodName: "CreateInstance",
			Handler:    _RuntimeService_CreateInstance_Handler,
		},
		{
			MethodName: "DeleteInstance",
			Handler:    _RuntimeService_DeleteInstance_Handler,
		},
		{
			MethodName: "ListCatalogObjects",
			Handler:    _RuntimeService_ListCatalogObjects_Handler,
		},
		{
			MethodName: "GetCatalogObject",
			Handler:    _RuntimeService_GetCatalogObject_Handler,
		},
		{
			MethodName: "TriggerRefresh",
			Handler:    _RuntimeService_TriggerRefresh_Handler,
		},
		{
			MethodName: "Migrate",
			Handler:    _RuntimeService_Migrate_Handler,
		},
		{
			MethodName: "MigrateSingle",
			Handler:    _RuntimeService_MigrateSingle_Handler,
		},
		{
			MethodName: "MigrateDelete",
			Handler:    _RuntimeService_MigrateDelete_Handler,
		},
		{
			MethodName: "Query",
			Handler:    _RuntimeService_Query_Handler,
		},
		{
			MethodName: "QueryDirect",
			Handler:    _RuntimeService_QueryDirect_Handler,
		},
		{
			MethodName: "MetricsViewMeta",
			Handler:    _RuntimeService_MetricsViewMeta_Handler,
		},
		{
			MethodName: "MetricsViewToplist",
			Handler:    _RuntimeService_MetricsViewToplist_Handler,
		},
		{
			MethodName: "MetricsViewTimeSeries",
			Handler:    _RuntimeService_MetricsViewTimeSeries_Handler,
		},
		{
			MethodName: "MetricsViewTotals",
			Handler:    _RuntimeService_MetricsViewTotals_Handler,
		},
		{
			MethodName: "GetTopK",
			Handler:    _RuntimeService_GetTopK_Handler,
		},
		{
			MethodName: "ListConnectors",
			Handler:    _RuntimeService_ListConnectors_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "runtime.proto",
}

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

Functions

func RegisterRuntimeServiceHandler 

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

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

func RegisterRuntimeServiceHandlerClient 

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

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

func RegisterRuntimeServiceHandlerFromEndpoint 

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

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

func RegisterRuntimeServiceHandlerServer 

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

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

func RegisterRuntimeServiceServer 

func RegisterRuntimeServiceServer(s grpc.ServiceRegistrar, srv RuntimeServiceServer)

Types

type CatalogObject 

type CatalogObject struct {

	// Types that are assignable to Type:
	//
	//	*CatalogObject_Source
	//	*CatalogObject_MetricsView
	//	*CatalogObject_UnmanagedTable
	Type        isCatalogObject_Type   `protobuf_oneof:"type"`
	RefreshedOn *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=refreshed_on,json=refreshedOn,proto3" json:"refreshed_on,omitempty"`
	// contains filtered or unexported fields
}

CatalogObject represents an object stored in the catalog

func (*CatalogObject) Descriptor deprecated 

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

Deprecated: Use CatalogObject.ProtoReflect.Descriptor instead.

func (*CatalogObject) GetMetricsView 

func (x *CatalogObject) GetMetricsView() *MetricsView

func (*CatalogObject) GetRefreshedOn added in v0.13.0 

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

func (*CatalogObject) GetSource 

func (x *CatalogObject) GetSource() *Source

func (*CatalogObject) GetType 

func (m *CatalogObject) GetType() isCatalogObject_Type

func (*CatalogObject) GetUnmanagedTable 

func (x *CatalogObject) GetUnmanagedTable() *UnmanagedTable

func (*CatalogObject) ProtoMessage 

func (*CatalogObject) ProtoMessage()

func (*CatalogObject) ProtoReflect 

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

func (*CatalogObject) Reset 

func (x *CatalogObject) Reset()

func (*CatalogObject) String 

func (x *CatalogObject) String() string

type CatalogObject_MetricsView 

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

type CatalogObject_Source 

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

type CatalogObject_UnmanagedTable 

type CatalogObject_UnmanagedTable struct {
	UnmanagedTable *UnmanagedTable `protobuf:"bytes,3,opt,name=unmanaged_table,json=unmanagedTable,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=runtime.v1.Connector_Property_Type" json:"type,omitempty"`
	// Nullable is true if the field is optional
	Nullable bool `protobuf:"varint,6,opt,name=nullable,proto3" json:"nullable,omitempty"`
	// Additional textual explanation for use in UIs
	Hint string `protobuf:"bytes,7,opt,name=hint,proto3" json:"hint,omitempty"`
	// Link to documentation for this property
	Href string `protobuf:"bytes,8,opt,name=href,proto3" json:"href,omitempty"`
	// contains filtered or unexported fields
}

Property represents one of the connector's config properties

func (*Connector_Property) Descriptor deprecated 

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

Deprecated: Use Connector_Property.ProtoReflect.Descriptor instead.

func (*Connector_Property) GetDescription 

func (x *Connector_Property) GetDescription() string

func (*Connector_Property) GetDisplayName 

func (x *Connector_Property) GetDisplayName() string

func (*Connector_Property) GetHint added in v0.13.0 

func (x *Connector_Property) GetHint() string

func (*Connector_Property) GetHref added in v0.13.0 

func (x *Connector_Property) GetHref() string

func (*Connector_Property) GetKey 

func (x *Connector_Property) GetKey() string

func (*Connector_Property) GetNullable 

func (x *Connector_Property) GetNullable() bool

func (*Connector_Property) GetPlaceholder 

func (x *Connector_Property) GetPlaceholder() string

func (*Connector_Property) GetType 

func (x *Connector_Property) GetType() Connector_Property_Type

func (*Connector_Property) ProtoMessage 

func (*Connector_Property) ProtoMessage()

func (*Connector_Property) ProtoReflect 

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

func (*Connector_Property) Reset 

func (x *Connector_Property) Reset()

func (*Connector_Property) String 

func (x *Connector_Property) String() string

type Connector_Property_Type 

type Connector_Property_Type int32

Type represents the field type 

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

func (Connector_Property_Type) Descriptor 

func (Connector_Property_Type) Descriptor() protoreflect.EnumDescriptor

func (Connector_Property_Type) Enum 

func (x Connector_Property_Type) Enum() *Connector_Property_Type

func (Connector_Property_Type) EnumDescriptor deprecated 

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

Deprecated: Use Connector_Property_Type.Descriptor instead.

func (Connector_Property_Type) Number 

func (x Connector_Property_Type) Number() protoreflect.EnumNumber

func (Connector_Property_Type) String 

func (x Connector_Property_Type) String() string

func (Connector_Property_Type) Type 

func (Connector_Property_Type) Type() protoreflect.EnumType

type CreateInstanceRequest 

type CreateInstanceRequest struct {

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

Request message for RuntimeService.CreateInstance

func (*CreateInstanceRequest) Descriptor deprecated 

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

Deprecated: Use CreateInstanceRequest.ProtoReflect.Descriptor instead.

func (*CreateInstanceRequest) GetDriver 

func (x *CreateInstanceRequest) GetDriver() string

func (*CreateInstanceRequest) GetDsn 

func (x *CreateInstanceRequest) GetDsn() string

func (*CreateInstanceRequest) GetEmbedCatalog 

func (x *CreateInstanceRequest) GetEmbedCatalog() bool

func (*CreateInstanceRequest) GetExposed 

func (x *CreateInstanceRequest) GetExposed() bool

func (*CreateInstanceRequest) GetObjectPrefix 

func (x *CreateInstanceRequest) GetObjectPrefix() string

func (*CreateInstanceRequest) ProtoMessage 

func (*CreateInstanceRequest) ProtoMessage()

func (*CreateInstanceRequest) ProtoReflect 

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

func (*CreateInstanceRequest) Reset 

func (x *CreateInstanceRequest) Reset()

func (*CreateInstanceRequest) String 

func (x *CreateInstanceRequest) String() string

type CreateInstanceResponse 

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

Response message for RuntimeService.CreateInstance

func (*CreateInstanceResponse) Descriptor deprecated 

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

Deprecated: Use CreateInstanceResponse.ProtoReflect.Descriptor instead.

func (*CreateInstanceResponse) GetInstance 

func (x *CreateInstanceResponse) GetInstance() *Instance

func (*CreateInstanceResponse) GetInstanceId 

func (x *CreateInstanceResponse) GetInstanceId() string

func (*CreateInstanceResponse) ProtoMessage 

func (*CreateInstanceResponse) ProtoMessage()

func (*CreateInstanceResponse) ProtoReflect 

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

func (*CreateInstanceResponse) Reset 

func (x *CreateInstanceResponse) Reset()

func (*CreateInstanceResponse) String 

func (x *CreateInstanceResponse) String() string

type CreateRepoRequest 

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

Request message for RuntimeService.CreateRepo

func (*CreateRepoRequest) Descriptor deprecated 

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

Deprecated: Use CreateRepoRequest.ProtoReflect.Descriptor instead.

func (*CreateRepoRequest) GetDriver 

func (x *CreateRepoRequest) GetDriver() string

func (*CreateRepoRequest) GetDsn 

func (x *CreateRepoRequest) GetDsn() string

func (*CreateRepoRequest) ProtoMessage 

func (*CreateRepoRequest) ProtoMessage()

func (*CreateRepoRequest) ProtoReflect 

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

func (*CreateRepoRequest) Reset 

func (x *CreateRepoRequest) Reset()

func (*CreateRepoRequest) String 

func (x *CreateRepoRequest) String() string

type CreateRepoResponse 

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

Response message for RuntimeService.CreateRepo

func (*CreateRepoResponse) Descriptor deprecated 

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

Deprecated: Use CreateRepoResponse.ProtoReflect.Descriptor instead.

func (*CreateRepoResponse) GetRepo 

func (x *CreateRepoResponse) GetRepo() *Repo

func (*CreateRepoResponse) ProtoMessage 

func (*CreateRepoResponse) ProtoMessage()

func (*CreateRepoResponse) ProtoReflect 

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

func (*CreateRepoResponse) Reset 

func (x *CreateRepoResponse) Reset()

func (*CreateRepoResponse) String 

func (x *CreateRepoResponse) String() string

type DeleteInstanceRequest 

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

Request message for RuntimeService.DeleteInstance

func (*DeleteInstanceRequest) Descriptor deprecated 

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

Deprecated: Use DeleteInstanceRequest.ProtoReflect.Descriptor instead.

func (*DeleteInstanceRequest) GetInstanceId 

func (x *DeleteInstanceRequest) GetInstanceId() string

func (*DeleteInstanceRequest) ProtoMessage 

func (*DeleteInstanceRequest) ProtoMessage()

func (*DeleteInstanceRequest) ProtoReflect 

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

func (*DeleteInstanceRequest) Reset 

func (x *DeleteInstanceRequest) Reset()

func (*DeleteInstanceRequest) String 

func (x *DeleteInstanceRequest) String() string

type DeleteInstanceResponse 

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

Response message for RuntimeService.DeleteInstance

func (*DeleteInstanceResponse) Descriptor deprecated 

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

Deprecated: Use DeleteInstanceResponse.ProtoReflect.Descriptor instead.

func (*DeleteInstanceResponse) ProtoMessage 

func (*DeleteInstanceResponse) ProtoMessage()

func (*DeleteInstanceResponse) ProtoReflect 

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

func (*DeleteInstanceResponse) Reset 

func (x *DeleteInstanceResponse) Reset()

func (*DeleteInstanceResponse) String 

func (x *DeleteInstanceResponse) String() string

type DeleteRepoRequest 

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

Request message for RuntimeService.DeleteRepo

func (*DeleteRepoRequest) Descriptor deprecated 

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

Deprecated: Use DeleteRepoRequest.ProtoReflect.Descriptor instead.

func (*DeleteRepoRequest) GetRepoId 

func (x *DeleteRepoRequest) GetRepoId() string

func (*DeleteRepoRequest) ProtoMessage 

func (*DeleteRepoRequest) ProtoMessage()

func (*DeleteRepoRequest) ProtoReflect 

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

func (*DeleteRepoRequest) Reset 

func (x *DeleteRepoRequest) Reset()

func (*DeleteRepoRequest) String 

func (x *DeleteRepoRequest) String() string

type DeleteRepoResponse 

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

Response message for RuntimeService.DeleteRepo

func (*DeleteRepoResponse) Descriptor deprecated 

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

Deprecated: Use DeleteRepoResponse.ProtoReflect.Descriptor instead.

func (*DeleteRepoResponse) ProtoMessage 

func (*DeleteRepoResponse) ProtoMessage()

func (*DeleteRepoResponse) ProtoReflect 

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

func (*DeleteRepoResponse) Reset 

func (x *DeleteRepoResponse) Reset()

func (*DeleteRepoResponse) String 

func (x *DeleteRepoResponse) String() string

type GetCatalogObjectRequest 

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

Request message for RuntimeService.GetCatalogObject

func (*GetCatalogObjectRequest) Descriptor deprecated 

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

Deprecated: Use GetCatalogObjectRequest.ProtoReflect.Descriptor instead.

func (*GetCatalogObjectRequest) GetInstanceId 

func (x *GetCatalogObjectRequest) GetInstanceId() string

func (*GetCatalogObjectRequest) GetName 

func (x *GetCatalogObjectRequest) GetName() string

func (*GetCatalogObjectRequest) ProtoMessage 

func (*GetCatalogObjectRequest) ProtoMessage()

func (*GetCatalogObjectRequest) ProtoReflect 

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

func (*GetCatalogObjectRequest) Reset 

func (x *GetCatalogObjectRequest) Reset()

func (*GetCatalogObjectRequest) String 

func (x *GetCatalogObjectRequest) String() string

type GetCatalogObjectResponse 

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

Response message for RuntimeService.GetCatalogObject

func (*GetCatalogObjectResponse) Descriptor deprecated 

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

Deprecated: Use GetCatalogObjectResponse.ProtoReflect.Descriptor instead.

func (*GetCatalogObjectResponse) GetObject 

func (x *GetCatalogObjectResponse) GetObject() *CatalogObject

func (*GetCatalogObjectResponse) ProtoMessage 

func (*GetCatalogObjectResponse) ProtoMessage()

func (*GetCatalogObjectResponse) ProtoReflect 

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

func (*GetCatalogObjectResponse) Reset 

func (x *GetCatalogObjectResponse) Reset()

func (*GetCatalogObjectResponse) String 

func (x *GetCatalogObjectResponse) String() string

type 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 GetRepoObjectRequest 

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

Request message for RuntimeService.GetRepoObjectRequest

func (*GetRepoObjectRequest) Descriptor deprecated 

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

Deprecated: Use GetRepoObjectRequest.ProtoReflect.Descriptor instead.

func (*GetRepoObjectRequest) GetPath 

func (x *GetRepoObjectRequest) GetPath() string

func (*GetRepoObjectRequest) GetRepoId 

func (x *GetRepoObjectRequest) GetRepoId() string

func (*GetRepoObjectRequest) ProtoMessage 

func (*GetRepoObjectRequest) ProtoMessage()

func (*GetRepoObjectRequest) ProtoReflect 

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

func (*GetRepoObjectRequest) Reset 

func (x *GetRepoObjectRequest) Reset()

func (*GetRepoObjectRequest) String 

func (x *GetRepoObjectRequest) String() string

type GetRepoObjectResponse 

type GetRepoObjectResponse struct {
	Blob string `protobuf:"bytes,1,opt,name=blob,proto3" json:"blob,omitempty"`
	// contains filtered or unexported fields
}

Reponse message for RuntimeService.GetRepoObjectResponse

func (*GetRepoObjectResponse) Descriptor deprecated 

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

Deprecated: Use GetRepoObjectResponse.ProtoReflect.Descriptor instead.

func (*GetRepoObjectResponse) GetBlob 

func (x *GetRepoObjectResponse) GetBlob() string

func (*GetRepoObjectResponse) ProtoMessage 

func (*GetRepoObjectResponse) ProtoMessage()

func (*GetRepoObjectResponse) ProtoReflect 

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

func (*GetRepoObjectResponse) Reset 

func (x *GetRepoObjectResponse) Reset()

func (*GetRepoObjectResponse) String 

func (x *GetRepoObjectResponse) String() string

type GetRepoRequest 

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

Request message for RuntimeService.GetRepo

func (*GetRepoRequest) Descriptor deprecated 

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

Deprecated: Use GetRepoRequest.ProtoReflect.Descriptor instead.

func (*GetRepoRequest) GetRepoId 

func (x *GetRepoRequest) GetRepoId() string

func (*GetRepoRequest) ProtoMessage 

func (*GetRepoRequest) ProtoMessage()

func (*GetRepoRequest) ProtoReflect 

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

func (*GetRepoRequest) Reset 

func (x *GetRepoRequest) Reset()

func (*GetRepoRequest) String 

func (x *GetRepoRequest) String() string

type GetRepoResponse 

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

Response message for RuntimeService.GetRepo

func (*GetRepoResponse) Descriptor deprecated 

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

Deprecated: Use GetRepoResponse.ProtoReflect.Descriptor instead.

func (*GetRepoResponse) GetRepo 

func (x *GetRepoResponse) GetRepo() *Repo

func (*GetRepoResponse) ProtoMessage 

func (*GetRepoResponse) ProtoMessage()

func (*GetRepoResponse) ProtoReflect 

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

func (*GetRepoResponse) Reset 

func (x *GetRepoResponse) Reset()

func (*GetRepoResponse) String 

func (x *GetRepoResponse) String() string

type Instance 

type Instance struct {

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

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

func (*Instance) Descriptor deprecated 

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

Deprecated: Use Instance.ProtoReflect.Descriptor instead.

func (*Instance) GetDriver 

func (x *Instance) GetDriver() string

func (*Instance) GetDsn 

func (x *Instance) GetDsn() string

func (*Instance) GetEmbedCatalog 

func (x *Instance) GetEmbedCatalog() bool

func (*Instance) GetExposed 

func (x *Instance) GetExposed() bool

func (*Instance) GetInstanceId 

func (x *Instance) GetInstanceId() string

func (*Instance) GetObjectPrefix 

func (x *Instance) GetObjectPrefix() string

func (*Instance) ProtoMessage 

func (*Instance) ProtoMessage()

func (*Instance) ProtoReflect 

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

func (*Instance) Reset 

func (x *Instance) Reset()

func (*Instance) String 

func (x *Instance) String() string

type ListCatalogObjectsRequest 

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

Request message for RuntimeService.ListCatalogObjects

func (*ListCatalogObjectsRequest) Descriptor deprecated 

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

Deprecated: Use ListCatalogObjectsRequest.ProtoReflect.Descriptor instead.

func (*ListCatalogObjectsRequest) GetInstanceId 

func (x *ListCatalogObjectsRequest) GetInstanceId() string

func (*ListCatalogObjectsRequest) ProtoMessage 

func (*ListCatalogObjectsRequest) ProtoMessage()

func (*ListCatalogObjectsRequest) ProtoReflect 

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

func (*ListCatalogObjectsRequest) Reset 

func (x *ListCatalogObjectsRequest) Reset()

func (*ListCatalogObjectsRequest) String 

func (x *ListCatalogObjectsRequest) String() string

type ListCatalogObjectsResponse 

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

Response message for RuntimeService.ListCatalogObjects

func (*ListCatalogObjectsResponse) Descriptor deprecated 

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

Deprecated: Use ListCatalogObjectsResponse.ProtoReflect.Descriptor instead.

func (*ListCatalogObjectsResponse) GetObjects 

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

func (*ListCatalogObjectsResponse) ProtoMessage 

func (*ListCatalogObjectsResponse) ProtoMessage()

func (*ListCatalogObjectsResponse) ProtoReflect 

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

func (*ListCatalogObjectsResponse) Reset 

func (x *ListCatalogObjectsResponse) Reset()

func (*ListCatalogObjectsResponse) String 

func (x *ListCatalogObjectsResponse) String() string

type ListConnectorsRequest 

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

Request message for RuntimeService.ListConnectors

func (*ListConnectorsRequest) Descriptor deprecated 

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

Deprecated: Use ListConnectorsRequest.ProtoReflect.Descriptor instead.

func (*ListConnectorsRequest) ProtoMessage 

func (*ListConnectorsRequest) ProtoMessage()

func (*ListConnectorsRequest) ProtoReflect 

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

func (*ListConnectorsRequest) Reset 

func (x *ListConnectorsRequest) Reset()

func (*ListConnectorsRequest) String 

func (x *ListConnectorsRequest) String() string

type ListConnectorsResponse 

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

Response message for RuntimeService.ListConnectors

func (*ListConnectorsResponse) Descriptor deprecated 

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

Deprecated: Use ListConnectorsResponse.ProtoReflect.Descriptor instead.

func (*ListConnectorsResponse) GetConnectors 

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

func (*ListConnectorsResponse) ProtoMessage 

func (*ListConnectorsResponse) ProtoMessage()

func (*ListConnectorsResponse) ProtoReflect 

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

func (*ListConnectorsResponse) Reset 

func (x *ListConnectorsResponse) Reset()

func (*ListConnectorsResponse) String 

func (x *ListConnectorsResponse) String() string

type 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 ListRepoObjectsRequest 

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

Request message for RuntimeService.ListRepoObjects

func (*ListRepoObjectsRequest) Descriptor deprecated 

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

Deprecated: Use ListRepoObjectsRequest.ProtoReflect.Descriptor instead.

func (*ListRepoObjectsRequest) GetRepoId 

func (x *ListRepoObjectsRequest) GetRepoId() string

func (*ListRepoObjectsRequest) ProtoMessage 

func (*ListRepoObjectsRequest) ProtoMessage()

func (*ListRepoObjectsRequest) ProtoReflect 

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

func (*ListRepoObjectsRequest) Reset 

func (x *ListRepoObjectsRequest) Reset()

func (*ListRepoObjectsRequest) String 

func (x *ListRepoObjectsRequest) String() string

type ListRepoObjectsResponse 

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

Response message for RuntimeService.ListRepoObjects

func (*ListRepoObjectsResponse) Descriptor deprecated 

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

Deprecated: Use ListRepoObjectsResponse.ProtoReflect.Descriptor instead.

func (*ListRepoObjectsResponse) GetPaths 

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

func (*ListRepoObjectsResponse) ProtoMessage 

func (*ListRepoObjectsResponse) ProtoMessage()

func (*ListRepoObjectsResponse) ProtoReflect 

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

func (*ListRepoObjectsResponse) Reset 

func (x *ListRepoObjectsResponse) Reset()

func (*ListRepoObjectsResponse) String 

func (x *ListRepoObjectsResponse) String() string

type ListReposRequest 

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

Request message for RuntimeService.ListRepos

func (*ListReposRequest) Descriptor deprecated 

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

Deprecated: Use ListReposRequest.ProtoReflect.Descriptor instead.

func (*ListReposRequest) GetPageSize 

func (x *ListReposRequest) GetPageSize() int32

func (*ListReposRequest) GetPageToken 

func (x *ListReposRequest) GetPageToken() string

func (*ListReposRequest) ProtoMessage 

func (*ListReposRequest) ProtoMessage()

func (*ListReposRequest) ProtoReflect 

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

func (*ListReposRequest) Reset 

func (x *ListReposRequest) Reset()

func (*ListReposRequest) String 

func (x *ListReposRequest) String() string

type ListReposResponse 

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

Response message for RuntimeService.ListRepos

func (*ListReposResponse) Descriptor deprecated 

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

Deprecated: Use ListReposResponse.ProtoReflect.Descriptor instead.

func (*ListReposResponse) GetNextPageToken 

func (x *ListReposResponse) GetNextPageToken() string

func (*ListReposResponse) GetRepos 

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

func (*ListReposResponse) ProtoMessage 

func (*ListReposResponse) ProtoMessage()

func (*ListReposResponse) ProtoReflect 

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

func (*ListReposResponse) Reset 

func (x *ListReposResponse) Reset()

func (*ListReposResponse) String 

func (x *ListReposResponse) String() string

type MetricsView 

type MetricsView struct {

	// Formatted SQL DDL for the metrics view
	Sql string `protobuf:"bytes,1,opt,name=sql,proto3" json:"sql,omitempty"`
	// Name of the metrics view
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// Name of the source or model that the metrics view is based on
	FromObject string `protobuf:"bytes,3,opt,name=from_object,json=fromObject,proto3" json:"from_object,omitempty"`
	// Dimensions in the metrics view
	Dimensions []*MetricsView_Dimension `protobuf:"bytes,4,rep,name=dimensions,proto3" json:"dimensions,omitempty"`
	// Measures in the metrics view
	Measures []*MetricsView_Measure `protobuf:"bytes,5,rep,name=measures,proto3" json:"measures,omitempty"`
	// contains filtered or unexported fields
}

MetricsView represents a catalog object created using CREATE METRICS VIEW

func (*MetricsView) Descriptor deprecated 

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

Deprecated: Use MetricsView.ProtoReflect.Descriptor instead.

func (*MetricsView) GetDimensions 

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

func (*MetricsView) GetFromObject 

func (x *MetricsView) GetFromObject() string

func (*MetricsView) GetMeasures 

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

func (*MetricsView) GetName 

func (x *MetricsView) GetName() string

func (*MetricsView) GetSql 

func (x *MetricsView) GetSql() 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 MetricsViewFilter 

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

Filter clause for metrics view requests

func (*MetricsViewFilter) Descriptor deprecated 

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

Deprecated: Use MetricsViewFilter.ProtoReflect.Descriptor instead.

func (*MetricsViewFilter) GetExclude 

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

func (*MetricsViewFilter) GetInclude 

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

func (*MetricsViewFilter) GetMatch 

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

func (*MetricsViewFilter) ProtoMessage 

func (*MetricsViewFilter) ProtoMessage()

func (*MetricsViewFilter) ProtoReflect 

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

func (*MetricsViewFilter) Reset 

func (x *MetricsViewFilter) Reset()

func (*MetricsViewFilter) String 

func (x *MetricsViewFilter) String() string

type MetricsViewFilter_Cond 

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

func (*MetricsViewFilter_Cond) Descriptor deprecated 

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

Deprecated: Use MetricsViewFilter_Cond.ProtoReflect.Descriptor instead.

func (*MetricsViewFilter_Cond) GetIn 

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

func (*MetricsViewFilter_Cond) GetLike 

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

func (*MetricsViewFilter_Cond) GetName 

func (x *MetricsViewFilter_Cond) GetName() string

func (*MetricsViewFilter_Cond) ProtoMessage 

func (*MetricsViewFilter_Cond) ProtoMessage()

func (*MetricsViewFilter_Cond) ProtoReflect 

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

func (*MetricsViewFilter_Cond) Reset 

func (x *MetricsViewFilter_Cond) Reset()

func (*MetricsViewFilter_Cond) String 

func (x *MetricsViewFilter_Cond) String() string

type MetricsViewMetaRequest 

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

Request message for RuntimeService.MetricsViewMeta

func (*MetricsViewMetaRequest) Descriptor deprecated 

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

Deprecated: Use MetricsViewMetaRequest.ProtoReflect.Descriptor instead.

func (*MetricsViewMetaRequest) GetInstanceId 

func (x *MetricsViewMetaRequest) GetInstanceId() string

func (*MetricsViewMetaRequest) GetMetricsViewName 

func (x *MetricsViewMetaRequest) GetMetricsViewName() string

func (*MetricsViewMetaRequest) ProtoMessage 

func (*MetricsViewMetaRequest) ProtoMessage()

func (*MetricsViewMetaRequest) ProtoReflect 

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

func (*MetricsViewMetaRequest) Reset 

func (x *MetricsViewMetaRequest) Reset()

func (*MetricsViewMetaRequest) String 

func (x *MetricsViewMetaRequest) String() string

type MetricsViewMetaResponse 

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

Response message for RuntimeService.MetricsViewMeta

func (*MetricsViewMetaResponse) Descriptor deprecated 

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

Deprecated: Use MetricsViewMetaResponse.ProtoReflect.Descriptor instead.

func (*MetricsViewMetaResponse) GetDimensions 

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

func (*MetricsViewMetaResponse) GetFromObject 

func (x *MetricsViewMetaResponse) GetFromObject() string

func (*MetricsViewMetaResponse) GetMeasures 

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

func (*MetricsViewMetaResponse) GetMetricsViewName 

func (x *MetricsViewMetaResponse) GetMetricsViewName() string

func (*MetricsViewMetaResponse) ProtoMessage 

func (*MetricsViewMetaResponse) ProtoMessage()

func (*MetricsViewMetaResponse) ProtoReflect 

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

func (*MetricsViewMetaResponse) Reset 

func (x *MetricsViewMetaResponse) Reset()

func (*MetricsViewMetaResponse) String 

func (x *MetricsViewMetaResponse) String() string

type 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       int64              `protobuf:"varint,4,opt,name=time_start,json=timeStart,proto3" json:"time_start,omitempty"`
	TimeEnd         int64              `protobuf:"varint,5,opt,name=time_end,json=timeEnd,proto3" json:"time_end,omitempty"`
	TimeGranularity string             `protobuf:"bytes,6,opt,name=time_granularity,json=timeGranularity,proto3" json:"time_granularity,omitempty"`
	Filter          *MetricsViewFilter `protobuf:"bytes,7,opt,name=filter,proto3" json:"filter,omitempty"`
	// contains filtered or unexported fields
}

Request message for RuntimeService.MetricsViewTimeSeries

func (*MetricsViewTimeSeriesRequest) Descriptor deprecated 

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

Deprecated: Use MetricsViewTimeSeriesRequest.ProtoReflect.Descriptor instead.

func (*MetricsViewTimeSeriesRequest) GetFilter 

func (x *MetricsViewTimeSeriesRequest) GetFilter() *MetricsViewFilter

func (*MetricsViewTimeSeriesRequest) GetInstanceId 

func (x *MetricsViewTimeSeriesRequest) GetInstanceId() string

func (*MetricsViewTimeSeriesRequest) GetMeasureNames 

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

func (*MetricsViewTimeSeriesRequest) GetMetricsViewName 

func (x *MetricsViewTimeSeriesRequest) GetMetricsViewName() string

func (*MetricsViewTimeSeriesRequest) GetTimeEnd 

func (x *MetricsViewTimeSeriesRequest) GetTimeEnd() int64

func (*MetricsViewTimeSeriesRequest) GetTimeGranularity 

func (x *MetricsViewTimeSeriesRequest) GetTimeGranularity() string

func (*MetricsViewTimeSeriesRequest) GetTimeStart 

func (x *MetricsViewTimeSeriesRequest) GetTimeStart() int64

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 []*SchemaColumn    `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() []*SchemaColumn

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       int64              `protobuf:"varint,5,opt,name=time_start,json=timeStart,proto3" json:"time_start,omitempty"`
	TimeEnd         int64              `protobuf:"varint,6,opt,name=time_end,json=timeEnd,proto3" json:"time_end,omitempty"`
	Limit           int64              `protobuf:"varint,7,opt,name=limit,proto3" json:"limit,omitempty"`
	Offset          int64              `protobuf:"varint,8,opt,name=offset,proto3" json:"offset,omitempty"`
	Sort            []*MetricsViewSort `protobuf:"bytes,9,rep,name=sort,proto3" json:"sort,omitempty"`
	Filter          *MetricsViewFilter `protobuf:"bytes,10,opt,name=filter,proto3" json:"filter,omitempty"`
	// contains filtered or unexported fields
}

Request message for RuntimeService.MetricsViewToplist

func (*MetricsViewToplistRequest) Descriptor deprecated 

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

Deprecated: Use MetricsViewToplistRequest.ProtoReflect.Descriptor instead.

func (*MetricsViewToplistRequest) GetDimensionName 

func (x *MetricsViewToplistRequest) GetDimensionName() string

func (*MetricsViewToplistRequest) GetFilter 

func (x *MetricsViewToplistRequest) GetFilter() *MetricsViewFilter

func (*MetricsViewToplistRequest) GetInstanceId 

func (x *MetricsViewToplistRequest) GetInstanceId() string

func (*MetricsViewToplistRequest) GetLimit 

func (x *MetricsViewToplistRequest) GetLimit() int64

func (*MetricsViewToplistRequest) GetMeasureNames 

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

func (*MetricsViewToplistRequest) GetMetricsViewName 

func (x *MetricsViewToplistRequest) GetMetricsViewName() string

func (*MetricsViewToplistRequest) GetOffset 

func (x *MetricsViewToplistRequest) GetOffset() int64

func (*MetricsViewToplistRequest) GetSort 

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

func (*MetricsViewToplistRequest) GetTimeEnd 

func (x *MetricsViewToplistRequest) GetTimeEnd() int64

func (*MetricsViewToplistRequest) GetTimeStart 

func (x *MetricsViewToplistRequest) GetTimeStart() int64

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 []*SchemaColumn    `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() []*SchemaColumn

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       int64              `protobuf:"varint,4,opt,name=time_start,json=timeStart,proto3" json:"time_start,omitempty"`
	TimeEnd         int64              `protobuf:"varint,5,opt,name=time_end,json=timeEnd,proto3" json:"time_end,omitempty"`
	Filter          *MetricsViewFilter `protobuf:"bytes,7,opt,name=filter,proto3" json:"filter,omitempty"`
	// contains filtered or unexported fields
}

Request message for RuntimeService.MetricsViewTotals

func (*MetricsViewTotalsRequest) Descriptor deprecated 

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

Deprecated: Use MetricsViewTotalsRequest.ProtoReflect.Descriptor instead.

func (*MetricsViewTotalsRequest) GetFilter 

func (x *MetricsViewTotalsRequest) GetFilter() *MetricsViewFilter

func (*MetricsViewTotalsRequest) GetInstanceId 

func (x *MetricsViewTotalsRequest) GetInstanceId() string

func (*MetricsViewTotalsRequest) GetMeasureNames 

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

func (*MetricsViewTotalsRequest) GetMetricsViewName 

func (x *MetricsViewTotalsRequest) GetMetricsViewName() string

func (*MetricsViewTotalsRequest) GetTimeEnd 

func (x *MetricsViewTotalsRequest) GetTimeEnd() int64

func (*MetricsViewTotalsRequest) GetTimeStart 

func (x *MetricsViewTotalsRequest) GetTimeStart() int64

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 []*SchemaColumn  `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() []*SchemaColumn

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"`
	Type        string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	PrimaryTime bool   `protobuf:"varint,3,opt,name=primary_time,json=primaryTime,proto3" json:"primary_time,omitempty"`
	Description string `protobuf:"bytes,4,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) GetName 

func (x *MetricsView_Dimension) GetName() string

func (*MetricsView_Dimension) GetPrimaryTime 

func (x *MetricsView_Dimension) GetPrimaryTime() bool

func (*MetricsView_Dimension) GetType 

func (x *MetricsView_Dimension) GetType() 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"`
	Type        string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	Description string `protobuf:"bytes,3,opt,name=description,proto3" json:"description,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) GetName 

func (x *MetricsView_Measure) GetName() string

func (*MetricsView_Measure) GetType 

func (x *MetricsView_Measure) GetType() string

func (*MetricsView_Measure) ProtoMessage 

func (*MetricsView_Measure) ProtoMessage()

func (*MetricsView_Measure) ProtoReflect 

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

func (*MetricsView_Measure) Reset 

func (x *MetricsView_Measure) Reset()

func (*MetricsView_Measure) String 

func (x *MetricsView_Measure) String() string

type MigrateDeleteRequest 

type MigrateDeleteRequest struct {

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

Request message for RuntimeService.MigrateDelete

func (*MigrateDeleteRequest) Descriptor deprecated 

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

Deprecated: Use MigrateDeleteRequest.ProtoReflect.Descriptor instead.

func (*MigrateDeleteRequest) GetInstanceId 

func (x *MigrateDeleteRequest) GetInstanceId() string

func (*MigrateDeleteRequest) GetName 

func (x *MigrateDeleteRequest) GetName() string

func (*MigrateDeleteRequest) ProtoMessage 

func (*MigrateDeleteRequest) ProtoMessage()

func (*MigrateDeleteRequest) ProtoReflect 

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

func (*MigrateDeleteRequest) Reset 

func (x *MigrateDeleteRequest) Reset()

func (*MigrateDeleteRequest) String 

func (x *MigrateDeleteRequest) String() string

type MigrateDeleteResponse 

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

Response message for RuntimeService.MigrateDelete

func (*MigrateDeleteResponse) Descriptor deprecated 

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

Deprecated: Use MigrateDeleteResponse.ProtoReflect.Descriptor instead.

func (*MigrateDeleteResponse) ProtoMessage 

func (*MigrateDeleteResponse) ProtoMessage()

func (*MigrateDeleteResponse) ProtoReflect 

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

func (*MigrateDeleteResponse) Reset 

func (x *MigrateDeleteResponse) Reset()

func (*MigrateDeleteResponse) String 

func (x *MigrateDeleteResponse) String() string

type MigrateRequest 

type MigrateRequest struct {

	// Instance to migrate
	InstanceId string `protobuf:"bytes,1,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"`
	// Contents of files containing one or more SQL DDL statements
	Blobs []string `protobuf:"bytes,2,rep,name=blobs,proto3" json:"blobs,omitempty"`
	// If true, all catalog objects not present in blobs (except for unmanaged tables) will be deleted
	DropDeleted bool `protobuf:"varint,3,opt,name=drop_deleted,json=dropDeleted,proto3" json:"drop_deleted,omitempty"`
	// If true, will validate the SQL, but not actually execute the migrations
	DryRun bool `protobuf:"varint,4,opt,name=dry_run,json=dryRun,proto3" json:"dry_run,omitempty"`
	// contains filtered or unexported fields
}

Request message for RuntimeService.Migrate

func (*MigrateRequest) Descriptor deprecated 

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

Deprecated: Use MigrateRequest.ProtoReflect.Descriptor instead.

func (*MigrateRequest) GetBlobs 

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

func (*MigrateRequest) GetDropDeleted 

func (x *MigrateRequest) GetDropDeleted() bool

func (*MigrateRequest) GetDryRun 

func (x *MigrateRequest) GetDryRun() bool

func (*MigrateRequest) GetInstanceId 

func (x *MigrateRequest) GetInstanceId() string

func (*MigrateRequest) ProtoMessage 

func (*MigrateRequest) ProtoMessage()

func (*MigrateRequest) ProtoReflect 

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

func (*MigrateRequest) Reset 

func (x *MigrateRequest) Reset()

func (*MigrateRequest) String 

func (x *MigrateRequest) String() string

type MigrateResponse 

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

Response message for RuntimeService.Migrate

func (*MigrateResponse) Descriptor deprecated 

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

Deprecated: Use MigrateResponse.ProtoReflect.Descriptor instead.

func (*MigrateResponse) ProtoMessage 

func (*MigrateResponse) ProtoMessage()

func (*MigrateResponse) ProtoReflect 

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

func (*MigrateResponse) Reset 

func (x *MigrateResponse) Reset()

func (*MigrateResponse) String 

func (x *MigrateResponse) String() string

type MigrateSingleRequest 

type MigrateSingleRequest struct {

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

Request message for RuntimeService.MigrateSingle

func (*MigrateSingleRequest) Descriptor deprecated 

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

Deprecated: Use MigrateSingleRequest.ProtoReflect.Descriptor instead.

func (*MigrateSingleRequest) GetCreateOrReplace 

func (x *MigrateSingleRequest) GetCreateOrReplace() bool

func (*MigrateSingleRequest) GetDryRun 

func (x *MigrateSingleRequest) GetDryRun() bool

func (*MigrateSingleRequest) GetInstanceId 

func (x *MigrateSingleRequest) GetInstanceId() string

func (*MigrateSingleRequest) GetRenameFrom added in v0.13.0 

func (x *MigrateSingleRequest) GetRenameFrom() string

func (*MigrateSingleRequest) GetSql 

func (x *MigrateSingleRequest) GetSql() string

func (*MigrateSingleRequest) ProtoMessage 

func (*MigrateSingleRequest) ProtoMessage()

func (*MigrateSingleRequest) ProtoReflect 

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

func (*MigrateSingleRequest) Reset 

func (x *MigrateSingleRequest) Reset()

func (*MigrateSingleRequest) String 

func (x *MigrateSingleRequest) String() string

type MigrateSingleResponse 

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

Response message for RuntimeService.MigrateSingle

func (*MigrateSingleResponse) Descriptor deprecated 

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

Deprecated: Use MigrateSingleResponse.ProtoReflect.Descriptor instead.

func (*MigrateSingleResponse) ProtoMessage 

func (*MigrateSingleResponse) ProtoMessage()

func (*MigrateSingleResponse) ProtoReflect 

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

func (*MigrateSingleResponse) Reset 

func (x *MigrateSingleResponse) Reset()

func (*MigrateSingleResponse) String 

func (x *MigrateSingleResponse) String() string

type 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 PutRepoObjectRequest 

type PutRepoObjectRequest struct {
	RepoId string `protobuf:"bytes,1,opt,name=repo_id,json=repoId,proto3" json:"repo_id,omitempty"`
	Path   string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	Blob   string `protobuf:"bytes,3,opt,name=blob,proto3" json:"blob,omitempty"`
	Delete bool   `protobuf:"varint,4,opt,name=delete,proto3" json:"delete,omitempty"`
	// contains filtered or unexported fields
}

Request message for RuntimeService.PutRepoObjectRequest

func (*PutRepoObjectRequest) Descriptor deprecated 

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

Deprecated: Use PutRepoObjectRequest.ProtoReflect.Descriptor instead.

func (*PutRepoObjectRequest) GetBlob 

func (x *PutRepoObjectRequest) GetBlob() string

func (*PutRepoObjectRequest) GetDelete 

func (x *PutRepoObjectRequest) GetDelete() bool

func (*PutRepoObjectRequest) GetPath 

func (x *PutRepoObjectRequest) GetPath() string

func (*PutRepoObjectRequest) GetRepoId 

func (x *PutRepoObjectRequest) GetRepoId() string

func (*PutRepoObjectRequest) ProtoMessage 

func (*PutRepoObjectRequest) ProtoMessage()

func (*PutRepoObjectRequest) ProtoReflect 

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

func (*PutRepoObjectRequest) Reset 

func (x *PutRepoObjectRequest) Reset()

func (*PutRepoObjectRequest) String 

func (x *PutRepoObjectRequest) String() string

type PutRepoObjectResponse 

type PutRepoObjectResponse struct {
	FilePath string `protobuf:"bytes,1,opt,name=file_path,json=filePath,proto3" json:"file_path,omitempty"`
	// contains filtered or unexported fields
}

Response message for RuntimeService.PutRepoObjectRequest

func (*PutRepoObjectResponse) Descriptor deprecated 

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

Deprecated: Use PutRepoObjectResponse.ProtoReflect.Descriptor instead.

func (*PutRepoObjectResponse) GetFilePath added in v0.13.0 

func (x *PutRepoObjectResponse) GetFilePath() string

func (*PutRepoObjectResponse) ProtoMessage 

func (*PutRepoObjectResponse) ProtoMessage()

func (*PutRepoObjectResponse) ProtoReflect 

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

func (*PutRepoObjectResponse) Reset 

func (x *PutRepoObjectResponse) Reset()

func (*PutRepoObjectResponse) String 

func (x *PutRepoObjectResponse) String() string

type QueryDirectRequest 

type QueryDirectRequest struct {

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

Request message for RuntimeService.QueryDirect

func (*QueryDirectRequest) Descriptor deprecated 

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

Deprecated: Use QueryDirectRequest.ProtoReflect.Descriptor instead.

func (*QueryDirectRequest) GetArgs 

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

func (*QueryDirectRequest) GetDryRun 

func (x *QueryDirectRequest) GetDryRun() bool

func (*QueryDirectRequest) GetInstanceId 

func (x *QueryDirectRequest) GetInstanceId() string

func (*QueryDirectRequest) GetPriority 

func (x *QueryDirectRequest) GetPriority() int64

func (*QueryDirectRequest) GetSql 

func (x *QueryDirectRequest) GetSql() string

func (*QueryDirectRequest) ProtoMessage 

func (*QueryDirectRequest) ProtoMessage()

func (*QueryDirectRequest) ProtoReflect 

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

func (*QueryDirectRequest) Reset 

func (x *QueryDirectRequest) Reset()

func (*QueryDirectRequest) String 

func (x *QueryDirectRequest) String() string

type QueryDirectResponse 

type QueryDirectResponse struct {

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

Response message for RuntimeService.QueryDirect

func (*QueryDirectResponse) Descriptor deprecated 

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

Deprecated: Use QueryDirectResponse.ProtoReflect.Descriptor instead.

func (*QueryDirectResponse) GetData 

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

func (*QueryDirectResponse) GetMeta 

func (x *QueryDirectResponse) GetMeta() []*SchemaColumn

func (*QueryDirectResponse) ProtoMessage 

func (*QueryDirectResponse) ProtoMessage()

func (*QueryDirectResponse) ProtoReflect 

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

func (*QueryDirectResponse) Reset 

func (x *QueryDirectResponse) Reset()

func (*QueryDirectResponse) String 

func (x *QueryDirectResponse) String() string

type QueryRequest 

type QueryRequest struct {

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

Request message for RuntimeService.Query

func (*QueryRequest) Descriptor deprecated 

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

Deprecated: Use QueryRequest.ProtoReflect.Descriptor instead.

func (*QueryRequest) GetArgs 

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

func (*QueryRequest) GetDryRun 

func (x *QueryRequest) GetDryRun() bool

func (*QueryRequest) GetInstanceId 

func (x *QueryRequest) GetInstanceId() string

func (*QueryRequest) GetPriority 

func (x *QueryRequest) GetPriority() int64

func (*QueryRequest) GetSql 

func (x *QueryRequest) GetSql() string

func (*QueryRequest) ProtoMessage 

func (*QueryRequest) ProtoMessage()

func (*QueryRequest) ProtoReflect 

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

func (*QueryRequest) Reset 

func (x *QueryRequest) Reset()

func (*QueryRequest) String 

func (x *QueryRequest) String() string

type QueryResponse 

type QueryResponse struct {

	// Schema of result data
	Meta []*SchemaColumn `protobuf:"bytes,1,rep,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() []*SchemaColumn

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 Repo 

type Repo struct {

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

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

func (*Repo) Descriptor deprecated 

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

Deprecated: Use Repo.ProtoReflect.Descriptor instead.

func (*Repo) GetDriver 

func (x *Repo) GetDriver() string

func (*Repo) GetDsn 

func (x *Repo) GetDsn() string

func (*Repo) GetRepoId 

func (x *Repo) GetRepoId() string

func (*Repo) ProtoMessage 

func (*Repo) ProtoMessage()

func (*Repo) ProtoReflect 

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

func (*Repo) Reset 

func (x *Repo) Reset()

func (*Repo) String 

func (x *Repo) String() string

type RuntimeServiceClient 

type RuntimeServiceClient interface {
	// Ping returns information about the runtime
	Ping(ctx context.Context, in *PingRequest, opts ...grpc.CallOption) (*PingResponse, error)
	// ListRepos lists all the repos currently managed by the runtime
	ListRepos(ctx context.Context, in *ListReposRequest, opts ...grpc.CallOption) (*ListReposResponse, error)
	// GetRepo returns info about a specific repo
	GetRepo(ctx context.Context, in *GetRepoRequest, opts ...grpc.CallOption) (*GetRepoResponse, error)
	// CreateRepo creates a new repo. See the Repo message for an explanation of repos.
	CreateRepo(ctx context.Context, in *CreateRepoRequest, opts ...grpc.CallOption) (*CreateRepoResponse, error)
	// DeleteRepo deletes a repo
	DeleteRepo(ctx context.Context, in *DeleteRepoRequest, opts ...grpc.CallOption) (*DeleteRepoResponse, error)
	// ListRepoObjects lists all the objects (files) in a repo sorted by full path.
	// It includes objects in nested "directories".
	ListRepoObjects(ctx context.Context, in *ListRepoObjectsRequest, opts ...grpc.CallOption) (*ListRepoObjectsResponse, error)
	// GetRepoObject returns the contents of a specific object (file) in a repo.
	GetRepoObject(ctx context.Context, in *GetRepoObjectRequest, opts ...grpc.CallOption) (*GetRepoObjectResponse, error)
	// PutRepoObject can be used to create, update, or delete an object (file) in a repo
	PutRepoObject(ctx context.Context, in *PutRepoObjectRequest, opts ...grpc.CallOption) (*PutRepoObjectResponse, error)
	// ListInstances lists all the instances currently managed by the runtime
	ListInstances(ctx context.Context, in *ListInstancesRequest, opts ...grpc.CallOption) (*ListInstancesResponse, error)
	// GetInstance returns information about a specific instance
	GetInstance(ctx context.Context, in *GetInstanceRequest, opts ...grpc.CallOption) (*GetInstanceResponse, error)
	// CreateInstance creates a new instance
	CreateInstance(ctx context.Context, in *CreateInstanceRequest, opts ...grpc.CallOption) (*CreateInstanceResponse, error)
	// DeleteInstance deletes an instance
	DeleteInstance(ctx context.Context, in *DeleteInstanceRequest, opts ...grpc.CallOption) (*DeleteInstanceResponse, error)
	// ListCatalogObjects lists all the objects (like tables, sources or metrics views) registered in an instance's catalog
	ListCatalogObjects(ctx context.Context, in *ListCatalogObjectsRequest, opts ...grpc.CallOption) (*ListCatalogObjectsResponse, error)
	// GetCatalogObject returns information about a specific object in the catalog
	GetCatalogObject(ctx context.Context, in *GetCatalogObjectRequest, opts ...grpc.CallOption) (*GetCatalogObjectResponse, error)
	// TriggerRefresh triggers a refresh of a refreshable catalog object.
	// It currently only supports sources (which will be re-ingested), but will also support materialized models in the future.
	// It does not respond until the refresh has completed (will move to async jobs when the task scheduler is in place).
	TriggerRefresh(ctx context.Context, in *TriggerRefreshRequest, opts ...grpc.CallOption) (*TriggerRefreshResponse, error)
	// Migrate applies a full set of SQL artifacts (files containing CREATE statements) to the catalog/infra.
	// It attempts to infer a minimal number of migrations to apply to reconcile the current state with
	// the desired state expressed in the artifacts. Any existing objects not described in the submitted
	// artifacts will be deleted.
	Migrate(ctx context.Context, in *MigrateRequest, opts ...grpc.CallOption) (*MigrateResponse, error)
	// MigrateSingle applies a single `CREATE` statement.
	// It bypasses the reconciling migrations described in Migrate.
	// We aim to deprecate this function once reconciling migrations are mature and adopted in the modeller.
	MigrateSingle(ctx context.Context, in *MigrateSingleRequest, opts ...grpc.CallOption) (*MigrateSingleResponse, error)
	// MigrateDelete deletes a single object.
	// It bypasses the reconciling migrations described in Migrate.
	// We aim to deprecate this function once reconciling migrations are mature and adopted in the modeller.
	MigrateDelete(ctx context.Context, in *MigrateDeleteRequest, opts ...grpc.CallOption) (*MigrateDeleteResponse, error)
	// Query runs a Rill SQL query by transpiling it and proxying it to the instance's OLAP datastore.
	Query(ctx context.Context, in *QueryRequest, opts ...grpc.CallOption) (*QueryResponse, error)
	// QueryDirect runs a SQL query by directly executing it against the instance's OLAP datastore.
	// It bypasses Rill SQL and expects the query to use the underlying dialect.
	QueryDirect(ctx context.Context, in *QueryDirectRequest, opts ...grpc.CallOption) (*QueryDirectResponse, error)
	// MetricsViewMeta returns metadata about a metrics view.
	// It's comparable to calling GetCatalogObject and will be deprecated in the future.
	MetricsViewMeta(ctx context.Context, in *MetricsViewMetaRequest, opts ...grpc.CallOption) (*MetricsViewMetaResponse, error)
	// MetricsViewToplist returns the top dimension values of a metrics view sorted by one or more measures.
	// It's a convenience API for querying a metrics view.
	MetricsViewToplist(ctx context.Context, in *MetricsViewToplistRequest, opts ...grpc.CallOption) (*MetricsViewToplistResponse, error)
	// MetricsViewTimeSeries returns time series for the measures in the metrics view.
	// It's a convenience API for querying a metrics view.
	MetricsViewTimeSeries(ctx context.Context, in *MetricsViewTimeSeriesRequest, opts ...grpc.CallOption) (*MetricsViewTimeSeriesResponse, error)
	// MetricsViewTotals returns totals over a time period for the measures in a metrics view.
	// It's a convenience API for querying a metrics view.
	MetricsViewTotals(ctx context.Context, in *MetricsViewTotalsRequest, opts ...grpc.CallOption) (*MetricsViewTotalsResponse, error)
	// Get TopK elements from a table for a column given an agg function
	// agg function and k are optional, defaults are count(*) and 50 respectively
	GetTopK(ctx context.Context, in *TopKRequest, opts ...grpc.CallOption) (*TopKResponse, error)
	// ListConnectors returns a description of all the connectors implemented in the runtime,
	// including their schema and validation rules
	ListConnectors(ctx context.Context, in *ListConnectorsRequest, opts ...grpc.CallOption) (*ListConnectorsResponse, error)
}

RuntimeServiceClient is the client API for RuntimeService service.

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

func NewRuntimeServiceClient 

func NewRuntimeServiceClient(cc grpc.ClientConnInterface) RuntimeServiceClient

type RuntimeServiceServer 

type RuntimeServiceServer interface {
	// Ping returns information about the runtime
	Ping(context.Context, *PingRequest) (*PingResponse, error)
	// ListRepos lists all the repos currently managed by the runtime
	ListRepos(context.Context, *ListReposRequest) (*ListReposResponse, error)
	// GetRepo returns info about a specific repo
	GetRepo(context.Context, *GetRepoRequest) (*GetRepoResponse, error)
	// CreateRepo creates a new repo. See the Repo message for an explanation of repos.
	CreateRepo(context.Context, *CreateRepoRequest) (*CreateRepoResponse, error)
	// DeleteRepo deletes a repo
	DeleteRepo(context.Context, *DeleteRepoRequest) (*DeleteRepoResponse, error)
	// ListRepoObjects lists all the objects (files) in a repo sorted by full path.
	// It includes objects in nested "directories".
	ListRepoObjects(context.Context, *ListRepoObjectsRequest) (*ListRepoObjectsResponse, error)
	// GetRepoObject returns the contents of a specific object (file) in a repo.
	GetRepoObject(context.Context, *GetRepoObjectRequest) (*GetRepoObjectResponse, error)
	// PutRepoObject can be used to create, update, or delete an object (file) in a repo
	PutRepoObject(context.Context, *PutRepoObjectRequest) (*PutRepoObjectResponse, error)
	// ListInstances lists all the instances currently managed by the runtime
	ListInstances(context.Context, *ListInstancesRequest) (*ListInstancesResponse, error)
	// GetInstance returns information about a specific instance
	GetInstance(context.Context, *GetInstanceRequest) (*GetInstanceResponse, error)
	// CreateInstance creates a new instance
	CreateInstance(context.Context, *CreateInstanceRequest) (*CreateInstanceResponse, error)
	// DeleteInstance deletes an instance
	DeleteInstance(context.Context, *DeleteInstanceRequest) (*DeleteInstanceResponse, error)
	// ListCatalogObjects lists all the objects (like tables, sources or metrics views) registered in an instance's catalog
	ListCatalogObjects(context.Context, *ListCatalogObjectsRequest) (*ListCatalogObjectsResponse, error)
	// GetCatalogObject returns information about a specific object in the catalog
	GetCatalogObject(context.Context, *GetCatalogObjectRequest) (*GetCatalogObjectResponse, error)
	// TriggerRefresh triggers a refresh of a refreshable catalog object.
	// It currently only supports sources (which will be re-ingested), but will also support materialized models in the future.
	// It does not respond until the refresh has completed (will move to async jobs when the task scheduler is in place).
	TriggerRefresh(context.Context, *TriggerRefreshRequest) (*TriggerRefreshResponse, error)
	// Migrate applies a full set of SQL artifacts (files containing CREATE statements) to the catalog/infra.
	// It attempts to infer a minimal number of migrations to apply to reconcile the current state with
	// the desired state expressed in the artifacts. Any existing objects not described in the submitted
	// artifacts will be deleted.
	Migrate(context.Context, *MigrateRequest) (*MigrateResponse, error)
	// MigrateSingle applies a single `CREATE` statement.
	// It bypasses the reconciling migrations described in Migrate.
	// We aim to deprecate this function once reconciling migrations are mature and adopted in the modeller.
	MigrateSingle(context.Context, *MigrateSingleRequest) (*MigrateSingleResponse, error)
	// MigrateDelete deletes a single object.
	// It bypasses the reconciling migrations described in Migrate.
	// We aim to deprecate this function once reconciling migrations are mature and adopted in the modeller.
	MigrateDelete(context.Context, *MigrateDeleteRequest) (*MigrateDeleteResponse, error)
	// Query runs a Rill SQL query by transpiling it and proxying it to the instance's OLAP datastore.
	Query(context.Context, *QueryRequest) (*QueryResponse, error)
	// QueryDirect runs a SQL query by directly executing it against the instance's OLAP datastore.
	// It bypasses Rill SQL and expects the query to use the underlying dialect.
	QueryDirect(context.Context, *QueryDirectRequest) (*QueryDirectResponse, error)
	// MetricsViewMeta returns metadata about a metrics view.
	// It's comparable to calling GetCatalogObject and will be deprecated in the future.
	MetricsViewMeta(context.Context, *MetricsViewMetaRequest) (*MetricsViewMetaResponse, error)
	// MetricsViewToplist returns the top dimension values of a metrics view sorted by one or more measures.
	// It's a convenience API for querying a metrics view.
	MetricsViewToplist(context.Context, *MetricsViewToplistRequest) (*MetricsViewToplistResponse, error)
	// MetricsViewTimeSeries returns time series for the measures in the metrics view.
	// It's a convenience API for querying a metrics view.
	MetricsViewTimeSeries(context.Context, *MetricsViewTimeSeriesRequest) (*MetricsViewTimeSeriesResponse, error)
	// MetricsViewTotals returns totals over a time period for the measures in a metrics view.
	// It's a convenience API for querying a metrics view.
	MetricsViewTotals(context.Context, *MetricsViewTotalsRequest) (*MetricsViewTotalsResponse, error)
	// Get TopK elements from a table for a column given an agg function
	// agg function and k are optional, defaults are count(*) and 50 respectively
	GetTopK(context.Context, *TopKRequest) (*TopKResponse, 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 SchemaColumn 

type SchemaColumn 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
}

func (*SchemaColumn) Descriptor deprecated 

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

Deprecated: Use SchemaColumn.ProtoReflect.Descriptor instead.

func (*SchemaColumn) GetName 

func (x *SchemaColumn) GetName() string

func (*SchemaColumn) GetNullable 

func (x *SchemaColumn) GetNullable() bool

func (*SchemaColumn) GetType 

func (x *SchemaColumn) GetType() string

func (*SchemaColumn) ProtoMessage 

func (*SchemaColumn) ProtoMessage()

func (*SchemaColumn) ProtoReflect 

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

func (*SchemaColumn) Reset 

func (x *SchemaColumn) Reset()

func (*SchemaColumn) String 

func (x *SchemaColumn) String() string

type Source 

type Source struct {

	// Formatted SQL DDL for the source
	Sql string `protobuf:"bytes,1,opt,name=sql,proto3" json:"sql,omitempty"`
	// Name of the source
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// Connector used by the source
	Connector string `protobuf:"bytes,3,opt,name=connector,proto3" json:"connector,omitempty"`
	// Connector properties assigned in the source
	Properties *structpb.Struct `protobuf:"bytes,4,opt,name=properties,proto3" json:"properties,omitempty"`
	// contains filtered or unexported fields
}

Source represents a catalog object created using CREATE SOURCE

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

func (x *Source) GetSql() string

func (*Source) ProtoMessage 

func (*Source) ProtoMessage()

func (*Source) ProtoReflect 

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

func (*Source) Reset 

func (x *Source) Reset()

func (*Source) String 

func (x *Source) String() string

type TopKRequest added in v0.14.0 

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

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

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

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

Deprecated: Use TopKRequest.ProtoReflect.Descriptor instead.

func (*TopKRequest) GetAgg added in v0.14.0 

func (x *TopKRequest) GetAgg() string

func (*TopKRequest) GetColumnName added in v0.14.0 

func (x *TopKRequest) GetColumnName() string

func (*TopKRequest) GetInstanceId added in v0.14.0 

func (x *TopKRequest) GetInstanceId() string

func (*TopKRequest) GetK added in v0.14.0 

func (x *TopKRequest) GetK() int32

func (*TopKRequest) GetTableName added in v0.14.0 

func (x *TopKRequest) GetTableName() string

func (*TopKRequest) ProtoMessage added in v0.14.0 

func (*TopKRequest) ProtoMessage()

func (*TopKRequest) ProtoReflect added in v0.14.0 

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

func (*TopKRequest) Reset added in v0.14.0 

func (x *TopKRequest) Reset()

func (*TopKRequest) String added in v0.14.0 

func (x *TopKRequest) String() string

type TopKResponse added in v0.14.0 

type TopKResponse struct {
	Meta []*SchemaColumn    `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 for RuntimeService.GetTopK.

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

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

Deprecated: Use TopKResponse.ProtoReflect.Descriptor instead.

func (*TopKResponse) GetData added in v0.14.0 

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

func (*TopKResponse) GetMeta added in v0.14.0 

func (x *TopKResponse) GetMeta() []*SchemaColumn

func (*TopKResponse) ProtoMessage added in v0.14.0 

func (*TopKResponse) ProtoMessage()

func (*TopKResponse) ProtoReflect added in v0.14.0 

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

func (*TopKResponse) Reset added in v0.14.0 

func (x *TopKResponse) Reset()

func (*TopKResponse) String added in v0.14.0 

func (x *TopKResponse) String() string

type 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 UnimplementedRuntimeServiceServer 

type UnimplementedRuntimeServiceServer struct {
}

UnimplementedRuntimeServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedRuntimeServiceServer) CreateInstance 

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

func (UnimplementedRuntimeServiceServer) CreateRepo 

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

func (UnimplementedRuntimeServiceServer) DeleteInstance 

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

func (UnimplementedRuntimeServiceServer) DeleteRepo 

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

func (UnimplementedRuntimeServiceServer) GetCatalogObject 

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

func (UnimplementedRuntimeServiceServer) GetInstance 

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

func (UnimplementedRuntimeServiceServer) GetRepo 

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

func (UnimplementedRuntimeServiceServer) GetRepoObject 

func (UnimplementedRuntimeServiceServer) GetRepoObject(context.Context, *GetRepoObjectRequest) (*GetRepoObjectResponse, error)

func (UnimplementedRuntimeServiceServer) GetTopK added in v0.14.0 

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

func (UnimplementedRuntimeServiceServer) ListCatalogObjects 

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

func (UnimplementedRuntimeServiceServer) ListConnectors 

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

func (UnimplementedRuntimeServiceServer) ListInstances 

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

func (UnimplementedRuntimeServiceServer) ListRepoObjects 

func (UnimplementedRuntimeServiceServer) ListRepoObjects(context.Context, *ListRepoObjectsRequest) (*ListRepoObjectsResponse, error)

func (UnimplementedRuntimeServiceServer) ListRepos 

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

func (UnimplementedRuntimeServiceServer) MetricsViewMeta 

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

func (UnimplementedRuntimeServiceServer) MetricsViewTimeSeries 

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

func (UnimplementedRuntimeServiceServer) MetricsViewToplist 

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

func (UnimplementedRuntimeServiceServer) MetricsViewTotals 

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

func (UnimplementedRuntimeServiceServer) Migrate 

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

func (UnimplementedRuntimeServiceServer) MigrateDelete 

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

func (UnimplementedRuntimeServiceServer) MigrateSingle 

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

func (UnimplementedRuntimeServiceServer) Ping 

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

func (UnimplementedRuntimeServiceServer) PutRepoObject 

func (UnimplementedRuntimeServiceServer) PutRepoObject(context.Context, *PutRepoObjectRequest) (*PutRepoObjectResponse, error)

func (UnimplementedRuntimeServiceServer) Query 

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

func (UnimplementedRuntimeServiceServer) QueryDirect 

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

func (UnimplementedRuntimeServiceServer) TriggerRefresh 

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

type UnmanagedTable 

type UnmanagedTable struct {
	Name   string          `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	View   bool            `protobuf:"varint,2,opt,name=view,proto3" json:"view,omitempty"`
	Schema []*SchemaColumn `protobuf:"bytes,3,rep,name=schema,proto3" json:"schema,omitempty"`
	// contains filtered or unexported fields
}

UnmanagedTable represents a pre-existing table in the OLAP database (i.e. a table that was NOT created through the runtime's migrations). The runtime periodically looks for unmanaged tables in the database's information schema if the instance is created with exposed=true.

func (*UnmanagedTable) Descriptor deprecated 

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

Deprecated: Use UnmanagedTable.ProtoReflect.Descriptor instead.

func (*UnmanagedTable) GetName 

func (x *UnmanagedTable) GetName() string

func (*UnmanagedTable) GetSchema 

func (x *UnmanagedTable) GetSchema() []*SchemaColumn

func (*UnmanagedTable) GetView 

func (x *UnmanagedTable) GetView() bool

func (*UnmanagedTable) ProtoMessage 

func (*UnmanagedTable) ProtoMessage()

func (*UnmanagedTable) ProtoReflect 

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

func (*UnmanagedTable) Reset 

func (x *UnmanagedTable) Reset()

func (*UnmanagedTable) String 

func (x *UnmanagedTable) String() string

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.