indexedmap

package
v0.8.0 Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthManager        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowManager          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupManager = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthPrimitive        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowPrimitive          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupPrimitive = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var Event_Type_name = map[int32]string{
	0: "NONE",
	1: "INSERT",
	2: "UPDATE",
	3: "REMOVE",
	4: "REPLAY",
}
View Source 
var Event_Type_value = map[string]int32{
	"NONE":   0,
	"INSERT": 1,
	"UPDATE": 2,
	"REMOVE": 3,
	"REPLAY": 4,
}
View Source 
var IndexedMapCacheStrategy_name = map[int32]string{
	0: "NEAR",
	1: "READ_THROUGH",
	2: "WRITE_THROUGH",
	3: "READ_THROUGH_WRITE_THROUGH",
}
View Source 
var IndexedMapCacheStrategy_value = map[string]int32{
	"NEAR":                       0,
	"READ_THROUGH":               1,
	"WRITE_THROUGH":              2,
	"READ_THROUGH_WRITE_THROUGH": 3,
}

Functions

func RegisterIndexedMapManagerServer added in v0.7.0 

func RegisterIndexedMapManagerServer(s *grpc.Server, srv IndexedMapManagerServer)

func RegisterIndexedMapServer 

func RegisterIndexedMapServer(s *grpc.Server, srv IndexedMapServer)

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 CloseSessionRequest 

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

func (*CloseSessionRequest) Descriptor 

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

func (*CloseSessionRequest) GetSessionID 

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

func (*CloseSessionRequest) Marshal 

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

func (*CloseSessionRequest) MarshalTo 

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

func (*CloseSessionRequest) MarshalToSizedBuffer 

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

func (*CloseSessionRequest) ProtoMessage 

func (*CloseSessionRequest) ProtoMessage()

func (*CloseSessionRequest) Reset 

func (m *CloseSessionRequest) Reset()

func (*CloseSessionRequest) Size 

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

func (*CloseSessionRequest) String 

func (m *CloseSessionRequest) String() string

func (*CloseSessionRequest) Unmarshal 

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

func (*CloseSessionRequest) XXX_DiscardUnknown 

func (m *CloseSessionRequest) XXX_DiscardUnknown()

func (*CloseSessionRequest) XXX_Marshal 

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

func (*CloseSessionRequest) XXX_Merge 

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

func (*CloseSessionRequest) XXX_Size 

func (m *CloseSessionRequest) XXX_Size() int

func (*CloseSessionRequest) XXX_Unmarshal 

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

type CloseSessionResponse 

type CloseSessionResponse struct {
}

func (*CloseSessionResponse) Descriptor 

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

func (*CloseSessionResponse) Marshal 

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

func (*CloseSessionResponse) MarshalTo 

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

func (*CloseSessionResponse) MarshalToSizedBuffer 

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

func (*CloseSessionResponse) ProtoMessage 

func (*CloseSessionResponse) ProtoMessage()

func (*CloseSessionResponse) Reset 

func (m *CloseSessionResponse) Reset()

func (*CloseSessionResponse) Size 

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

func (*CloseSessionResponse) String 

func (m *CloseSessionResponse) String() string

func (*CloseSessionResponse) Unmarshal 

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

func (*CloseSessionResponse) XXX_DiscardUnknown 

func (m *CloseSessionResponse) XXX_DiscardUnknown()

func (*CloseSessionResponse) XXX_Marshal 

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

func (*CloseSessionResponse) XXX_Merge 

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

func (*CloseSessionResponse) XXX_Size 

func (m *CloseSessionResponse) XXX_Size() int

func (*CloseSessionResponse) XXX_Unmarshal 

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

type 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 {
	Entry Entry `protobuf:"bytes,2,opt,name=entry,proto3" json:"entry"`
}

func (*EntriesResponse) Descriptor 

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

func (*EntriesResponse) GetEntry 

func (m *EntriesResponse) GetEntry() Entry

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 Entry 

type Entry struct {
	Position `protobuf:"bytes,1,opt,name=pos,proto3,embedded=pos" json:"pos"`
	Value    `protobuf:"bytes,2,opt,name=value,proto3,embedded=value" json:"value"`
}

