Documentation ¶
Index ¶
- Variables
- func NewDialOptions(config TLSConfig) ([]grpc.DialOption, error)
- func NewServerOptions(config TLSConfig) ([]grpc.ServerOption, error)
- func RegisterMetricsServiceServer(s *grpc.Server, srv MetricsServiceServer)
- type MetricsRequest
- type MetricsResponse
- func (*MetricsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *MetricsResponse) GetCapacity() int32
- func (x *MetricsResponse) GetRemaining() int32
- func (*MetricsResponse) ProtoMessage()
- func (x *MetricsResponse) ProtoReflect() protoreflect.Message
- func (x *MetricsResponse) Reset()
- func (x *MetricsResponse) String() string
- type MetricsServiceClient
- type MetricsServiceServer
- type MetricsService_MonitorClient
- type MetricsService_MonitorServer
- type TLSConfig
- type UnimplementedMetricsServiceServer
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.
func NewMetricsServiceClient ¶
func NewMetricsServiceClient(cc grpc.ClientConnInterface) MetricsServiceClient
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 UnimplementedMetricsServiceServer ¶
type UnimplementedMetricsServiceServer struct { }
UnimplementedMetricsServiceServer can be embedded to have forward compatible implementations.
func (*UnimplementedMetricsServiceServer) Monitor ¶
func (*UnimplementedMetricsServiceServer) Monitor(*MetricsRequest, MetricsService_MonitorServer) error
Click to show internal directories.
Click to hide internal directories.