query_manager

package
v0.0.0-...-baa1f0e Latest Latest
Warning

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

 Go to latest Published: Oct 31, 2023 License: Apache-2.0 Imports: 8 Imported by: 4

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_proto_query_manager_server_proto protoreflect.FileDescriptor

Functions

func RegisterServerService 

func RegisterServerService(s grpc.ServiceRegistrar, srv *ServerService)

RegisterServerService registers a service implementation with a gRPC server.

Types

type EmptyArg 

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

func (*EmptyArg) Descriptor deprecated 

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

Deprecated: Use EmptyArg.ProtoReflect.Descriptor instead.

func (*EmptyArg) ProtoMessage 

func (*EmptyArg) ProtoMessage()

func (*EmptyArg) ProtoReflect 

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

func (*EmptyArg) Reset 

func (x *EmptyArg) Reset()

func (*EmptyArg) String 

func (x *EmptyArg) String() string

type MetricArg 

type MetricArg struct {
	QueryType        string            `protobuf:"bytes,1,opt,name=query_type,json=queryType,proto3" json:"query_type,omitempty"`
	Metric           string            `protobuf:"bytes,2,opt,name=metric,proto3" json:"metric,omitempty"`
	StartTime        string            `protobuf:"bytes,3,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	EndTime          string            `protobuf:"bytes,4,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
	TimeInterval     string            `protobuf:"bytes,5,opt,name=time_interval,json=timeInterval,proto3" json:"time_interval,omitempty"`
	Filters          map[string]string `` /* 155-byte string literal not displayed */
	Hierarchy        map[string]string `` /* 159-byte string literal not displayed */
	UserProvidedArgs map[string]string `` /* 199-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*MetricArg) Descriptor deprecated 

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

Deprecated: Use MetricArg.ProtoReflect.Descriptor instead.

func (*MetricArg) GetEndTime 

func (x *MetricArg) GetEndTime() string

func (*MetricArg) GetFilters 

func (x *MetricArg) GetFilters() map[string]string

func (*MetricArg) GetHierarchy 

func (x *MetricArg) GetHierarchy() map[string]string

func (*MetricArg) GetMetric 

func (x *MetricArg) GetMetric() string

func (*MetricArg) GetQueryType 

func (x *MetricArg) GetQueryType() string

func (*MetricArg) GetStartTime 

func (x *MetricArg) GetStartTime() string

func (*MetricArg) GetTimeInterval 

func (x *MetricArg) GetTimeInterval() string

func (*MetricArg) GetUserProvidedArgs 

func (x *MetricArg) GetUserProvidedArgs() map[string]string

func (*MetricArg) ProtoMessage 

func (*MetricArg) ProtoMessage()

func (*MetricArg) ProtoReflect 

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

func (*MetricArg) Reset 

func (x *MetricArg) Reset()

func (*MetricArg) String 

func (x *MetricArg) String() string

type ServerClient 

type ServerClient interface {
	// Create a new Resource Group
	GetMetrics(ctx context.Context, in *MetricArg, opts ...grpc.CallOption) (*TimeSeriesResponse, error)
}

ServerClient is the client API for Server 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 NewServerClient 

func NewServerClient(cc grpc.ClientConnInterface) ServerClient

type ServerService 

type ServerService struct {
	// Create a new Resource Group
	GetMetrics func(context.Context, *MetricArg) (*TimeSeriesResponse, error)
}

ServerService is the service API for Server service. Fields should be assigned to their respective handler implementations only before RegisterServerService is called. Any unassigned fields will result in the handler for that method returning an Unimplemented error.

func NewServerService 

func NewServerService(s interface{}) *ServerService

NewServerService creates a new ServerService containing the implemented methods of the Server service in s. Any unimplemented methods will result in the gRPC server returning an UNIMPLEMENTED status to the client. This includes situations where the method handler is misspelled or has the wrong signature. For this reason, this function should be used with great care and is not recommended to be used by most users.

type TimeSeriesResponse 

type TimeSeriesResponse struct {

	// name of the group
	Code         uint32                               `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
	Message      string                               `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	Data         []*TimeSeriesResponse_TimeSeriesItem `protobuf:"bytes,3,rep,name=data,proto3" json:"data,omitempty"`
	Last         string                               `protobuf:"bytes,4,opt,name=last,proto3" json:"last,omitempty"`
	TotalRecords uint32                               `protobuf:"varint,5,opt,name=total_records,json=totalRecords,proto3" json:"total_records,omitempty"`
	// contains filtered or unexported fields
}

Used in federating a service from one cluster to another

func (*TimeSeriesResponse) Descriptor deprecated 

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

Deprecated: Use TimeSeriesResponse.ProtoReflect.Descriptor instead.

func (*TimeSeriesResponse) GetCode 

func (x *TimeSeriesResponse) GetCode() uint32

func (*TimeSeriesResponse) GetData 

func (x *TimeSeriesResponse) GetData() []*TimeSeriesResponse_TimeSeriesItem

func (*TimeSeriesResponse) GetLast 

func (x *TimeSeriesResponse) GetLast() string

func (*TimeSeriesResponse) GetMessage 

func (x *TimeSeriesResponse) GetMessage() string

func (*TimeSeriesResponse) GetTotalRecords 

func (x *TimeSeriesResponse) GetTotalRecords() uint32

func (*TimeSeriesResponse) ProtoMessage 

func (*TimeSeriesResponse) ProtoMessage()

func (*TimeSeriesResponse) ProtoReflect 

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

func (*TimeSeriesResponse) Reset 

func (x *TimeSeriesResponse) Reset()

func (*TimeSeriesResponse) String 

func (x *TimeSeriesResponse) String() string

type TimeSeriesResponse_TimeSeriesItem 

type TimeSeriesResponse_TimeSeriesItem struct {
	Timeslot string            `protobuf:"bytes,1,opt,name=timeslot,proto3" json:"timeslot,omitempty"`
	Data     map[string]string `` /* 149-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*TimeSeriesResponse_TimeSeriesItem) Descriptor deprecated 

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

Deprecated: Use TimeSeriesResponse_TimeSeriesItem.ProtoReflect.Descriptor instead.

func (*TimeSeriesResponse_TimeSeriesItem) GetData 

func (x *TimeSeriesResponse_TimeSeriesItem) GetData() map[string]string

func (*TimeSeriesResponse_TimeSeriesItem) GetTimeslot 

func (x *TimeSeriesResponse_TimeSeriesItem) GetTimeslot() string

func (*TimeSeriesResponse_TimeSeriesItem) ProtoMessage 

func (*TimeSeriesResponse_TimeSeriesItem) ProtoMessage()

func (*TimeSeriesResponse_TimeSeriesItem) ProtoReflect 

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

func (*TimeSeriesResponse_TimeSeriesItem) Reset 

func (x *TimeSeriesResponse_TimeSeriesItem) Reset()

func (*TimeSeriesResponse_TimeSeriesItem) String 

func (x *TimeSeriesResponse_TimeSeriesItem) String() string

type UnstableServerService 

type UnstableServerService interface {
	// Create a new Resource Group
	GetMetrics(context.Context, *MetricArg) (*TimeSeriesResponse, error)
}

UnstableServerService is the service API for Server service. New methods may be added to this interface if they are added to the service definition, which is not a backward-compatible change. For this reason, use of this type is not recommended.

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.