_map

package
v0.6.3 Latest Latest
Warning

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

 Go to latest Published: Apr 13, 2021 License: Apache-2.0 Imports: 21 Imported by: 0

Documentation

Index

Constants

View Source 
const Type = primitiveapi.PrimitiveType_MAP

Type is the map primitive type

Variables

View Source 
var (
	ErrInvalidLengthMap        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowMap          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupMap = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var ListenResponse_Type_name = map[int32]string{
	0: "NONE",
	1: "INSERTED",
	2: "UPDATED",
	3: "REMOVED",
}
View Source 
var ListenResponse_Type_value = map[string]int32{
	"NONE":     0,
	"INSERTED": 1,
	"UPDATED":  2,
	"REMOVED":  3,
}
View Source 
var UpdateStatus_name = map[int32]string{
	0: "OK",
	1: "NOOP",
	2: "WRITE_LOCK",
	3: "PRECONDITION_FAILED",
}
View Source 
var UpdateStatus_value = map[string]int32{
	"OK":                  0,
	"NOOP":                1,
	"WRITE_LOCK":          2,
	"PRECONDITION_FAILED": 3,
}

Functions

func RegisterPrimitive 

func RegisterPrimitive(node *atomix.Node)

RegisterPrimitive registers the primitive on the given node

Types

type ClearRequest 

type ClearRequest struct {
}

func (*ClearRequest) Descriptor 

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

func (*ClearRequest) Marshal 

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

func (*ClearRequest) MarshalTo 

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

func (*ClearRequest) MarshalToSizedBuffer 

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

func (*ClearRequest) ProtoMessage 

func (*ClearRequest) ProtoMessage()

func (*ClearRequest) Reset 

func (m *ClearRequest) Reset()

func (*ClearRequest) Size 

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

func (*ClearRequest) String 

func (m *ClearRequest) String() string

func (*ClearRequest) Unmarshal 

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

func (*ClearRequest) XXX_DiscardUnknown 

func (m *ClearRequest) XXX_DiscardUnknown()

func (*ClearRequest) XXX_Marshal 

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

func (*ClearRequest) XXX_Merge 

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

func (*ClearRequest) XXX_Size 

func (m *ClearRequest) XXX_Size() int

func (*ClearRequest) XXX_Unmarshal 

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

type ClearResponse 

type ClearResponse struct {
}

func (*ClearResponse) Descriptor 

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

func (*ClearResponse) Marshal 

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

func (*ClearResponse) MarshalTo 

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

func (*ClearResponse) MarshalToSizedBuffer 

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

func (*ClearResponse) ProtoMessage 

func (*ClearResponse) ProtoMessage()

func (*ClearResponse) Reset 

func (m *ClearResponse) Reset()

func (*ClearResponse) Size 

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

func (*ClearResponse) String 

func (m *ClearResponse) String() string

func (*ClearResponse) Unmarshal 

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

func (*ClearResponse) XXX_DiscardUnknown 

func (m *ClearResponse) XXX_DiscardUnknown()

func (*ClearResponse) XXX_Marshal 

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

func (*ClearResponse) XXX_Merge 

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

func (*ClearResponse) XXX_Size 

func (m *ClearResponse) XXX_Size() int

func (*ClearResponse) XXX_Unmarshal 

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

type ContainsKeyRequest 

type ContainsKeyRequest struct {
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
}

func (*ContainsKeyRequest) Descriptor 

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

func (*ContainsKeyRequest) GetKey 

func (m *ContainsKeyRequest) GetKey() string

func (*ContainsKeyRequest) Marshal 

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

func (*ContainsKeyRequest) MarshalTo 

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

func (*ContainsKeyRequest) MarshalToSizedBuffer 

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

func (*ContainsKeyRequest) ProtoMessage 

func (*ContainsKeyRequest) ProtoMessage()

func (*ContainsKeyRequest) Reset 

func (m *ContainsKeyRequest) Reset()

func (*ContainsKeyRequest) Size 

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

func (*ContainsKeyRequest) String 

func (m *ContainsKeyRequest) String() string

func (*ContainsKeyRequest) Unmarshal 

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

func (*ContainsKeyRequest) XXX_DiscardUnknown 

func (m *ContainsKeyRequest) XXX_DiscardUnknown()

func (*ContainsKeyRequest) XXX_Marshal 

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

func (*ContainsKeyRequest) XXX_Merge 

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

func (*ContainsKeyRequest) XXX_Size 

func (m *ContainsKeyRequest) XXX_Size() int

func (*ContainsKeyRequest) XXX_Unmarshal 

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

type ContainsKeyResponse 

type ContainsKeyResponse struct {
	ContainsKey bool `protobuf:"varint,1,opt,name=contains_key,json=containsKey,proto3" json:"contains_key,omitempty"`
}

func (*ContainsKeyResponse) Descriptor 

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

func (*ContainsKeyResponse) GetContainsKey 

func (m *ContainsKeyResponse) GetContainsKey() bool

func (*ContainsKeyResponse) Marshal 

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

func (*ContainsKeyResponse) MarshalTo 

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

func (*ContainsKeyResponse) MarshalToSizedBuffer 

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

func (*ContainsKeyResponse) ProtoMessage 

func (*ContainsKeyResponse) ProtoMessage()

func (*ContainsKeyResponse) Reset 

func (m *ContainsKeyResponse) Reset()

func (*ContainsKeyResponse) Size 

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

func (*ContainsKeyResponse) String 

func (m *ContainsKeyResponse) String() string

func (*ContainsKeyResponse) Unmarshal 

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

func (*ContainsKeyResponse) XXX_DiscardUnknown 

func (m *ContainsKeyResponse) XXX_DiscardUnknown()

func (*ContainsKeyResponse) XXX_Marshal 

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

func (*ContainsKeyResponse) XXX_Merge 

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

func (*ContainsKeyResponse) XXX_Size 

func (m *ContainsKeyResponse) XXX_Size() int

func (*ContainsKeyResponse) XXX_Unmarshal 

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

type EntriesRequest 

type EntriesRequest struct {
}

func (*EntriesRequest) Descriptor 

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

func (*EntriesRequest) Marshal 

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

func (*EntriesRequest) MarshalTo 

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

func (*EntriesRequest) MarshalToSizedBuffer 

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

func (*EntriesRequest) ProtoMessage 

func (*EntriesRequest) ProtoMessage()

func (*EntriesRequest) Reset 

func (m *EntriesRequest) Reset()

func (*EntriesRequest) Size 

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

func (*EntriesRequest) String 

func (m *EntriesRequest) String() string

func (*EntriesRequest) Unmarshal 

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

func (*EntriesRequest) XXX_DiscardUnknown 

func (m *EntriesRequest) XXX_DiscardUnknown()

func (*EntriesRequest) XXX_Marshal 

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

func (*EntriesRequest) XXX_Merge 

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

func (*EntriesRequest) XXX_Size 

func (m *EntriesRequest) XXX_Size() int

func (*EntriesRequest) XXX_Unmarshal 

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

type EntriesResponse 

type EntriesResponse struct {
	Key     string    `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value   []byte    `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	Version uint64    `protobuf:"varint,3,opt,name=version,proto3" json:"version,omitempty"`
	Created time.Time `protobuf:"bytes,4,opt,name=created,proto3,stdtime" json:"created"`
	Updated time.Time `protobuf:"bytes,5,opt,name=updated,proto3,stdtime" json:"updated"`
}

func (*EntriesResponse) Descriptor 

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

func (*EntriesResponse) GetCreated 

func (m *EntriesResponse) GetCreated() time.Time

func (*EntriesResponse) GetKey 

func (m *EntriesResponse) GetKey() string

func (*EntriesResponse) GetUpdated 

func (m *EntriesResponse) GetUpdated() time.Time

func (*EntriesResponse) GetValue 

func (m *EntriesResponse) GetValue() []byte

func (*EntriesResponse) GetVersion 

func (m *EntriesResponse) GetVersion() uint64

func (*EntriesResponse) Marshal 

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

func (*EntriesResponse) MarshalTo 

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

func (*EntriesResponse) MarshalToSizedBuffer 

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

func (*EntriesResponse) ProtoMessage 

func (*EntriesResponse) ProtoMessage()

func (*EntriesResponse) Reset 

func (m *EntriesResponse) Reset()

func (*EntriesResponse) Size 

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

func (*EntriesResponse) String 

func (m *EntriesResponse) String() string

func (*EntriesResponse) Unmarshal 

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

func (*EntriesResponse) XXX_DiscardUnknown 

func (m *EntriesResponse) XXX_DiscardUnknown()

func (*EntriesResponse) XXX_Marshal 

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

func (*EntriesResponse) XXX_Merge 

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

func (*EntriesResponse) XXX_Size 

func (m *EntriesResponse) XXX_Size() int

func (*EntriesResponse) XXX_Unmarshal 

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

type GetRequest 

type GetRequest struct {
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
}

func (*GetRequest) Descriptor 

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

func (*GetRequest) GetKey 

func (m *GetRequest) GetKey() string

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   []byte    `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	Version uint64    `protobuf:"varint,2,opt,name=version,proto3" json:"version,omitempty"`
	Created time.Time `protobuf:"bytes,3,opt,name=created,proto3,stdtime" json:"created"`
	Updated time.Time `protobuf:"bytes,4,opt,name=updated,proto3,stdtime" json:"updated"`
}

func (*GetResponse) Descriptor 

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

func (*GetResponse) GetCreated 

func (m *GetResponse) GetCreated() time.Time

func (*GetResponse) GetUpdated 

func (m *GetResponse) GetUpdated() time.Time

func (*GetResponse) GetValue 

func (m *GetResponse) GetValue() []byte

func (*GetResponse) GetVersion 

func (m *GetResponse) GetVersion() uint64

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 KeysRequest 

type KeysRequest struct {
}

func (*KeysRequest) Descriptor 

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

func (*KeysRequest) Marshal 

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

func (*KeysRequest) MarshalTo 

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

func (*KeysRequest) MarshalToSizedBuffer 

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

func (*KeysRequest) ProtoMessage 

func (*KeysRequest) ProtoMessage()

func (*KeysRequest) Reset 

func (m *KeysRequest) Reset()

func (*KeysRequest) Size 

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

func (*KeysRequest) String 

func (m *KeysRequest) String() string

func (*KeysRequest) Unmarshal 

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

func (*KeysRequest) XXX_DiscardUnknown 

func (m *KeysRequest) XXX_DiscardUnknown()

func (*KeysRequest) XXX_Marshal 

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

func (*KeysRequest) XXX_Merge 

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

func (*KeysRequest) XXX_Size 

func (m *KeysRequest) XXX_Size() int

func (*KeysRequest) XXX_Unmarshal 

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

type KeysResponse 

type KeysResponse struct {
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
}

func (*KeysResponse) Descriptor 

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

func (*KeysResponse) GetKey 

func (m *KeysResponse) GetKey() string

func (*KeysResponse) Marshal 

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

func (*KeysResponse) MarshalTo 

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

func (*KeysResponse) MarshalToSizedBuffer 

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

func (*KeysResponse) ProtoMessage 

func (*KeysResponse) ProtoMessage()

func (*KeysResponse) Reset 

func (m *KeysResponse) Reset()

func (*KeysResponse) Size 

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

func (*KeysResponse) String 

func (m *KeysResponse) String() string

func (*KeysResponse) Unmarshal 

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

func (*KeysResponse) XXX_DiscardUnknown 

func (m *KeysResponse) XXX_DiscardUnknown()

func (*KeysResponse) XXX_Marshal 

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

func (*KeysResponse) XXX_Merge 

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

func (*KeysResponse) XXX_Size 

func (m *KeysResponse) XXX_Size() int

func (*KeysResponse) XXX_Unmarshal 

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

type ListenRequest 

type ListenRequest struct {
	Replay bool   `protobuf:"varint,1,opt,name=replay,proto3" json:"replay,omitempty"`
	Key    string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
}

func (*ListenRequest) Descriptor 

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

func (*ListenRequest) GetKey 

func (m *ListenRequest) GetKey() string

func (*ListenRequest) GetReplay 

func (m *ListenRequest) GetReplay() bool

func (*ListenRequest) Marshal 

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

func (*ListenRequest) MarshalTo 

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

func (*ListenRequest) MarshalToSizedBuffer 

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

func (*ListenRequest) ProtoMessage 

func (*ListenRequest) ProtoMessage()

func (*ListenRequest) Reset 

func (m *ListenRequest) Reset()

func (*ListenRequest) Size 

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

func (*ListenRequest) String 

func (m *ListenRequest) String() string

func (*ListenRequest) Unmarshal 

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

func (*ListenRequest) XXX_DiscardUnknown 

func (m *ListenRequest) XXX_DiscardUnknown()

func (*ListenRequest) XXX_Marshal 

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

func (*ListenRequest) XXX_Merge 

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

func (*ListenRequest) XXX_Size 

func (m *ListenRequest) XXX_Size() int

func (*ListenRequest) XXX_Unmarshal 

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

type ListenResponse 

type ListenResponse struct {
	Type    ListenResponse_Type `protobuf:"varint,1,opt,name=type,proto3,enum=atomix.map.service.ListenResponse_Type" json:"type,omitempty"`
	Key     string              `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	Value   []byte              `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	Version uint64              `protobuf:"varint,4,opt,name=version,proto3" json:"version,omitempty"`
	Created time.Time           `protobuf:"bytes,5,opt,name=created,proto3,stdtime" json:"created"`
	Updated time.Time           `protobuf:"bytes,6,opt,name=updated,proto3,stdtime" json:"updated"`
}

func (*ListenResponse) Descriptor 

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

func (*ListenResponse) GetCreated 

func (m *ListenResponse) GetCreated() time.Time

func (*ListenResponse) GetKey 

func (m *ListenResponse) GetKey() string

func (*ListenResponse) GetType 

func (m *ListenResponse) GetType() ListenResponse_Type

func (*ListenResponse) GetUpdated 

func (m *ListenResponse) GetUpdated() time.Time

func (*ListenResponse) GetValue 

func (m *ListenResponse) GetValue() []byte

func (*ListenResponse) GetVersion 

func (m *ListenResponse) GetVersion() uint64

func (*ListenResponse) Marshal 

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

func (*ListenResponse) MarshalTo 

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

func (*ListenResponse) MarshalToSizedBuffer 

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

func (*ListenResponse) ProtoMessage 

func (*ListenResponse) ProtoMessage()

func (*ListenResponse) Reset 

func (m *ListenResponse) Reset()

func (*ListenResponse) Size 

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

func (*ListenResponse) String 

func (m *ListenResponse) String() string

func (*ListenResponse) Unmarshal 

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

func (*ListenResponse) XXX_DiscardUnknown 

func (m *ListenResponse) XXX_DiscardUnknown()

func (*ListenResponse) XXX_Marshal 

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

func (*ListenResponse) XXX_Merge 

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

func (*ListenResponse) XXX_Size 

func (m *ListenResponse) XXX_Size() int

func (*ListenResponse) XXX_Unmarshal 

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

type ListenResponse_Type 

type ListenResponse_Type int32
const (
	ListenResponse_NONE     ListenResponse_Type = 0
	ListenResponse_INSERTED ListenResponse_Type = 1
	ListenResponse_UPDATED  ListenResponse_Type = 2
	ListenResponse_REMOVED  ListenResponse_Type = 3
)

func (ListenResponse_Type) EnumDescriptor 

func (ListenResponse_Type) EnumDescriptor() ([]byte, []int)

func (ListenResponse_Type) String 

func (x ListenResponse_Type) String() string

type Listener 

type Listener struct {
	SessionId uint64 `protobuf:"varint,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	StreamId  uint64 `protobuf:"varint,2,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty"`
	Key       string `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty"`
}

