counter

package
v0.8.0 Latest Latest
Warning

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

 Go to latest Published: Nov 21, 2021 License: Apache-2.0 Imports: 15 Imported by: 4

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthManager        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowManager          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupManager = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthPrimitive        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowPrimitive          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupPrimitive = fmt.Errorf("proto: unexpected end of group")
)

Functions

func RegisterCounterManagerServer added in v0.7.0 

func RegisterCounterManagerServer(s *grpc.Server, srv CounterManagerServer)

func RegisterCounterServer 

func RegisterCounterServer(s *grpc.Server, srv CounterServer)

Types

type CloseSessionRequest 

type CloseSessionRequest struct {
	SessionID github_com_atomix_atomix_api_go_atomix_primitive_v1.SessionID `` /* 160-byte string literal not displayed */
}

func (*CloseSessionRequest) Descriptor 

func (*CloseSessionRequest) Descriptor() ([]byte, []int)

func (*CloseSessionRequest) GetSessionID 

func (m *CloseSessionRequest) GetSessionID() github_com_atomix_atomix_api_go_atomix_primitive_v1.SessionID

func (*CloseSessionRequest) Marshal 

func (m *CloseSessionRequest) Marshal() (dAtA []byte, err error)

func (*CloseSessionRequest) MarshalTo 

func (m *CloseSessionRequest) MarshalTo(dAtA []byte) (int, error)

func (*CloseSessionRequest) MarshalToSizedBuffer 

func (m *CloseSessionRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CloseSessionRequest) ProtoMessage 

func (*CloseSessionRequest) ProtoMessage()

func (*CloseSessionRequest) Reset 

func (m *CloseSessionRequest) Reset()

func (*CloseSessionRequest) Size 

func (m *CloseSessionRequest) Size() (n int)

func (*CloseSessionRequest) String 

func (m *CloseSessionRequest) String() string

func (*CloseSessionRequest) Unmarshal 

func (m *CloseSessionRequest) Unmarshal(dAtA []byte) error

func (*CloseSessionRequest) XXX_DiscardUnknown 

func (m *CloseSessionRequest) XXX_DiscardUnknown()

func (*CloseSessionRequest) XXX_Marshal 

func (m *CloseSessionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CloseSessionRequest) XXX_Merge 

func (m *CloseSessionRequest) XXX_Merge(src proto.Message)

func (*CloseSessionRequest) XXX_Size 

func (m *CloseSessionRequest) XXX_Size() int

func (*CloseSessionRequest) XXX_Unmarshal 

func (m *CloseSessionRequest) XXX_Unmarshal(b []byte) error

type CloseSessionResponse 

type CloseSessionResponse struct {
}

func (*CloseSessionResponse) Descriptor 

func (*CloseSessionResponse) Descriptor() ([]byte, []int)

func (*CloseSessionResponse) Marshal 

func (m *CloseSessionResponse) Marshal() (dAtA []byte, err error)

func (*CloseSessionResponse) MarshalTo 

func (m *CloseSessionResponse) MarshalTo(dAtA []byte) (int, error)

func (*CloseSessionResponse) MarshalToSizedBuffer 

func (m *CloseSessionResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CloseSessionResponse) ProtoMessage 

func (*CloseSessionResponse) ProtoMessage()

func (*CloseSessionResponse) Reset 

func (m *CloseSessionResponse) Reset()

func (*CloseSessionResponse) Size 

func (m *CloseSessionResponse) Size() (n int)

func (*CloseSessionResponse) String 

func (m *CloseSessionResponse) String() string

func (*CloseSessionResponse) Unmarshal 

func (m *CloseSessionResponse) Unmarshal(dAtA []byte) error

func (*CloseSessionResponse) XXX_DiscardUnknown 

func (m *CloseSessionResponse) XXX_DiscardUnknown()

func (*CloseSessionResponse) XXX_Marshal 

func (m *CloseSessionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CloseSessionResponse) XXX_Merge 

func (m *CloseSessionResponse) XXX_Merge(src proto.Message)

func (*CloseSessionResponse) XXX_Size 

func (m *CloseSessionResponse) XXX_Size() int

func (*CloseSessionResponse) XXX_Unmarshal 

func (m *CloseSessionResponse) XXX_Unmarshal(b []byte) error

type CounterClient 

type CounterClient interface {
	// Set sets the counter value
	Set(ctx context.Context, in *SetRequest, opts ...grpc.CallOption) (*SetResponse, error)
	// Get gets the current counter value
	Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetResponse, error)
	// Increment increments the counter value
	Increment(ctx context.Context, in *IncrementRequest, opts ...grpc.CallOption) (*IncrementResponse, error)
	// Decrement decrements the counter value
	Decrement(ctx context.Context, in *DecrementRequest, opts ...grpc.CallOption) (*DecrementResponse, error)
}