func (*Entry) Descriptor 

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

func (*Entry) Marshal 

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

func (*Entry) MarshalTo 

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

func (*Entry) MarshalToSizedBuffer 

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

func (*Entry) ProtoMessage 

func (*Entry) ProtoMessage()

func (*Entry) Reset 

func (m *Entry) Reset()

func (*Entry) Size 

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

func (*Entry) String 

func (m *Entry) String() string

func (*Entry) Unmarshal 

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

func (*Entry) XXX_DiscardUnknown 

func (m *Entry) XXX_DiscardUnknown()

func (*Entry) XXX_Marshal 

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

func (*Entry) XXX_Merge 

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

func (*Entry) XXX_Size 

func (m *Entry) XXX_Size() int

func (*Entry) XXX_Unmarshal 

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

type Event 

type Event struct {
	Type  Event_Type `protobuf:"varint,1,opt,name=type,proto3,enum=atomix.primitive.indexedmap.v1.Event_Type" json:"type,omitempty"`
	Entry Entry      `protobuf:"bytes,2,opt,name=entry,proto3" json:"entry"`
}

func (*Event) Descriptor 

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

func (*Event) GetEntry 

func (m *Event) GetEntry() Entry

func (*Event) GetType 

func (m *Event) GetType() Event_Type

func (*Event) Marshal 

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

func (*Event) MarshalTo 

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

func (*Event) MarshalToSizedBuffer 

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

func (*Event) ProtoMessage 

func (*Event) ProtoMessage()

func (*Event) Reset 

func (m *Event) Reset()

func (*Event) Size 

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

func (*Event) String 

func (m *Event) String() string

func (*Event) Unmarshal 

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

func (*Event) XXX_DiscardUnknown 

func (m *Event) XXX_DiscardUnknown()

func (*Event) XXX_Marshal 

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

func (*Event) XXX_Merge 

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

func (*Event) XXX_Size 

func (m *Event) XXX_Size() int

func (*Event) XXX_Unmarshal 

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

type Event_Type 

type Event_Type int32
const (
	Event_NONE   Event_Type = 0
	Event_INSERT Event_Type = 1
	Event_UPDATE Event_Type = 2
	Event_REMOVE Event_Type = 3
	Event_REPLAY Event_Type = 4
)

func (Event_Type) EnumDescriptor 

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

func (Event_Type) String 

func (x Event_Type) String() string

type EventsRequest 

type EventsRequest struct {
	Pos    Position `protobuf:"bytes,2,opt,name=pos,proto3" json:"pos"`
	Replay bool     `protobuf:"varint,3,opt,name=replay,proto3" json:"replay,omitempty"`
}

func (*EventsRequest) Descriptor 

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

func (*EventsRequest) GetPos 

func (m *EventsRequest) GetPos() Position

func (*EventsRequest) GetReplay 

func (m *EventsRequest) GetReplay() bool

func (*EventsRequest) Marshal 

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

func (*EventsRequest) MarshalTo 

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

func (*EventsRequest) MarshalToSizedBuffer 

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

func (*EventsRequest) ProtoMessage 

func (*EventsRequest) ProtoMessage()

func (*EventsRequest) Reset 

func (m *EventsRequest) Reset()

func (*EventsRequest) Size 

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

func (*EventsRequest) String 

func (m *EventsRequest) String() string

func (*EventsRequest) Unmarshal 

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

func (*EventsRequest) XXX_DiscardUnknown 

func (m *EventsRequest) XXX_DiscardUnknown()

func (*EventsRequest) XXX_Marshal 

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

func (*EventsRequest) XXX_Merge 

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

func (*EventsRequest) XXX_Size 

func (m *EventsRequest) XXX_Size() int

func (*EventsRequest) XXX_Unmarshal 

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

type EventsResponse 

type EventsResponse struct {
	Event Event `protobuf:"bytes,2,opt,name=event,proto3" json:"event"`
}

func (*EventsResponse) Descriptor 

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

func (*EventsResponse) GetEvent 

func (m *EventsResponse) GetEvent() Event

func (*EventsResponse) Marshal 

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

func (*EventsResponse) MarshalTo 

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