Listener is a map listener

func (*Listener) Descriptor 

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

func (*Listener) GetKey 

func (m *Listener) GetKey() string

func (*Listener) GetSessionId 

func (m *Listener) GetSessionId() uint64

func (*Listener) GetStreamId 

func (m *Listener) GetStreamId() uint64

func (*Listener) Marshal 

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

func (*Listener) MarshalTo 

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

func (*Listener) MarshalToSizedBuffer 

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

func (*Listener) ProtoMessage 

func (*Listener) ProtoMessage()

func (*Listener) Reset 

func (m *Listener) Reset()

func (*Listener) Size 

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

func (*Listener) String 

func (m *Listener) String() string

func (*Listener) Unmarshal 

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

func (*Listener) XXX_DiscardUnknown 

func (m *Listener) XXX_DiscardUnknown()

func (*Listener) XXX_Marshal 

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

func (*Listener) XXX_Merge 

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

func (*Listener) XXX_Size 

func (m *Listener) XXX_Size() int

func (*Listener) XXX_Unmarshal 

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

type MapEntry 

type MapEntry struct {
	Key   string         `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value *MapEntryValue `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
}

Map entry

func (*MapEntry) Descriptor 

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

func (*MapEntry) GetKey 

func (m *MapEntry) GetKey() string