CounterClient is the client API for Counter service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewCounterClient 

func NewCounterClient(cc *grpc.ClientConn) CounterClient

type CounterManagerClient added in v0.7.0 

type CounterManagerClient interface {
	OpenSession(ctx context.Context, in *OpenSessionRequest, opts ...grpc.CallOption) (*OpenSessionResponse, error)
	CloseSession(ctx context.Context, in *CloseSessionRequest, opts ...grpc.CallOption) (*CloseSessionResponse, error)
}

CounterManagerClient is the client API for CounterManager service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewCounterManagerClient added in v0.7.0 

func NewCounterManagerClient(cc *grpc.ClientConn) CounterManagerClient

type CounterManagerServer added in v0.7.0 

type CounterManagerServer interface {
	OpenSession(context.Context, *OpenSessionRequest) (*OpenSessionResponse, error)
	CloseSession(context.Context, *CloseSessionRequest) (*CloseSessionResponse, error)
}

CounterManagerServer is the server API for CounterManager service.

type CounterServer 

type CounterServer interface {
	// Set sets the counter value
	Set(context.Context, *SetRequest) (*SetResponse, error)
	// Get gets the current counter value
	Get(context.Context, *GetRequest) (*GetResponse, error)
	// Increment increments the counter value
	Increment(context.Context, *IncrementRequest) (*IncrementResponse, error)
	// Decrement decrements the counter value
	Decrement(context.Context, *DecrementRequest) (*DecrementResponse, error)
}

CounterServer is the server API for Counter service.

type CounterSessionOptions 

type CounterSessionOptions struct {
}

func (*CounterSessionOptions) Descriptor 

func (*CounterSessionOptions) Descriptor() ([]byte, []int)

func (*CounterSessionOptions) Marshal 

func (m *CounterSessionOptions) Marshal() (dAtA []byte, err error)

func (*CounterSessionOptions) MarshalTo 

func (m *CounterSessionOptions) MarshalTo(dAtA []byte) (int, error)

func (*CounterSessionOptions) MarshalToSizedBuffer 

func (m *CounterSessionOptions) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CounterSessionOptions) ProtoMessage 

func (*CounterSessionOptions) ProtoMessage()

func (*CounterSessionOptions) Reset 

func (m *CounterSessionOptions) Reset()

func (*CounterSessionOptions) Size 

func (m *CounterSessionOptions) Size() (n int)

func (*CounterSessionOptions) String 

func (m *CounterSessionOptions) String() string

func (*CounterSessionOptions) Unmarshal 

func (m *CounterSessionOptions) Unmarshal(dAtA []byte) error

func (*CounterSessionOptions) XXX_DiscardUnknown 

func (m *CounterSessionOptions) XXX_DiscardUnknown()

func (*CounterSessionOptions) XXX_Marshal 

func (m *CounterSessionOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CounterSessionOptions) XXX_Merge 

func (m *CounterSessionOptions) XXX_Merge(src proto.Message)

func (*CounterSessionOptions) XXX_Size 

func (m *CounterSessionOptions) XXX_Size() int

func (*CounterSessionOptions) XXX_Unmarshal 

func (m *CounterSessionOptions) XXX_Unmarshal(b []byte) error

type DecrementRequest 

type DecrementRequest struct {
	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) 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 {
	Value int64 `protobuf:"varint,2,opt,name=value,proto3" json:"value,omitempty"`
}

func (*DecrementResponse) Descriptor 

func (*DecrementResponse) Descriptor() ([]byte, []int)

func (*DecrementResponse) GetValue 

func (m *DecrementResponse) GetValue() 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 {
}

func (*GetRequest) Descriptor 

func (*GetRequest) Descriptor() ([]byte, []int)

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 {
	Value int64 `protobuf:"varint,2,opt,name=value,proto3" json:"value,omitempty"`
}

func (*GetResponse) Descriptor 

func (*GetResponse) Descriptor() ([]byte, []int)

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 {
	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) 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 {
	Value int64 `protobuf:"varint,2,opt,name=value,proto3" json:"value,omitempty"`
}

func (*IncrementResponse) Descriptor 

func (*IncrementResponse) Descriptor() ([]byte, []int)

func (*IncrementResponse) GetValue 

func (m *IncrementResponse) GetValue() 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 OpenSessionRequest 

type OpenSessionRequest struct {
	PrimitiveID github_com_atomix_atomix_api_go_atomix_primitive_v1.ID `` /* 158-byte string literal not displayed */
	Options     CounterSessionOptions                                  `protobuf:"bytes,2,opt,name=options,proto3" json:"options"`
}

func (*OpenSessionRequest) Descriptor 

func (*OpenSessionRequest) Descriptor() ([]byte, []int)

func (*OpenSessionRequest) GetOptions 