func (*EventsResponse) MarshalToSizedBuffer 

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

func (*EventsResponse) ProtoMessage 

func (*EventsResponse) ProtoMessage()

func (*EventsResponse) Reset 

func (m *EventsResponse) Reset()

func (*EventsResponse) Size 

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

func (*EventsResponse) String 

func (m *EventsResponse) String() string

func (*EventsResponse) Unmarshal 

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

func (*EventsResponse) XXX_DiscardUnknown 

func (m *EventsResponse) XXX_DiscardUnknown()

func (*EventsResponse) XXX_Marshal 

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

func (*EventsResponse) XXX_Merge 

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

func (*EventsResponse) XXX_Size 

func (m *EventsResponse) XXX_Size() int

func (*EventsResponse) XXX_Unmarshal 

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

type FirstEntryRequest 

type FirstEntryRequest struct {
}

func (*FirstEntryRequest) Descriptor 

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

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 {
	Entry *Entry `protobuf:"bytes,2,opt,name=entry,proto3" json:"entry,omitempty"`
}

func (*FirstEntryResponse) Descriptor 

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

func (*FirstEntryResponse) GetEntry 

func (m *FirstEntryResponse) GetEntry() *Entry

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 {
	Position Position `protobuf:"bytes,2,opt,name=position,proto3" json:"position"`
}

func (*GetRequest) Descriptor 

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

func (*GetRequest) GetPosition 

func (m *GetRequest) GetPosition() Position

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 {
	Entry *Entry `protobuf:"bytes,2,opt,name=entry,proto3" json:"entry,omitempty"`
}

func (*GetResponse) Descriptor 

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

func (*GetResponse) GetEntry 

func (m *GetResponse) GetEntry() *Entry

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 IndexedMapCacheOptions 

type IndexedMapCacheOptions struct {
	Enabled  bool                    `protobuf:"varint,1,opt,name=enabled,proto3" json:"enabled,omitempty"`
	Strategy IndexedMapCacheStrategy `` /* 130-byte string literal not displayed */
}

func (*IndexedMapCacheOptions) Descriptor 

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

func (*IndexedMapCacheOptions) GetEnabled 

func (m *IndexedMapCacheOptions) GetEnabled() bool

func (*IndexedMapCacheOptions) GetStrategy 

func (m *IndexedMapCacheOptions) GetStrategy() IndexedMapCacheStrategy

func (*IndexedMapCacheOptions) Marshal 

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

func (*IndexedMapCacheOptions) MarshalTo 

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

func (*IndexedMapCacheOptions) MarshalToSizedBuffer 

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

func (*IndexedMapCacheOptions) ProtoMessage 

func (*IndexedMapCacheOptions) ProtoMessage()

func (*IndexedMapCacheOptions) Reset 

func (m *IndexedMapCacheOptions) Reset()

func (*IndexedMapCacheOptions) Size 

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

func (*IndexedMapCacheOptions) String 

func (m *IndexedMapCacheOptions) String() string

func (*IndexedMapCacheOptions) Unmarshal 

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

func (*IndexedMapCacheOptions) XXX_DiscardUnknown 

func (m *IndexedMapCacheOptions) XXX_DiscardUnknown()

func (*IndexedMapCacheOptions) XXX_Marshal 

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

func (*IndexedMapCacheOptions) XXX_Merge 

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

func (*IndexedMapCacheOptions) XXX_Size 

func (m *IndexedMapCacheOptions) XXX_Size() int

func (*IndexedMapCacheOptions) XXX_Unmarshal 

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

type IndexedMapCacheStrategy 

type IndexedMapCacheStrategy int32
const (
	IndexedMapCacheStrategy_NEAR                       IndexedMapCacheStrategy = 0
	IndexedMapCacheStrategy_READ_THROUGH               IndexedMapCacheStrategy = 1
	IndexedMapCacheStrategy_WRITE_THROUGH              IndexedMapCacheStrategy = 2
	IndexedMapCacheStrategy_READ_THROUGH_WRITE_THROUGH IndexedMapCacheStrategy = 3
)

func (IndexedMapCacheStrategy) EnumDescriptor 

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

func (IndexedMapCacheStrategy) String 