func (*MapEntry) GetValue 

func (m *MapEntry) GetValue() *MapEntryValue

func (*MapEntry) Marshal 

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

func (*MapEntry) MarshalTo 

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

func (*MapEntry) MarshalToSizedBuffer 

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

func (*MapEntry) ProtoMessage 

func (*MapEntry) ProtoMessage()

func (*MapEntry) Reset 

func (m *MapEntry) Reset()

func (*MapEntry) Size 

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

func (*MapEntry) String 

func (m *MapEntry) String() string

func (*MapEntry) Unmarshal 

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

func (*MapEntry) XXX_DiscardUnknown 

func (m *MapEntry) XXX_DiscardUnknown()

func (*MapEntry) XXX_Marshal 

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

func (*MapEntry) XXX_Merge 

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

func (*MapEntry) XXX_Size 

func (m *MapEntry) XXX_Size() int

func (*MapEntry) XXX_Unmarshal 

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

type MapEntryValue 

type MapEntryValue struct {
	Version uint64         `protobuf:"varint,1,opt,name=version,proto3" json:"version,omitempty"`
	Value   []byte         `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	Created time.Time      `protobuf:"bytes,3,opt,name=created,proto3,stdtime" json:"created"`
	Updated time.Time      `protobuf:"bytes,4,opt,name=updated,proto3,stdtime" json:"updated"`
	TTL     *time.Duration `protobuf:"bytes,5,opt,name=ttl,proto3,stdduration" json:"ttl,omitempty"`
}

Map entry value

func (*MapEntryValue) Descriptor 

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

func (*MapEntryValue) GetCreated 

func (m *MapEntryValue) GetCreated() time.Time

func (*MapEntryValue) GetTTL 

func (m *MapEntryValue) GetTTL() *time.Duration

func (*MapEntryValue) GetUpdated 

func (m *MapEntryValue) GetUpdated() time.Time

func (*MapEntryValue) GetValue 

func (m *MapEntryValue) GetValue() []byte

func (*MapEntryValue) GetVersion 

func (m *MapEntryValue) GetVersion() uint64

func (*MapEntryValue) Marshal 

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

func (*MapEntryValue) MarshalTo 

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

func (*MapEntryValue) MarshalToSizedBuffer 

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

func (*MapEntryValue) ProtoMessage 

func (*MapEntryValue) ProtoMessage()

func (*MapEntryValue) Reset 

func (m *MapEntryValue) Reset()

func (*MapEntryValue) Size 

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

func (*MapEntryValue) String 

func (m *MapEntryValue) String() string

func (*MapEntryValue) Unmarshal 

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

func (*MapEntryValue) XXX_DiscardUnknown 

func (m *MapEntryValue) XXX_DiscardUnknown()

func (*MapEntryValue) XXX_Marshal 

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

func (*MapEntryValue) XXX_Merge 

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

func (*MapEntryValue) XXX_Size 

func (m *MapEntryValue) XXX_Size() int

func (*MapEntryValue) XXX_Unmarshal 

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

type MapSnapshot 

type MapSnapshot struct {
	Listeners []*Listener `protobuf:"bytes,1,rep,name=listeners,proto3" json:"listeners,omitempty"`
}

Map snapshot

func (*MapSnapshot) Descriptor 

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

func (*MapSnapshot) GetListeners 

func (m *MapSnapshot) GetListeners() []*Listener

func (*MapSnapshot) Marshal 

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

func (*MapSnapshot) MarshalTo 

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

func (*MapSnapshot) MarshalToSizedBuffer 

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

func (*MapSnapshot) ProtoMessage 

func (*MapSnapshot) ProtoMessage()

func (*MapSnapshot) Reset 

func (m *MapSnapshot) Reset()

func (*MapSnapshot) Size 

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

func (*MapSnapshot) String 

func (m *MapSnapshot) String() string

func (*MapSnapshot) Unmarshal 

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

func (*MapSnapshot) XXX_DiscardUnknown 

func (m *MapSnapshot) XXX_DiscardUnknown()

func (*MapSnapshot) XXX_Marshal 

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

func (*MapSnapshot) XXX_Merge 

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

func (*MapSnapshot) XXX_Size 

func (m *MapSnapshot) XXX_Size() int

func (*MapSnapshot) XXX_Unmarshal 

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

type Primitive 

type Primitive struct{}

Primitive is the counter primitive

func (*Primitive) NewService 

func (p *Primitive) NewService(scheduler primitive.Scheduler, context primitive.ServiceContext) primitive.Service

NewService creates a new map service

func (*Primitive) RegisterServer 

func (p *Primitive) RegisterServer(server *grpc.Server, protocol primitive.Protocol)

RegisterServer registers the map server with the protocol

type PutRequest 

type PutRequest struct {
	Key     string         `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value   []byte         `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	Version uint64         `protobuf:"varint,3,opt,name=version,proto3" json:"version,omitempty"`
	TTL     *time.Duration `protobuf:"bytes,4,opt,name=ttl,proto3,stdduration" json:"ttl,omitempty"`
	IfEmpty bool           `protobuf:"varint,5,opt,name=if_empty,json=ifEmpty,proto3" json:"if_empty,omitempty"`
}

func (*PutRequest) Descriptor 

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

func (*PutRequest) GetIfEmpty 

func (m *PutRequest) GetIfEmpty() bool

func (*PutRequest) GetKey 

func (m *PutRequest) GetKey() string

func (*PutRequest) GetTTL 

func (m *PutRequest) GetTTL() *time.Duration

func (*PutRequest) GetValue 

func (m *PutRequest) GetValue() []byte

func (*PutRequest) GetVersion 

func (m *PutRequest) GetVersion() uint64

func (*PutRequest) Marshal 

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

func (*PutRequest) MarshalTo 

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

func (*PutRequest) MarshalToSizedBuffer 

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

func (*PutRequest) ProtoMessage 

func (*PutRequest) ProtoMessage()

func (*PutRequest) Reset 

func (m *PutRequest) Reset()

func (*PutRequest) Size 

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

func (*PutRequest) String 

func (m *PutRequest) String() string

func (*PutRequest) Unmarshal 

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

func (*PutRequest) XXX_DiscardUnknown 

func (m *PutRequest) XXX_DiscardUnknown()

func (*PutRequest) XXX_Marshal 

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

func (*PutRequest) XXX_Merge 

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

func (*PutRequest) XXX_Size 

func (m *PutRequest) XXX_Size() int

func (*PutRequest) XXX_Unmarshal 

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

type PutResponse 

type PutResponse struct {
	Status          UpdateStatus `protobuf:"varint,1,opt,name=status,proto3,enum=atomix.map.service.UpdateStatus" json:"status,omitempty"`
	PreviousValue   []byte       `protobuf:"bytes,2,opt,name=previous_value,json=previousValue,proto3" json:"previous_value,omitempty"`
	PreviousVersion uint64       `protobuf:"varint,3,opt,name=previous_version,json=previousVersion,proto3" json:"previous_version,omitempty"`
	NewVersion      uint64       `protobuf:"varint,4,opt,name=new_version,json=newVersion,proto3" json:"new_version,omitempty"`
	Created         time.Time    `protobuf:"bytes,5,opt,name=created,proto3,stdtime" json:"created"`
	Updated         time.Time    `protobuf:"bytes,6,opt,name=updated,proto3,stdtime" json:"updated"`
}

func (*PutResponse) Descriptor 

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

func (*PutResponse) GetCreated 

func (m *PutResponse) GetCreated() time.Time

func (*PutResponse) GetNewVersion 

func (m *PutResponse) GetNewVersion() uint64

func (*PutResponse) GetPreviousValue 

func (m *PutResponse) GetPreviousValue() []byte

func (*PutResponse) GetPreviousVersion 

func (m *PutResponse) GetPreviousVersion() uint64

func (*PutResponse) GetStatus 

func (m *PutResponse) GetStatus() UpdateStatus

func (*PutResponse) GetUpdated 

func (m *PutResponse) GetUpdated() time.Time

func (*PutResponse) Marshal 

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

func (*PutResponse) MarshalTo 

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

func (*PutResponse) MarshalToSizedBuffer 

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

func (*PutResponse) ProtoMessage 

func (*PutResponse) ProtoMessage()

func (*PutResponse) Reset 

func (m *PutResponse) Reset()

func (*PutResponse) Size 

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

func (*PutResponse) String 

func (m *PutResponse) String() string

func (*PutResponse) Unmarshal 

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

func (*PutResponse) XXX_DiscardUnknown 

func (m *PutResponse) XXX_DiscardUnknown()

func (*PutResponse) XXX_Marshal 

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

func (*PutResponse) XXX_Merge 

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

func (*PutResponse) XXX_Size 

func (m *PutResponse) XXX_Size() int

func (*PutResponse) XXX_Unmarshal 

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

type RemoveRequest 

type RemoveRequest struct {
	Key     string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value   []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	Version uint64 `protobuf:"varint,3,opt,name=version,proto3" json:"version,omitempty"`
}

func (*RemoveRequest) Descriptor 

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

func (*RemoveRequest) GetKey 

func (m *RemoveRequest) GetKey() string

func (*RemoveRequest) GetValue 

func (m *RemoveRequest) GetValue() []byte

func (*RemoveRequest) GetVersion 

func (m *RemoveRequest) GetVersion() uint64

func (*RemoveRequest) Marshal 

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

func (*RemoveRequest) MarshalTo 

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

func (*RemoveRequest) MarshalToSizedBuffer 

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

func (*RemoveRequest) ProtoMessage 

func (*RemoveRequest) ProtoMessage()

func (*RemoveRequest) Reset 

func (m *RemoveRequest) Reset()

func (*RemoveRequest) Size 

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

func (*RemoveRequest) String 

func (m *RemoveRequest) String() string

func (*RemoveRequest) Unmarshal 

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

func (*RemoveRequest) XXX_DiscardUnknown 

func (m *RemoveRequest) XXX_DiscardUnknown()

func (*RemoveRequest) XXX_Marshal 

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

func (*RemoveRequest) XXX_Merge 

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

func (*RemoveRequest) XXX_Size 

func (m *RemoveRequest) XXX_Size() int

func (*RemoveRequest) XXX_Unmarshal 

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

type RemoveResponse 

type RemoveResponse struct {
	Status          UpdateStatus `protobuf:"varint,1,opt,name=status,proto3,enum=atomix.map.service.UpdateStatus" json:"status,omitempty"`
	PreviousValue   []byte       `protobuf:"bytes,2,opt,name=previous_value,json=previousValue,proto3" json:"previous_value,omitempty"`
	PreviousVersion uint64       `protobuf:"varint,3,opt,name=previous_version,json=previousVersion,proto3" json:"previous_version,omitempty"`
	Created         time.Time    `protobuf:"bytes,4,opt,name=created,proto3,stdtime" json:"created"`
	Updated         time.Time    `protobuf:"bytes,5,opt,name=updated,proto3,stdtime" json:"updated"`
}

func (*RemoveResponse) Descriptor 

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

func (*RemoveResponse) GetCreated 

func (m *RemoveResponse) GetCreated() time.Time

func (*RemoveResponse) GetPreviousValue 

func (m *RemoveResponse) GetPreviousValue() []byte

func (*RemoveResponse) GetPreviousVersion 

func (m *RemoveResponse) GetPreviousVersion() uint64

func (*RemoveResponse) GetStatus 

func (m *RemoveResponse) GetStatus() UpdateStatus

func (*RemoveResponse) GetUpdated 

func (m *RemoveResponse) GetUpdated() time.Time

func (*RemoveResponse) Marshal 

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

func (*RemoveResponse) MarshalTo 

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

func (*RemoveResponse) MarshalToSizedBuffer 

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

func (*RemoveResponse) ProtoMessage 

func (*RemoveResponse) ProtoMessage()

func (*RemoveResponse) Reset 

func (m *RemoveResponse) Reset()

func (*RemoveResponse) Size 

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

func (*RemoveResponse) String 

func (m *RemoveResponse) String() string

func (*RemoveResponse) Unmarshal 

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

func (*RemoveResponse) XXX_DiscardUnknown 

func (m *RemoveResponse) XXX_DiscardUnknown()

func (*RemoveResponse) XXX_Marshal 

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

func (*RemoveResponse) XXX_Merge 

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

func (*RemoveResponse) XXX_Size 

func (m *RemoveResponse) XXX_Size() int

func (*RemoveResponse) XXX_Unmarshal 

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

type ReplaceRequest 

type ReplaceRequest struct {
	Key             string         `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	PreviousValue   []byte         `protobuf:"bytes,2,opt,name=previous_value,json=previousValue,proto3" json:"previous_value,omitempty"`
	PreviousVersion uint64         `protobuf:"varint,3,opt,name=previous_version,json=previousVersion,proto3" json:"previous_version,omitempty"`
	NewValue        []byte         `protobuf:"bytes,4,opt,name=new_value,json=newValue,proto3" json:"new_value,omitempty"`
	TTL             *time.Duration `protobuf:"bytes,5,opt,name=ttl,proto3,stdduration" json:"ttl,omitempty"`
}

