grpc_testing

package
v1.32.0 Latest Latest
Warning

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

 Go to latest Published: Sep 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 RegisterMetricsServiceService added in v1.32.0 

func RegisterMetricsServiceService(s grpc.ServiceRegistrar, srv *MetricsServiceService)

RegisterMetricsServiceService registers a service implementation with a gRPC server.

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 MetricsServiceService added in v1.32.0 

type MetricsServiceService struct {
	// Returns the values of all the gauges that are currently being maintained by
	// the service
	GetAllGauges func(*EmptyMessage, MetricsService_GetAllGaugesServer) error
	// Returns the value of one gauge
	GetGauge func(context.Context, *GaugeRequest) (*GaugeResponse, error)
}

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

func NewMetricsServiceService added in v1.32.0 

func NewMetricsServiceService(s interface{}) *MetricsServiceService

NewMetricsServiceService creates a new MetricsServiceService containing the implemented methods of the MetricsService 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 MetricsService_GetAllGaugesClient 

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

type MetricsService_GetAllGaugesServer 

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

type UnstableMetricsServiceService added in v1.32.0 

type UnstableMetricsServiceService 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)
}

UnstableMetricsServiceService is the service API for MetricsService 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.