func (m *OpenSessionRequest) GetOptions() CounterSessionOptions

func (*OpenSessionRequest) GetPrimitiveID 

func (m *OpenSessionRequest) GetPrimitiveID() github_com_atomix_atomix_api_go_atomix_primitive_v1.ID

func (*OpenSessionRequest) Marshal 

func (m *OpenSessionRequest) Marshal() (dAtA []byte, err error)

func (*OpenSessionRequest) MarshalTo 

func (m *OpenSessionRequest) MarshalTo(dAtA []byte) (int, error)

func (*OpenSessionRequest) MarshalToSizedBuffer 

func (m *OpenSessionRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*OpenSessionRequest) ProtoMessage 

func (*OpenSessionRequest) ProtoMessage()

func (*OpenSessionRequest) Reset 

func (m *OpenSessionRequest) Reset()

func (*OpenSessionRequest) Size 

func (m *OpenSessionRequest) Size() (n int)

func (*OpenSessionRequest) String 

func (m *OpenSessionRequest) String() string

func (*OpenSessionRequest) Unmarshal 

func (m *OpenSessionRequest) Unmarshal(dAtA []byte) error

func (*OpenSessionRequest) XXX_DiscardUnknown 

func (m *OpenSessionRequest) XXX_DiscardUnknown()

func (*OpenSessionRequest) XXX_Marshal 

func (m *OpenSessionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*OpenSessionRequest) XXX_Merge 

func (m *OpenSessionRequest) XXX_Merge(src proto.Message)

func (*OpenSessionRequest) XXX_Size 

func (m *OpenSessionRequest) XXX_Size() int

func (*OpenSessionRequest) XXX_Unmarshal 

func (m *OpenSessionRequest) XXX_Unmarshal(b []byte) error

type OpenSessionResponse 

type OpenSessionResponse struct {
	SessionID github_com_atomix_atomix_api_go_atomix_primitive_v1.SessionID `` /* 160-byte string literal not displayed */
}

func (*OpenSessionResponse) Descriptor 

func (*OpenSessionResponse) Descriptor() ([]byte, []int)

func (*OpenSessionResponse) GetSessionID 

func (m *OpenSessionResponse) GetSessionID() github_com_atomix_atomix_api_go_atomix_primitive_v1.SessionID

func (*OpenSessionResponse) Marshal 

func (m *OpenSessionResponse) Marshal() (dAtA []byte, err error)

func (*OpenSessionResponse) MarshalTo 

func (m *OpenSessionResponse) MarshalTo(dAtA []byte) (int, error)

func (*OpenSessionResponse) MarshalToSizedBuffer 

func (m *OpenSessionResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*OpenSessionResponse) ProtoMessage 

func (*OpenSessionResponse) ProtoMessage()

func (*OpenSessionResponse) Reset 

func (m *OpenSessionResponse) Reset()

func (*OpenSessionResponse) Size 

func (m *OpenSessionResponse) Size() (n int)

func (*OpenSessionResponse) String 

func (m *OpenSessionResponse) String() string

func (*OpenSessionResponse) Unmarshal 

func (m *OpenSessionResponse) Unmarshal(dAtA []byte) error

func (*OpenSessionResponse) XXX_DiscardUnknown 

func (m *OpenSessionResponse) XXX_DiscardUnknown()

func (*OpenSessionResponse) XXX_Marshal 

func (m *OpenSessionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*OpenSessionResponse) XXX_Merge 

func (m *OpenSessionResponse) XXX_Merge(src proto.Message)

func (*OpenSessionResponse) XXX_Size 

func (m *OpenSessionResponse) XXX_Size() int

func (*OpenSessionResponse) XXX_Unmarshal 

func (m *OpenSessionResponse) XXX_Unmarshal(b []byte) error

type Precondition 

type Precondition struct {
	// Types that are valid to be assigned to Precondition:
	//	*Precondition_Value
	Precondition isPrecondition_Precondition `protobuf_oneof:"precondition"`
}

func (*Precondition) Descriptor 

func (*Precondition) Descriptor() ([]byte, []int)

func (*Precondition) GetPrecondition 

func (m *Precondition) GetPrecondition() isPrecondition_Precondition

func (*Precondition) GetValue 

func (m *Precondition) GetValue() int64

func (*Precondition) Marshal 

func (m *Precondition) Marshal() (dAtA []byte, err error)

func (*Precondition) MarshalTo 

func (m *Precondition) MarshalTo(dAtA []byte) (int, error)

func (*Precondition) MarshalToSizedBuffer 

func (m *Precondition) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Precondition) ProtoMessage 

func (*Precondition) ProtoMessage()

func (*Precondition) Reset 

func (m *Precondition) Reset()

func (*Precondition) Size 

func (m *Precondition) Size() (n int)

func (*Precondition) String 