func (*ReplaceRequest) Descriptor 

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

func (*ReplaceRequest) GetKey 

func (m *ReplaceRequest) GetKey() string

func (*ReplaceRequest) GetNewValue 

func (m *ReplaceRequest) GetNewValue() []byte

func (*ReplaceRequest) GetPreviousValue 

func (m *ReplaceRequest) GetPreviousValue() []byte

func (*ReplaceRequest) GetPreviousVersion 

func (m *ReplaceRequest) GetPreviousVersion() uint64

func (*ReplaceRequest) GetTTL 

func (m *ReplaceRequest) GetTTL() *time.Duration

func (*ReplaceRequest) Marshal 

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

func (*ReplaceRequest) MarshalTo 

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

func (*ReplaceRequest) MarshalToSizedBuffer 

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

func (*ReplaceRequest) ProtoMessage 

func (*ReplaceRequest) ProtoMessage()

func (*ReplaceRequest) Reset 

func (m *ReplaceRequest) Reset()

func (*ReplaceRequest) Size 

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

func (*ReplaceRequest) String 

func (m *ReplaceRequest) String() string

func (*ReplaceRequest) Unmarshal 

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

func (*ReplaceRequest) XXX_DiscardUnknown 

func (m *ReplaceRequest) XXX_DiscardUnknown()

