indexedmap

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

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

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

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthIndexedmap        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowIndexedmap          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupIndexedmap = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var EventResponse_Type_name = map[int32]string{
	0: "NONE",
	1: "INSERTED",
	2: "UPDATED",
	3: "REMOVED",
}
View Source 
var EventResponse_Type_value = map[string]int32{
	"NONE":     0,
	"INSERTED": 1,
	"UPDATED":  2,
	"REMOVED":  3,
}
View Source 
var ResponseStatus_name = map[int32]string{
	0: "OK",
	1: "NOOP",
	2: "WRITE_LOCK",
	3: "PRECONDITION_FAILED",
}
View Source 
var ResponseStatus_value = map[string]int32{
	"OK":                  0,
	"NOOP":                1,
	"WRITE_LOCK":          2,
	"PRECONDITION_FAILED": 3,
}

Functions

func RegisterIndexedMapServiceServer 

func RegisterIndexedMapServiceServer(s *grpc.Server, srv IndexedMapServiceServer)

Types

type ClearRequest 

type ClearRequest struct {
	Header *headers.RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
}

func (*ClearRequest) Descriptor 

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

func (*ClearRequest) GetHeader 

func (m *ClearRequest) GetHeader() *headers.RequestHeader

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 {
	Header *headers.ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
}

func (*ClearResponse) Descriptor 

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

func (*ClearResponse) GetHeader 

func (m *ClearResponse) GetHeader() *headers.ResponseHeader

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 CloseRequest 

type CloseRequest struct {
	Header *headers.RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Delete bool                   `protobuf:"varint,2,opt,name=delete,proto3" json:"delete,omitempty"`
}

func (*CloseRequest) Descriptor 

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

func (*CloseRequest) GetDelete 

func (m *CloseRequest) GetDelete() bool

func (*CloseRequest) GetHeader 

func (m *CloseRequest) GetHeader() *headers.RequestHeader

func (*CloseRequest) Marshal 

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

func (*CloseRequest) MarshalTo 

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

func (*CloseRequest) MarshalToSizedBuffer 

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

func (*CloseRequest) ProtoMessage 

func (*CloseRequest) ProtoMessage()

func (*CloseRequest) Reset 

func (m *CloseRequest) Reset()

func (*CloseRequest) Size 

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

func (*CloseRequest) String 

func (m *CloseRequest) String() string

func (*CloseRequest) Unmarshal 

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

func (*CloseRequest) XXX_DiscardUnknown 

func (m *CloseRequest) XXX_DiscardUnknown()

func (*CloseRequest) XXX_Marshal 

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

func (*CloseRequest) XXX_Merge 

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

func (*CloseRequest) XXX_Size 

func (m *CloseRequest) XXX_Size() int

func (*CloseRequest) XXX_Unmarshal 

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

type CloseResponse 

type CloseResponse struct {
	Header *headers.ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
}

func (*CloseResponse) Descriptor 

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

func (*CloseResponse) GetHeader 

func (m *CloseResponse) GetHeader() *headers.ResponseHeader

func (*CloseResponse) Marshal 

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

func (*CloseResponse) MarshalTo 

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

func (*CloseResponse) MarshalToSizedBuffer 

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

func (*CloseResponse) ProtoMessage 

func (*CloseResponse) ProtoMessage()

func (*CloseResponse) Reset 

func (m *CloseResponse) Reset()

func (*CloseResponse) Size 

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

func (*CloseResponse) String 

func (m *CloseResponse) String() string

func (*CloseResponse) Unmarshal 

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

func (*CloseResponse) XXX_DiscardUnknown 

func (m *CloseResponse) XXX_DiscardUnknown()

func (*CloseResponse) XXX_Marshal 

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

func (*CloseResponse) XXX_Merge 

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

func (*CloseResponse) XXX_Size 

func (m *CloseResponse) XXX_Size() int

func (*CloseResponse) XXX_Unmarshal 

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

type CreateRequest 

type CreateRequest struct {
	Header  *headers.RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Timeout *time.Duration         `protobuf:"bytes,2,opt,name=timeout,proto3,stdduration" json:"timeout,omitempty"`
}

func (*CreateRequest) Descriptor 

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

func (*CreateRequest) GetHeader 

func (m *CreateRequest) GetHeader() *headers.RequestHeader

func (*CreateRequest) GetTimeout 

func (m *CreateRequest) GetTimeout() *time.Duration

func (*CreateRequest) Marshal 

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

func (*CreateRequest) MarshalTo 

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

func (*CreateRequest) MarshalToSizedBuffer 

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

func (*CreateRequest) ProtoMessage 

func (*CreateRequest) ProtoMessage()

func (*CreateRequest) Reset 

func (m *CreateRequest) Reset()

func (*CreateRequest) Size 

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

func (*CreateRequest) String 

func (m *CreateRequest) String() string

func (*CreateRequest) Unmarshal 

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

func (*CreateRequest) XXX_DiscardUnknown 

func (m *CreateRequest) XXX_DiscardUnknown()

func (*CreateRequest) XXX_Marshal 

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

func (*CreateRequest) XXX_Merge 

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

func (*CreateRequest) XXX_Size 

func (m *CreateRequest) XXX_Size() int

func (*CreateRequest) XXX_Unmarshal 

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

type CreateResponse 

type CreateResponse struct {
	Header *headers.ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
}

func (*CreateResponse) Descriptor 

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

func (*CreateResponse) GetHeader 

func (m *CreateResponse) GetHeader() *headers.ResponseHeader

func (*CreateResponse) Marshal 

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

func (*CreateResponse) MarshalTo 

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

func (*CreateResponse) MarshalToSizedBuffer 

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

func (*CreateResponse) ProtoMessage 

func (*CreateResponse) ProtoMessage()

func (*CreateResponse) Reset 

func (m *CreateResponse) Reset()

func (*CreateResponse) Size 

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

func (*CreateResponse) String 

func (m *CreateResponse) String() string

func (*CreateResponse) Unmarshal 

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

func (*CreateResponse) XXX_DiscardUnknown 

func (m *CreateResponse) XXX_DiscardUnknown()

func (*CreateResponse) XXX_Marshal 

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

func (*CreateResponse) XXX_Merge 

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

func (*CreateResponse) XXX_Size 