func (x IndexedMapCacheStrategy) String() string

type IndexedMapClient 

type IndexedMapClient interface {
	// Size returns the size of the map
	Size(ctx context.Context, in *SizeRequest, opts ...grpc.CallOption) (*SizeResponse, error)
	// Put puts an entry into the map
	Put(ctx context.Context, in *PutRequest, opts ...grpc.CallOption) (*PutResponse, error)
	// Get gets the entry for a key
	Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetResponse, error)
	// FirstEntry gets the first entry in the map
	FirstEntry(ctx context.Context, in *FirstEntryRequest, opts ...grpc.CallOption) (*FirstEntryResponse, error)
	// LastEntry gets the last entry in the map
	LastEntry(ctx context.Context, in *LastEntryRequest, opts ...grpc.CallOption) (*LastEntryResponse, error)
	// PrevEntry gets the previous entry in the map
	PrevEntry(ctx context.Context, in *PrevEntryRequest, opts ...grpc.CallOption) (*PrevEntryResponse, error)
	// NextEntry gets the next entry in the map
	NextEntry(ctx context.Context, in *NextEntryRequest, opts ...grpc.CallOption) (*NextEntryResponse, error)
	// Remove removes an entry from the map
	Remove(ctx context.Context, in *RemoveRequest, opts ...grpc.CallOption) (*RemoveResponse, error)
	// Clear removes all entries from the map
	Clear(ctx context.Context, in *ClearRequest, opts ...grpc.CallOption) (*ClearResponse, error)
	// Events listens for change events
	Events(ctx context.Context, in *EventsRequest, opts ...grpc.CallOption) (IndexedMap_EventsClient, error)
	// Entries lists all entries in the map
	Entries(ctx context.Context, in *EntriesRequest, opts ...grpc.CallOption) (IndexedMap_EntriesClient, error)
}

IndexedMapClient is the client API for IndexedMap service.

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

func NewIndexedMapClient 

func NewIndexedMapClient(cc *grpc.ClientConn) IndexedMapClient

type IndexedMapManagerClient added in v0.7.0 

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

IndexedMapManagerClient is the client API for IndexedMapManager service.

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

func NewIndexedMapManagerClient added in v0.7.0 

func NewIndexedMapManagerClient(cc *grpc.ClientConn) IndexedMapManagerClient

type IndexedMapManagerServer added in v0.7.0 

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

IndexedMapManagerServer is the server API for IndexedMapManager service.

type IndexedMapServer 

type IndexedMapServer interface {
	// Size returns the size of the map
	Size(context.Context, *SizeRequest) (*SizeResponse, error)
	// Put puts an entry into the map
	Put(context.Context, *PutRequest) (*PutResponse, error)
	// Get gets the entry for a key
	Get(context.Context, *GetRequest) (*GetResponse, error)
	// FirstEntry gets the first entry in the map
	FirstEntry(context.Context, *FirstEntryRequest) (*FirstEntryResponse, error)
	// LastEntry gets the last entry in the map
	LastEntry(context.Context, *LastEntryRequest) (*LastEntryResponse, error)
	// PrevEntry gets the previous entry in the map
	PrevEntry(context.Context, *PrevEntryRequest) (*PrevEntryResponse, error)
	// NextEntry gets the next entry in the map
	NextEntry(context.Context, *NextEntryRequest) (*NextEntryResponse, error)
	// Remove removes an entry from the map
	Remove(context.Context, *RemoveRequest) (*RemoveResponse, error)
	// Clear removes all entries from the map
	Clear(context.Context, *ClearRequest) (*ClearResponse, error)
	// Events listens for change events
	Events(*EventsRequest, IndexedMap_EventsServer) error
	// Entries lists all entries in the map
	Entries(*EntriesRequest, IndexedMap_EntriesServer) error
}

IndexedMapServer is the server API for IndexedMap service.

type IndexedMapSessionOptions 

type IndexedMapSessionOptions struct {
	Cache IndexedMapCacheOptions `protobuf:"bytes,1,opt,name=cache,proto3" json:"cache"`
}

func (*IndexedMapSessionOptions) Descriptor 

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

func (*IndexedMapSessionOptions) GetCache 

