api

package
v0.0.0-...-a6e60e5 Latest Latest
Warning

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

Go to latest
Published: Mar 20, 2024 License: Apache-2.0 Imports: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var File_service_proto protoreflect.FileDescriptor

Functions

func NewDialOptions

func NewDialOptions(config TLSConfig) ([]grpc.DialOption, error)

func NewServerOptions

func NewServerOptions(config TLSConfig) ([]grpc.ServerOption, error)

func RegisterMetricsServiceServer

func RegisterMetricsServiceServer(s *grpc.Server, srv MetricsServiceServer)

Types

type MetricsRequest

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

func (*MetricsRequest) Descriptor deprecated

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

Deprecated: Use MetricsRequest.ProtoReflect.Descriptor instead.

func (*MetricsRequest) GetRouter

func (x *MetricsRequest) GetRouter() string

func (*MetricsRequest) ProtoMessage

func (*MetricsRequest) ProtoMessage()

func (*MetricsRequest) ProtoReflect

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

func (*MetricsRequest) Reset

func (x *MetricsRequest) Reset()

func (*MetricsRequest) String

func (x *MetricsRequest) String() string

type MetricsResponse

type MetricsResponse struct {
	Capacity  *int32 `protobuf:"varint,1,opt,name=capacity,proto3,oneof" json:"capacity,omitempty"`
	Remaining *int32 `protobuf:"varint,2,opt,name=remaining,proto3,oneof" json:"remaining,omitempty"`
	// contains filtered or unexported fields
}

func (*MetricsResponse) Descriptor deprecated

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

Deprecated: Use MetricsResponse.ProtoReflect.Descriptor instead.

func (*MetricsResponse) GetCapacity

func (x *MetricsResponse) GetCapacity() int32

func (*MetricsResponse) GetRemaining

func (x *MetricsResponse) GetRemaining() int32

func (*MetricsResponse) ProtoMessage

func (*MetricsResponse) ProtoMessage()

func (*MetricsResponse) ProtoReflect

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

func (*MetricsResponse) Reset

func (x *MetricsResponse) Reset()

func (*MetricsResponse) String

func (x *MetricsResponse) String() string

type MetricsServiceClient

type MetricsServiceClient interface {
	Monitor(ctx context.Context, in *MetricsRequest, opts ...grpc.CallOption) (MetricsService_MonitorClient, error)
}

MetricsServiceClient is the client API for MetricsService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

type MetricsServiceServer

type MetricsServiceServer interface {
	Monitor(*MetricsRequest, MetricsService_MonitorServer) error
}

MetricsServiceServer is the server API for MetricsService service.

type MetricsService_MonitorClient

type MetricsService_MonitorClient interface {
	Recv() (*MetricsResponse, error)
	grpc.ClientStream
}

type MetricsService_MonitorServer

type MetricsService_MonitorServer interface {
	Send(*MetricsResponse) error
	grpc.ServerStream
}

type TLSConfig

type TLSConfig struct {
	Insecure bool
	CACerts  string
	Cert     string
	Key      string
}

type UnimplementedMetricsServiceServer

type UnimplementedMetricsServiceServer struct {
}

UnimplementedMetricsServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedMetricsServiceServer) Monitor

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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