func (*ReplaceRequest) XXX_Marshal 

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

func (*ReplaceRequest) XXX_Merge 

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

func (*ReplaceRequest) XXX_Size 

func (m *ReplaceRequest) XXX_Size() int

func (*ReplaceRequest) XXX_Unmarshal 

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

type ReplaceResponse 

type ReplaceResponse struct {
	Status          UpdateStatus `protobuf:"varint,1,opt,name=status,proto3,enum=atomix.map.service.UpdateStatus" json:"status,omitempty"`
	PreviousValue   []byte       `protobuf:"bytes,2,opt,name=previous_value,json=previousValue,proto3" json:"previous_value,omitempty"`
	PreviousVersion uint64       `protobuf:"varint,3,opt,name=previous_version,json=previousVersion,proto3" json:"previous_version,omitempty"`
	NewVersion      uint64       `protobuf:"varint,4,opt,name=new_version,json=newVersion,proto3" json:"new_version,omitempty"`
	Created         time.Time    `protobuf:"bytes,5,opt,name=created,proto3,stdtime" json:"created"`
	Updated         time.Time    `protobuf:"bytes,6,opt,name=updated,proto3,stdtime" json:"updated"`
}

func (*ReplaceResponse) Descriptor 

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

func (*ReplaceResponse) GetCreated 

