testgrpc

package
v0.12.0-rc2 Latest Latest
Warning

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

 Go to latest Published: Nov 2, 2023 License: Apache-2.0 Imports: 17 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	SimpleService_Increment_FullMethodName                       = "/testgrpc.cached.SimpleService/Increment"
	SimpleService_GetValue_FullMethodName                        = "/testgrpc.cached.SimpleService/GetValue"
	SimpleService_GetValueWithForcedClientCaching_FullMethodName = "/testgrpc.cached.SimpleService/GetValueWithForcedClientCaching"
)
View Source 
const (
	ObjectService_IncrementObject_FullMethodName = "/testgrpc.cached.ObjectService/IncrementObject"
	ObjectService_GetObjectValue_FullMethodName  = "/testgrpc.cached.ObjectService/GetObjectValue"
	ObjectService_List_FullMethodName            = "/testgrpc.cached.ObjectService/List"
)
View Source 
const (
	AggregatorService_IncrementAll_FullMethodName            = "/testgrpc.cached.AggregatorService/IncrementAll"
	AggregatorService_GetAll_FullMethodName                  = "/testgrpc.cached.AggregatorService/GetAll"
	AggregatorService_GetAllWithNestedCaching_FullMethodName = "/testgrpc.cached.AggregatorService/GetAllWithNestedCaching"
)
View Source 
const (
	StreamService_Stream_FullMethodName = "/testgrpc.stream.StreamService/Stream"
)

Variables

View Source 
var AggregatorService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "testgrpc.cached.AggregatorService",
	HandlerType: (*AggregatorServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "IncrementAll",
			Handler:    _AggregatorService_IncrementAll_Handler,
		},
		{
			MethodName: "GetAll",
			Handler:    _AggregatorService_GetAll_Handler,
		},
		{
			MethodName: "GetAllWithNestedCaching",
			Handler:    _AggregatorService_GetAllWithNestedCaching_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "github.com/rancher/opni/pkg/test/testgrpc/cached.proto",
}

AggregatorService_ServiceDesc is the grpc.ServiceDesc for AggregatorService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var File_github_com_rancher_opni_pkg_test_testgrpc_alerting_test_proto protoreflect.FileDescriptor
View Source 
var File_github_com_rancher_opni_pkg_test_testgrpc_cached_proto protoreflect.FileDescriptor
View Source 
var File_github_com_rancher_opni_pkg_test_testgrpc_stream_proto protoreflect.FileDescriptor
View Source 
var ObjectService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "testgrpc.cached.ObjectService",
	HandlerType: (*ObjectServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "IncrementObject",
			Handler:    _ObjectService_IncrementObject_Handler,
		},
		{
			MethodName: "GetObjectValue",
			Handler:    _ObjectService_GetObjectValue_Handler,
		},
		{
			MethodName: "List",
			Handler:    _ObjectService_List_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "github.com/rancher/opni/pkg/test/testgrpc/cached.proto",
}

ObjectService_ServiceDesc is the grpc.ServiceDesc for ObjectService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var SimpleService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "testgrpc.cached.SimpleService",
	HandlerType: (*SimpleServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Increment",
			Handler:    _SimpleService_Increment_Handler,
		},
		{
			MethodName: "GetValue",
			Handler:    _SimpleService_GetValue_Handler,
		},
		{
			MethodName: "GetValueWithForcedClientCaching",
			Handler:    _SimpleService_GetValueWithForcedClientCaching_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "github.com/rancher/opni/pkg/test/testgrpc/cached.proto",
}

SimpleService_ServiceDesc is the grpc.ServiceDesc for SimpleService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var StreamService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "testgrpc.stream.StreamService",
	HandlerType: (*StreamServiceServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Stream",
			Handler:       _StreamService_Stream_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "github.com/rancher/opni/pkg/test/testgrpc/stream.proto",
}

StreamService_ServiceDesc is the grpc.ServiceDesc for StreamService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterAggregatorServiceServer added in v0.9.2 

func RegisterAggregatorServiceServer(s grpc.ServiceRegistrar, srv AggregatorServiceServer)

func RegisterObjectServiceServer added in v0.9.2 

func RegisterObjectServiceServer(s grpc.ServiceRegistrar, srv ObjectServiceServer)

func RegisterSimpleServiceServer added in v0.9.2 

func RegisterSimpleServiceServer(s grpc.ServiceRegistrar, srv SimpleServiceServer)

func RegisterStreamServiceServer 

func RegisterStreamServiceServer(s grpc.ServiceRegistrar, srv StreamServiceServer)

Types

type AggregatorServer added in v0.9.2 