func (m *IndexedMapSessionOptions) GetCache() IndexedMapCacheOptions

func (*IndexedMapSessionOptions) Marshal 

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

func (*IndexedMapSessionOptions) MarshalTo 

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

func (*IndexedMapSessionOptions) MarshalToSizedBuffer 

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

func (*IndexedMapSessionOptions) ProtoMessage 

func (*IndexedMapSessionOptions) ProtoMessage()

func (*IndexedMapSessionOptions) Reset 

func (m *IndexedMapSessionOptions) Reset()

func (*IndexedMapSessionOptions) Size 

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

func (*IndexedMapSessionOptions) String 

func (m *IndexedMapSessionOptions) String() string

func (*IndexedMapSessionOptions) Unmarshal 

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

func (*IndexedMapSessionOptions) XXX_DiscardUnknown 

func (m *IndexedMapSessionOptions) XXX_DiscardUnknown()

func (*IndexedMapSessionOptions) XXX_Marshal 

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

func (*IndexedMapSessionOptions) XXX_Merge 

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

func (*IndexedMapSessionOptions) XXX_Size 

func (m *IndexedMapSessionOptions) XXX_Size() int

func (*IndexedMapSessionOptions) XXX_Unmarshal 

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

type IndexedMap_EntriesClient 

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

type IndexedMap_EntriesServer 

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

type IndexedMap_EventsClient 

type IndexedMap_EventsClient interface {
	Recv() (*EventsResponse, error)
	grpc.ClientStream
}

type IndexedMap_EventsServer 

type IndexedMap_EventsServer interface {
	Send(*EventsResponse) error
	grpc.ServerStream
}

type LastEntryRequest 

type LastEntryRequest struct {
}

func (*LastEntryRequest) Descriptor 

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

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 {
	Entry *Entry `protobuf:"bytes,2,opt,name=entry,proto3" json:"entry,omitempty"`
}

func (*LastEntryResponse) Descriptor 

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

func (*LastEntryResponse) GetEntry 

func (m *LastEntryResponse) GetEntry() *Entry

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 {
	Index uint64 `protobuf:"varint,2,opt,name=index,proto3" json:"index,omitempty"`
}

func (*NextEntryRequest) Descriptor 

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

func (*NextEntryRequest) GetIndex 

func (m *NextEntryRequest) GetIndex() uint64

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 {
	Entry *Entry `protobuf:"bytes,2,opt,name=entry,proto3" json:"entry,omitempty"`
}

func (*NextEntryResponse) Descriptor 

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

func (*NextEntryResponse) GetEntry 

func (m *NextEntryResponse) GetEntry() *Entry

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 OpenSessionRequest 

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

func (*OpenSessionRequest) Descriptor 

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

func (*OpenSessionRequest) GetOptions 

func (m *OpenSessionRequest) GetOptions() IndexedMapSessionOptions

func (*OpenSessionRequest) GetPrimitiveID 

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

func (*OpenSessionRequest) Marshal 

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

func (*OpenSessionRequest) MarshalTo 

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

func (*OpenSessionRequest) MarshalToSizedBuffer 

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

func (*OpenSessionRequest) ProtoMessage 

func (*OpenSessionRequest) ProtoMessage()

func (*OpenSessionRequest) Reset 

func (m *OpenSessionRequest) Reset()

func (*OpenSessionRequest) Size 

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

func (*OpenSessionRequest) String 

func (m *OpenSessionRequest) String() string

func (*OpenSessionRequest) Unmarshal 

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

func (*OpenSessionRequest) XXX_DiscardUnknown 

func (m *OpenSessionRequest) XXX_DiscardUnknown()

func (*OpenSessionRequest) XXX_Marshal 

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

func (*OpenSessionRequest) XXX_Merge 

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

func (*OpenSessionRequest) XXX_Size 

func (m *OpenSessionRequest) XXX_Size() int

func (*OpenSessionRequest) XXX_Unmarshal 

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

type OpenSessionResponse 

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

func (*OpenSessionResponse) Descriptor 

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

func (*OpenSessionResponse) GetSessionID 

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

func (*OpenSessionResponse) Marshal 

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