func (m *ReplaceResponse) GetCreated() time.Time

func (*ReplaceResponse) GetNewVersion 

func (m *ReplaceResponse) GetNewVersion() uint64

func (*ReplaceResponse) GetPreviousValue 

func (m *ReplaceResponse) GetPreviousValue() []byte

func (*ReplaceResponse) GetPreviousVersion 

func (m *ReplaceResponse) GetPreviousVersion() uint64

func (*ReplaceResponse) GetStatus 

func (m *ReplaceResponse) GetStatus() UpdateStatus

func (*ReplaceResponse) GetUpdated 

func (m *ReplaceResponse) GetUpdated() time.Time

func (*ReplaceResponse) Marshal 

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

func (*ReplaceResponse) MarshalTo 

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

func (*ReplaceResponse) MarshalToSizedBuffer 

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

func (*ReplaceResponse) ProtoMessage 

func (*ReplaceResponse) ProtoMessage()

func (*ReplaceResponse) Reset 

func (m *ReplaceResponse) Reset()

func (*ReplaceResponse) Size 

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

func (*ReplaceResponse) String 

func (m *ReplaceResponse) String() string

func (*ReplaceResponse) Unmarshal 

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

func (*ReplaceResponse) XXX_DiscardUnknown 

func (m *ReplaceResponse) XXX_DiscardUnknown()

