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"
)
var File_intstore_proto protoreflect.FileDescriptor
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)
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", }
func RegisterIntStoreServer(s grpc.ServiceRegistrar, srv IntStoreServer)
type GetRequest struct {
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// contains filtered or unexported fields
}
func (*GetRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetRequest.ProtoReflect.Descriptor instead.
func (x *GetRequest) GetName() string
func (*GetRequest) ProtoMessage()
func (x *GetRequest) ProtoReflect() protoreflect.Message
func (x *GetRequest) Reset()
func (x *GetRequest) String() string
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.
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)
}
func NewIntStoreClient(cc grpc.ClientConnInterface) IntStoreClient
IntStoreServer is the server API for IntStore service. All implementations must embed UnimplementedIntStoreServer for forward compatibility
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
}
type IntStore_ListItemsClient interface {
Recv() (*Item, error)
grpc.ClientStream
}
type IntStore_ListItemsServer interface {
Send(*Item) error
grpc.ServerStream
}
type IntStore_SetStreamClient interface {
Send(*Item) error
CloseAndRecv() (*Summary, error)
grpc.ClientStream
}
type IntStore_SetStreamServer interface {
SendAndClose(*Summary) error
Recv() (*Item, error)
grpc.ServerStream
}
type IntStore_StreamChatClient interface {
Send(*Item) error
Recv() (*Item, error)
grpc.ClientStream
}
type IntStore_StreamChatServer interface {
Send(*Item) error
Recv() (*Item, error)
grpc.ServerStream
}
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() ([]byte, []int)
Deprecated: Use Item.ProtoReflect.Descriptor instead.
func (x *Item) GetName() string
func (x *Item) GetValue() int32
func (*Item) ProtoMessage()
func (x *Item) ProtoReflect() protoreflect.Message
func (x *Item) Reset()
func (x *Item) String() string
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() ([]byte, []int)
Deprecated: Use ListItemsRequest.ProtoReflect.Descriptor instead.
func (x *ListItemsRequest) GetGreaterThan() int32
func (*ListItemsRequest) ProtoMessage()
func (x *ListItemsRequest) ProtoReflect() protoreflect.Message
func (x *ListItemsRequest) Reset()
func (x *ListItemsRequest) String() string
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() ([]byte, []int)
Deprecated: Use SetResponse.ProtoReflect.Descriptor instead.
func (x *SetResponse) GetPrevValue() int32
func (*SetResponse) ProtoMessage()
func (x *SetResponse) ProtoReflect() protoreflect.Message
func (x *SetResponse) Reset()
func (x *SetResponse) String() string
type Summary struct {
Count int32 `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"`
// contains filtered or unexported fields
}
func (*Summary) Descriptor() ([]byte, []int)
Deprecated: Use Summary.ProtoReflect.Descriptor instead.
func (x *Summary) GetCount() int32
func (*Summary) ProtoMessage()
func (x *Summary) ProtoReflect() protoreflect.Message
func (x *Summary) Reset()
func (x *Summary) String() string
UnimplementedIntStoreServer must be embedded to have forward compatible implementations.
type UnimplementedIntStoreServer struct {
}
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
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.
type UnsafeIntStoreServer interface {
// contains filtered or unexported methods
}