func (*OpenSessionResponse) MarshalTo 

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

func (*OpenSessionResponse) MarshalToSizedBuffer 

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

func (*OpenSessionResponse) ProtoMessage 

func (*OpenSessionResponse) ProtoMessage()

func (*OpenSessionResponse) Reset 

func (m *OpenSessionResponse) Reset()

func (*OpenSessionResponse) Size 

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

func (*OpenSessionResponse) String 

func (m *OpenSessionResponse) String() string

func (*OpenSessionResponse) Unmarshal 

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

func (*OpenSessionResponse) XXX_DiscardUnknown 

func (m *OpenSessionResponse) XXX_DiscardUnknown()

func (*OpenSessionResponse) XXX_Marshal 

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

func (*OpenSessionResponse) XXX_Merge 

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

func (*OpenSessionResponse) XXX_Size 

func (m *OpenSessionResponse) XXX_Size() int

func (*OpenSessionResponse) XXX_Unmarshal 

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

type Position 

type Position struct {
	Index uint64 `protobuf:"varint,1,opt,name=index,proto3" json:"index,omitempty"`
	Key   string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
}

func (*Position) Descriptor 

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

func (*Position) GetIndex 

func (m *Position) GetIndex() uint64

func (*Position) GetKey 

func (m *Position) GetKey() string

func (*Position) Marshal 

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

func (*Position) MarshalTo 

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

func (*Position) MarshalToSizedBuffer 

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

func (*Position) ProtoMessage 

func (*Position) ProtoMessage()

func (*Position) Reset 

func (m *Position) Reset()

func (*Position) Size 

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

func (*Position) String 

func (m *Position) String() string

func (*Position) Unmarshal 

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

func (*Position) XXX_DiscardUnknown 

func (m *Position) XXX_DiscardUnknown()

func (*Position) XXX_Marshal 

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

func (*Position) XXX_Merge 

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

func (*Position) XXX_Size 

func (m *Position) XXX_Size() int

func (*Position) XXX_Unmarshal 

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

type Precondition 

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

func (*Precondition) Descriptor 

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

func (*Precondition) GetMetadata 

func (m *Precondition) GetMetadata() *v1.ObjectMeta

func (*Precondition) GetPrecondition 

func (m *Precondition) GetPrecondition() isPrecondition_Precondition

func (*Precondition) Marshal 

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

func (*Precondition) MarshalTo 

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

func (*Precondition) MarshalToSizedBuffer 

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

func (*Precondition) ProtoMessage 

func (*Precondition) ProtoMessage()

func (*Precondition) Reset 

func (m *Precondition) Reset()

func (*Precondition) Size 

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

func (*Precondition) String 

func (m *Precondition) String() string

func (*Precondition) Unmarshal 

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

func (*Precondition) XXX_DiscardUnknown 

func (m *Precondition) XXX_DiscardUnknown()

func (*Precondition) XXX_Marshal 

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

func (*Precondition) XXX_Merge 

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

func (*Precondition) XXX_OneofWrappers 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*Precondition) XXX_Size 

func (m *Precondition) XXX_Size() int

func (*Precondition) XXX_Unmarshal 

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

type Precondition_Metadata 

type Precondition_Metadata struct {
	Metadata *v1.ObjectMeta `protobuf:"bytes,1,opt,name=metadata,proto3,oneof" json:"metadata,omitempty"`
}

func (*Precondition_Metadata) MarshalTo 

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

func (*Precondition_Metadata) MarshalToSizedBuffer 

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

func (*Precondition_Metadata) Size 

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

type PrevEntryRequest 

type PrevEntryRequest struct {
	Index uint64 `protobuf:"varint,2,opt,name=index,proto3" json:"index,omitempty"`
}

func (*PrevEntryRequest) Descriptor 

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

func (*PrevEntryRequest) GetIndex 

func (m *PrevEntryRequest) GetIndex() uint64

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 {
	Entry *Entry `protobuf:"bytes,2,opt,name=entry,proto3" json:"entry,omitempty"`
}

func (*PrevEntryResponse) Descriptor 

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

func (*PrevEntryResponse) GetEntry 