func (*ReplaceResponse) XXX_Marshal 

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

func (*ReplaceResponse) XXX_Merge 

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

func (*ReplaceResponse) XXX_Size 

func (m *ReplaceResponse) XXX_Size() int

func (*ReplaceResponse) XXX_Unmarshal 

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

type Server 

type Server struct {
	*primitive.Server
}

Server is an implementation of MapServiceServer for the map primitive

func (*Server) Clear 

func (s *Server) Clear(ctx context.Context, request *api.ClearRequest) (*api.ClearResponse, error)

Clear removes all keys from the map

func (*Server) Close 

func (s *Server) Close(ctx context.Context, request *api.CloseRequest) (*api.CloseResponse, error)

Close closes a session

func (*Server) Create 

func (s *Server) Create(ctx context.Context, request *api.CreateRequest) (*api.CreateResponse, error)

Create opens a new session

func (*Server) Entries 

func (s *Server) Entries(request *api.EntriesRequest, srv api.MapService_EntriesServer) error

Entries lists all entries currently in the map

func (*Server) Events 

func (s *Server) Events(request *api.EventRequest, srv api.MapService_EventsServer) error

Events listens for map change events

func (*Server) Exists 

func (s *Server) Exists(ctx context.Context, request *api.ExistsRequest) (*api.ExistsResponse, error)

Exists checks whether the map contains a key

func (*Server) Get 

func (s *Server) Get(ctx context.Context, request *api.GetRequest) (*api.GetResponse, error)

Get gets the value of a key

func (*Server) Put 

func (s *Server) Put(ctx context.Context, request *api.PutRequest) (*api.PutResponse, error)

Put puts a key/value pair into the map

func (*Server) Remove 

func (s *Server) Remove(ctx context.Context, request *api.RemoveRequest) (*api.RemoveResponse, error)

Remove removes a key from the map

func (*Server) Replace 

func (s *Server) Replace(ctx context.Context, request *api.ReplaceRequest) (*api.ReplaceResponse, error)

Replace replaces a key/value pair in the map

func (*Server) Size 

func (s *Server) Size(ctx context.Context, request *api.SizeRequest) (*api.SizeResponse, error)

Size gets the number of entries in the map

type Service 

type Service struct {
	primitive.Service
	// contains filtered or unexported fields
}

Service is a state machine for a map primitive

func (*Service) Backup 

func (m *Service) Backup(writer io.Writer) error

Backup takes a snapshot of the service

func (*Service) Clear 

func (m *Service) Clear(value []byte) ([]byte, error)

Clear removes all entries from the map

func (*Service) Entries 

func (m *Service) Entries(value []byte, stream primitive.Stream)

Entries returns a stream of entries to the client

func (*Service) Events 

func (m *Service) Events(bytes []byte, stream primitive.Stream)

Events sends change events to the client

func (*Service) Exists 

func (m *Service) Exists(bytes []byte) ([]byte, error)

Exists checks if the map contains a key

func (*Service) Get 

func (m *Service) Get(bytes []byte) ([]byte, error)

Get gets a value from the map

func (*Service) Put 

func (m *Service) Put(value []byte) ([]byte, error)

Put puts a key/value pair in the map

func (*Service) Remove 

func (m *Service) Remove(bytes []byte) ([]byte, error)

Remove removes a key/value pair from the map