func (m *CreateResponse) XXX_Size() int

func (*CreateResponse) XXX_Unmarshal 

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

type EntriesRequest 

type EntriesRequest struct {
	Header *headers.RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
}

func (*EntriesRequest) Descriptor 

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

func (*EntriesRequest) GetHeader 

func (m *EntriesRequest) GetHeader() *headers.RequestHeader

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 {
	Header  *headers.ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Key     string                  `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	Index   int64                   `protobuf:"varint,3,opt,name=index,proto3" json:"index,omitempty"`
	Value   []byte                  `protobuf:"bytes,4,opt,name=value,proto3" json:"value,omitempty"`
	Version int64                   `protobuf:"varint,5,opt,name=version,proto3" json:"version,omitempty"`
	Created time.Time               `protobuf:"bytes,6,opt,name=created,proto3,stdtime" json:"created"`
	Updated time.Time               `protobuf:"bytes,7,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) GetHeader 

func (m *EntriesResponse) GetHeader() *headers.ResponseHeader

func (*EntriesResponse) GetIndex 

func (m *EntriesResponse) GetIndex() int64

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() int64

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 EventRequest 

type EventRequest struct {
	Header *headers.RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Replay bool                   `protobuf:"varint,2,opt,name=replay,proto3" json:"replay,omitempty"`
	Key    string                 `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty"`
	Index  int64                  `protobuf:"varint,4,opt,name=index,proto3" json:"index,omitempty"`
}

func (*EventRequest) Descriptor 

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

func (*EventRequest) GetHeader 

func (m *EventRequest) GetHeader() *headers.RequestHeader

func (*EventRequest) GetIndex 

func (m *EventRequest) GetIndex() int64

func (*EventRequest) GetKey 

func (m *EventRequest) GetKey() string

func (*EventRequest) GetReplay 

func (m *EventRequest) GetReplay() bool

func (*EventRequest) Marshal 

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

func (*EventRequest) MarshalTo 

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

func (*EventRequest) MarshalToSizedBuffer 

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

func (*EventRequest) ProtoMessage 

func (*EventRequest) ProtoMessage()

func (*EventRequest) Reset 

func (m *EventRequest) Reset()

func (*EventRequest) Size 

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

func (*EventRequest) String 

func (m *EventRequest) String() string

func (*EventRequest) Unmarshal 

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

func (*EventRequest) XXX_DiscardUnknown 

func (m *EventRequest) XXX_DiscardUnknown()

func (*EventRequest) XXX_Marshal 

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

func (*EventRequest) XXX_Merge 

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

func (*EventRequest) XXX_Size 

func (m *EventRequest) XXX_Size() int

func (*EventRequest) XXX_Unmarshal 

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

type EventResponse 

type EventResponse struct {
	Header  *headers.ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Type    EventResponse_Type      `protobuf:"varint,2,opt,name=type,proto3,enum=atomix.indexedmap.EventResponse_Type" json:"type,omitempty"`
	Key     string                  `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty"`
	Index   int64                   `protobuf:"varint,4,opt,name=index,proto3" json:"index,omitempty"`
	Value   []byte                  `protobuf:"bytes,5,opt,name=value,proto3" json:"value,omitempty"`
	Version int64                   `protobuf:"varint,6,opt,name=version,proto3" json:"version,omitempty"`
	Created time.Time               `protobuf:"bytes,7,opt,name=created,proto3,stdtime" json:"created"`
	Updated time.Time               `protobuf:"bytes,8,opt,name=updated,proto3,stdtime" json:"updated"`
}

func (*EventResponse) Descriptor 

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

func (*EventResponse) GetCreated 

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

func (*EventResponse) GetHeader 

func (m *EventResponse) GetHeader() *headers.ResponseHeader

func (*EventResponse) GetIndex 

func (m *EventResponse) GetIndex() int64

func (*EventResponse) GetKey 

func (m *EventResponse) GetKey() string

func (*EventResponse) GetType 

func (m *EventResponse) GetType() EventResponse_Type

func (*EventResponse) GetUpdated 

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

func (*EventResponse) GetValue 

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

func (*EventResponse) GetVersion 

func (m *EventResponse) GetVersion() int64

func (*EventResponse) Marshal 

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

func (*EventResponse) MarshalTo 

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

func (*EventResponse) MarshalToSizedBuffer 

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

func (*EventResponse) ProtoMessage 

func (*EventResponse) ProtoMessage()

func (*EventResponse) Reset 

func (m *EventResponse) Reset()

func (*EventResponse) Size 

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

func (*EventResponse) String 

func (m *EventResponse) String() string

func (*EventResponse) Unmarshal 

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

func (*EventResponse) XXX_DiscardUnknown 

func (m *EventResponse) XXX_DiscardUnknown()

func (*EventResponse) XXX_Marshal 

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

func (*EventResponse) XXX_Merge 

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

func (*EventResponse) XXX_Size 

func (m *EventResponse) XXX_Size() int

func (*EventResponse) XXX_Unmarshal 

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

type EventResponse_Type 

type EventResponse_Type int32
const (
	EventResponse_NONE     EventResponse_Type = 0
	EventResponse_INSERTED EventResponse_Type = 1
	EventResponse_UPDATED  EventResponse_Type = 2
	EventResponse_REMOVED  EventResponse_Type = 3
)

func (EventResponse_Type) EnumDescriptor 

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

func (EventResponse_Type) String 

func (x EventResponse_Type) String() string

type ExistsRequest 

type ExistsRequest struct {
	Header *headers.RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Key    string                 `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
}

func (*ExistsRequest) Descriptor 

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

func (*ExistsRequest) GetHeader 

func (m *ExistsRequest) GetHeader() *headers.RequestHeader

func (*ExistsRequest) GetKey 

func (m *ExistsRequest) GetKey() string

func (*ExistsRequest) Marshal 

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

func (*ExistsRequest) MarshalTo 

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

func (*ExistsRequest) MarshalToSizedBuffer 

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

func (*ExistsRequest) ProtoMessage 

func (*ExistsRequest) ProtoMessage()

func (*ExistsRequest) Reset 

func (m *ExistsRequest) Reset()

func (*ExistsRequest) Size 

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

func (*ExistsRequest) String 

func (m *ExistsRequest) String() string

func (*ExistsRequest) Unmarshal 

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

func (*ExistsRequest) XXX_DiscardUnknown 

func (m *ExistsRequest) XXX_DiscardUnknown()

func (*ExistsRequest) XXX_Marshal 

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

func (*ExistsRequest) XXX_Merge 

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

func (*ExistsRequest) XXX_Size 

func (m *ExistsRequest) XXX_Size() int

func (*ExistsRequest) XXX_Unmarshal 

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

type ExistsResponse 

type ExistsResponse struct {
	Header      *headers.ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	ContainsKey bool                    `protobuf:"varint,2,opt,name=contains_key,json=containsKey,proto3" json:"contains_key,omitempty"`
}

func (*ExistsResponse) Descriptor 

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

func (*ExistsResponse) GetContainsKey 

func (m *ExistsResponse) GetContainsKey() bool

func (*ExistsResponse) GetHeader 

func (m *ExistsResponse) GetHeader() *headers.ResponseHeader

func (*ExistsResponse) Marshal 

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

func (*ExistsResponse) MarshalTo 

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

func (*ExistsResponse) MarshalToSizedBuffer 

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

func (*ExistsResponse) ProtoMessage 

func (*ExistsResponse) ProtoMessage()

func (*ExistsResponse) Reset 

func (m *ExistsResponse) Reset()

func (*ExistsResponse) Size 

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

func (*ExistsResponse) String 

func (m *ExistsResponse) String() string

func (*ExistsResponse) Unmarshal 

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

func (*ExistsResponse) XXX_DiscardUnknown 

func (m *ExistsResponse) XXX_DiscardUnknown()

func (*ExistsResponse) XXX_Marshal 

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

func (*ExistsResponse) XXX_Merge 

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

func (*ExistsResponse) XXX_Size 

func (m *ExistsResponse) XXX_Size() int

func (*ExistsResponse) XXX_Unmarshal 

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

type FirstEntryRequest 

type FirstEntryRequest struct {
	Header *headers.RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
}

func (*FirstEntryRequest) Descriptor 

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

func (*FirstEntryRequest) GetHeader 

func (m *FirstEntryRequest) GetHeader() *headers.RequestHeader

func (*FirstEntryRequest) Marshal 

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

func (*FirstEntryRequest) MarshalTo 

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

func (*FirstEntryRequest) MarshalToSizedBuffer 

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

func (*FirstEntryRequest) ProtoMessage 

func (*FirstEntryRequest) ProtoMessage()

func (*FirstEntryRequest) Reset 

func (m *FirstEntryRequest) Reset()

func (*FirstEntryRequest) Size 

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

func (*FirstEntryRequest) String 

func (m *FirstEntryRequest) String() string

func (*FirstEntryRequest) Unmarshal 

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

func (*FirstEntryRequest) XXX_DiscardUnknown 

func (m *FirstEntryRequest) XXX_DiscardUnknown()

func (*FirstEntryRequest) XXX_Marshal 

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

func (*FirstEntryRequest) XXX_Merge 

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

func (*FirstEntryRequest) XXX_Size 

func (m *FirstEntryRequest) XXX_Size() int

func (*FirstEntryRequest) XXX_Unmarshal 

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

type FirstEntryResponse 

type FirstEntryResponse struct {
	Header  *headers.ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Index   int64                   `protobuf:"varint,2,opt,name=index,proto3" json:"index,omitempty"`
	Key     string                  `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty"`
	Value   []byte                  `protobuf:"bytes,4,opt,name=value,proto3" json:"value,omitempty"`
	Version int64                   `protobuf:"varint,5,opt,name=version,proto3" json:"version,omitempty"`
	Created time.Time               `protobuf:"bytes,6,opt,name=created,proto3,stdtime" json:"created"`
	Updated time.Time               `protobuf:"bytes,7,opt,name=updated,proto3,stdtime" json:"updated"`
}

func (*FirstEntryResponse) Descriptor 

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

func (*FirstEntryResponse) GetCreated 

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

func (*FirstEntryResponse) GetHeader 

func (m *FirstEntryResponse) GetHeader() *headers.ResponseHeader

func (*FirstEntryResponse) GetIndex 

func (m *FirstEntryResponse) GetIndex() int64

func (*FirstEntryResponse) GetKey 

func (m *FirstEntryResponse) GetKey() string

func (*FirstEntryResponse) GetUpdated 

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

func (*FirstEntryResponse) GetValue 

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

func (*FirstEntryResponse) GetVersion 

func (m *FirstEntryResponse) GetVersion() int64

func (*FirstEntryResponse) Marshal 

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

func (*FirstEntryResponse) MarshalTo 

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

func (*FirstEntryResponse) MarshalToSizedBuffer 

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

func (*FirstEntryResponse) ProtoMessage 

func (*FirstEntryResponse) ProtoMessage()

func (*FirstEntryResponse) Reset 

func (m *FirstEntryResponse) Reset()

func (*FirstEntryResponse) Size 

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

func (*FirstEntryResponse) String 

func (m *FirstEntryResponse) String() string

func (*FirstEntryResponse) Unmarshal 

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

func (*FirstEntryResponse) XXX_DiscardUnknown 

func (m *FirstEntryResponse) XXX_DiscardUnknown()

func (*FirstEntryResponse) XXX_Marshal 

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

func (*FirstEntryResponse) XXX_Merge 

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

func (*FirstEntryResponse) XXX_Size 

func (m *FirstEntryResponse) XXX_Size() int

func (*FirstEntryResponse) XXX_Unmarshal 

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

type GetRequest 

type GetRequest struct {
	Header *headers.RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Index  int64                  `protobuf:"varint,2,opt,name=index,proto3" json:"index,omitempty"`
	Key    string                 `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty"`
}

func (*GetRequest) Descriptor 

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

func (*GetRequest) GetHeader 

func (m *GetRequest) GetHeader() *headers.RequestHeader

func (*GetRequest) GetIndex 

func (m *GetRequest) GetIndex() int64

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 {
	Header  *headers.ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Index   int64                   `protobuf:"varint,2,opt,name=index,proto3" json:"index,omitempty"`
	Key     string                  `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty"`
	Value   []byte                  `protobuf:"bytes,4,opt,name=value,proto3" json:"value,omitempty"`
	Version int64                   `protobuf:"varint,5,opt,name=version,proto3" json:"version,omitempty"`
	Created time.Time               `protobuf:"bytes,6,opt,name=created,proto3,stdtime" json:"created"`
	Updated time.Time               `protobuf:"bytes,7,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) GetHeader 

func (m *GetResponse) GetHeader() *headers.ResponseHeader

func (*GetResponse) GetIndex 

func (m *GetResponse) GetIndex() int64

func (*GetResponse) GetKey 

func (m *GetResponse) GetKey() string

func (*GetResponse) GetUpdated 

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

func (*GetResponse) GetValue 

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

func (*GetResponse) GetVersion 

func (m *GetResponse) GetVersion() int64

func (*GetResponse) Marshal 

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

func (*GetResponse) MarshalTo 

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

func (*GetResponse) MarshalToSizedBuffer 

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

func (*GetResponse) ProtoMessage 

func (*GetResponse) ProtoMessage()

func (*GetResponse) Reset 

func (m *GetResponse) Reset()

func (*GetResponse) Size 

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

func (*GetResponse) String 

func (m *GetResponse) String() string

func (*GetResponse) Unmarshal 

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

func (*GetResponse) XXX_DiscardUnknown 

func (m *GetResponse) XXX_DiscardUnknown()

func (*GetResponse) XXX_Marshal 

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

func (*GetResponse) XXX_Merge 

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

func (*GetResponse) XXX_Size 

func (m *GetResponse) XXX_Size() int

func (*GetResponse) XXX_Unmarshal 

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

type IndexedMapServiceClient 

type IndexedMapServiceClient interface {
	Create(ctx context.Context, in *CreateRequest, opts ...grpc.CallOption) (*CreateResponse, error)
	KeepAlive(ctx context.Context, in *KeepAliveRequest, opts ...grpc.CallOption) (*KeepAliveResponse, error)
	Close(ctx context.Context, in *CloseRequest, opts ...grpc.CallOption) (*CloseResponse, error)
	Size(ctx context.Context, in *SizeRequest, opts ...grpc.CallOption) (*SizeResponse, error)
	Exists(ctx context.Context, in *ExistsRequest, opts ...grpc.CallOption) (*ExistsResponse, error)
	Put(ctx context.Context, in *PutRequest, opts ...grpc.CallOption) (*PutResponse, error)
	Replace(ctx context.Context, in *ReplaceRequest, opts ...grpc.CallOption) (*ReplaceResponse, error)
	Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetResponse, error)
	FirstEntry(ctx context.Context, in *FirstEntryRequest, opts ...grpc.CallOption) (*FirstEntryResponse, error)
	LastEntry(ctx context.Context, in *LastEntryRequest, opts ...grpc.CallOption) (*LastEntryResponse, error)
	PrevEntry(ctx context.Context, in *PrevEntryRequest, opts ...grpc.CallOption) (*PrevEntryResponse, error)
	NextEntry(ctx context.Context, in *NextEntryRequest, opts ...grpc.CallOption) (*NextEntryResponse, error)
	Remove(ctx context.Context, in *RemoveRequest, opts ...grpc.CallOption) (*RemoveResponse, error)
	Clear(ctx context.Context, in *ClearRequest, opts ...grpc.CallOption) (*ClearResponse, error)
	Events(ctx context.Context, in *EventRequest, opts ...grpc.CallOption) (IndexedMapService_EventsClient, error)
	Entries(ctx context.Context, in *EntriesRequest, opts ...grpc.CallOption) (IndexedMapService_EntriesClient, error)
}

IndexedMapServiceClient is the client API for IndexedMapService service.

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

func NewIndexedMapServiceClient 

func NewIndexedMapServiceClient(cc *grpc.ClientConn) IndexedMapServiceClient

type IndexedMapServiceServer 

type IndexedMapServiceServer interface {
	Create(context.Context, *CreateRequest) (*CreateResponse, error)
	KeepAlive(context.Context, *KeepAliveRequest) (*KeepAliveResponse, error)
	Close(context.Context, *CloseRequest) (*CloseResponse, error)
	Size(context.Context, *SizeRequest) (*SizeResponse, error)
	Exists(context.Context, *ExistsRequest) (*ExistsResponse, error)
	Put(context.Context, *PutRequest) (*PutResponse, error)
	Replace(context.Context, *ReplaceRequest) (*ReplaceResponse, error)
	Get(context.Context, *GetRequest) (*GetResponse, error)
	FirstEntry(context.Context, *FirstEntryRequest) (*FirstEntryResponse, error)
	LastEntry(context.Context, *LastEntryRequest) (*LastEntryResponse, error)
	PrevEntry(context.Context, *PrevEntryRequest) (*PrevEntryResponse, error)
	NextEntry(context.Context, *NextEntryRequest) (*NextEntryResponse, error)
	Remove(context.Context, *RemoveRequest) (*RemoveResponse, error)
	Clear(context.Context, *ClearRequest) (*ClearResponse, error)
	Events(*EventRequest, IndexedMapService_EventsServer) error
	Entries(*EntriesRequest, IndexedMapService_EntriesServer) error
}

IndexedMapServiceServer is the server API for IndexedMapService service.

type IndexedMapService_EntriesClient 

type IndexedMapService_EntriesClient interface {
	Recv() (*EntriesResponse, error)
	grpc.ClientStream
}

type IndexedMapService_EntriesServer 

type IndexedMapService_EntriesServer interface {
	Send(*EntriesResponse) error
	grpc.ServerStream
}

type IndexedMapService_EventsClient 

type IndexedMapService_EventsClient interface {
	Recv() (*EventResponse, error)
	grpc.ClientStream
}

type IndexedMapService_EventsServer 

type IndexedMapService_EventsServer interface {
	Send(*EventResponse) error
	grpc.ServerStream
}

type KeepAliveRequest 

type KeepAliveRequest struct {
	Header *headers.RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
}

func (*KeepAliveRequest) Descriptor 

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

func (*KeepAliveRequest) GetHeader 

func (m *KeepAliveRequest) GetHeader() *headers.RequestHeader

func (*KeepAliveRequest) Marshal 

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

func (*KeepAliveRequest) MarshalTo 

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

func (*KeepAliveRequest) MarshalToSizedBuffer 

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

func (*KeepAliveRequest) ProtoMessage 

func (*KeepAliveRequest) ProtoMessage()

func (*KeepAliveRequest) Reset 

func (m *KeepAliveRequest) Reset()

func (*KeepAliveRequest) Size 

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

func (*KeepAliveRequest) String 

func (m *KeepAliveRequest) String() string

func (*KeepAliveRequest) Unmarshal 

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

func (*KeepAliveRequest) XXX_DiscardUnknown 

func (m *KeepAliveRequest) XXX_DiscardUnknown()

func (*KeepAliveRequest) XXX_Marshal 

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

func (*KeepAliveRequest) XXX_Merge 

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

func (*KeepAliveRequest) XXX_Size 

func (m *KeepAliveRequest) XXX_Size() int

func (*KeepAliveRequest) XXX_Unmarshal 

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

type KeepAliveResponse 

type KeepAliveResponse struct {
	Header *headers.ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
}

func (*KeepAliveResponse) Descriptor 

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

func (*KeepAliveResponse) GetHeader 

func (m *KeepAliveResponse) GetHeader() *headers.ResponseHeader

func (*KeepAliveResponse) Marshal 

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

func (*KeepAliveResponse) MarshalTo 

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

func (*KeepAliveResponse) MarshalToSizedBuffer 

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

func (*KeepAliveResponse) ProtoMessage 

func (*KeepAliveResponse) ProtoMessage()

func (*KeepAliveResponse) Reset 

func (m *KeepAliveResponse) Reset()

func (*KeepAliveResponse) Size 

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

func (*KeepAliveResponse) String 

func (m *KeepAliveResponse) String() string

func (*KeepAliveResponse) Unmarshal 

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

func (*KeepAliveResponse) XXX_DiscardUnknown 

func (m *KeepAliveResponse) XXX_DiscardUnknown()

func (*KeepAliveResponse) XXX_Marshal 

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

func (*KeepAliveResponse) XXX_Merge 

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

func (*KeepAliveResponse) XXX_Size 

func (m *KeepAliveResponse) XXX_Size() int

func (*KeepAliveResponse) XXX_Unmarshal 

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

type LastEntryRequest 

type LastEntryRequest struct {
	Header *headers.RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
}

func (*LastEntryRequest) Descriptor 

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

func (*LastEntryRequest) GetHeader 

func (m *LastEntryRequest) GetHeader() *headers.RequestHeader

func (*LastEntryRequest) Marshal 

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

func (*LastEntryRequest) MarshalTo 

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

func (*LastEntryRequest) MarshalToSizedBuffer 

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

func (*LastEntryRequest) ProtoMessage 

func (*LastEntryRequest) ProtoMessage()

func (*LastEntryRequest) Reset 

func (m *LastEntryRequest) Reset()

func (*LastEntryRequest) Size 

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

func (*LastEntryRequest) String 

func (m *LastEntryRequest) String() string

func (*LastEntryRequest) Unmarshal 

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

func (*LastEntryRequest) XXX_DiscardUnknown 

func (m *LastEntryRequest) XXX_DiscardUnknown()

func (*LastEntryRequest) XXX_Marshal 

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

func (*LastEntryRequest) XXX_Merge 

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

func (*LastEntryRequest) XXX_Size 

func (m *LastEntryRequest) XXX_Size() int

func (*LastEntryRequest) XXX_Unmarshal 

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

type LastEntryResponse 

type LastEntryResponse struct {
	Header  *headers.ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Index   int64                   `protobuf:"varint,2,opt,name=index,proto3" json:"index,omitempty"`
	Key     string                  `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty"`
	Value   []byte                  `protobuf:"bytes,4,opt,name=value,proto3" json:"value,omitempty"`
	Version int64                   `protobuf:"varint,5,opt,name=version,proto3" json:"version,omitempty"`
	Created time.Time               `protobuf:"bytes,6,opt,name=created,proto3,stdtime" json:"created"`
	Updated time.Time               `protobuf:"bytes,7,opt,name=updated,proto3,stdtime" json:"updated"`
}

func (*LastEntryResponse) Descriptor 

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

func (*LastEntryResponse) GetCreated 

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

func (*LastEntryResponse) GetHeader 

func (m *LastEntryResponse) GetHeader() *headers.ResponseHeader

func (*LastEntryResponse) GetIndex 

func (m *LastEntryResponse) GetIndex() int64

func (*LastEntryResponse) GetKey 

func (m *LastEntryResponse) GetKey() string

func (*LastEntryResponse) GetUpdated 

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

func (*LastEntryResponse) GetValue 

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

func (*LastEntryResponse) GetVersion 

func (m *LastEntryResponse) GetVersion() int64

func (*LastEntryResponse) Marshal 

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

func (*LastEntryResponse) MarshalTo 

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

func (*LastEntryResponse) MarshalToSizedBuffer 

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

func (*LastEntryResponse) ProtoMessage 

func (*LastEntryResponse) ProtoMessage()

func (*LastEntryResponse) Reset 

func (m *LastEntryResponse) Reset()

func (*LastEntryResponse) Size 

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

func (*LastEntryResponse) String 

func (m *LastEntryResponse) String() string

func (*LastEntryResponse) Unmarshal 

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

func (*LastEntryResponse) XXX_DiscardUnknown 

func (m *LastEntryResponse) XXX_DiscardUnknown()

func (*LastEntryResponse) XXX_Marshal 

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

func (*LastEntryResponse) XXX_Merge 

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

func (*LastEntryResponse) XXX_Size 

func (m *LastEntryResponse) XXX_Size() int

func (*LastEntryResponse) XXX_Unmarshal 

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

type NextEntryRequest 

type NextEntryRequest struct {
	Header *headers.RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Index  int64                  `protobuf:"varint,2,opt,name=index,proto3" json:"index,omitempty"`
}

func (*NextEntryRequest) Descriptor 

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

func (*NextEntryRequest) GetHeader 

func (m *NextEntryRequest) GetHeader() *headers.RequestHeader

func (*NextEntryRequest) GetIndex 

func (m *NextEntryRequest) GetIndex() int64

func (*NextEntryRequest) Marshal 

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

func (*NextEntryRequest) MarshalTo 

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

func (*NextEntryRequest) MarshalToSizedBuffer 

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

func (*NextEntryRequest) ProtoMessage 

func (*NextEntryRequest) ProtoMessage()

func (*NextEntryRequest) Reset 

func (m *NextEntryRequest) Reset()

func (*NextEntryRequest) Size 

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

func (*NextEntryRequest) String 

func (m *NextEntryRequest) String() string

func (*NextEntryRequest) Unmarshal 

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

func (*NextEntryRequest) XXX_DiscardUnknown 

func (m *NextEntryRequest) XXX_DiscardUnknown()

func (*NextEntryRequest) XXX_Marshal 

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

func (*NextEntryRequest) XXX_Merge 

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

func (*NextEntryRequest) XXX_Size 

func (m *NextEntryRequest) XXX_Size() int

func (*NextEntryRequest) XXX_Unmarshal 

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

type NextEntryResponse 

type NextEntryResponse struct {
	Header  *headers.ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Index   int64                   `protobuf:"varint,2,opt,name=index,proto3" json:"index,omitempty"`
	Key     string                  `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty"`
	Value   []byte                  `protobuf:"bytes,4,opt,name=value,proto3" json:"value,omitempty"`
	Version int64                   `protobuf:"varint,5,opt,name=version,proto3" json:"version,omitempty"`
	Created time.Time               `protobuf:"bytes,6,opt,name=created,proto3,stdtime" json:"created"`
	Updated time.Time               `protobuf:"bytes,7,opt,name=updated,proto3,stdtime" json:"updated"`
}

func (*NextEntryResponse) Descriptor 

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

func (*NextEntryResponse) GetCreated 

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

func (*NextEntryResponse) GetHeader 

func (m *NextEntryResponse) GetHeader() *headers.ResponseHeader

func (*NextEntryResponse) GetIndex 

func (m *NextEntryResponse) GetIndex() int64

func (*NextEntryResponse) GetKey 

func (m *NextEntryResponse) GetKey() string

func (*NextEntryResponse) GetUpdated 

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

func (*NextEntryResponse) GetValue 

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

func (*NextEntryResponse) GetVersion 

func (m *NextEntryResponse) GetVersion() int64

func (*NextEntryResponse) Marshal 

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

func (*NextEntryResponse) MarshalTo 

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

func (*NextEntryResponse) MarshalToSizedBuffer 

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

func (*NextEntryResponse) ProtoMessage 

func (*NextEntryResponse) ProtoMessage()

func (*NextEntryResponse) Reset 

func (m *NextEntryResponse) Reset()

func (*NextEntryResponse) Size 

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

func (*NextEntryResponse) String 

func (m *NextEntryResponse) String() string

func (*NextEntryResponse) Unmarshal 

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

func (*NextEntryResponse) XXX_DiscardUnknown 

func (m *NextEntryResponse) XXX_DiscardUnknown()

func (*NextEntryResponse) XXX_Marshal 

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

func (*NextEntryResponse) XXX_Merge 

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

func (*NextEntryResponse) XXX_Size 

func (m *NextEntryResponse) XXX_Size() int

func (*NextEntryResponse) XXX_Unmarshal 

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

type PrevEntryRequest 

type PrevEntryRequest struct {
	Header *headers.RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Index  int64                  `protobuf:"varint,2,opt,name=index,proto3" json:"index,omitempty"`
}

func (*PrevEntryRequest) Descriptor 

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

func (*PrevEntryRequest) GetHeader 

func (m *PrevEntryRequest) GetHeader() *headers.RequestHeader

func (*PrevEntryRequest) GetIndex 

func (m *PrevEntryRequest) GetIndex() int64

func (*PrevEntryRequest) Marshal 

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

func (*PrevEntryRequest) MarshalTo 

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

func (*PrevEntryRequest) MarshalToSizedBuffer 

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

func (*PrevEntryRequest) ProtoMessage 

func (*PrevEntryRequest) ProtoMessage()

func (*PrevEntryRequest) Reset 

func (m *PrevEntryRequest) Reset()

func (*PrevEntryRequest) Size 

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

func (*PrevEntryRequest) String 

func (m *PrevEntryRequest) String() string

func (*PrevEntryRequest) Unmarshal 

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

func (*PrevEntryRequest) XXX_DiscardUnknown 

func (m *PrevEntryRequest) XXX_DiscardUnknown()

func (*PrevEntryRequest) XXX_Marshal 

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

func (*PrevEntryRequest) XXX_Merge 

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

func (*PrevEntryRequest) XXX_Size 

func (m *PrevEntryRequest) XXX_Size() int

func (*PrevEntryRequest) XXX_Unmarshal 

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

type PrevEntryResponse 

type PrevEntryResponse struct {
	Header  *headers.ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Index   int64                   `protobuf:"varint,2,opt,name=index,proto3" json:"index,omitempty"`
	Key     string                  `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty"`
	Value   []byte                  `protobuf:"bytes,4,opt,name=value,proto3" json:"value,omitempty"`
	Version int64                   `protobuf:"varint,5,opt,name=version,proto3" json:"version,omitempty"`
	Created time.Time               `protobuf:"bytes,6,opt,name=created,proto3,stdtime" json:"created"`
	Updated time.Time               `protobuf:"bytes,7,opt,name=updated,proto3,stdtime" json:"updated"`
}

func (*PrevEntryResponse) Descriptor 

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

func (*PrevEntryResponse) GetCreated 

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

func (*PrevEntryResponse) GetHeader 

func (m *PrevEntryResponse) GetHeader() *headers.ResponseHeader

func (*PrevEntryResponse) GetIndex 

func (m *PrevEntryResponse) GetIndex() int64

func (*PrevEntryResponse) GetKey 

func (m *PrevEntryResponse) GetKey() string

func (*PrevEntryResponse) GetUpdated 

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

func (*PrevEntryResponse) GetValue 

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

func (*PrevEntryResponse) GetVersion 

func (m *PrevEntryResponse) GetVersion() int64

func (*PrevEntryResponse) Marshal 

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

func (*PrevEntryResponse) MarshalTo 

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

func (*PrevEntryResponse) MarshalToSizedBuffer 

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

func (*PrevEntryResponse) ProtoMessage 

func (*PrevEntryResponse) ProtoMessage()

func (*PrevEntryResponse) Reset 

func (m *PrevEntryResponse) Reset()

func (*PrevEntryResponse) Size 

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

func (*PrevEntryResponse) String 

func (m *PrevEntryResponse) String() string

func (*PrevEntryResponse) Unmarshal 

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

func (*PrevEntryResponse) XXX_DiscardUnknown 

func (m *PrevEntryResponse) XXX_DiscardUnknown()

func (*PrevEntryResponse) XXX_Marshal 

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

func (*PrevEntryResponse) XXX_Merge 

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

func (*PrevEntryResponse) XXX_Size 

func (m *PrevEntryResponse) XXX_Size() int

func (*PrevEntryResponse) XXX_Unmarshal 

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

type PutRequest 

type PutRequest struct {
	Header  *headers.RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Index   int64                  `protobuf:"varint,2,opt,name=index,proto3" json:"index,omitempty"`
	Key     string                 `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty"`
	Value   []byte                 `protobuf:"bytes,4,opt,name=value,proto3" json:"value,omitempty"`
	Version int64                  `protobuf:"varint,5,opt,name=version,proto3" json:"version,omitempty"`
	TTL     *time.Duration         `protobuf:"bytes,6,opt,name=ttl,proto3,stdduration" json:"ttl,omitempty"`
}

func (*PutRequest) Descriptor 

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

func (*PutRequest) GetHeader 

func (m *PutRequest) GetHeader() *headers.RequestHeader

func (*PutRequest) GetIndex 

func (m *PutRequest) GetIndex() int64

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() int64

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 {
	Header          *headers.ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Status          ResponseStatus          `protobuf:"varint,2,opt,name=status,proto3,enum=atomix.indexedmap.ResponseStatus" json:"status,omitempty"`
	Index           int64                   `protobuf:"varint,3,opt,name=index,proto3" json:"index,omitempty"`
	Key             string                  `protobuf:"bytes,4,opt,name=key,proto3" json:"key,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"`
	PreviousValue   []byte                  `protobuf:"bytes,7,opt,name=previous_value,json=previousValue,proto3" json:"previous_value,omitempty"`
	PreviousVersion int64                   `protobuf:"varint,8,opt,name=previous_version,json=previousVersion,proto3" json:"previous_version,omitempty"`
}

func (*PutResponse) Descriptor 

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

func (*PutResponse) GetCreated 

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

func (*PutResponse) GetHeader 

func (m *PutResponse) GetHeader() *headers.ResponseHeader

func (*PutResponse) GetIndex 

func (m *PutResponse) GetIndex() int64

func (*PutResponse) GetKey 

func (m *PutResponse) GetKey() string

func (*PutResponse) GetPreviousValue 

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

func (*PutResponse) GetPreviousVersion 

func (m *PutResponse) GetPreviousVersion() int64

func (*PutResponse) GetStatus 

func (m *PutResponse) GetStatus() ResponseStatus

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 {
	Header  *headers.RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Index   int64                  `protobuf:"varint,2,opt,name=index,proto3" json:"index,omitempty"`
	Key     string                 `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty"`
	Value   []byte                 `protobuf:"bytes,4,opt,name=value,proto3" json:"value,omitempty"`
	Version int64                  `protobuf:"varint,5,opt,name=version,proto3" json:"version,omitempty"`
	Created time.Time              `protobuf:"bytes,6,opt,name=created,proto3,stdtime" json:"created"`
	Updated time.Time              `protobuf:"bytes,7,opt,name=updated,proto3,stdtime" json:"updated"`
}

func (*RemoveRequest) Descriptor 

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

func (*RemoveRequest) GetCreated 

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

func (*RemoveRequest) GetHeader 

func (m *RemoveRequest) GetHeader() *headers.RequestHeader

func (*RemoveRequest) GetIndex 

func (m *RemoveRequest) GetIndex() int64

func (*RemoveRequest) GetKey 

func (m *RemoveRequest) GetKey() string

func (*RemoveRequest) GetUpdated 

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

func (*RemoveRequest) GetValue 

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

func (*RemoveRequest) GetVersion 

func (m *RemoveRequest) GetVersion() int64

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 {
	Header          *headers.ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Status          ResponseStatus          `protobuf:"varint,2,opt,name=status,proto3,enum=atomix.indexedmap.ResponseStatus" json:"status,omitempty"`
	Index           int64                   `protobuf:"varint,3,opt,name=index,proto3" json:"index,omitempty"`
	Key             string                  `protobuf:"bytes,4,opt,name=key,proto3" json:"key,omitempty"`
	PreviousValue   []byte                  `protobuf:"bytes,5,opt,name=previous_value,json=previousValue,proto3" json:"previous_value,omitempty"`
	PreviousVersion int64                   `protobuf:"varint,6,opt,name=previous_version,json=previousVersion,proto3" json:"previous_version,omitempty"`
}

func (*RemoveResponse) Descriptor 

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

func (*RemoveResponse) GetHeader 

func (m *RemoveResponse) GetHeader() *headers.ResponseHeader

func (*RemoveResponse) GetIndex 

func (m *RemoveResponse) GetIndex() int64

func (*RemoveResponse) GetKey 

func (m *RemoveResponse) GetKey() string

func (*RemoveResponse) GetPreviousValue 

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

func (*RemoveResponse) GetPreviousVersion 

func (m *RemoveResponse) GetPreviousVersion() int64

func (*RemoveResponse) GetStatus 

func (m *RemoveResponse) GetStatus() ResponseStatus

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 {
	Header          *headers.RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Index           int64                  `protobuf:"varint,2,opt,name=index,proto3" json:"index,omitempty"`
	Key             string                 `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty"`
	PreviousValue   []byte                 `protobuf:"bytes,4,opt,name=previous_value,json=previousValue,proto3" json:"previous_value,omitempty"`
	PreviousVersion int64                  `protobuf:"varint,5,opt,name=previous_version,json=previousVersion,proto3" json:"previous_version,omitempty"`
	NewValue        []byte                 `protobuf:"bytes,6,opt,name=new_value,json=newValue,proto3" json:"new_value,omitempty"`
	TTL             *time.Duration         `protobuf:"bytes,7,opt,name=ttl,proto3,stdduration" json:"ttl,omitempty"`
}

func (*ReplaceRequest) Descriptor 

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

func (*ReplaceRequest) GetHeader 

func (m *ReplaceRequest) GetHeader() *headers.RequestHeader

func (*ReplaceRequest) GetIndex 

func (m *ReplaceRequest) GetIndex() int64

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() int64

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 {
	Header          *headers.ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Status          ResponseStatus          `protobuf:"varint,2,opt,name=status,proto3,enum=atomix.indexedmap.ResponseStatus" json:"status,omitempty"`
	Index           int64                   `protobuf:"varint,3,opt,name=index,proto3" json:"index,omitempty"`
	Key             string                  `protobuf:"bytes,4,opt,name=key,proto3" json:"key,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"`
	PreviousValue   []byte                  `protobuf:"bytes,7,opt,name=previous_value,json=previousValue,proto3" json:"previous_value,omitempty"`
	PreviousVersion int64                   `protobuf:"varint,8,opt,name=previous_version,json=previousVersion,proto3" json:"previous_version,omitempty"`
}

func (*ReplaceResponse) Descriptor 

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

func (*ReplaceResponse) GetCreated 

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

func (*ReplaceResponse) GetHeader 

func (m *ReplaceResponse) GetHeader() *headers.ResponseHeader

func (*ReplaceResponse) GetIndex 

func (m *ReplaceResponse) GetIndex() int64

func (*ReplaceResponse) GetKey 

func (m *ReplaceResponse) GetKey() string

func (*ReplaceResponse) GetPreviousValue 

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

func (*ReplaceResponse) GetPreviousVersion 

func (m *ReplaceResponse) GetPreviousVersion() int64

func (*ReplaceResponse) GetStatus 

func (m *ReplaceResponse) GetStatus() ResponseStatus

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 ResponseStatus 

type ResponseStatus int32
const (
	ResponseStatus_OK                  ResponseStatus = 0
	ResponseStatus_NOOP                ResponseStatus = 1
	ResponseStatus_WRITE_LOCK          ResponseStatus = 2
	ResponseStatus_PRECONDITION_FAILED ResponseStatus = 3
)

func (ResponseStatus) EnumDescriptor 

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

func (ResponseStatus) String 

func (x ResponseStatus) String() string

type SizeRequest 

type SizeRequest struct {
	Header *headers.RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
}

func (*SizeRequest) Descriptor 

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

func (*SizeRequest) GetHeader 

func (m *SizeRequest) GetHeader() *headers.RequestHeader

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 {
	Header *headers.ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Size_  int32                   `protobuf:"varint,2,opt,name=size,proto3" json:"size,omitempty"`
}

func (*SizeResponse) Descriptor 

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

func (*SizeResponse) GetHeader 

func (m *SizeResponse) GetHeader() *headers.ResponseHeader

func (*SizeResponse) GetSize_ 

func (m *SizeResponse) GetSize_() int32

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 UnimplementedIndexedMapServiceServer 

type UnimplementedIndexedMapServiceServer struct {
}

UnimplementedIndexedMapServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedIndexedMapServiceServer) Clear 

