counter

package
v0.0.0-...-4e5fb1c Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jan 23, 2020 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthCounter        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowCounter          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupCounter = fmt.Errorf("proto: unexpected end of group")
)

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) MarshalTo 

func (m *CloseRequest) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

func (m *CloseResponse) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

func (m *CreateRequest) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

func (m *CreateResponse) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

func (m *DecrementRequest) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

func (m *GetRequest) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

func (m *GetResponse) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

func (m *IncrementRequest) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

func (m *SetRequest) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

func (m *SetResponse) MarshalTo(dAtA []byte) (int, 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)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.