- 0.121.6 (latest)
- 0.121.5
- 0.120.1
- 0.119.0
- 0.118.3
- 0.117.0
- 0.116.0
- 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.
