...
ActiveGo 1.8Package grpc_testing
Overview ▹
Index ▹
func RegisterMetricsServiceServer ¶
func RegisterMetricsServiceServer(s *grpc.Server, srv MetricsServiceServer)
type EmptyMessage ¶
type EmptyMessage struct {
}
func (*EmptyMessage) Descriptor ¶
func (*EmptyMessage) Descriptor() ([]byte, []int)
func (*EmptyMessage) ProtoMessage ¶
func (*EmptyMessage) ProtoMessage()
func (*EmptyMessage) Reset ¶
func (m *EmptyMessage) Reset()
func (*EmptyMessage) String ¶
func (m *EmptyMessage) String() string
type GaugeRequest ¶
Request message containing the gauge name
type GaugeRequest struct {
Name string `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
}
func (*GaugeRequest) Descriptor ¶
func (*GaugeRequest) Descriptor() ([]byte, []int)
func (*GaugeRequest) ProtoMessage ¶
func (*GaugeRequest) ProtoMessage()
func (*GaugeRequest) Reset ¶
func (m *GaugeRequest) Reset()
func (*GaugeRequest) String ¶
func (m *GaugeRequest) String() string
type GaugeResponse ¶
Reponse message containing the gauge name and value
type GaugeResponse struct {
Name string `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
// Types that are valid to be assigned to Value:
// *GaugeResponse_LongValue
// *GaugeResponse_DoubleValue
// *GaugeResponse_StringValue
Value isGaugeResponse_Value `protobuf_oneof:"value"`
}
func (*GaugeResponse) Descriptor ¶
func (*GaugeResponse) Descriptor() ([]byte, []int)
func (*GaugeResponse) GetDoubleValue ¶
func (m *GaugeResponse) GetDoubleValue() float64
func (*GaugeResponse) GetLongValue ¶
func (m *GaugeResponse) GetLongValue() int64
func (*GaugeResponse) GetStringValue ¶
func (m *GaugeResponse) GetStringValue() string
func (*GaugeResponse) GetValue ¶
func (m *GaugeResponse) GetValue() isGaugeResponse_Value
func (*GaugeResponse) ProtoMessage ¶
func (*GaugeResponse) ProtoMessage()
func (*GaugeResponse) Reset ¶
func (m *GaugeResponse) Reset()
func (*GaugeResponse) String ¶
func (m *GaugeResponse) String() string
func (*GaugeResponse) XXX_OneofFuncs ¶
func (*GaugeResponse) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})
XXX_OneofFuncs is for the internal use of the proto package.
type GaugeResponse_DoubleValue ¶
type GaugeResponse_DoubleValue struct {
DoubleValue float64 `protobuf:"fixed64,3,opt,name=double_value,json=doubleValue,oneof"`
}
type GaugeResponse_LongValue ¶
type GaugeResponse_LongValue struct {
LongValue int64 `protobuf:"varint,2,opt,name=long_value,json=longValue,oneof"`
}
type GaugeResponse_StringValue ¶
type GaugeResponse_StringValue struct {
StringValue string `protobuf:"bytes,4,opt,name=string_value,json=stringValue,oneof"`
}
type MetricsServiceClient ¶
type MetricsServiceClient interface {
// Returns the values of all the gauges that are currently being maintained by
// the service
GetAllGauges(ctx context.Context, in *EmptyMessage, opts ...grpc.CallOption) (MetricsService_GetAllGaugesClient, error)
// Returns the value of one gauge
GetGauge(ctx context.Context, in *GaugeRequest, opts ...grpc.CallOption) (*GaugeResponse, error)
}
func NewMetricsServiceClient ¶
func NewMetricsServiceClient(cc *grpc.ClientConn) MetricsServiceClient
type MetricsServiceServer ¶
type MetricsServiceServer interface {
// Returns the values of all the gauges that are currently being maintained by
// the service
GetAllGauges(*EmptyMessage, MetricsService_GetAllGaugesServer) error
// Returns the value of one gauge
GetGauge(context.Context, *GaugeRequest) (*GaugeResponse, error)
}
type MetricsService_GetAllGaugesClient ¶
type MetricsService_GetAllGaugesClient interface {
Recv() (*GaugeResponse, error)
grpc.ClientStream
}
type MetricsService_GetAllGaugesServer ¶
type MetricsService_GetAllGaugesServer interface {
Send(*GaugeResponse) error
grpc.ServerStream
}