- 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
Functions
func RegisterIntStoreServer
func RegisterIntStoreServer(s *grpc.Server, srv IntStoreServer)
GetRequest
type GetRequest 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:"-"`
}
func (*GetRequest) Descriptor
func (*GetRequest) Descriptor() ([]byte, []int)
func (*GetRequest) GetName
func (m *GetRequest) GetName() string
func (*GetRequest) ProtoMessage
func (*GetRequest) ProtoMessage()
func (*GetRequest) Reset
func (m *GetRequest) Reset()
func (*GetRequest) String
func (m *GetRequest) String() string
func (*GetRequest) XXX_DiscardUnknown
func (m *GetRequest) XXX_DiscardUnknown()
func (*GetRequest) XXX_Marshal
func (m *GetRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetRequest) XXX_Merge
func (dst *GetRequest) XXX_Merge(src proto.Message)
func (*GetRequest) XXX_Size
func (m *GetRequest) XXX_Size() int
func (*GetRequest) XXX_Unmarshal
func (m *GetRequest) XXX_Unmarshal(b []byte) error
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://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewIntStoreClient
func NewIntStoreClient(cc *grpc.ClientConn) 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
}
IntStoreServer is the server API for IntStore service.
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"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*Item) Descriptor
func (*Item) GetName
func (*Item) GetValue
func (*Item) ProtoMessage
func (*Item) ProtoMessage()
func (*Item) Reset
func (m *Item) Reset()
func (*Item) String
func (*Item) XXX_DiscardUnknown
func (m *Item) XXX_DiscardUnknown()
func (*Item) XXX_Marshal
func (*Item) XXX_Merge
func (*Item) XXX_Size
func (*Item) XXX_Unmarshal
ListItemsRequest
type ListItemsRequest struct {
GreaterThan int32 `protobuf:"varint,1,opt,name=greaterThan,proto3" json:"greaterThan,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*ListItemsRequest) Descriptor
func (*ListItemsRequest) Descriptor() ([]byte, []int)
func (*ListItemsRequest) GetGreaterThan
func (m *ListItemsRequest) GetGreaterThan() int32
func (*ListItemsRequest) ProtoMessage
func (*ListItemsRequest) ProtoMessage()
func (*ListItemsRequest) Reset
func (m *ListItemsRequest) Reset()
func (*ListItemsRequest) String
func (m *ListItemsRequest) String() string
func (*ListItemsRequest) XXX_DiscardUnknown
func (m *ListItemsRequest) XXX_DiscardUnknown()
func (*ListItemsRequest) XXX_Marshal
func (m *ListItemsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ListItemsRequest) XXX_Merge
func (dst *ListItemsRequest) XXX_Merge(src proto.Message)
func (*ListItemsRequest) XXX_Size
func (m *ListItemsRequest) XXX_Size() int
func (*ListItemsRequest) XXX_Unmarshal
func (m *ListItemsRequest) XXX_Unmarshal(b []byte) error
SetResponse
type SetResponse struct {
PrevValue int32 `protobuf:"varint,1,opt,name=prev_value,json=prevValue,proto3" json:"prev_value,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*SetResponse) Descriptor
func (*SetResponse) Descriptor() ([]byte, []int)
func (*SetResponse) GetPrevValue
func (m *SetResponse) GetPrevValue() int32
func (*SetResponse) ProtoMessage
func (*SetResponse) ProtoMessage()
func (*SetResponse) Reset
func (m *SetResponse) Reset()
func (*SetResponse) String
func (m *SetResponse) String() string
func (*SetResponse) XXX_DiscardUnknown
func (m *SetResponse) XXX_DiscardUnknown()
func (*SetResponse) XXX_Marshal
func (m *SetResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SetResponse) XXX_Merge
func (dst *SetResponse) XXX_Merge(src proto.Message)
func (*SetResponse) XXX_Size
func (m *SetResponse) XXX_Size() int
func (*SetResponse) XXX_Unmarshal
func (m *SetResponse) XXX_Unmarshal(b []byte) error
Summary
type Summary struct {
Count int32 `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*Summary) Descriptor
func (*Summary) GetCount
func (*Summary) ProtoMessage
func (*Summary) ProtoMessage()
func (*Summary) Reset
func (m *Summary) Reset()
func (*Summary) String
func (*Summary) XXX_DiscardUnknown
func (m *Summary) XXX_DiscardUnknown()