- 0.116.0 (latest)
- 0.115.1
- 0.114.0
- 0.113.0
- 0.112.2
- 0.111.0
- 0.110.10
- 0.109.0
- 0.108.0
- 0.107.0
- 0.106.0
- 0.105.0
- 0.104.0
- 0.103.0
- 0.102.1
- 0.101.1
- 0.100.2
- 0.99.0
- 0.98.0
- 0.97.0
- 0.96.0
- 0.95.0
- 0.94.1
- 0.93.3
- 0.92.3
- 0.91.1
- 0.90.0
- 0.89.0
- 0.88.0
- 0.87.0
- 0.86.0
- 0.85.0
- 0.84.0
- 0.83.0
- 0.82.0
- 0.81.0
- 0.80.0
- 0.79.0
- 0.78.0
- 0.77.0
- 0.76.0
- 0.75.0
Constants
IntStore_Set_FullMethodName, IntStore_Get_FullMethodName, IntStore_ListItems_FullMethodName, IntStore_SetStream_FullMethodName, IntStore_StreamChat_FullMethodName
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
File_intstore_proto
var File_intstore_proto protoreflect.FileDescriptor
IntStore_ServiceDesc
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)
GetRequest
type GetRequest struct {
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// contains filtered or unexported fields
}
func (*GetRequest) Descriptor
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
func (x *GetRequest) ProtoReflect() protoreflect.Message
func (*GetRequest) Reset
func (x *GetRequest) Reset()
func (*GetRequest) String
func (x *GetRequest) String() string
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
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
IntStore_ListItemsClient
type IntStore_ListItemsClient interface {
Recv() (*Item, error)
grpc.ClientStream
}
IntStore_ListItemsServer
type IntStore_ListItemsServer interface {
Send(*Item) error
grpc.ServerStream
}
IntStore_SetStreamClient
type IntStore_SetStreamClient interface {
Send(*Item) error
CloseAndRecv() (*Summary, error)
grpc.ClientStream
}
IntStore_SetStreamServer
type IntStore_SetStreamServer interface {
SendAndClose(*Summary) error
Recv() (*Item, error)
grpc.ServerStream
}
IntStore_StreamChatClient
type IntStore_StreamChatClient interface {
Send(*Item) error
Recv() (*Item, error)
grpc.ClientStream
}
IntStore_StreamChatServer
type IntStore_StreamChatServer interface {
Send(*Item) error
Recv() (*Item, error)
grpc.ServerStream
}
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: Use Item.ProtoReflect.Descriptor instead.
func (*Item) GetName
func (*Item) GetValue
func (*Item) ProtoMessage
func (*Item) ProtoMessage()
func (*Item) ProtoReflect
func (x *Item) ProtoReflect() protoreflect.Message
func (*Item) Reset
func (x *Item) Reset()
func (*Item) String
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
func (*ListItemsRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListItemsRequest.ProtoReflect.Descriptor instead.
func (*ListItemsRequest) GetGreaterThan
func (x *ListItemsRequest) GetGreaterThan() int32
func (*ListItemsRequest) ProtoMessage
func (*ListItemsRequest) ProtoMessage()
func (*ListItemsRequest) ProtoReflect
func (x *ListItemsRequest) ProtoReflect() protoreflect.Message
func (*ListItemsRequest) Reset
func (x *ListItemsRequest) Reset()
func (*ListItemsRequest) String
func (x *ListItemsRequest) String() string
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
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
func (x *SetResponse) ProtoReflect() protoreflect.Message
func (*SetResponse) Reset
func (x *SetResponse) Reset()
func (*SetResponse) String
func (x *SetResponse) String() string
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: Use Summary.ProtoReflect.Descriptor instead.
func (*Summary) GetCount
func (*Summary) ProtoMessage
func (*Summary) ProtoMessage()
func (*Summary) ProtoReflect
func (x *Summary) ProtoReflect() protoreflect.Message
func (*Summary) Reset
func (x *Summary) Reset()
func (*Summary) String
UnimplementedIntStoreServer
type UnimplementedIntStoreServer struct {
}
UnimplementedIntStoreServer must be embedded to have forward compatible implementations.
func (UnimplementedIntStoreServer) Get
func (UnimplementedIntStoreServer) Get(context.Context, *GetRequest) (*Item, error)
func (UnimplementedIntStoreServer) ListItems
func (UnimplementedIntStoreServer) ListItems(*ListItemsRequest, IntStore_ListItemsServer) error
func (UnimplementedIntStoreServer) Set
func (UnimplementedIntStoreServer) Set(context.Context, *Item) (*SetResponse, error)
func (UnimplementedIntStoreServer) SetStream
func (UnimplementedIntStoreServer) SetStream(IntStore_SetStreamServer) error
func (UnimplementedIntStoreServer) StreamChat
func (UnimplementedIntStoreServer) StreamChat(IntStore_StreamChatServer) error
UnsafeIntStoreServer
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.