grpc_testing

package
v1.34.0-dev Latest Latest
Warning

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

 Go to latest Published: Oct 8, 2020 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterMetricsServiceServer 

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

Types

type EmptyMessage 

type EmptyMessage struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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

func (*EmptyMessage) XXX_DiscardUnknown added in v1.12.0 

func (m *EmptyMessage) XXX_DiscardUnknown()

func (*EmptyMessage) XXX_Marshal added in v1.12.0 

func (m *EmptyMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EmptyMessage) XXX_Merge added in v1.12.0 

func (m *EmptyMessage) XXX_Merge(src proto.Message)

func (*EmptyMessage) XXX_Size added in v1.12.0 

func (m *EmptyMessage) XXX_Size() int

func (*EmptyMessage) XXX_Unmarshal added in v1.12.0 

func (m *EmptyMessage) XXX_Unmarshal(b []byte) error

type GaugeRequest 

type GaugeRequest struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Request message containing the gauge name

func (*GaugeRequest) Descriptor 

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

func (*GaugeRequest) GetName added in v1.6.0 

func (m *GaugeRequest) GetName() string

func (*GaugeRequest) ProtoMessage 

func (*GaugeRequest) ProtoMessage()

func (*GaugeRequest) Reset 

func (m *GaugeRequest) Reset()

func (*GaugeRequest) String 

func (m *GaugeRequest) String() string

func (*GaugeRequest) XXX_DiscardUnknown added in v1.12.0 

func (m *GaugeRequest) XXX_DiscardUnknown()

func (*GaugeRequest) XXX_Marshal added in v1.12.0 

func (m *GaugeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GaugeRequest) XXX_Merge added in v1.12.0 

func (m *GaugeRequest) XXX_Merge(src proto.Message)

func (*GaugeRequest) XXX_Size added in v1.12.0 

func (m *GaugeRequest) XXX_Size() int

func (*GaugeRequest) XXX_Unmarshal added in v1.12.0 

func (m *GaugeRequest) XXX_Unmarshal(b []byte) error

type GaugeResponse 

type GaugeResponse struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Types that are valid to be assigned to Value:
	//	*GaugeResponse_LongValue
	//	*GaugeResponse_DoubleValue
	//	*GaugeResponse_StringValue
	Value                isGaugeResponse_Value `protobuf_oneof:"value"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

Response message containing the gauge name and 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) GetName added in v1.6.0 

func (m *GaugeResponse) GetName() string

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_DiscardUnknown added in v1.12.0 

func (m *GaugeResponse) XXX_DiscardUnknown()

func (*GaugeResponse) XXX_Marshal added in v1.12.0 

func (m *GaugeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GaugeResponse) XXX_Merge added in v1.12.0 

func (m *GaugeResponse) XXX_Merge(src proto.Message)

func (*GaugeResponse) XXX_OneofWrappers added in v1.24.0 

func (*GaugeResponse) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*GaugeResponse) XXX_Size added in v1.12.0 

func (m *GaugeResponse) XXX_Size() int

func (*GaugeResponse) XXX_Unmarshal added in v1.12.0 

func (m *GaugeResponse) XXX_Unmarshal(b []byte) error

type GaugeResponse_DoubleValue 

type GaugeResponse_DoubleValue struct {
	DoubleValue float64 `protobuf:"fixed64,3,opt,name=double_value,json=doubleValue,proto3,oneof"`
}

type GaugeResponse_LongValue 

type GaugeResponse_LongValue struct {
	LongValue int64 `protobuf:"varint,2,opt,name=long_value,json=longValue,proto3,oneof"`
}

type GaugeResponse_StringValue 

type GaugeResponse_StringValue struct {
	StringValue string `protobuf:"bytes,4,opt,name=string_value,json=stringValue,proto3,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)
}

MetricsServiceClient is the client API for MetricsService 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 NewMetricsServiceClient 

func NewMetricsServiceClient(cc grpc.ClientConnInterface) 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)
	// contains filtered or unexported methods
}

MetricsServiceServer is the server API for MetricsService service. All implementations must embed UnimplementedMetricsServiceServer for forward compatibility

type MetricsService_GetAllGaugesClient 

type MetricsService_GetAllGaugesClient interface {
	Recv() (*GaugeResponse, error)
	grpc.ClientStream
}

type MetricsService_GetAllGaugesServer 

type MetricsService_GetAllGaugesServer interface {
	Send(*GaugeResponse) error
	grpc.ServerStream
}

type UnimplementedMetricsServiceServer added in v1.24.0 

type UnimplementedMetricsServiceServer struct {
}

UnimplementedMetricsServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedMetricsServiceServer) GetAllGauges added in v1.24.0 

func (UnimplementedMetricsServiceServer) GetAllGauges(*EmptyMessage, MetricsService_GetAllGaugesServer) error

func (UnimplementedMetricsServiceServer) GetGauge added in v1.24.0 

func (UnimplementedMetricsServiceServer) GetGauge(context.Context, *GaugeRequest) (*GaugeResponse, error)

type UnsafeMetricsServiceServer added in v1.33.0 

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

UnsafeMetricsServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to MetricsServiceServer 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.