func (*UnimplementedIndexedMapServiceServer) Clear(ctx context.Context, req *ClearRequest) (*ClearResponse, error)

func (*UnimplementedIndexedMapServiceServer) Close 

func (*UnimplementedIndexedMapServiceServer) Close(ctx context.Context, req *CloseRequest) (*CloseResponse, error)

func (*UnimplementedIndexedMapServiceServer) Create 

func (*UnimplementedIndexedMapServiceServer) Create(ctx context.Context, req *CreateRequest) (*CreateResponse, error)

func (*UnimplementedIndexedMapServiceServer) Entries 

func (*UnimplementedIndexedMapServiceServer) Entries(req *EntriesRequest, srv IndexedMapService_EntriesServer) error

func (*UnimplementedIndexedMapServiceServer) Events 

func (*UnimplementedIndexedMapServiceServer) Events(req *EventRequest, srv IndexedMapService_EventsServer) error

func (*UnimplementedIndexedMapServiceServer) Exists 

func (*UnimplementedIndexedMapServiceServer) Exists(ctx context.Context, req *ExistsRequest) (*ExistsResponse, error)

func (*UnimplementedIndexedMapServiceServer) FirstEntry 

func (*UnimplementedIndexedMapServiceServer) FirstEntry(ctx context.Context, req *FirstEntryRequest) (*FirstEntryResponse, error)