func (*Service) Replace 

func (m *Service) Replace(value []byte) ([]byte, error)

Replace replaces a key/value pair in the map

func (*Service) Restore 

func (m *Service) Restore(reader io.Reader) error

Restore restores the service from a snapshot

func (*Service) Size 

func (m *Service) Size(bytes []byte) ([]byte, error)

Size returns the size of the map

type SizeRequest 

type SizeRequest struct {
}

func (*SizeRequest) Descriptor 

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

func (*SizeRequest) Marshal 

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

func (*SizeRequest) MarshalTo 

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

func (*SizeRequest) MarshalToSizedBuffer 

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

func (*SizeRequest) ProtoMessage 

func (*SizeRequest) ProtoMessage()

func (*SizeRequest) Reset 

func (m *SizeRequest) Reset()

func (*SizeRequest) Size 

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

func (*SizeRequest) String 

func (m *SizeRequest) String() string

func (*SizeRequest) Unmarshal 

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

func (*SizeRequest) XXX_DiscardUnknown 

func (m *SizeRequest) XXX_DiscardUnknown()

func (*SizeRequest) XXX_Marshal 

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

func (*SizeRequest) XXX_Merge 

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

func (*SizeRequest) XXX_Size 

func (m *SizeRequest) XXX_Size() int

func (*SizeRequest) XXX_Unmarshal 

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

type SizeResponse 

type SizeResponse struct {
	Size_ uint32 `protobuf:"varint,1,opt,name=size,proto3" json:"size,omitempty"`
}

func (*SizeResponse) Descriptor 

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

func (*SizeResponse) GetSize_ 

func (m *SizeResponse) GetSize_() uint32

func (*SizeResponse) Marshal 

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

func (*SizeResponse) MarshalTo 

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

func (*SizeResponse) MarshalToSizedBuffer 

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

func (*SizeResponse) ProtoMessage 

func (*SizeResponse) ProtoMessage()

func (*SizeResponse) Reset 

func (m *SizeResponse) Reset()

func (*SizeResponse) Size 

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

func (*SizeResponse) String 

func (m *SizeResponse) String() string

func (*SizeResponse) Unmarshal 

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

func (*SizeResponse) XXX_DiscardUnknown 

func (m *SizeResponse) XXX_DiscardUnknown()

func (*SizeResponse) XXX_Marshal 

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

func (*SizeResponse) XXX_Merge 

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

func (*SizeResponse) XXX_Size 

func (m *SizeResponse) XXX_Size() int

func (*SizeResponse) XXX_Unmarshal 

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

type UnlistenRequest 

type UnlistenRequest struct {
	StreamId int64 `protobuf:"varint,1,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty"`
}

func (*UnlistenRequest) Descriptor 

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

func (*UnlistenRequest) GetStreamId 

func (m *UnlistenRequest) GetStreamId() int64

func (*UnlistenRequest) Marshal 

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

func (*UnlistenRequest) MarshalTo 

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

func (*UnlistenRequest) MarshalToSizedBuffer 

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

func (*UnlistenRequest) ProtoMessage 

func (*UnlistenRequest) ProtoMessage()

func (*UnlistenRequest) Reset 

func (m *UnlistenRequest) Reset()

func (*UnlistenRequest) Size 

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

func (*UnlistenRequest) String 

func (m *UnlistenRequest) String() string

func (*UnlistenRequest) Unmarshal 

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

func (*UnlistenRequest) XXX_DiscardUnknown 

func (m *UnlistenRequest) XXX_DiscardUnknown()

func (*UnlistenRequest) XXX_Marshal 

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

func (*UnlistenRequest) XXX_Merge 

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

func (*UnlistenRequest) XXX_Size 

func (m *UnlistenRequest) XXX_Size() int

func (*UnlistenRequest) XXX_Unmarshal 

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

type UnlistenResponse 

type UnlistenResponse struct {
}

func (*UnlistenResponse) Descriptor 

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

func (*UnlistenResponse) Marshal 

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

func (*UnlistenResponse) MarshalTo 

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

func (*UnlistenResponse) MarshalToSizedBuffer 

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

func (*UnlistenResponse) ProtoMessage 

func (*UnlistenResponse) ProtoMessage()

func (*UnlistenResponse) Reset 

func (m *UnlistenResponse) Reset()

func (*UnlistenResponse) Size 

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

func (*UnlistenResponse) String 

func (m *UnlistenResponse) String() string

func (*UnlistenResponse) Unmarshal 

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

func (*UnlistenResponse) XXX_DiscardUnknown 

func (m *UnlistenResponse) XXX_DiscardUnknown()

func (*UnlistenResponse) XXX_Marshal 

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

func (*UnlistenResponse) XXX_Merge 

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

func (*UnlistenResponse) XXX_Size 

func (m *UnlistenResponse) XXX_Size() int

func (*UnlistenResponse) XXX_Unmarshal 

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

type UpdateStatus 

type UpdateStatus int32
const (
	UpdateStatus_OK                  UpdateStatus = 0
	UpdateStatus_NOOP                UpdateStatus = 1
	UpdateStatus_WRITE_LOCK          UpdateStatus = 2
	UpdateStatus_PRECONDITION_FAILED UpdateStatus = 3
)

func (UpdateStatus) EnumDescriptor 

func (UpdateStatus) EnumDescriptor() ([]byte, []int)

func (UpdateStatus) String 

func (x UpdateStatus) String() string

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.