Documentation ¶
Index ¶
- Constants
- Variables
- func RegisterIntStoreServer(s grpc.ServiceRegistrar, srv IntStoreServer)
- type GetRequest
- type IntStoreClient
- type IntStoreServer
- type IntStore_ListItemsClient
- type IntStore_ListItemsServer
- type IntStore_SetStreamClient
- type IntStore_SetStreamServer
- type IntStore_StreamChatClient
- type IntStore_StreamChatServer
- type Item
- type ListItemsRequest
- type SetResponse
- type Summary
- type UnimplementedIntStoreServer
- func (UnimplementedIntStoreServer) Get(context.Context, *GetRequest) (*Item, error)
- func (UnimplementedIntStoreServer) ListItems(*ListItemsRequest, IntStore_ListItemsServer) error
- func (UnimplementedIntStoreServer) Set(context.Context, *Item) (*SetResponse, error)
- func (UnimplementedIntStoreServer) SetStream(IntStore_SetStreamServer) error
- func (UnimplementedIntStoreServer) StreamChat(IntStore_StreamChatServer) error
- type UnsafeIntStoreServer
Constants ¶
const ( IntStore_Set_FullMethodName = "/intstore.IntStore/Set" IntStore_Get_FullMethodName = "/intstore.IntStore/Get" IntStore_ListItems_FullMethodName = "/intstore.IntStore/ListItems" IntStore_SetStream_FullMethodName = "/intstore.IntStore/SetStream" IntStore_StreamChat_FullMethodName = "/intstore.IntStore/StreamChat" )
Variables ¶
var File_intstore_proto protoreflect.FileDescriptor
var IntStore_ServiceDesc = grpc.ServiceDesc{ ServiceName: "intstore.IntStore", HandlerType: (*IntStoreServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Set", Handler: _IntStore_Set_Handler, }, { MethodName: "Get", Handler: _IntStore_Get_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "ListItems", Handler: _IntStore_ListItems_Handler, ServerStreams: true, }, { StreamName: "SetStream", Handler: _IntStore_SetStream_Handler, ClientStreams: true, }, { StreamName: "StreamChat", Handler: _IntStore_StreamChat_Handler, ServerStreams: true, ClientStreams: true, }, }, Metadata: "intstore.proto", }
IntStore_ServiceDesc is the grpc.ServiceDesc for IntStore service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterIntStoreServer ¶
func RegisterIntStoreServer(s grpc.ServiceRegistrar, srv IntStoreServer)
Types ¶
type GetRequest ¶
type GetRequest struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // contains filtered or unexported fields }
func (*GetRequest) Descriptor
deprecated
func (*GetRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetRequest.ProtoReflect.Descriptor instead.
func (*GetRequest) GetName ¶
func (x *GetRequest) GetName() string
func (*GetRequest) ProtoMessage ¶
func (*GetRequest) ProtoMessage()
func (*GetRequest) ProtoReflect ¶ added in v0.83.0
func (x *GetRequest) ProtoReflect() protoreflect.Message
func (*GetRequest) Reset ¶
func (x *GetRequest) Reset()
func (*GetRequest) String ¶
func (x *GetRequest) String() string
type IntStoreClient ¶
type IntStoreClient interface { Set(ctx context.Context, in *Item, opts ...grpc.CallOption) (*SetResponse, error) Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*Item, error) // A server-to-client streaming RPC. ListItems(ctx context.Context, in *ListItemsRequest, opts ...grpc.CallOption) (IntStore_ListItemsClient, error) // A client-to-server streaming RPC. SetStream(ctx context.Context, opts ...grpc.CallOption) (IntStore_SetStreamClient, error) // A Bidirectional streaming RPC. StreamChat(ctx context.Context, opts ...grpc.CallOption) (IntStore_StreamChatClient, error) }
IntStoreClient is the client API for IntStore 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 NewIntStoreClient ¶
func NewIntStoreClient(cc grpc.ClientConnInterface) IntStoreClient
type IntStoreServer ¶
type IntStoreServer interface { Set(context.Context, *Item) (*SetResponse, error) Get(context.Context, *GetRequest) (*Item, error) // A server-to-client streaming RPC. ListItems(*ListItemsRequest, IntStore_ListItemsServer) error // A client-to-server streaming RPC. SetStream(IntStore_SetStreamServer) error // A Bidirectional streaming RPC. StreamChat(IntStore_StreamChatServer) error // contains filtered or unexported methods }
IntStoreServer is the server API for IntStore service. All implementations must embed UnimplementedIntStoreServer for forward compatibility
type IntStore_ListItemsClient ¶
type IntStore_ListItemsClient interface { Recv() (*Item, error) grpc.ClientStream }
type IntStore_ListItemsServer ¶
type IntStore_ListItemsServer interface { Send(*Item) error grpc.ServerStream }
type Item ¶
type Item struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Value int32 `protobuf:"varint,2,opt,name=value,proto3" json:"value,omitempty"` // contains filtered or unexported fields }
func (*Item) Descriptor
deprecated
func (*Item) ProtoMessage ¶
func (*Item) ProtoMessage()
func (*Item) ProtoReflect ¶ added in v0.83.0
func (x *Item) ProtoReflect() protoreflect.Message
type ListItemsRequest ¶
type ListItemsRequest struct { // Only list items whose value is greater than this. GreaterThan int32 `protobuf:"varint,1,opt,name=greaterThan,proto3" json:"greaterThan,omitempty"` // contains filtered or unexported fields }
func (*ListItemsRequest) Descriptor
deprecated
func (*ListItemsRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListItemsRequest.ProtoReflect.Descriptor instead.
func (*ListItemsRequest) GetGreaterThan ¶ added in v0.39.0
func (x *ListItemsRequest) GetGreaterThan() int32
func (*ListItemsRequest) ProtoMessage ¶
func (*ListItemsRequest) ProtoMessage()
func (*ListItemsRequest) ProtoReflect ¶ added in v0.83.0
func (x *ListItemsRequest) ProtoReflect() protoreflect.Message
func (*ListItemsRequest) Reset ¶
func (x *ListItemsRequest) Reset()
func (*ListItemsRequest) String ¶
func (x *ListItemsRequest) String() string
type SetResponse ¶
type SetResponse struct { PrevValue int32 `protobuf:"varint,1,opt,name=prev_value,json=prevValue,proto3" json:"prev_value,omitempty"` // contains filtered or unexported fields }
func (*SetResponse) Descriptor
deprecated
func (*SetResponse) Descriptor() ([]byte, []int)
Deprecated: Use SetResponse.ProtoReflect.Descriptor instead.
func (*SetResponse) GetPrevValue ¶
func (x *SetResponse) GetPrevValue() int32
func (*SetResponse) ProtoMessage ¶
func (*SetResponse) ProtoMessage()
func (*SetResponse) ProtoReflect ¶ added in v0.83.0
func (x *SetResponse) ProtoReflect() protoreflect.Message
func (*SetResponse) Reset ¶
func (x *SetResponse) Reset()
func (*SetResponse) String ¶
func (x *SetResponse) String() string
type Summary ¶
type Summary struct { Count int32 `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"` // contains filtered or unexported fields }
func (*Summary) Descriptor
deprecated
func (*Summary) ProtoMessage ¶
func (*Summary) ProtoMessage()
func (*Summary) ProtoReflect ¶ added in v0.83.0
func (x *Summary) ProtoReflect() protoreflect.Message
type UnimplementedIntStoreServer ¶ added in v0.83.0
type UnimplementedIntStoreServer struct { }
UnimplementedIntStoreServer must be embedded to have forward compatible implementations.
func (UnimplementedIntStoreServer) Get ¶ added in v0.83.0
func (UnimplementedIntStoreServer) Get(context.Context, *GetRequest) (*Item, error)
func (UnimplementedIntStoreServer) ListItems ¶ added in v0.83.0
func (UnimplementedIntStoreServer) ListItems(*ListItemsRequest, IntStore_ListItemsServer) error
func (UnimplementedIntStoreServer) Set ¶ added in v0.83.0
func (UnimplementedIntStoreServer) Set(context.Context, *Item) (*SetResponse, error)
func (UnimplementedIntStoreServer) SetStream ¶ added in v0.83.0
func (UnimplementedIntStoreServer) SetStream(IntStore_SetStreamServer) error
func (UnimplementedIntStoreServer) StreamChat ¶ added in v0.83.0
func (UnimplementedIntStoreServer) StreamChat(IntStore_StreamChatServer) error
type UnsafeIntStoreServer ¶ added in v0.113.0
type UnsafeIntStoreServer interface {
// contains filtered or unexported methods
}
UnsafeIntStoreServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to IntStoreServer will result in compilation errors.