func (m *PrevEntryResponse) GetEntry() *Entry

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 {
	Entry         Entry          `protobuf:"bytes,2,opt,name=entry,proto3" json:"entry"`
	Preconditions []Precondition `protobuf:"bytes,3,rep,name=preconditions,proto3" json:"preconditions"`
}

func (*PutRequest) Descriptor 

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

func (*PutRequest) GetEntry 

func (m *PutRequest) GetEntry() Entry

func (*PutRequest) GetPreconditions 

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

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 {
	Entry *Entry `protobuf:"bytes,2,opt,name=entry,proto3" json:"entry,omitempty"`
}

func (*PutResponse) Descriptor 

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

func (*PutResponse) GetEntry 

func (m *PutResponse) GetEntry() *Entry

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 {
	Entry         *Entry         `protobuf:"bytes,2,opt,name=entry,proto3" json:"entry,omitempty"`
	Preconditions []Precondition `protobuf:"bytes,3,rep,name=preconditions,proto3" json:"preconditions"`
}

func (*RemoveRequest) Descriptor 

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

func (*RemoveRequest) GetEntry 

func (m *RemoveRequest) GetEntry() *Entry

func (*RemoveRequest) GetPreconditions 

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

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 {
	Entry *Entry `protobuf:"bytes,2,opt,name=entry,proto3" json:"entry,omitempty"`
}

func (*RemoveResponse) Descriptor 

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

func (*RemoveResponse) GetEntry 

func (m *RemoveResponse) GetEntry() *Entry

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 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,2,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 UnimplementedIndexedMapManagerServer added in v0.7.0 

type UnimplementedIndexedMapManagerServer struct {
}

UnimplementedIndexedMapManagerServer can be embedded to have forward compatible implementations.

func (*UnimplementedIndexedMapManagerServer) CloseSession added in v0.7.0 

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

func (*UnimplementedIndexedMapManagerServer) OpenSession added in v0.7.0 

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

type UnimplementedIndexedMapServer 

type UnimplementedIndexedMapServer struct {
}

UnimplementedIndexedMapServer can be embedded to have forward compatible implementations.

func (*UnimplementedIndexedMapServer) Clear 

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

func (*UnimplementedIndexedMapServer) Entries 

func (*UnimplementedIndexedMapServer) Entries(req *EntriesRequest, srv IndexedMap_EntriesServer) error

func (*UnimplementedIndexedMapServer) Events 

func (*UnimplementedIndexedMapServer) Events(req *EventsRequest, srv IndexedMap_EventsServer) error

func (*UnimplementedIndexedMapServer) FirstEntry 

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

func (*UnimplementedIndexedMapServer) Get 

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

func (*UnimplementedIndexedMapServer) LastEntry 

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

func (*UnimplementedIndexedMapServer) NextEntry 

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

func (*UnimplementedIndexedMapServer) PrevEntry 

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

func (*UnimplementedIndexedMapServer) Put 

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

func (*UnimplementedIndexedMapServer) Remove 

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

func (*UnimplementedIndexedMapServer) Size 

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

type Value 

type Value struct {
	v1.ObjectMeta `protobuf:"bytes,1,opt,name=meta,proto3,embedded=meta" json:"meta"`
	Value         []byte         `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	TTL           *time.Duration `protobuf:"bytes,3,opt,name=ttl,proto3,stdduration" json:"ttl,omitempty"`
}

func (*Value) Descriptor 

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

func (*Value) GetTTL 

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

func (*Value) GetValue 

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

func (*Value) Marshal 

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

func (*Value) MarshalTo 

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

func (*Value) MarshalToSizedBuffer 

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

func (*Value) ProtoMessage 

func (*Value) ProtoMessage()

func (*Value) Reset 

func (m *Value) Reset()

func (*Value) Size 

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

func (*Value) String 

func (m *Value) String() string

func (*Value) Unmarshal 

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

func (*Value) XXX_DiscardUnknown 

func (m *Value) XXX_DiscardUnknown()

func (*Value) XXX_Marshal 

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

func (*Value) XXX_Merge 

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

func (*Value) XXX_Size 

func (m *Value) XXX_Size() int

func (*Value) XXX_Unmarshal 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

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