func (*UnimplementedIndexedMapServiceServer) Get 

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

func (*UnimplementedIndexedMapServiceServer) KeepAlive 

func (*UnimplementedIndexedMapServiceServer) KeepAlive(ctx context.Context, req *KeepAliveRequest) (*KeepAliveResponse, error)

func (*UnimplementedIndexedMapServiceServer) LastEntry 

func (*UnimplementedIndexedMapServiceServer) LastEntry(ctx context.Context, req *LastEntryRequest) (*LastEntryResponse, error)

func (*UnimplementedIndexedMapServiceServer) NextEntry 

func (*UnimplementedIndexedMapServiceServer) NextEntry(ctx context.Context, req *NextEntryRequest) (*NextEntryResponse, error)

func (*UnimplementedIndexedMapServiceServer) PrevEntry 

func (*UnimplementedIndexedMapServiceServer) PrevEntry(ctx context.Context, req *PrevEntryRequest) (*PrevEntryResponse, error)

func (*UnimplementedIndexedMapServiceServer) Put 

func (*UnimplementedIndexedMapServiceServer) Put(ctx context.Context, req *PutRequest) (*PutResponse, error)

func (*UnimplementedIndexedMapServiceServer) Remove 

func (*UnimplementedIndexedMapServiceServer) Remove(ctx context.Context, req *RemoveRequest) (*RemoveResponse, error)

func (*UnimplementedIndexedMapServiceServer) Replace 

func (*UnimplementedIndexedMapServiceServer) Replace(ctx context.Context, req *ReplaceRequest) (*ReplaceResponse, error)

func (*UnimplementedIndexedMapServiceServer) Size 

func (*UnimplementedIndexedMapServiceServer) Size(ctx context.Context, req *SizeRequest) (*SizeResponse, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

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