_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

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL