proto

package
v0.10.0 Latest Latest
Warning

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

 Go to latest Published: Sep 15, 2022 License: Apache-2.0 Imports: 17 Imported by: 0

Documentation

Overview

Package proto is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

View Source 
var File_runtime_proto_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: "CreateInstance",
			Handler:    _RuntimeService_CreateInstance_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,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "runtime/proto/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 CreateInstanceRequest 

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

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) 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"`
	// contains filtered or unexported fields
}

func (*CreateInstanceResponse) Descriptor deprecated 

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

Deprecated: Use CreateInstanceResponse.ProtoReflect.Descriptor instead.

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 MetricsViewDimension 

type MetricsViewDimension 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"`
	// contains filtered or unexported fields
}

func (*MetricsViewDimension) Descriptor deprecated 

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

Deprecated: Use MetricsViewDimension.ProtoReflect.Descriptor instead.

func (*MetricsViewDimension) GetName 

func (x *MetricsViewDimension) GetName() string

func (*MetricsViewDimension) GetPrimaryTime 

func (x *MetricsViewDimension) GetPrimaryTime() bool

func (*MetricsViewDimension) GetType 

func (x *MetricsViewDimension) GetType() string

func (*MetricsViewDimension) ProtoMessage 

func (*MetricsViewDimension) ProtoMessage()

func (*MetricsViewDimension) ProtoReflect 

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

func (*MetricsViewDimension) Reset 

func (x *MetricsViewDimension) Reset()

func (*MetricsViewDimension) String 

func (x *MetricsViewDimension) String() string

type MetricsViewFilter 

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

func (*MetricsViewFilter) Descriptor deprecated 

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

Deprecated: Use MetricsViewFilter.ProtoReflect.Descriptor instead.

func (*MetricsViewFilter) GetExclude 

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

func (*MetricsViewFilter) GetInclude 

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

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 MetricsViewFilterCond 

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

func (*MetricsViewFilterCond) Descriptor deprecated 

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

Deprecated: Use MetricsViewFilterCond.ProtoReflect.Descriptor instead.

func (*MetricsViewFilterCond) GetName 

func (x *MetricsViewFilterCond) GetName() string

func (*MetricsViewFilterCond) GetValues 

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

func (*MetricsViewFilterCond) ProtoMessage 

func (*MetricsViewFilterCond) ProtoMessage()

func (*MetricsViewFilterCond) ProtoReflect 

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

func (*MetricsViewFilterCond) Reset 

func (x *MetricsViewFilterCond) Reset()

func (*MetricsViewFilterCond) String 

func (x *MetricsViewFilterCond) String() string

type MetricsViewMeasure 

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

func (*MetricsViewMeasure) Descriptor deprecated 

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

Deprecated: Use MetricsViewMeasure.ProtoReflect.Descriptor instead.

func (*MetricsViewMeasure) GetDescription 

func (x *MetricsViewMeasure) GetDescription() string

func (*MetricsViewMeasure) GetName 

func (x *MetricsViewMeasure) GetName() string

func (*MetricsViewMeasure) GetType 

func (x *MetricsViewMeasure) GetType() string

func (*MetricsViewMeasure) ProtoMessage 

func (*MetricsViewMeasure) ProtoMessage()

func (*MetricsViewMeasure) ProtoReflect 

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

func (*MetricsViewMeasure) Reset 

func (x *MetricsViewMeasure) Reset()

func (*MetricsViewMeasure) String 

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

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"`
	Dimensions      []*MetricsViewDimension `protobuf:"bytes,2,rep,name=dimensions,proto3" json:"dimensions,omitempty"`
	Measures        []*MetricsViewMeasure   `protobuf:"bytes,3,rep,name=measures,proto3" json:"measures,omitempty"`
	// contains filtered or unexported fields
}

func (*MetricsViewMetaResponse) Descriptor deprecated 

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

Deprecated: Use MetricsViewMetaResponse.ProtoReflect.Descriptor instead.

func (*MetricsViewMetaResponse) GetDimensions 

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

func (*MetricsViewMetaResponse) GetMeasures 

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

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
}

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
}

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
}

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
}

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
}

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 PingRequest 

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

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 {
	Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*PingResponse) Descriptor deprecated 

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

Deprecated: Use PingResponse.ProtoReflect.Descriptor instead.

func (*PingResponse) GetMessage 

func (x *PingResponse) GetMessage() 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 QueryDirectRequest 

type QueryDirectRequest struct {
	InstanceId string            `protobuf:"bytes,1,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"`
	Sql        string            `protobuf:"bytes,2,opt,name=sql,proto3" json:"sql,omitempty"`
	Args       []*structpb.Value `protobuf:"bytes,3,rep,name=args,proto3" json:"args,omitempty"`
	Priority   int64             `protobuf:"varint,4,opt,name=priority,proto3" json:"priority,omitempty"`
	DryRun     bool              `protobuf:"varint,5,opt,name=dry_run,json=dryRun,proto3" json:"dry_run,omitempty"`
	// contains filtered or unexported fields
}

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 added in v0.10.0 

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

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 RuntimeServiceClient 

type RuntimeServiceClient interface {
	Ping(ctx context.Context, in *PingRequest, opts ...grpc.CallOption) (*PingResponse, error)
	CreateInstance(ctx context.Context, in *CreateInstanceRequest, opts ...grpc.CallOption) (*CreateInstanceResponse, error)
	QueryDirect(ctx context.Context, in *QueryDirectRequest, opts ...grpc.CallOption) (*QueryDirectResponse, error)
	MetricsViewMeta(ctx context.Context, in *MetricsViewMetaRequest, opts ...grpc.CallOption) (*MetricsViewMetaResponse, error)
	MetricsViewToplist(ctx context.Context, in *MetricsViewToplistRequest, opts ...grpc.CallOption) (*MetricsViewToplistResponse, error)
	MetricsViewTimeSeries(ctx context.Context, in *MetricsViewTimeSeriesRequest, opts ...grpc.CallOption) (*MetricsViewTimeSeriesResponse, 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(context.Context, *PingRequest) (*PingResponse, error)
	CreateInstance(context.Context, *CreateInstanceRequest) (*CreateInstanceResponse, error)
	QueryDirect(context.Context, *QueryDirectRequest) (*QueryDirectResponse, error)
	MetricsViewMeta(context.Context, *MetricsViewMetaRequest) (*MetricsViewMetaResponse, error)
	MetricsViewToplist(context.Context, *MetricsViewToplistRequest) (*MetricsViewToplistResponse, error)
	MetricsViewTimeSeries(context.Context, *MetricsViewTimeSeriesRequest) (*MetricsViewTimeSeriesResponse, 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 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) 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) Ping 

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

func (UnimplementedRuntimeServiceServer) QueryDirect 

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

type UnsafeRuntimeServiceServer 

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

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

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