type AggregatorServer struct {
	UnsafeAggregatorServiceServer

	SimpleServiceClient
	ObjectServiceClient
	// contains filtered or unexported fields
}

func NewAggregatorServer added in v0.9.2 

func NewAggregatorServer(
	cacheMaxAge time.Duration,
	simpleClient SimpleServiceClient,
	objectClient ObjectServiceClient,
) *AggregatorServer

func (*AggregatorServer) GetAll added in v0.9.2 

func (a *AggregatorServer) GetAll(ctx context.Context, _ *emptypb.Empty) (*Value, error)

func (*AggregatorServer) GetAllWithNestedCaching added in v0.9.2 

func (a *AggregatorServer) GetAllWithNestedCaching(ctx context.Context, _ *emptypb.Empty) (*Value, error)

func (*AggregatorServer) IncrementAll added in v0.9.2 

func (a *AggregatorServer) IncrementAll(ctx context.Context, req *IncrementRequest) (*emptypb.Empty, error)

type AggregatorServiceClient added in v0.9.2 

type AggregatorServiceClient interface {
	// Increments the global value and all object values by 1,
	// by making nested RPC calls.
	// returns an aggregate value of all other values.
	IncrementAll(ctx context.Context, in *IncrementRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// returns sum of all values
	GetAll(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*Value, error)
	GetAllWithNestedCaching(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*Value, error)
}

AggregatorServiceClient is the client API for AggregatorService 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 NewAggregatorServiceClient added in v0.9.2 

func NewAggregatorServiceClient(cc grpc.ClientConnInterface) AggregatorServiceClient

type AggregatorServiceServer added in v0.9.2 

type AggregatorServiceServer interface {
	// Increments the global value and all object values by 1,
	// by making nested RPC calls.
	// returns an aggregate value of all other values.
	IncrementAll(context.Context, *IncrementRequest) (*emptypb.Empty, error)
	// returns sum of all values
	GetAll(context.Context, *emptypb.Empty) (*Value, error)
	GetAllWithNestedCaching(context.Context, *emptypb.Empty) (*Value, error)
	// contains filtered or unexported methods
}

AggregatorServiceServer is the server API for AggregatorService service. All implementations must embed UnimplementedAggregatorServiceServer for forward compatibility

type CachingHttpServer added in v0.8.3 

type CachingHttpServer struct {
	*http.Server
	// contains filtered or unexported fields
}

--- Http server for caching tests ---

func NewCachingHttpServer added in v0.8.3 

func NewCachingHttpServer(serverPort int) *CachingHttpServer

type IncrementObjectRequest added in v0.9.2 

type IncrementObjectRequest struct {
	Id    *ObjectReference `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Value int64            `protobuf:"varint,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*IncrementObjectRequest) Descriptor deprecated added in v0.9.2 

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

Deprecated: Use IncrementObjectRequest.ProtoReflect.Descriptor instead.

func (*IncrementObjectRequest) GetId added in v0.9.2 

func (x *IncrementObjectRequest) GetId() *ObjectReference

func (*IncrementObjectRequest) GetValue added in v0.9.2 

func (x *IncrementObjectRequest) GetValue() int64

func (*IncrementObjectRequest) ProtoMessage added in v0.9.2 

func (*IncrementObjectRequest) ProtoMessage()

func (*IncrementObjectRequest) ProtoReflect added in v0.9.2 

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

func (*IncrementObjectRequest) Reset added in v0.9.2 

func (x *IncrementObjectRequest) Reset()

func (*IncrementObjectRequest) String added in v0.9.2 

func (x *IncrementObjectRequest) String() string

type IncrementRequest added in v0.9.2 

type IncrementRequest struct {
	Value int64 `protobuf:"varint,1,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*IncrementRequest) Descriptor deprecated added in v0.9.2 

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

Deprecated: Use IncrementRequest.ProtoReflect.Descriptor instead.

func (*IncrementRequest) GetValue added in v0.9.2 

func (x *IncrementRequest) GetValue() int64

func (*IncrementRequest) ProtoMessage added in v0.9.2 

func (*IncrementRequest) ProtoMessage()

func (*IncrementRequest) ProtoReflect added in v0.9.2 

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

func (*IncrementRequest) Reset added in v0.9.2 

func (x *IncrementRequest) Reset()

func (*IncrementRequest) String added in v0.9.2 

func (x *IncrementRequest) String() string

type ObjectList added in v0.9.2 

type ObjectList struct {
	Items []*ObjectReference `protobuf:"bytes,1,rep,name=items,proto3" json:"items,omitempty"`
	// contains filtered or unexported fields
}

func (*ObjectList) Descriptor deprecated added in v0.9.2 

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

Deprecated: Use ObjectList.ProtoReflect.Descriptor instead.

func (*ObjectList) GetItems added in v0.9.2 

func (x *ObjectList) GetItems() []*ObjectReference

func (*ObjectList) ProtoMessage added in v0.9.2 

func (*ObjectList) ProtoMessage()

func (*ObjectList) ProtoReflect added in v0.9.2 

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

func (*ObjectList) Reset added in v0.9.2 

func (x *ObjectList) Reset()

func (*ObjectList) String added in v0.9.2 

func (x *ObjectList) String() string

type ObjectReference added in v0.9.2 

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

ObjectReference must implement the `CacheKeyer` interface

func (*ObjectReference) CacheKey added in v0.9.2 

func (x *ObjectReference) CacheKey() string

func (*ObjectReference) Descriptor deprecated added in v0.9.2 

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

Deprecated: Use ObjectReference.ProtoReflect.Descriptor instead.

func (*ObjectReference) GetId added in v0.9.2 

func (x *ObjectReference) GetId() string

func (*ObjectReference) ProtoMessage added in v0.9.2 

func (*ObjectReference) ProtoMessage()

func (*ObjectReference) ProtoReflect added in v0.9.2 

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

func (*ObjectReference) Reset added in v0.9.2 

func (x *ObjectReference) Reset()

func (*ObjectReference) String added in v0.9.2 

func (x *ObjectReference) String() string

type ObjectServer added in v0.9.2 

type ObjectServer struct {
	UnsafeObjectServiceServer
	// contains filtered or unexported fields
}

func NewObjectServer added in v0.9.2 

func NewObjectServer(cacheMaxAge time.Duration) *ObjectServer

func (*ObjectServer) GetObjectValue added in v0.9.2 

func (o *ObjectServer) GetObjectValue(_ context.Context, reference *ObjectReference) (*Value, error)

func (*ObjectServer) IncrementObject added in v0.9.2 

func (o *ObjectServer) IncrementObject(_ context.Context, request *IncrementObjectRequest) (*emptypb.Empty, error)

func (*ObjectServer) List added in v0.9.2 

func (o *ObjectServer) List(_ context.Context, _ *emptypb.Empty) (*ObjectList, error)

type ObjectServiceClient added in v0.9.2 

type ObjectServiceClient interface {
	// Adds the value to the an arbitrary server-side object.
	// If the object doesn't exist create a new one and it set it to the value.
	IncrementObject(ctx context.Context, in *IncrementObjectRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	GetObjectValue(ctx context.Context, in *ObjectReference, opts ...grpc.CallOption) (*Value, error)
	List(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ObjectList, error)
}

ObjectServiceClient is the client API for ObjectService 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 NewObjectServiceClient added in v0.9.2 

func NewObjectServiceClient(cc grpc.ClientConnInterface) ObjectServiceClient

type ObjectServiceServer added in v0.9.2 

type ObjectServiceServer interface {
	// Adds the value to the an arbitrary server-side object.
	// If the object doesn't exist create a new one and it set it to the value.
	IncrementObject(context.Context, *IncrementObjectRequest) (*emptypb.Empty, error)
	GetObjectValue(context.Context, *ObjectReference) (*Value, error)
	List(context.Context, *emptypb.Empty) (*ObjectList, error)
	// contains filtered or unexported methods
}

ObjectServiceServer is the server API for ObjectService service. All implementations must embed UnimplementedObjectServiceServer for forward compatibility

type RefreshRequest added in v0.9.2 

type RefreshRequest struct {
	Refresh bool `protobuf:"varint,1,opt,name=refresh,proto3" json:"refresh,omitempty"`
	// contains filtered or unexported fields
}

func (*RefreshRequest) Descriptor deprecated added in v0.9.2 

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

Deprecated: Use RefreshRequest.ProtoReflect.Descriptor instead.

func (*RefreshRequest) GetRefresh added in v0.9.2 

func (x *RefreshRequest) GetRefresh() bool

func (*RefreshRequest) ProtoMessage added in v0.9.2 

func (*RefreshRequest) ProtoMessage()

func (*RefreshRequest) ProtoReflect added in v0.9.2 

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

func (*RefreshRequest) Reset added in v0.9.2 

func (x *RefreshRequest) Reset()

func (*RefreshRequest) String added in v0.9.2 

func (x *RefreshRequest) String() string

type SimpleServer added in v0.9.2 

type SimpleServer struct {
	UnsafeSimpleServiceServer
	// contains filtered or unexported fields
}

func NewSimpleServer added in v0.9.2 

func NewSimpleServer(cacheMaxAge time.Duration) *SimpleServer

func (*SimpleServer) GetValue added in v0.9.2 

func (c *SimpleServer) GetValue(_ context.Context, _ *emptypb.Empty) (*Value, error)

func (*SimpleServer) GetValueWithForcedClientCaching added in v0.9.2 

func (c *SimpleServer) GetValueWithForcedClientCaching(ctx context.Context, _ *emptypb.Empty) (*Value, error)

func (*SimpleServer) Increment added in v0.9.2 

func (c *SimpleServer) Increment(_ context.Context, request *IncrementRequest) (*emptypb.Empty, error)

type SimpleServiceClient added in v0.9.2 

type SimpleServiceClient interface {
	Increment(ctx context.Context, in *IncrementRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	GetValue(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*Value, error)
	GetValueWithForcedClientCaching(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*Value, error)
}

SimpleServiceClient is the client API for SimpleService 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 NewSimpleServiceClient added in v0.9.2 

func NewSimpleServiceClient(cc grpc.ClientConnInterface) SimpleServiceClient

type SimpleServiceServer added in v0.9.2 

type SimpleServiceServer interface {
	Increment(context.Context, *IncrementRequest) (*emptypb.Empty, error)
	GetValue(context.Context, *emptypb.Empty) (*Value, error)
	GetValueWithForcedClientCaching(context.Context, *emptypb.Empty) (*Value, error)
	// contains filtered or unexported methods
}

SimpleServiceServer is the server API for SimpleService service. All implementations must embed UnimplementedSimpleServiceServer for forward compatibility

type StreamRequest 

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

func (*StreamRequest) Descriptor deprecated 

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

Deprecated: Use StreamRequest.ProtoReflect.Descriptor instead.

func (*StreamRequest) GetRequest 

func (x *StreamRequest) GetRequest() string

func (*StreamRequest) ProtoMessage 

func (*StreamRequest) ProtoMessage()

func (*StreamRequest) ProtoReflect 

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

func (*StreamRequest) Reset 

func (x *StreamRequest) Reset()

func (*StreamRequest) String 

func (x *StreamRequest) String() string

type StreamResponse 

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

func (*StreamResponse) Descriptor deprecated 

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

Deprecated: Use StreamResponse.ProtoReflect.Descriptor instead.

func (*StreamResponse) GetResponse 

func (x *StreamResponse) GetResponse() string

func (*StreamResponse) ProtoMessage 

func (*StreamResponse) ProtoMessage()

func (*StreamResponse) ProtoReflect 

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

func (*StreamResponse) Reset 

func (x *StreamResponse) Reset()

func (*StreamResponse) String 

func (x *StreamResponse) String() string

type StreamServer 

type StreamServer struct {
	UnsafeStreamServiceServer

	ServerHandler func(stream StreamService_StreamServer) error
}

func (*StreamServer) Stream 

func (s *StreamServer) Stream(stream StreamService_StreamServer) error

type StreamServiceClient 

type StreamServiceClient interface {
	Stream(ctx context.Context, opts ...grpc.CallOption) (StreamService_StreamClient, error)
}

StreamServiceClient is the client API for StreamService 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 NewStreamServiceClient 

func NewStreamServiceClient(cc grpc.ClientConnInterface) StreamServiceClient

type StreamServiceServer 

type StreamServiceServer interface {
	Stream(StreamService_StreamServer) error
	// contains filtered or unexported methods
}

StreamServiceServer is the server API for StreamService service. All implementations must embed UnimplementedStreamServiceServer for forward compatibility

type StreamService_StreamClient 

type StreamService_StreamClient interface {
	Send(*StreamRequest) error
	Recv() (*StreamResponse, error)
	grpc.ClientStream
}

type StreamService_StreamServer 

type StreamService_StreamServer interface {
	Send(*StreamResponse) error
	Recv() (*StreamRequest, error)
	grpc.ServerStream
}

type TestSecret added in v0.8.2 

type TestSecret struct {
	Username string `protobuf:"bytes,1,opt,name=username,proto3" json:"username,omitempty"`
	Password string `protobuf:"bytes,2,opt,name=password,proto3" json:"password,omitempty"`
	// contains filtered or unexported fields
}

func (*TestSecret) CheckRedactedSecrets added in v0.8.2 

func (t *TestSecret) CheckRedactedSecrets(unredacted, redacted *TestSecret) bool

func (*TestSecret) Descriptor deprecated added in v0.8.2 

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

Deprecated: Use TestSecret.ProtoReflect.Descriptor instead.

func (*TestSecret) GetPassword added in v0.8.2 

func (x *TestSecret) GetPassword() string

func (*TestSecret) GetUsername added in v0.8.2 

func (x *TestSecret) GetUsername() string

func (*TestSecret) ProtoMessage added in v0.8.2 

func (*TestSecret) ProtoMessage()

func (*TestSecret) ProtoReflect added in v0.8.2 

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

func (*TestSecret) RedactSecrets added in v0.8.2 

func (t *TestSecret) RedactSecrets()

func (*TestSecret) Reset added in v0.8.2 

func (x *TestSecret) Reset()

func (*TestSecret) String added in v0.8.2 

func (x *TestSecret) String() string

type UnimplementedAggregatorServiceServer added in v0.9.2 

type UnimplementedAggregatorServiceServer struct {
}

UnimplementedAggregatorServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedAggregatorServiceServer) GetAll added in v0.9.2 

func (UnimplementedAggregatorServiceServer) GetAll(context.Context, *emptypb.Empty) (*Value, error)

func (UnimplementedAggregatorServiceServer) GetAllWithNestedCaching added in v0.9.2 

func (UnimplementedAggregatorServiceServer) GetAllWithNestedCaching(context.Context, *emptypb.Empty) (*Value, error)

func (UnimplementedAggregatorServiceServer) IncrementAll added in v0.9.2 

func (UnimplementedAggregatorServiceServer) IncrementAll(context.Context, *IncrementRequest) (*emptypb.Empty, error)

type UnimplementedObjectServiceServer added in v0.9.2 

type UnimplementedObjectServiceServer struct {
}

UnimplementedObjectServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedObjectServiceServer) GetObjectValue added in v0.9.2 

func (UnimplementedObjectServiceServer) GetObjectValue(context.Context, *ObjectReference) (*Value, error)

func (UnimplementedObjectServiceServer) IncrementObject added in v0.9.2 

func (UnimplementedObjectServiceServer) IncrementObject(context.Context, *IncrementObjectRequest) (*emptypb.Empty, error)

func (UnimplementedObjectServiceServer) List added in v0.9.2 

func (UnimplementedObjectServiceServer) List(context.Context, *emptypb.Empty) (*ObjectList, error)

type UnimplementedSimpleServiceServer added in v0.9.2 

type UnimplementedSimpleServiceServer struct {
}

UnimplementedSimpleServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedSimpleServiceServer) GetValue added in v0.9.2 

func (UnimplementedSimpleServiceServer) GetValue(context.Context, *emptypb.Empty) (*Value, error)

func (UnimplementedSimpleServiceServer) GetValueWithForcedClientCaching added in v0.9.2 

func (UnimplementedSimpleServiceServer) GetValueWithForcedClientCaching(context.Context, *emptypb.Empty) (*Value, error)

func (UnimplementedSimpleServiceServer) Increment added in v0.9.2 

func (UnimplementedSimpleServiceServer) Increment(context.Context, *IncrementRequest) (*emptypb.Empty, error)

type UnimplementedStreamServiceServer 

type UnimplementedStreamServiceServer struct {
}

UnimplementedStreamServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedStreamServiceServer) Stream 

func (UnimplementedStreamServiceServer) Stream(StreamService_StreamServer) error

type UnsafeAggregatorServiceServer added in v0.9.2 

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

UnsafeAggregatorServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to AggregatorServiceServer will result in compilation errors.

type UnsafeObjectServiceServer added in v0.9.2 

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

UnsafeObjectServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ObjectServiceServer will result in compilation errors.

type UnsafeSimpleServiceServer added in v0.9.2 

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

UnsafeSimpleServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to SimpleServiceServer will result in compilation errors.

type UnsafeStreamServiceServer 

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

UnsafeStreamServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to StreamServiceServer will result in compilation errors.

type Value added in v0.9.2 

type Value struct {
	Value int64 `protobuf:"varint,1,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*Value) Descriptor deprecated added in v0.9.2 

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

Deprecated: Use Value.ProtoReflect.Descriptor instead.

func (*Value) GetValue added in v0.9.2 

func (x *Value) GetValue() int64

func (*Value) ProtoMessage added in v0.9.2 

func (*Value) ProtoMessage()

func (*Value) ProtoReflect added in v0.9.2 

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

func (*Value) Reset added in v0.9.2 

func (x *Value) Reset()

func (*Value) String added in v0.9.2 

func (x *Value) String() string

type ValueResponse added in v0.8.3 

type ValueResponse struct {
	Value int `json:"value"`
}

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.