Documentation ¶
Index ¶
- Variables
- func RegisterCounterServiceServer(s *grpc.Server, srv CounterServiceServer)
- type CheckAndSetRequest
- func (*CheckAndSetRequest) Descriptor() ([]byte, []int)
- func (m *CheckAndSetRequest) GetExpect() int64
- func (m *CheckAndSetRequest) GetHeader() *headers.RequestHeader
- func (m *CheckAndSetRequest) GetUpdate() int64
- func (m *CheckAndSetRequest) Marshal() (dAtA []byte, err error)
- func (m *CheckAndSetRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *CheckAndSetRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*CheckAndSetRequest) ProtoMessage()
- func (m *CheckAndSetRequest) Reset()
- func (m *CheckAndSetRequest) Size() (n int)
- func (m *CheckAndSetRequest) String() string
- func (m *CheckAndSetRequest) Unmarshal(dAtA []byte) error
- func (m *CheckAndSetRequest) XXX_DiscardUnknown()
- func (m *CheckAndSetRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CheckAndSetRequest) XXX_Merge(src proto.Message)
- func (m *CheckAndSetRequest) XXX_Size() int
- func (m *CheckAndSetRequest) XXX_Unmarshal(b []byte) error
- type CheckAndSetResponse
- func (*CheckAndSetResponse) Descriptor() ([]byte, []int)
- func (m *CheckAndSetResponse) GetHeader() *headers.ResponseHeader
- func (m *CheckAndSetResponse) GetSucceeded() bool
- func (m *CheckAndSetResponse) Marshal() (dAtA []byte, err error)
- func (m *CheckAndSetResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *CheckAndSetResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*CheckAndSetResponse) ProtoMessage()
- func (m *CheckAndSetResponse) Reset()
- func (m *CheckAndSetResponse) Size() (n int)
- func (m *CheckAndSetResponse) String() string
- func (m *CheckAndSetResponse) Unmarshal(dAtA []byte) error
- func (m *CheckAndSetResponse) XXX_DiscardUnknown()
- func (m *CheckAndSetResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CheckAndSetResponse) XXX_Merge(src proto.Message)
- func (m *CheckAndSetResponse) XXX_Size() int
- func (m *CheckAndSetResponse) XXX_Unmarshal(b []byte) error
- type CloseRequest
- func (*CloseRequest) Descriptor() ([]byte, []int)
- func (m *CloseRequest) GetDelete() bool
- func (m *CloseRequest) GetHeader() *headers.RequestHeader
- func (m *CloseRequest) Marshal() (dAtA []byte, err error)
- func (m *CloseRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *CloseRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*CloseRequest) ProtoMessage()
- func (m *CloseRequest) Reset()
- func (m *CloseRequest) Size() (n int)
- func (m *CloseRequest) String() string
- func (m *CloseRequest) Unmarshal(dAtA []byte) error
- func (m *CloseRequest) XXX_DiscardUnknown()
- func (m *CloseRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CloseRequest) XXX_Merge(src proto.Message)
- func (m *CloseRequest) XXX_Size() int
- func (m *CloseRequest) XXX_Unmarshal(b []byte) error
- type CloseResponse
- func (*CloseResponse) Descriptor() ([]byte, []int)
- func (m *CloseResponse) GetHeader() *headers.ResponseHeader
- func (m *CloseResponse) Marshal() (dAtA []byte, err error)
- func (m *CloseResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *CloseResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*CloseResponse) ProtoMessage()
- func (m *CloseResponse) Reset()
- func (m *CloseResponse) Size() (n int)
- func (m *CloseResponse) String() string
- func (m *CloseResponse) Unmarshal(dAtA []byte) error
- func (m *CloseResponse) XXX_DiscardUnknown()
- func (m *CloseResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CloseResponse) XXX_Merge(src proto.Message)
- func (m *CloseResponse) XXX_Size() int
- func (m *CloseResponse) XXX_Unmarshal(b []byte) error
- type CounterServiceClient
- type CounterServiceServer
- type CreateRequest
- func (*CreateRequest) Descriptor() ([]byte, []int)
- func (m *CreateRequest) GetHeader() *headers.RequestHeader
- func (m *CreateRequest) Marshal() (dAtA []byte, err error)
- func (m *CreateRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *CreateRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*CreateRequest) ProtoMessage()
- func (m *CreateRequest) Reset()
- func (m *CreateRequest) Size() (n int)
- func (m *CreateRequest) String() string
- func (m *CreateRequest) Unmarshal(dAtA []byte) error
- func (m *CreateRequest) XXX_DiscardUnknown()
- func (m *CreateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CreateRequest) XXX_Merge(src proto.Message)
- func (m *CreateRequest) XXX_Size() int
- func (m *CreateRequest) XXX_Unmarshal(b []byte) error
- type CreateResponse
- func (*CreateResponse) Descriptor() ([]byte, []int)
- func (m *CreateResponse) GetHeader() *headers.ResponseHeader
- func (m *CreateResponse) Marshal() (dAtA []byte, err error)
- func (m *CreateResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *CreateResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*CreateResponse) ProtoMessage()
- func (m *CreateResponse) Reset()
- func (m *CreateResponse) Size() (n int)
- func (m *CreateResponse) String() string
- func (m *CreateResponse) Unmarshal(dAtA []byte) error
- func (m *CreateResponse) XXX_DiscardUnknown()
- func (m *CreateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CreateResponse) XXX_Merge(src proto.Message)
- func (m *CreateResponse) XXX_Size() int
- func (m *CreateResponse) XXX_Unmarshal(b []byte) error
- type DecrementRequest
- func (*DecrementRequest) Descriptor() ([]byte, []int)
- func (m *DecrementRequest) GetDelta() int64
- func (m *DecrementRequest) GetHeader() *headers.RequestHeader
- func (m *DecrementRequest) Marshal() (dAtA []byte, err error)
- func (m *DecrementRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *DecrementRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*DecrementRequest) ProtoMessage()
- func (m *DecrementRequest) Reset()
- func (m *DecrementRequest) Size() (n int)
- func (m *DecrementRequest) String() string
- func (m *DecrementRequest) Unmarshal(dAtA []byte) error
- func (m *DecrementRequest) XXX_DiscardUnknown()
- func (m *DecrementRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DecrementRequest) XXX_Merge(src proto.Message)
- func (m *DecrementRequest) XXX_Size() int
- func (m *DecrementRequest) XXX_Unmarshal(b []byte) error
- type DecrementResponse
- func (*DecrementResponse) Descriptor() ([]byte, []int)
- func (m *DecrementResponse) GetHeader() *headers.ResponseHeader
- func (m *DecrementResponse) GetNextValue() int64
- func (m *DecrementResponse) GetPreviousValue() int64
- func (m *DecrementResponse) Marshal() (dAtA []byte, err error)
- func (m *DecrementResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *DecrementResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*DecrementResponse) ProtoMessage()
- func (m *DecrementResponse) Reset()
- func (m *DecrementResponse) Size() (n int)
- func (m *DecrementResponse) String() string
- func (m *DecrementResponse) Unmarshal(dAtA []byte) error
- func (m *DecrementResponse) XXX_DiscardUnknown()
- func (m *DecrementResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DecrementResponse) XXX_Merge(src proto.Message)
- func (m *DecrementResponse) XXX_Size() int
- func (m *DecrementResponse) XXX_Unmarshal(b []byte) error
- type GetRequest
- func (*GetRequest) Descriptor() ([]byte, []int)
- func (m *GetRequest) GetHeader() *headers.RequestHeader
- func (m *GetRequest) Marshal() (dAtA []byte, err error)
- func (m *GetRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *GetRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GetRequest) ProtoMessage()
- func (m *GetRequest) Reset()
- func (m *GetRequest) Size() (n int)
- func (m *GetRequest) String() string
- func (m *GetRequest) Unmarshal(dAtA []byte) error
- func (m *GetRequest) XXX_DiscardUnknown()
- func (m *GetRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetRequest) XXX_Merge(src proto.Message)
- func (m *GetRequest) XXX_Size() int
- func (m *GetRequest) XXX_Unmarshal(b []byte) error
- type GetResponse
- func (*GetResponse) Descriptor() ([]byte, []int)
- func (m *GetResponse) GetHeader() *headers.ResponseHeader
- func (m *GetResponse) GetValue() int64
- func (m *GetResponse) Marshal() (dAtA []byte, err error)
- func (m *GetResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *GetResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GetResponse) ProtoMessage()
- func (m *GetResponse) Reset()
- func (m *GetResponse) Size() (n int)
- func (m *GetResponse) String() string
- func (m *GetResponse) Unmarshal(dAtA []byte) error
- func (m *GetResponse) XXX_DiscardUnknown()
- func (m *GetResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetResponse) XXX_Merge(src proto.Message)
- func (m *GetResponse) XXX_Size() int
- func (m *GetResponse) XXX_Unmarshal(b []byte) error
- type IncrementRequest
- func (*IncrementRequest) Descriptor() ([]byte, []int)
- func (m *IncrementRequest) GetDelta() int64
- func (m *IncrementRequest) GetHeader() *headers.RequestHeader
- func (m *IncrementRequest) Marshal() (dAtA []byte, err error)
- func (m *IncrementRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *IncrementRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*IncrementRequest) ProtoMessage()
- func (m *IncrementRequest) Reset()
- func (m *IncrementRequest) Size() (n int)
- func (m *IncrementRequest) String() string
- func (m *IncrementRequest) Unmarshal(dAtA []byte) error
- func (m *IncrementRequest) XXX_DiscardUnknown()
- func (m *IncrementRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *IncrementRequest) XXX_Merge(src proto.Message)
- func (m *IncrementRequest) XXX_Size() int
- func (m *IncrementRequest) XXX_Unmarshal(b []byte) error
- type IncrementResponse
- func (*IncrementResponse) Descriptor() ([]byte, []int)
- func (m *IncrementResponse) GetHeader() *headers.ResponseHeader
- func (m *IncrementResponse) GetNextValue() int64
- func (m *IncrementResponse) GetPreviousValue() int64
- func (m *IncrementResponse) Marshal() (dAtA []byte, err error)
- func (m *IncrementResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *IncrementResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*IncrementResponse) ProtoMessage()
- func (m *IncrementResponse) Reset()
- func (m *IncrementResponse) Size() (n int)
- func (m *IncrementResponse) String() string
- func (m *IncrementResponse) Unmarshal(dAtA []byte) error
- func (m *IncrementResponse) XXX_DiscardUnknown()
- func (m *IncrementResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *IncrementResponse) XXX_Merge(src proto.Message)
- func (m *IncrementResponse) XXX_Size() int
- func (m *IncrementResponse) XXX_Unmarshal(b []byte) error
- type SetRequest
- func (*SetRequest) Descriptor() ([]byte, []int)
- func (m *SetRequest) GetHeader() *headers.RequestHeader
- func (m *SetRequest) GetValue() int64
- func (m *SetRequest) Marshal() (dAtA []byte, err error)
- func (m *SetRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *SetRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*SetRequest) ProtoMessage()
- func (m *SetRequest) Reset()
- func (m *SetRequest) Size() (n int)
- func (m *SetRequest) String() string
- func (m *SetRequest) Unmarshal(dAtA []byte) error
- func (m *SetRequest) XXX_DiscardUnknown()
- func (m *SetRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SetRequest) XXX_Merge(src proto.Message)
- func (m *SetRequest) XXX_Size() int
- func (m *SetRequest) XXX_Unmarshal(b []byte) error
- type SetResponse
- func (*SetResponse) Descriptor() ([]byte, []int)
- func (m *SetResponse) GetHeader() *headers.ResponseHeader
- func (m *SetResponse) GetPreviousValue() int64
- func (m *SetResponse) Marshal() (dAtA []byte, err error)
- func (m *SetResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *SetResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*SetResponse) ProtoMessage()
- func (m *SetResponse) Reset()
- func (m *SetResponse) Size() (n int)
- func (m *SetResponse) String() string
- func (m *SetResponse) Unmarshal(dAtA []byte) error
- func (m *SetResponse) XXX_DiscardUnknown()
- func (m *SetResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SetResponse) XXX_Merge(src proto.Message)
- func (m *SetResponse) XXX_Size() int
- func (m *SetResponse) XXX_Unmarshal(b []byte) error
- type UnimplementedCounterServiceServer
- func (*UnimplementedCounterServiceServer) CheckAndSet(ctx context.Context, req *CheckAndSetRequest) (*CheckAndSetResponse, error)
- func (*UnimplementedCounterServiceServer) Close(ctx context.Context, req *CloseRequest) (*CloseResponse, error)
- func (*UnimplementedCounterServiceServer) Create(ctx context.Context, req *CreateRequest) (*CreateResponse, error)
- func (*UnimplementedCounterServiceServer) Decrement(ctx context.Context, req *DecrementRequest) (*DecrementResponse, error)
- func (*UnimplementedCounterServiceServer) Get(ctx context.Context, req *GetRequest) (*GetResponse, error)
- func (*UnimplementedCounterServiceServer) Increment(ctx context.Context, req *IncrementRequest) (*IncrementResponse, error)
- func (*UnimplementedCounterServiceServer) Set(ctx context.Context, req *SetRequest) (*SetResponse, error)
Constants ¶
This section is empty.
Variables ¶
Functions ¶
func RegisterCounterServiceServer ¶
func RegisterCounterServiceServer(s *grpc.Server, srv CounterServiceServer)
Types ¶
type CheckAndSetRequest ¶
type CheckAndSetRequest struct { Header *headers.RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` Expect int64 `protobuf:"varint,2,opt,name=expect,proto3" json:"expect,omitempty"` Update int64 `protobuf:"varint,3,opt,name=update,proto3" json:"update,omitempty"` }
func (*CheckAndSetRequest) Descriptor ¶
func (*CheckAndSetRequest) Descriptor() ([]byte, []int)
func (*CheckAndSetRequest) GetExpect ¶
func (m *CheckAndSetRequest) GetExpect() int64
func (*CheckAndSetRequest) GetHeader ¶
func (m *CheckAndSetRequest) GetHeader() *headers.RequestHeader
func (*CheckAndSetRequest) GetUpdate ¶
func (m *CheckAndSetRequest) GetUpdate() int64
func (*CheckAndSetRequest) Marshal ¶
func (m *CheckAndSetRequest) Marshal() (dAtA []byte, err error)
func (*CheckAndSetRequest) MarshalTo ¶
func (m *CheckAndSetRequest) MarshalTo(dAtA []byte) (int, error)
func (*CheckAndSetRequest) MarshalToSizedBuffer ¶
func (m *CheckAndSetRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*CheckAndSetRequest) ProtoMessage ¶
func (*CheckAndSetRequest) ProtoMessage()
func (*CheckAndSetRequest) Reset ¶
func (m *CheckAndSetRequest) Reset()
func (*CheckAndSetRequest) Size ¶
func (m *CheckAndSetRequest) Size() (n int)
func (*CheckAndSetRequest) String ¶
func (m *CheckAndSetRequest) String() string
func (*CheckAndSetRequest) Unmarshal ¶
func (m *CheckAndSetRequest) Unmarshal(dAtA []byte) error
func (*CheckAndSetRequest) XXX_DiscardUnknown ¶
func (m *CheckAndSetRequest) XXX_DiscardUnknown()
func (*CheckAndSetRequest) XXX_Marshal ¶
func (m *CheckAndSetRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CheckAndSetRequest) XXX_Merge ¶
func (m *CheckAndSetRequest) XXX_Merge(src proto.Message)
func (*CheckAndSetRequest) XXX_Size ¶
func (m *CheckAndSetRequest) XXX_Size() int
func (*CheckAndSetRequest) XXX_Unmarshal ¶
func (m *CheckAndSetRequest) XXX_Unmarshal(b []byte) error
type CheckAndSetResponse ¶
type CheckAndSetResponse struct { Header *headers.ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` Succeeded bool `protobuf:"varint,2,opt,name=succeeded,proto3" json:"succeeded,omitempty"` }
func (*CheckAndSetResponse) Descriptor ¶
func (*CheckAndSetResponse) Descriptor() ([]byte, []int)
func (*CheckAndSetResponse) GetHeader ¶
func (m *CheckAndSetResponse) GetHeader() *headers.ResponseHeader
func (*CheckAndSetResponse) GetSucceeded ¶
func (m *CheckAndSetResponse) GetSucceeded() bool
func (*CheckAndSetResponse) Marshal ¶
func (m *CheckAndSetResponse) Marshal() (dAtA []byte, err error)
func (*CheckAndSetResponse) MarshalTo ¶
func (m *CheckAndSetResponse) MarshalTo(dAtA []byte) (int, error)
func (*CheckAndSetResponse) MarshalToSizedBuffer ¶
func (m *CheckAndSetResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*CheckAndSetResponse) ProtoMessage ¶
func (*CheckAndSetResponse) ProtoMessage()
func (*CheckAndSetResponse) Reset ¶
func (m *CheckAndSetResponse) Reset()
func (*CheckAndSetResponse) Size ¶
func (m *CheckAndSetResponse) Size() (n int)
func (*CheckAndSetResponse) String ¶
func (m *CheckAndSetResponse) String() string
func (*CheckAndSetResponse) Unmarshal ¶
func (m *CheckAndSetResponse) Unmarshal(dAtA []byte) error
func (*CheckAndSetResponse) XXX_DiscardUnknown ¶
func (m *CheckAndSetResponse) XXX_DiscardUnknown()
func (*CheckAndSetResponse) XXX_Marshal ¶
func (m *CheckAndSetResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CheckAndSetResponse) XXX_Merge ¶
func (m *CheckAndSetResponse) XXX_Merge(src proto.Message)
func (*CheckAndSetResponse) XXX_Size ¶
func (m *CheckAndSetResponse) XXX_Size() int
func (*CheckAndSetResponse) XXX_Unmarshal ¶
func (m *CheckAndSetResponse) XXX_Unmarshal(b []byte) error
type CloseRequest ¶
type CloseRequest struct { Header *headers.RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` Delete bool `protobuf:"varint,2,opt,name=delete,proto3" json:"delete,omitempty"` }
func (*CloseRequest) Descriptor ¶
func (*CloseRequest) Descriptor() ([]byte, []int)
func (*CloseRequest) GetDelete ¶
func (m *CloseRequest) GetDelete() bool
func (*CloseRequest) GetHeader ¶
func (m *CloseRequest) GetHeader() *headers.RequestHeader
func (*CloseRequest) Marshal ¶
func (m *CloseRequest) Marshal() (dAtA []byte, err error)
func (*CloseRequest) MarshalToSizedBuffer ¶
func (m *CloseRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*CloseRequest) ProtoMessage ¶
func (*CloseRequest) ProtoMessage()
func (*CloseRequest) Reset ¶
func (m *CloseRequest) Reset()
func (*CloseRequest) Size ¶
func (m *CloseRequest) Size() (n int)
func (*CloseRequest) String ¶
func (m *CloseRequest) String() string
func (*CloseRequest) Unmarshal ¶
func (m *CloseRequest) Unmarshal(dAtA []byte) error
func (*CloseRequest) XXX_DiscardUnknown ¶
func (m *CloseRequest) XXX_DiscardUnknown()
func (*CloseRequest) XXX_Marshal ¶
func (m *CloseRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CloseRequest) XXX_Merge ¶
func (m *CloseRequest) XXX_Merge(src proto.Message)
func (*CloseRequest) XXX_Size ¶
func (m *CloseRequest) XXX_Size() int
func (*CloseRequest) XXX_Unmarshal ¶
func (m *CloseRequest) XXX_Unmarshal(b []byte) error
type CloseResponse ¶
type CloseResponse struct {
Header *headers.ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
}
func (*CloseResponse) Descriptor ¶
func (*CloseResponse) Descriptor() ([]byte, []int)
func (*CloseResponse) GetHeader ¶
func (m *CloseResponse) GetHeader() *headers.ResponseHeader
func (*CloseResponse) Marshal ¶
func (m *CloseResponse) Marshal() (dAtA []byte, err error)
func (*CloseResponse) MarshalToSizedBuffer ¶
func (m *CloseResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*CloseResponse) ProtoMessage ¶
func (*CloseResponse) ProtoMessage()
func (*CloseResponse) Reset ¶
func (m *CloseResponse) Reset()
func (*CloseResponse) Size ¶
func (m *CloseResponse) Size() (n int)
func (*CloseResponse) String ¶
func (m *CloseResponse) String() string
func (*CloseResponse) Unmarshal ¶
func (m *CloseResponse) Unmarshal(dAtA []byte) error
func (*CloseResponse) XXX_DiscardUnknown ¶
func (m *CloseResponse) XXX_DiscardUnknown()
func (*CloseResponse) XXX_Marshal ¶
func (m *CloseResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CloseResponse) XXX_Merge ¶
func (m *CloseResponse) XXX_Merge(src proto.Message)
func (*CloseResponse) XXX_Size ¶
func (m *CloseResponse) XXX_Size() int
func (*CloseResponse) XXX_Unmarshal ¶
func (m *CloseResponse) XXX_Unmarshal(b []byte) error
type CounterServiceClient ¶
type CounterServiceClient interface { Create(ctx context.Context, in *CreateRequest, opts ...grpc.CallOption) (*CreateResponse, error) Close(ctx context.Context, in *CloseRequest, opts ...grpc.CallOption) (*CloseResponse, error) Set(ctx context.Context, in *SetRequest, opts ...grpc.CallOption) (*SetResponse, error) Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetResponse, error) Increment(ctx context.Context, in *IncrementRequest, opts ...grpc.CallOption) (*IncrementResponse, error) Decrement(ctx context.Context, in *DecrementRequest, opts ...grpc.CallOption) (*DecrementResponse, error) CheckAndSet(ctx context.Context, in *CheckAndSetRequest, opts ...grpc.CallOption) (*CheckAndSetResponse, error) }
CounterServiceClient is the client API for CounterService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewCounterServiceClient ¶
func NewCounterServiceClient(cc *grpc.ClientConn) CounterServiceClient
type CounterServiceServer ¶
type CounterServiceServer interface { Create(context.Context, *CreateRequest) (*CreateResponse, error) Close(context.Context, *CloseRequest) (*CloseResponse, error) Set(context.Context, *SetRequest) (*SetResponse, error) Get(context.Context, *GetRequest) (*GetResponse, error) Increment(context.Context, *IncrementRequest) (*IncrementResponse, error) Decrement(context.Context, *DecrementRequest) (*DecrementResponse, error) CheckAndSet(context.Context, *CheckAndSetRequest) (*CheckAndSetResponse, error) }
CounterServiceServer is the server API for CounterService service.
type CreateRequest ¶
type CreateRequest struct {
Header *headers.RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
}
func (*CreateRequest) Descriptor ¶
func (*CreateRequest) Descriptor() ([]byte, []int)
func (*CreateRequest) GetHeader ¶
func (m *CreateRequest) GetHeader() *headers.RequestHeader
func (*CreateRequest) Marshal ¶
func (m *CreateRequest) Marshal() (dAtA []byte, err error)
func (*CreateRequest) MarshalToSizedBuffer ¶
func (m *CreateRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*CreateRequest) ProtoMessage ¶
func (*CreateRequest) ProtoMessage()
func (*CreateRequest) Reset ¶
func (m *CreateRequest) Reset()
func (*CreateRequest) Size ¶
func (m *CreateRequest) Size() (n int)
func (*CreateRequest) String ¶
func (m *CreateRequest) String() string
func (*CreateRequest) Unmarshal ¶
func (m *CreateRequest) Unmarshal(dAtA []byte) error
func (*CreateRequest) XXX_DiscardUnknown ¶
func (m *CreateRequest) XXX_DiscardUnknown()
func (*CreateRequest) XXX_Marshal ¶
func (m *CreateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CreateRequest) XXX_Merge ¶
func (m *CreateRequest) XXX_Merge(src proto.Message)
func (*CreateRequest) XXX_Size ¶
func (m *CreateRequest) XXX_Size() int
func (*CreateRequest) XXX_Unmarshal ¶
func (m *CreateRequest) XXX_Unmarshal(b []byte) error
type CreateResponse ¶
type CreateResponse struct {
Header *headers.ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
}
func (*CreateResponse) Descriptor ¶
func (*CreateResponse) Descriptor() ([]byte, []int)
func (*CreateResponse) GetHeader ¶
func (m *CreateResponse) GetHeader() *headers.ResponseHeader
func (*CreateResponse) Marshal ¶
func (m *CreateResponse) Marshal() (dAtA []byte, err error)
func (*CreateResponse) MarshalToSizedBuffer ¶
func (m *CreateResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*CreateResponse) ProtoMessage ¶
func (*CreateResponse) ProtoMessage()
func (*CreateResponse) Reset ¶
func (m *CreateResponse) Reset()
func (*CreateResponse) Size ¶
func (m *CreateResponse) Size() (n int)
func (*CreateResponse) String ¶
func (m *CreateResponse) String() string
func (*CreateResponse) Unmarshal ¶
func (m *CreateResponse) Unmarshal(dAtA []byte) error
func (*CreateResponse) XXX_DiscardUnknown ¶
func (m *CreateResponse) XXX_DiscardUnknown()
func (*CreateResponse) XXX_Marshal ¶
func (m *CreateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CreateResponse) XXX_Merge ¶
func (m *CreateResponse) XXX_Merge(src proto.Message)
func (*CreateResponse) XXX_Size ¶
func (m *CreateResponse) XXX_Size() int
func (*CreateResponse) XXX_Unmarshal ¶
func (m *CreateResponse) XXX_Unmarshal(b []byte) error
type DecrementRequest ¶
type DecrementRequest struct { Header *headers.RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` Delta int64 `protobuf:"varint,2,opt,name=delta,proto3" json:"delta,omitempty"` }
func (*DecrementRequest) Descriptor ¶
func (*DecrementRequest) Descriptor() ([]byte, []int)
func (*DecrementRequest) GetDelta ¶
func (m *DecrementRequest) GetDelta() int64
func (*DecrementRequest) GetHeader ¶
func (m *DecrementRequest) GetHeader() *headers.RequestHeader
func (*DecrementRequest) Marshal ¶
func (m *DecrementRequest) Marshal() (dAtA []byte, err error)
func (*DecrementRequest) MarshalToSizedBuffer ¶
func (m *DecrementRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*DecrementRequest) ProtoMessage ¶
func (*DecrementRequest) ProtoMessage()
func (*DecrementRequest) Reset ¶
func (m *DecrementRequest) Reset()
func (*DecrementRequest) Size ¶
func (m *DecrementRequest) Size() (n int)
func (*DecrementRequest) String ¶
func (m *DecrementRequest) String() string
func (*DecrementRequest) Unmarshal ¶
func (m *DecrementRequest) Unmarshal(dAtA []byte) error
func (*DecrementRequest) XXX_DiscardUnknown ¶
func (m *DecrementRequest) XXX_DiscardUnknown()
func (*DecrementRequest) XXX_Marshal ¶
func (m *DecrementRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DecrementRequest) XXX_Merge ¶
func (m *DecrementRequest) XXX_Merge(src proto.Message)
func (*DecrementRequest) XXX_Size ¶
func (m *DecrementRequest) XXX_Size() int
func (*DecrementRequest) XXX_Unmarshal ¶
func (m *DecrementRequest) XXX_Unmarshal(b []byte) error
type DecrementResponse ¶
type DecrementResponse struct { Header *headers.ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` PreviousValue int64 `protobuf:"varint,2,opt,name=previous_value,json=previousValue,proto3" json:"previous_value,omitempty"` NextValue int64 `protobuf:"varint,3,opt,name=next_value,json=nextValue,proto3" json:"next_value,omitempty"` }
func (*DecrementResponse) Descriptor ¶
func (*DecrementResponse) Descriptor() ([]byte, []int)
func (*DecrementResponse) GetHeader ¶
func (m *DecrementResponse) GetHeader() *headers.ResponseHeader
func (*DecrementResponse) GetNextValue ¶
func (m *DecrementResponse) GetNextValue() int64
func (*DecrementResponse) GetPreviousValue ¶
func (m *DecrementResponse) GetPreviousValue() int64
func (*DecrementResponse) Marshal ¶
func (m *DecrementResponse) Marshal() (dAtA []byte, err error)
func (*DecrementResponse) MarshalTo ¶
func (m *DecrementResponse) MarshalTo(dAtA []byte) (int, error)
func (*DecrementResponse) MarshalToSizedBuffer ¶
func (m *DecrementResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*DecrementResponse) ProtoMessage ¶
func (*DecrementResponse) ProtoMessage()
func (*DecrementResponse) Reset ¶
func (m *DecrementResponse) Reset()
func (*DecrementResponse) Size ¶
func (m *DecrementResponse) Size() (n int)
func (*DecrementResponse) String ¶
func (m *DecrementResponse) String() string
func (*DecrementResponse) Unmarshal ¶
func (m *DecrementResponse) Unmarshal(dAtA []byte) error
func (*DecrementResponse) XXX_DiscardUnknown ¶
func (m *DecrementResponse) XXX_DiscardUnknown()
func (*DecrementResponse) XXX_Marshal ¶
func (m *DecrementResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DecrementResponse) XXX_Merge ¶
func (m *DecrementResponse) XXX_Merge(src proto.Message)
func (*DecrementResponse) XXX_Size ¶
func (m *DecrementResponse) XXX_Size() int
func (*DecrementResponse) XXX_Unmarshal ¶
func (m *DecrementResponse) XXX_Unmarshal(b []byte) error
type GetRequest ¶
type GetRequest struct {
Header *headers.RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
}
func (*GetRequest) Descriptor ¶
func (*GetRequest) Descriptor() ([]byte, []int)
func (*GetRequest) GetHeader ¶
func (m *GetRequest) GetHeader() *headers.RequestHeader
func (*GetRequest) Marshal ¶
func (m *GetRequest) Marshal() (dAtA []byte, err error)
func (*GetRequest) MarshalToSizedBuffer ¶
func (m *GetRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*GetRequest) ProtoMessage ¶
func (*GetRequest) ProtoMessage()
func (*GetRequest) Reset ¶
func (m *GetRequest) Reset()
func (*GetRequest) Size ¶
func (m *GetRequest) Size() (n int)
func (*GetRequest) String ¶
func (m *GetRequest) String() string
func (*GetRequest) Unmarshal ¶
func (m *GetRequest) Unmarshal(dAtA []byte) error
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 (m *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
type GetResponse ¶
type GetResponse struct { Header *headers.ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` Value int64 `protobuf:"varint,2,opt,name=value,proto3" json:"value,omitempty"` }
func (*GetResponse) Descriptor ¶
func (*GetResponse) Descriptor() ([]byte, []int)
func (*GetResponse) GetHeader ¶
func (m *GetResponse) GetHeader() *headers.ResponseHeader
func (*GetResponse) GetValue ¶
func (m *GetResponse) GetValue() int64
func (*GetResponse) Marshal ¶
func (m *GetResponse) Marshal() (dAtA []byte, err error)
func (*GetResponse) MarshalToSizedBuffer ¶
func (m *GetResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*GetResponse) ProtoMessage ¶
func (*GetResponse) ProtoMessage()
func (*GetResponse) Reset ¶
func (m *GetResponse) Reset()
func (*GetResponse) Size ¶
func (m *GetResponse) Size() (n int)
func (*GetResponse) String ¶
func (m *GetResponse) String() string
func (*GetResponse) Unmarshal ¶
func (m *GetResponse) Unmarshal(dAtA []byte) error
func (*GetResponse) XXX_DiscardUnknown ¶
func (m *GetResponse) XXX_DiscardUnknown()
func (*GetResponse) XXX_Marshal ¶
func (m *GetResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetResponse) XXX_Merge ¶
func (m *GetResponse) XXX_Merge(src proto.Message)
func (*GetResponse) XXX_Size ¶
func (m *GetResponse) XXX_Size() int
func (*GetResponse) XXX_Unmarshal ¶
func (m *GetResponse) XXX_Unmarshal(b []byte) error
type IncrementRequest ¶
type IncrementRequest struct { Header *headers.RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` Delta int64 `protobuf:"varint,2,opt,name=delta,proto3" json:"delta,omitempty"` }
func (*IncrementRequest) Descriptor ¶
func (*IncrementRequest) Descriptor() ([]byte, []int)
func (*IncrementRequest) GetDelta ¶
func (m *IncrementRequest) GetDelta() int64
func (*IncrementRequest) GetHeader ¶
func (m *IncrementRequest) GetHeader() *headers.RequestHeader
func (*IncrementRequest) Marshal ¶
func (m *IncrementRequest) Marshal() (dAtA []byte, err error)
func (*IncrementRequest) MarshalToSizedBuffer ¶
func (m *IncrementRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*IncrementRequest) ProtoMessage ¶
func (*IncrementRequest) ProtoMessage()
func (*IncrementRequest) Reset ¶
func (m *IncrementRequest) Reset()
func (*IncrementRequest) Size ¶
func (m *IncrementRequest) Size() (n int)
func (*IncrementRequest) String ¶
func (m *IncrementRequest) String() string
func (*IncrementRequest) Unmarshal ¶
func (m *IncrementRequest) Unmarshal(dAtA []byte) error
func (*IncrementRequest) XXX_DiscardUnknown ¶
func (m *IncrementRequest) XXX_DiscardUnknown()
func (*IncrementRequest) XXX_Marshal ¶
func (m *IncrementRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*IncrementRequest) XXX_Merge ¶
func (m *IncrementRequest) XXX_Merge(src proto.Message)
func (*IncrementRequest) XXX_Size ¶
func (m *IncrementRequest) XXX_Size() int
func (*IncrementRequest) XXX_Unmarshal ¶
func (m *IncrementRequest) XXX_Unmarshal(b []byte) error
type IncrementResponse ¶
type IncrementResponse struct { Header *headers.ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` PreviousValue int64 `protobuf:"varint,2,opt,name=previous_value,json=previousValue,proto3" json:"previous_value,omitempty"` NextValue int64 `protobuf:"varint,3,opt,name=next_value,json=nextValue,proto3" json:"next_value,omitempty"` }
func (*IncrementResponse) Descriptor ¶
func (*IncrementResponse) Descriptor() ([]byte, []int)
func (*IncrementResponse) GetHeader ¶
func (m *IncrementResponse) GetHeader() *headers.ResponseHeader
func (*IncrementResponse) GetNextValue ¶
func (m *IncrementResponse) GetNextValue() int64
func (*IncrementResponse) GetPreviousValue ¶
func (m *IncrementResponse) GetPreviousValue() int64
func (*IncrementResponse) Marshal ¶
func (m *IncrementResponse) Marshal() (dAtA []byte, err error)
func (*IncrementResponse) MarshalTo ¶
func (m *IncrementResponse) MarshalTo(dAtA []byte) (int, error)
func (*IncrementResponse) MarshalToSizedBuffer ¶
func (m *IncrementResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*IncrementResponse) ProtoMessage ¶
func (*IncrementResponse) ProtoMessage()
func (*IncrementResponse) Reset ¶
func (m *IncrementResponse) Reset()
func (*IncrementResponse) Size ¶
func (m *IncrementResponse) Size() (n int)
func (*IncrementResponse) String ¶
func (m *IncrementResponse) String() string
func (*IncrementResponse) Unmarshal ¶
func (m *IncrementResponse) Unmarshal(dAtA []byte) error
func (*IncrementResponse) XXX_DiscardUnknown ¶
func (m *IncrementResponse) XXX_DiscardUnknown()
func (*IncrementResponse) XXX_Marshal ¶
func (m *IncrementResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*IncrementResponse) XXX_Merge ¶
func (m *IncrementResponse) XXX_Merge(src proto.Message)
func (*IncrementResponse) XXX_Size ¶
func (m *IncrementResponse) XXX_Size() int
func (*IncrementResponse) XXX_Unmarshal ¶
func (m *IncrementResponse) XXX_Unmarshal(b []byte) error
type SetRequest ¶
type SetRequest struct { Header *headers.RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` Value int64 `protobuf:"varint,2,opt,name=value,proto3" json:"value,omitempty"` }
func (*SetRequest) Descriptor ¶
func (*SetRequest) Descriptor() ([]byte, []int)
func (*SetRequest) GetHeader ¶
func (m *SetRequest) GetHeader() *headers.RequestHeader
func (*SetRequest) GetValue ¶
func (m *SetRequest) GetValue() int64
func (*SetRequest) Marshal ¶
func (m *SetRequest) Marshal() (dAtA []byte, err error)
func (*SetRequest) MarshalToSizedBuffer ¶
func (m *SetRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SetRequest) ProtoMessage ¶
func (*SetRequest) ProtoMessage()
func (*SetRequest) Reset ¶
func (m *SetRequest) Reset()
func (*SetRequest) Size ¶
func (m *SetRequest) Size() (n int)
func (*SetRequest) String ¶
func (m *SetRequest) String() string
func (*SetRequest) Unmarshal ¶
func (m *SetRequest) Unmarshal(dAtA []byte) error
func (*SetRequest) XXX_DiscardUnknown ¶
func (m *SetRequest) XXX_DiscardUnknown()
func (*SetRequest) XXX_Marshal ¶
func (m *SetRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SetRequest) XXX_Merge ¶
func (m *SetRequest) XXX_Merge(src proto.Message)
func (*SetRequest) XXX_Size ¶
func (m *SetRequest) XXX_Size() int
func (*SetRequest) XXX_Unmarshal ¶
func (m *SetRequest) XXX_Unmarshal(b []byte) error
type SetResponse ¶
type SetResponse struct { Header *headers.ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` PreviousValue int64 `protobuf:"varint,2,opt,name=previous_value,json=previousValue,proto3" json:"previous_value,omitempty"` }
func (*SetResponse) Descriptor ¶
func (*SetResponse) Descriptor() ([]byte, []int)
func (*SetResponse) GetHeader ¶
func (m *SetResponse) GetHeader() *headers.ResponseHeader
func (*SetResponse) GetPreviousValue ¶
func (m *SetResponse) GetPreviousValue() int64
func (*SetResponse) Marshal ¶
func (m *SetResponse) Marshal() (dAtA []byte, err error)
func (*SetResponse) MarshalToSizedBuffer ¶
func (m *SetResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SetResponse) ProtoMessage ¶
func (*SetResponse) ProtoMessage()
func (*SetResponse) Reset ¶
func (m *SetResponse) Reset()
func (*SetResponse) Size ¶
func (m *SetResponse) Size() (n int)
func (*SetResponse) String ¶
func (m *SetResponse) String() string
func (*SetResponse) Unmarshal ¶
func (m *SetResponse) Unmarshal(dAtA []byte) error
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 (m *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
type UnimplementedCounterServiceServer ¶
type UnimplementedCounterServiceServer struct { }
UnimplementedCounterServiceServer can be embedded to have forward compatible implementations.
func (*UnimplementedCounterServiceServer) CheckAndSet ¶
func (*UnimplementedCounterServiceServer) CheckAndSet(ctx context.Context, req *CheckAndSetRequest) (*CheckAndSetResponse, error)
func (*UnimplementedCounterServiceServer) Close ¶
func (*UnimplementedCounterServiceServer) Close(ctx context.Context, req *CloseRequest) (*CloseResponse, error)
func (*UnimplementedCounterServiceServer) Create ¶
func (*UnimplementedCounterServiceServer) Create(ctx context.Context, req *CreateRequest) (*CreateResponse, error)
func (*UnimplementedCounterServiceServer) Decrement ¶
func (*UnimplementedCounterServiceServer) Decrement(ctx context.Context, req *DecrementRequest) (*DecrementResponse, error)
func (*UnimplementedCounterServiceServer) Get ¶
func (*UnimplementedCounterServiceServer) Get(ctx context.Context, req *GetRequest) (*GetResponse, error)
func (*UnimplementedCounterServiceServer) Increment ¶
func (*UnimplementedCounterServiceServer) Increment(ctx context.Context, req *IncrementRequest) (*IncrementResponse, error)
func (*UnimplementedCounterServiceServer) Set ¶
func (*UnimplementedCounterServiceServer) Set(ctx context.Context, req *SetRequest) (*SetResponse, error)
Click to show internal directories.
Click to hide internal directories.