func (m *Precondition) String() string

func (*Precondition) Unmarshal 

func (m *Precondition) Unmarshal(dAtA []byte) error

func (*Precondition) XXX_DiscardUnknown 

func (m *Precondition) XXX_DiscardUnknown()

func (*Precondition) XXX_Marshal 

func (m *Precondition) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Precondition) XXX_Merge 

func (m *Precondition) XXX_Merge(src proto.Message)

func (*Precondition) XXX_OneofWrappers 

func (*Precondition) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*Precondition) XXX_Size 

func (m *Precondition) XXX_Size() int

func (*Precondition) XXX_Unmarshal 

func (m *Precondition) XXX_Unmarshal(b []byte) error

type Precondition_Value 

type Precondition_Value struct {
	Value int64 `protobuf:"varint,1,opt,name=value,proto3,oneof" json:"value,omitempty"`
}

func (*Precondition_Value) MarshalTo 

func (m *Precondition_Value) MarshalTo(dAtA []byte) (int, error)

func (*Precondition_Value) MarshalToSizedBuffer 

func (m *Precondition_Value) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Precondition_Value) Size 

func (m *Precondition_Value) Size() (n int)

type SetRequest 

type SetRequest struct {
	Value         int64          `protobuf:"varint,2,opt,name=value,proto3" json:"value,omitempty"`
	Preconditions []Precondition `protobuf:"bytes,3,rep,name=preconditions,proto3" json:"preconditions"`
}

func (*SetRequest) Descriptor 

func (*SetRequest) Descriptor() ([]byte, []int)

func (*SetRequest) GetPreconditions 

func (m *SetRequest) GetPreconditions() []Precondition

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 {
	Value int64 `protobuf:"varint,2,opt,name=value,proto3" json:"value,omitempty"`
}

func (*SetResponse) Descriptor 

func (*SetResponse) Descriptor() ([]byte, []int)

func (*SetResponse) GetValue 

func (m *SetResponse) GetValue() 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 UnimplementedCounterManagerServer added in v0.7.0 

type UnimplementedCounterManagerServer struct {
}

UnimplementedCounterManagerServer can be embedded to have forward compatible implementations.

func (*UnimplementedCounterManagerServer) CloseSession added in v0.7.0 

func (*UnimplementedCounterManagerServer) CloseSession(ctx context.Context, req *CloseSessionRequest) (*CloseSessionResponse, error)

func (*UnimplementedCounterManagerServer) OpenSession added in v0.7.0 

func (*UnimplementedCounterManagerServer) OpenSession(ctx context.Context, req *OpenSessionRequest) (*OpenSessionResponse, error)

type UnimplementedCounterServer 

type UnimplementedCounterServer struct {
}

UnimplementedCounterServer can be embedded to have forward compatible implementations.

func (*UnimplementedCounterServer) Decrement 

func (*UnimplementedCounterServer) Decrement(ctx context.Context, req *DecrementRequest) (*DecrementResponse, error)

func (*UnimplementedCounterServer) Get 

func (*UnimplementedCounterServer) Get(ctx context.Context, req *GetRequest) (*GetResponse, error)

func (*UnimplementedCounterServer) Increment 

func (*UnimplementedCounterServer) Increment(ctx context.Context, req *IncrementRequest) (*IncrementResponse, error)

func (*UnimplementedCounterServer) Set 

func (*UnimplementedCounterServer) Set(ctx context.Context, req *SetRequest) (*SetResponse, error)

type Value 

type Value struct {
	Value int64 `protobuf:"varint,1,opt,name=value,proto3" json:"value,omitempty"`
}

func (*Value) Descriptor 

func (*Value) Descriptor() ([]byte, []int)

func (*Value) GetValue 

func (m *Value) GetValue() int64

func (*Value) Marshal 

func (m *Value) Marshal() (dAtA []byte, err error)

func (*Value) MarshalTo 

func (m *Value) MarshalTo(dAtA []byte) (int, error)

func (*Value) MarshalToSizedBuffer 

func (m *Value) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Value) ProtoMessage 

func (*Value) ProtoMessage()

func (*Value) Reset 

func (m *Value) Reset()

func (*Value) Size 

func (m *Value) Size() (n int)

func (*Value) String 

func (m *Value) String() string

func (*Value) Unmarshal 

func (m *Value) Unmarshal(dAtA []byte) error

func (*Value) XXX_DiscardUnknown 

func (m *Value) XXX_DiscardUnknown()

func (*Value) XXX_Marshal 

func (m *Value) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Value) XXX_Merge 

func (m *Value) XXX_Merge(src proto.Message)

func (*Value) XXX_Size 

func (m *Value) XXX_Size() int

func (*Value) XXX_Unmarshal 

func (m *Value) XXX_Unmarshal(b []byte) 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.