Documentation ¶
Index ¶
- Variables
- func RegisterListManagerServer(s *grpc.Server, srv ListManagerServer)
- func RegisterListServer(s *grpc.Server, srv ListServer)
- type AppendRequest
- func (*AppendRequest) Descriptor() ([]byte, []int)
- func (m *AppendRequest) GetValue() Value
- func (m *AppendRequest) Marshal() (dAtA []byte, err error)
- func (m *AppendRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *AppendRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*AppendRequest) ProtoMessage()
- func (m *AppendRequest) Reset()
- func (m *AppendRequest) Size() (n int)
- func (m *AppendRequest) String() string
- func (m *AppendRequest) Unmarshal(dAtA []byte) error
- func (m *AppendRequest) XXX_DiscardUnknown()
- func (m *AppendRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *AppendRequest) XXX_Merge(src proto.Message)
- func (m *AppendRequest) XXX_Size() int
- func (m *AppendRequest) XXX_Unmarshal(b []byte) error
- type AppendResponse
- func (*AppendResponse) Descriptor() ([]byte, []int)
- func (m *AppendResponse) Marshal() (dAtA []byte, err error)
- func (m *AppendResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *AppendResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*AppendResponse) ProtoMessage()
- func (m *AppendResponse) Reset()
- func (m *AppendResponse) Size() (n int)
- func (m *AppendResponse) String() string
- func (m *AppendResponse) Unmarshal(dAtA []byte) error
- func (m *AppendResponse) XXX_DiscardUnknown()
- func (m *AppendResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *AppendResponse) XXX_Merge(src proto.Message)
- func (m *AppendResponse) XXX_Size() int
- func (m *AppendResponse) XXX_Unmarshal(b []byte) error
- type ClearRequest
- func (*ClearRequest) Descriptor() ([]byte, []int)
- func (m *ClearRequest) Marshal() (dAtA []byte, err error)
- func (m *ClearRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *ClearRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ClearRequest) ProtoMessage()
- func (m *ClearRequest) Reset()
- func (m *ClearRequest) Size() (n int)
- func (m *ClearRequest) String() string
- func (m *ClearRequest) Unmarshal(dAtA []byte) error
- func (m *ClearRequest) XXX_DiscardUnknown()
- func (m *ClearRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ClearRequest) XXX_Merge(src proto.Message)
- func (m *ClearRequest) XXX_Size() int
- func (m *ClearRequest) XXX_Unmarshal(b []byte) error
- type ClearResponse
- func (*ClearResponse) Descriptor() ([]byte, []int)
- func (m *ClearResponse) Marshal() (dAtA []byte, err error)
- func (m *ClearResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *ClearResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ClearResponse) ProtoMessage()
- func (m *ClearResponse) Reset()
- func (m *ClearResponse) Size() (n int)
- func (m *ClearResponse) String() string
- func (m *ClearResponse) Unmarshal(dAtA []byte) error
- func (m *ClearResponse) XXX_DiscardUnknown()
- func (m *ClearResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ClearResponse) XXX_Merge(src proto.Message)
- func (m *ClearResponse) XXX_Size() int
- func (m *ClearResponse) XXX_Unmarshal(b []byte) error
- type CloseSessionRequest
- func (*CloseSessionRequest) Descriptor() ([]byte, []int)
- func (m *CloseSessionRequest) GetSessionID() github_com_atomix_atomix_api_go_atomix_primitive_v1.SessionID
- func (m *CloseSessionRequest) Marshal() (dAtA []byte, err error)
- func (m *CloseSessionRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *CloseSessionRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*CloseSessionRequest) ProtoMessage()
- func (m *CloseSessionRequest) Reset()
- func (m *CloseSessionRequest) Size() (n int)
- func (m *CloseSessionRequest) String() string
- func (m *CloseSessionRequest) Unmarshal(dAtA []byte) error
- func (m *CloseSessionRequest) XXX_DiscardUnknown()
- func (m *CloseSessionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CloseSessionRequest) XXX_Merge(src proto.Message)
- func (m *CloseSessionRequest) XXX_Size() int
- func (m *CloseSessionRequest) XXX_Unmarshal(b []byte) error
- type CloseSessionResponse
- func (*CloseSessionResponse) Descriptor() ([]byte, []int)
- func (m *CloseSessionResponse) Marshal() (dAtA []byte, err error)
- func (m *CloseSessionResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *CloseSessionResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*CloseSessionResponse) ProtoMessage()
- func (m *CloseSessionResponse) Reset()
- func (m *CloseSessionResponse) Size() (n int)
- func (m *CloseSessionResponse) String() string
- func (m *CloseSessionResponse) Unmarshal(dAtA []byte) error
- func (m *CloseSessionResponse) XXX_DiscardUnknown()
- func (m *CloseSessionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CloseSessionResponse) XXX_Merge(src proto.Message)
- func (m *CloseSessionResponse) XXX_Size() int
- func (m *CloseSessionResponse) XXX_Unmarshal(b []byte) error
- type ContainsRequest
- func (*ContainsRequest) Descriptor() ([]byte, []int)
- func (m *ContainsRequest) GetValue() Value
- func (m *ContainsRequest) Marshal() (dAtA []byte, err error)
- func (m *ContainsRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *ContainsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ContainsRequest) ProtoMessage()
- func (m *ContainsRequest) Reset()
- func (m *ContainsRequest) Size() (n int)
- func (m *ContainsRequest) String() string
- func (m *ContainsRequest) Unmarshal(dAtA []byte) error
- func (m *ContainsRequest) XXX_DiscardUnknown()
- func (m *ContainsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ContainsRequest) XXX_Merge(src proto.Message)
- func (m *ContainsRequest) XXX_Size() int
- func (m *ContainsRequest) XXX_Unmarshal(b []byte) error
- type ContainsResponse
- func (*ContainsResponse) Descriptor() ([]byte, []int)
- func (m *ContainsResponse) GetContains() bool
- func (m *ContainsResponse) Marshal() (dAtA []byte, err error)
- func (m *ContainsResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *ContainsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ContainsResponse) ProtoMessage()
- func (m *ContainsResponse) Reset()
- func (m *ContainsResponse) Size() (n int)
- func (m *ContainsResponse) String() string
- func (m *ContainsResponse) Unmarshal(dAtA []byte) error
- func (m *ContainsResponse) XXX_DiscardUnknown()
- func (m *ContainsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ContainsResponse) XXX_Merge(src proto.Message)
- func (m *ContainsResponse) XXX_Size() int
- func (m *ContainsResponse) XXX_Unmarshal(b []byte) error
- type ElementsRequest
- func (*ElementsRequest) Descriptor() ([]byte, []int)
- func (m *ElementsRequest) Marshal() (dAtA []byte, err error)
- func (m *ElementsRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *ElementsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ElementsRequest) ProtoMessage()
- func (m *ElementsRequest) Reset()
- func (m *ElementsRequest) Size() (n int)
- func (m *ElementsRequest) String() string
- func (m *ElementsRequest) Unmarshal(dAtA []byte) error
- func (m *ElementsRequest) XXX_DiscardUnknown()
- func (m *ElementsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ElementsRequest) XXX_Merge(src proto.Message)
- func (m *ElementsRequest) XXX_Size() int
- func (m *ElementsRequest) XXX_Unmarshal(b []byte) error
- type ElementsResponse
- func (*ElementsResponse) Descriptor() ([]byte, []int)
- func (m *ElementsResponse) GetItem() Item
- func (m *ElementsResponse) Marshal() (dAtA []byte, err error)
- func (m *ElementsResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *ElementsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ElementsResponse) ProtoMessage()
- func (m *ElementsResponse) Reset()
- func (m *ElementsResponse) Size() (n int)
- func (m *ElementsResponse) String() string
- func (m *ElementsResponse) Unmarshal(dAtA []byte) error
- func (m *ElementsResponse) XXX_DiscardUnknown()
- func (m *ElementsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ElementsResponse) XXX_Merge(src proto.Message)
- func (m *ElementsResponse) XXX_Size() int
- func (m *ElementsResponse) XXX_Unmarshal(b []byte) error
- type Event
- func (*Event) Descriptor() ([]byte, []int)
- func (m *Event) GetItem() Item
- func (m *Event) GetType() Event_Type
- func (m *Event) Marshal() (dAtA []byte, err error)
- func (m *Event) MarshalTo(dAtA []byte) (int, error)
- func (m *Event) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Event) ProtoMessage()
- func (m *Event) Reset()
- func (m *Event) Size() (n int)
- func (m *Event) String() string
- func (m *Event) Unmarshal(dAtA []byte) error
- func (m *Event) XXX_DiscardUnknown()
- func (m *Event) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Event) XXX_Merge(src proto.Message)
- func (m *Event) XXX_Size() int
- func (m *Event) XXX_Unmarshal(b []byte) error
- type Event_Type
- type EventsRequest
- func (*EventsRequest) Descriptor() ([]byte, []int)
- func (m *EventsRequest) GetReplay() bool
- func (m *EventsRequest) Marshal() (dAtA []byte, err error)
- func (m *EventsRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *EventsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*EventsRequest) ProtoMessage()
- func (m *EventsRequest) Reset()
- func (m *EventsRequest) Size() (n int)
- func (m *EventsRequest) String() string
- func (m *EventsRequest) Unmarshal(dAtA []byte) error
- func (m *EventsRequest) XXX_DiscardUnknown()
- func (m *EventsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *EventsRequest) XXX_Merge(src proto.Message)
- func (m *EventsRequest) XXX_Size() int
- func (m *EventsRequest) XXX_Unmarshal(b []byte) error
- type EventsResponse
- func (*EventsResponse) Descriptor() ([]byte, []int)
- func (m *EventsResponse) GetEvent() Event
- func (m *EventsResponse) Marshal() (dAtA []byte, err error)
- func (m *EventsResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *EventsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*EventsResponse) ProtoMessage()
- func (m *EventsResponse) Reset()
- func (m *EventsResponse) Size() (n int)
- func (m *EventsResponse) String() string
- func (m *EventsResponse) Unmarshal(dAtA []byte) error
- func (m *EventsResponse) XXX_DiscardUnknown()
- func (m *EventsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *EventsResponse) XXX_Merge(src proto.Message)
- func (m *EventsResponse) XXX_Size() int
- func (m *EventsResponse) XXX_Unmarshal(b []byte) error
- type GetRequest
- func (*GetRequest) Descriptor() ([]byte, []int)
- func (m *GetRequest) GetIndex() uint32
- func (m *GetRequest) Marshal() (dAtA []byte, err error)
- func (m *GetRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *GetRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GetRequest) ProtoMessage()
- func (m *GetRequest) Reset()
- func (m *GetRequest) Size() (n int)
- func (m *GetRequest) String() string
- func (m *GetRequest) Unmarshal(dAtA []byte) error
- func (m *GetRequest) XXX_DiscardUnknown()
- func (m *GetRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetRequest) XXX_Merge(src proto.Message)
- func (m *GetRequest) XXX_Size() int
- func (m *GetRequest) XXX_Unmarshal(b []byte) error
- type GetResponse
- func (*GetResponse) Descriptor() ([]byte, []int)
- func (m *GetResponse) GetItem() Item
- func (m *GetResponse) Marshal() (dAtA []byte, err error)
- func (m *GetResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *GetResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GetResponse) ProtoMessage()
- func (m *GetResponse) Reset()
- func (m *GetResponse) Size() (n int)
- func (m *GetResponse) String() string
- func (m *GetResponse) Unmarshal(dAtA []byte) error
- func (m *GetResponse) XXX_DiscardUnknown()
- func (m *GetResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetResponse) XXX_Merge(src proto.Message)
- func (m *GetResponse) XXX_Size() int
- func (m *GetResponse) XXX_Unmarshal(b []byte) error
- type InsertRequest
- func (*InsertRequest) Descriptor() ([]byte, []int)
- func (m *InsertRequest) GetItem() Item
- func (m *InsertRequest) GetPreconditions() []Precondition
- func (m *InsertRequest) Marshal() (dAtA []byte, err error)
- func (m *InsertRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *InsertRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*InsertRequest) ProtoMessage()
- func (m *InsertRequest) Reset()
- func (m *InsertRequest) Size() (n int)
- func (m *InsertRequest) String() string
- func (m *InsertRequest) Unmarshal(dAtA []byte) error
- func (m *InsertRequest) XXX_DiscardUnknown()
- func (m *InsertRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *InsertRequest) XXX_Merge(src proto.Message)
- func (m *InsertRequest) XXX_Size() int
- func (m *InsertRequest) XXX_Unmarshal(b []byte) error
- type InsertResponse
- func (*InsertResponse) Descriptor() ([]byte, []int)
- func (m *InsertResponse) GetItem() Item
- func (m *InsertResponse) Marshal() (dAtA []byte, err error)
- func (m *InsertResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *InsertResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*InsertResponse) ProtoMessage()
- func (m *InsertResponse) Reset()
- func (m *InsertResponse) Size() (n int)
- func (m *InsertResponse) String() string
- func (m *InsertResponse) Unmarshal(dAtA []byte) error
- func (m *InsertResponse) XXX_DiscardUnknown()
- func (m *InsertResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *InsertResponse) XXX_Merge(src proto.Message)
- func (m *InsertResponse) XXX_Size() int
- func (m *InsertResponse) XXX_Unmarshal(b []byte) error
- type Item
- func (*Item) Descriptor() ([]byte, []int)
- func (m *Item) GetIndex() uint32
- func (m *Item) Marshal() (dAtA []byte, err error)
- func (m *Item) MarshalTo(dAtA []byte) (int, error)
- func (m *Item) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Item) ProtoMessage()
- func (m *Item) Reset()
- func (m *Item) Size() (n int)
- func (m *Item) String() string
- func (m *Item) Unmarshal(dAtA []byte) error
- func (m *Item) XXX_DiscardUnknown()
- func (m *Item) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Item) XXX_Merge(src proto.Message)
- func (m *Item) XXX_Size() int
- func (m *Item) XXX_Unmarshal(b []byte) error
- type ListClient
- type ListManagerClient
- type ListManagerServer
- type ListServer
- type ListSessionOptions
- func (*ListSessionOptions) Descriptor() ([]byte, []int)
- func (m *ListSessionOptions) Marshal() (dAtA []byte, err error)
- func (m *ListSessionOptions) MarshalTo(dAtA []byte) (int, error)
- func (m *ListSessionOptions) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ListSessionOptions) ProtoMessage()
- func (m *ListSessionOptions) Reset()
- func (m *ListSessionOptions) Size() (n int)
- func (m *ListSessionOptions) String() string
- func (m *ListSessionOptions) Unmarshal(dAtA []byte) error
- func (m *ListSessionOptions) XXX_DiscardUnknown()
- func (m *ListSessionOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ListSessionOptions) XXX_Merge(src proto.Message)
- func (m *ListSessionOptions) XXX_Size() int
- func (m *ListSessionOptions) XXX_Unmarshal(b []byte) error
- type List_ElementsClient
- type List_ElementsServer
- type List_EventsClient
- type List_EventsServer
- type OpenSessionRequest
- func (*OpenSessionRequest) Descriptor() ([]byte, []int)
- func (m *OpenSessionRequest) GetOptions() ListSessionOptions
- func (m *OpenSessionRequest) GetPrimitiveID() github_com_atomix_atomix_api_go_atomix_primitive_v1.ID
- func (m *OpenSessionRequest) Marshal() (dAtA []byte, err error)
- func (m *OpenSessionRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *OpenSessionRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*OpenSessionRequest) ProtoMessage()
- func (m *OpenSessionRequest) Reset()
- func (m *OpenSessionRequest) Size() (n int)
- func (m *OpenSessionRequest) String() string
- func (m *OpenSessionRequest) Unmarshal(dAtA []byte) error
- func (m *OpenSessionRequest) XXX_DiscardUnknown()
- func (m *OpenSessionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *OpenSessionRequest) XXX_Merge(src proto.Message)
- func (m *OpenSessionRequest) XXX_Size() int
- func (m *OpenSessionRequest) XXX_Unmarshal(b []byte) error
- type OpenSessionResponse
- func (*OpenSessionResponse) Descriptor() ([]byte, []int)
- func (m *OpenSessionResponse) GetSessionID() github_com_atomix_atomix_api_go_atomix_primitive_v1.SessionID
- func (m *OpenSessionResponse) Marshal() (dAtA []byte, err error)
- func (m *OpenSessionResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *OpenSessionResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*OpenSessionResponse) ProtoMessage()
- func (m *OpenSessionResponse) Reset()
- func (m *OpenSessionResponse) Size() (n int)
- func (m *OpenSessionResponse) String() string
- func (m *OpenSessionResponse) Unmarshal(dAtA []byte) error
- func (m *OpenSessionResponse) XXX_DiscardUnknown()
- func (m *OpenSessionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *OpenSessionResponse) XXX_Merge(src proto.Message)
- func (m *OpenSessionResponse) XXX_Size() int
- func (m *OpenSessionResponse) XXX_Unmarshal(b []byte) error
- type Precondition
- func (*Precondition) Descriptor() ([]byte, []int)
- func (m *Precondition) GetMetadata() *v1.ObjectMeta
- func (m *Precondition) GetPrecondition() isPrecondition_Precondition
- func (m *Precondition) Marshal() (dAtA []byte, err error)
- func (m *Precondition) MarshalTo(dAtA []byte) (int, error)
- func (m *Precondition) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Precondition) ProtoMessage()
- func (m *Precondition) Reset()
- func (m *Precondition) Size() (n int)
- func (m *Precondition) String() string
- func (m *Precondition) Unmarshal(dAtA []byte) error
- func (m *Precondition) XXX_DiscardUnknown()
- func (m *Precondition) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Precondition) XXX_Merge(src proto.Message)
- func (*Precondition) XXX_OneofWrappers() []interface{}
- func (m *Precondition) XXX_Size() int
- func (m *Precondition) XXX_Unmarshal(b []byte) error
- type Precondition_Metadata
- type RemoveRequest
- func (*RemoveRequest) Descriptor() ([]byte, []int)
- func (m *RemoveRequest) GetIndex() uint32
- func (m *RemoveRequest) GetPreconditions() []Precondition
- func (m *RemoveRequest) Marshal() (dAtA []byte, err error)
- func (m *RemoveRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *RemoveRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*RemoveRequest) ProtoMessage()
- func (m *RemoveRequest) Reset()
- func (m *RemoveRequest) Size() (n int)
- func (m *RemoveRequest) String() string
- func (m *RemoveRequest) Unmarshal(dAtA []byte) error
- func (m *RemoveRequest) XXX_DiscardUnknown()
- func (m *RemoveRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RemoveRequest) XXX_Merge(src proto.Message)
- func (m *RemoveRequest) XXX_Size() int
- func (m *RemoveRequest) XXX_Unmarshal(b []byte) error
- type RemoveResponse
- func (*RemoveResponse) Descriptor() ([]byte, []int)
- func (m *RemoveResponse) GetItem() Item
- func (m *RemoveResponse) Marshal() (dAtA []byte, err error)
- func (m *RemoveResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *RemoveResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*RemoveResponse) ProtoMessage()
- func (m *RemoveResponse) Reset()
- func (m *RemoveResponse) Size() (n int)
- func (m *RemoveResponse) String() string
- func (m *RemoveResponse) Unmarshal(dAtA []byte) error
- func (m *RemoveResponse) XXX_DiscardUnknown()
- func (m *RemoveResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RemoveResponse) XXX_Merge(src proto.Message)
- func (m *RemoveResponse) XXX_Size() int
- func (m *RemoveResponse) XXX_Unmarshal(b []byte) error
- type SetRequest
- func (*SetRequest) Descriptor() ([]byte, []int)
- func (m *SetRequest) GetItem() Item
- func (m *SetRequest) GetPreconditions() []Precondition
- func (m *SetRequest) Marshal() (dAtA []byte, err error)
- func (m *SetRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *SetRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*SetRequest) ProtoMessage()
- func (m *SetRequest) Reset()
- func (m *SetRequest) Size() (n int)
- func (m *SetRequest) String() string
- func (m *SetRequest) Unmarshal(dAtA []byte) error
- func (m *SetRequest) XXX_DiscardUnknown()
- func (m *SetRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SetRequest) XXX_Merge(src proto.Message)
- func (m *SetRequest) XXX_Size() int
- func (m *SetRequest) XXX_Unmarshal(b []byte) error
- type SetResponse
- func (*SetResponse) Descriptor() ([]byte, []int)
- func (m *SetResponse) GetItem() Item
- func (m *SetResponse) Marshal() (dAtA []byte, err error)
- func (m *SetResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *SetResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*SetResponse) ProtoMessage()
- func (m *SetResponse) Reset()
- func (m *SetResponse) Size() (n int)
- func (m *SetResponse) String() string
- func (m *SetResponse) Unmarshal(dAtA []byte) error
- func (m *SetResponse) XXX_DiscardUnknown()
- func (m *SetResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SetResponse) XXX_Merge(src proto.Message)
- func (m *SetResponse) XXX_Size() int
- func (m *SetResponse) XXX_Unmarshal(b []byte) error
- type SizeRequest
- func (*SizeRequest) Descriptor() ([]byte, []int)
- func (m *SizeRequest) Marshal() (dAtA []byte, err error)
- func (m *SizeRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *SizeRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*SizeRequest) ProtoMessage()
- func (m *SizeRequest) Reset()
- func (m *SizeRequest) Size() (n int)
- func (m *SizeRequest) String() string
- func (m *SizeRequest) Unmarshal(dAtA []byte) error
- func (m *SizeRequest) XXX_DiscardUnknown()
- func (m *SizeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SizeRequest) XXX_Merge(src proto.Message)
- func (m *SizeRequest) XXX_Size() int
- func (m *SizeRequest) XXX_Unmarshal(b []byte) error
- type SizeResponse
- func (*SizeResponse) Descriptor() ([]byte, []int)
- func (m *SizeResponse) GetSize_() uint32
- func (m *SizeResponse) Marshal() (dAtA []byte, err error)
- func (m *SizeResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *SizeResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*SizeResponse) ProtoMessage()
- func (m *SizeResponse) Reset()
- func (m *SizeResponse) Size() (n int)
- func (m *SizeResponse) String() string
- func (m *SizeResponse) Unmarshal(dAtA []byte) error
- func (m *SizeResponse) XXX_DiscardUnknown()
- func (m *SizeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SizeResponse) XXX_Merge(src proto.Message)
- func (m *SizeResponse) XXX_Size() int
- func (m *SizeResponse) XXX_Unmarshal(b []byte) error
- type UnimplementedListManagerServer
- type UnimplementedListServer
- func (*UnimplementedListServer) Append(ctx context.Context, req *AppendRequest) (*AppendResponse, error)
- func (*UnimplementedListServer) Clear(ctx context.Context, req *ClearRequest) (*ClearResponse, error)
- func (*UnimplementedListServer) Elements(req *ElementsRequest, srv List_ElementsServer) error
- func (*UnimplementedListServer) Events(req *EventsRequest, srv List_EventsServer) error
- func (*UnimplementedListServer) Get(ctx context.Context, req *GetRequest) (*GetResponse, error)
- func (*UnimplementedListServer) Insert(ctx context.Context, req *InsertRequest) (*InsertResponse, error)
- func (*UnimplementedListServer) Remove(ctx context.Context, req *RemoveRequest) (*RemoveResponse, error)
- func (*UnimplementedListServer) Set(ctx context.Context, req *SetRequest) (*SetResponse, error)
- func (*UnimplementedListServer) Size(ctx context.Context, req *SizeRequest) (*SizeResponse, error)
- type Value
- func (*Value) Descriptor() ([]byte, []int)
- func (m *Value) GetValue() string
- func (m *Value) Marshal() (dAtA []byte, err error)
- func (m *Value) MarshalTo(dAtA []byte) (int, error)
- func (m *Value) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Value) ProtoMessage()
- func (m *Value) Reset()
- func (m *Value) Size() (n int)
- func (m *Value) String() string
- func (m *Value) Unmarshal(dAtA []byte) error
- func (m *Value) XXX_DiscardUnknown()
- func (m *Value) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Value) XXX_Merge(src proto.Message)
- func (m *Value) XXX_Size() int
- func (m *Value) XXX_Unmarshal(b []byte) error
Constants ¶
This section is empty.
Variables ¶
var ( ErrInvalidLengthManager = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowManager = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupManager = fmt.Errorf("proto: unexpected end of group") )
var ( ErrInvalidLengthPrimitive = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowPrimitive = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupPrimitive = fmt.Errorf("proto: unexpected end of group") )
var Event_Type_name = map[int32]string{
0: "NONE",
1: "ADD",
2: "REMOVE",
3: "REPLAY",
}
var Event_Type_value = map[string]int32{
"NONE": 0,
"ADD": 1,
"REMOVE": 2,
"REPLAY": 3,
}
Functions ¶
func RegisterListManagerServer ¶ added in v0.7.0
func RegisterListManagerServer(s *grpc.Server, srv ListManagerServer)
func RegisterListServer ¶
func RegisterListServer(s *grpc.Server, srv ListServer)
Types ¶
type AppendRequest ¶
type AppendRequest struct {
Value Value `protobuf:"bytes,2,opt,name=value,proto3" json:"value"`
}
func (*AppendRequest) Descriptor ¶
func (*AppendRequest) Descriptor() ([]byte, []int)
func (*AppendRequest) GetValue ¶
func (m *AppendRequest) GetValue() Value
func (*AppendRequest) Marshal ¶
func (m *AppendRequest) Marshal() (dAtA []byte, err error)
func (*AppendRequest) MarshalToSizedBuffer ¶
func (m *AppendRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*AppendRequest) ProtoMessage ¶
func (*AppendRequest) ProtoMessage()
func (*AppendRequest) Reset ¶
func (m *AppendRequest) Reset()
func (*AppendRequest) Size ¶
func (m *AppendRequest) Size() (n int)
func (*AppendRequest) String ¶
func (m *AppendRequest) String() string
func (*AppendRequest) Unmarshal ¶
func (m *AppendRequest) Unmarshal(dAtA []byte) error
func (*AppendRequest) XXX_DiscardUnknown ¶
func (m *AppendRequest) XXX_DiscardUnknown()
func (*AppendRequest) XXX_Marshal ¶
func (m *AppendRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*AppendRequest) XXX_Merge ¶
func (m *AppendRequest) XXX_Merge(src proto.Message)
func (*AppendRequest) XXX_Size ¶
func (m *AppendRequest) XXX_Size() int
func (*AppendRequest) XXX_Unmarshal ¶
func (m *AppendRequest) XXX_Unmarshal(b []byte) error
type AppendResponse ¶
type AppendResponse struct { }
func (*AppendResponse) Descriptor ¶
func (*AppendResponse) Descriptor() ([]byte, []int)
func (*AppendResponse) Marshal ¶
func (m *AppendResponse) Marshal() (dAtA []byte, err error)
func (*AppendResponse) MarshalToSizedBuffer ¶
func (m *AppendResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*AppendResponse) ProtoMessage ¶
func (*AppendResponse) ProtoMessage()
func (*AppendResponse) Reset ¶
func (m *AppendResponse) Reset()
func (*AppendResponse) Size ¶
func (m *AppendResponse) Size() (n int)
func (*AppendResponse) String ¶
func (m *AppendResponse) String() string
func (*AppendResponse) Unmarshal ¶
func (m *AppendResponse) Unmarshal(dAtA []byte) error
func (*AppendResponse) XXX_DiscardUnknown ¶
func (m *AppendResponse) XXX_DiscardUnknown()
func (*AppendResponse) XXX_Marshal ¶
func (m *AppendResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*AppendResponse) XXX_Merge ¶
func (m *AppendResponse) XXX_Merge(src proto.Message)
func (*AppendResponse) XXX_Size ¶
func (m *AppendResponse) XXX_Size() int
func (*AppendResponse) XXX_Unmarshal ¶
func (m *AppendResponse) XXX_Unmarshal(b []byte) error
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) 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) 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 ContainsRequest ¶
type ContainsRequest struct {
Value Value `protobuf:"bytes,2,opt,name=value,proto3" json:"value"`
}
func (*ContainsRequest) Descriptor ¶
func (*ContainsRequest) Descriptor() ([]byte, []int)
func (*ContainsRequest) GetValue ¶
func (m *ContainsRequest) GetValue() Value
func (*ContainsRequest) Marshal ¶
func (m *ContainsRequest) Marshal() (dAtA []byte, err error)
func (*ContainsRequest) MarshalToSizedBuffer ¶
func (m *ContainsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ContainsRequest) ProtoMessage ¶
func (*ContainsRequest) ProtoMessage()
func (*ContainsRequest) Reset ¶
func (m *ContainsRequest) Reset()
func (*ContainsRequest) Size ¶
func (m *ContainsRequest) Size() (n int)
func (*ContainsRequest) String ¶
func (m *ContainsRequest) String() string
func (*ContainsRequest) Unmarshal ¶
func (m *ContainsRequest) Unmarshal(dAtA []byte) error
func (*ContainsRequest) XXX_DiscardUnknown ¶
func (m *ContainsRequest) XXX_DiscardUnknown()
func (*ContainsRequest) XXX_Marshal ¶
func (m *ContainsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ContainsRequest) XXX_Merge ¶
func (m *ContainsRequest) XXX_Merge(src proto.Message)
func (*ContainsRequest) XXX_Size ¶
func (m *ContainsRequest) XXX_Size() int
func (*ContainsRequest) XXX_Unmarshal ¶
func (m *ContainsRequest) XXX_Unmarshal(b []byte) error
type ContainsResponse ¶
type ContainsResponse struct {
Contains bool `protobuf:"varint,2,opt,name=contains,proto3" json:"contains,omitempty"`
}
func (*ContainsResponse) Descriptor ¶
func (*ContainsResponse) Descriptor() ([]byte, []int)
func (*ContainsResponse) GetContains ¶
func (m *ContainsResponse) GetContains() bool
func (*ContainsResponse) Marshal ¶
func (m *ContainsResponse) Marshal() (dAtA []byte, err error)
func (*ContainsResponse) MarshalToSizedBuffer ¶
func (m *ContainsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ContainsResponse) ProtoMessage ¶
func (*ContainsResponse) ProtoMessage()
func (*ContainsResponse) Reset ¶
func (m *ContainsResponse) Reset()
func (*ContainsResponse) Size ¶
func (m *ContainsResponse) Size() (n int)
func (*ContainsResponse) String ¶
func (m *ContainsResponse) String() string
func (*ContainsResponse) Unmarshal ¶
func (m *ContainsResponse) Unmarshal(dAtA []byte) error
func (*ContainsResponse) XXX_DiscardUnknown ¶
func (m *ContainsResponse) XXX_DiscardUnknown()
func (*ContainsResponse) XXX_Marshal ¶
func (m *ContainsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ContainsResponse) XXX_Merge ¶
func (m *ContainsResponse) XXX_Merge(src proto.Message)
func (*ContainsResponse) XXX_Size ¶
func (m *ContainsResponse) XXX_Size() int
func (*ContainsResponse) XXX_Unmarshal ¶
func (m *ContainsResponse) XXX_Unmarshal(b []byte) error
type ElementsRequest ¶
type ElementsRequest struct { }
func (*ElementsRequest) Descriptor ¶
func (*ElementsRequest) Descriptor() ([]byte, []int)
func (*ElementsRequest) Marshal ¶
func (m *ElementsRequest) Marshal() (dAtA []byte, err error)
func (*ElementsRequest) MarshalToSizedBuffer ¶
func (m *ElementsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ElementsRequest) ProtoMessage ¶
func (*ElementsRequest) ProtoMessage()
func (*ElementsRequest) Reset ¶
func (m *ElementsRequest) Reset()
func (*ElementsRequest) Size ¶
func (m *ElementsRequest) Size() (n int)
func (*ElementsRequest) String ¶
func (m *ElementsRequest) String() string
func (*ElementsRequest) Unmarshal ¶
func (m *ElementsRequest) Unmarshal(dAtA []byte) error
func (*ElementsRequest) XXX_DiscardUnknown ¶
func (m *ElementsRequest) XXX_DiscardUnknown()
func (*ElementsRequest) XXX_Marshal ¶
func (m *ElementsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ElementsRequest) XXX_Merge ¶
func (m *ElementsRequest) XXX_Merge(src proto.Message)
func (*ElementsRequest) XXX_Size ¶
func (m *ElementsRequest) XXX_Size() int
func (*ElementsRequest) XXX_Unmarshal ¶
func (m *ElementsRequest) XXX_Unmarshal(b []byte) error
type ElementsResponse ¶
type ElementsResponse struct {
Item Item `protobuf:"bytes,2,opt,name=item,proto3" json:"item"`
}
func (*ElementsResponse) Descriptor ¶
func (*ElementsResponse) Descriptor() ([]byte, []int)
func (*ElementsResponse) GetItem ¶
func (m *ElementsResponse) GetItem() Item
func (*ElementsResponse) Marshal ¶
func (m *ElementsResponse) Marshal() (dAtA []byte, err error)
func (*ElementsResponse) MarshalToSizedBuffer ¶
func (m *ElementsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ElementsResponse) ProtoMessage ¶
func (*ElementsResponse) ProtoMessage()
func (*ElementsResponse) Reset ¶
func (m *ElementsResponse) Reset()
func (*ElementsResponse) Size ¶
func (m *ElementsResponse) Size() (n int)
func (*ElementsResponse) String ¶
func (m *ElementsResponse) String() string
func (*ElementsResponse) Unmarshal ¶
func (m *ElementsResponse) Unmarshal(dAtA []byte) error
func (*ElementsResponse) XXX_DiscardUnknown ¶
func (m *ElementsResponse) XXX_DiscardUnknown()
func (*ElementsResponse) XXX_Marshal ¶
func (m *ElementsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ElementsResponse) XXX_Merge ¶
func (m *ElementsResponse) XXX_Merge(src proto.Message)
func (*ElementsResponse) XXX_Size ¶
func (m *ElementsResponse) XXX_Size() int
func (*ElementsResponse) XXX_Unmarshal ¶
func (m *ElementsResponse) XXX_Unmarshal(b []byte) error
type Event ¶
type Event struct { Type Event_Type `protobuf:"varint,1,opt,name=type,proto3,enum=atomix.primitive.list.v1.Event_Type" json:"type,omitempty"` Item Item `protobuf:"bytes,2,opt,name=item,proto3" json:"item"` }
func (*Event) Descriptor ¶
func (*Event) GetType ¶
func (m *Event) GetType() Event_Type
func (*Event) ProtoMessage ¶
func (*Event) ProtoMessage()
func (*Event) XXX_DiscardUnknown ¶
func (m *Event) XXX_DiscardUnknown()
func (*Event) XXX_Marshal ¶
func (*Event) XXX_Unmarshal ¶
type Event_Type ¶
type Event_Type int32
const ( Event_NONE Event_Type = 0 Event_ADD Event_Type = 1 Event_REMOVE Event_Type = 2 Event_REPLAY Event_Type = 3 )
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 {
Replay bool `protobuf:"varint,2,opt,name=replay,proto3" json:"replay,omitempty"`
}
func (*EventsRequest) Descriptor ¶
func (*EventsRequest) Descriptor() ([]byte, []int)
func (*EventsRequest) GetReplay ¶
func (m *EventsRequest) GetReplay() bool
func (*EventsRequest) Marshal ¶
func (m *EventsRequest) Marshal() (dAtA []byte, err 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) 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 GetRequest ¶
type GetRequest struct {
Index uint32 `protobuf:"varint,2,opt,name=index,proto3" json:"index,omitempty"`
}
func (*GetRequest) Descriptor ¶
func (*GetRequest) Descriptor() ([]byte, []int)
func (*GetRequest) GetIndex ¶
func (m *GetRequest) GetIndex() uint32
func (*GetRequest) Marshal ¶
func (m *GetRequest) Marshal() (dAtA []byte, err 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 {
Item Item `protobuf:"bytes,2,opt,name=item,proto3" json:"item"`
}
func (*GetResponse) Descriptor ¶
func (*GetResponse) Descriptor() ([]byte, []int)
func (*GetResponse) GetItem ¶
func (m *GetResponse) GetItem() Item
func (*GetResponse) Marshal ¶
func (m *GetResponse) Marshal() (dAtA []byte, err 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 InsertRequest ¶
type InsertRequest struct { Item Item `protobuf:"bytes,2,opt,name=item,proto3" json:"item"` Preconditions []Precondition `protobuf:"bytes,3,rep,name=preconditions,proto3" json:"preconditions"` }
func (*InsertRequest) Descriptor ¶
func (*InsertRequest) Descriptor() ([]byte, []int)
func (*InsertRequest) GetItem ¶
func (m *InsertRequest) GetItem() Item
func (*InsertRequest) GetPreconditions ¶
func (m *InsertRequest) GetPreconditions() []Precondition
func (*InsertRequest) Marshal ¶
func (m *InsertRequest) Marshal() (dAtA []byte, err error)
func (*InsertRequest) MarshalToSizedBuffer ¶
func (m *InsertRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*InsertRequest) ProtoMessage ¶
func (*InsertRequest) ProtoMessage()
func (*InsertRequest) Reset ¶
func (m *InsertRequest) Reset()
func (*InsertRequest) Size ¶
func (m *InsertRequest) Size() (n int)
func (*InsertRequest) String ¶
func (m *InsertRequest) String() string
func (*InsertRequest) Unmarshal ¶
func (m *InsertRequest) Unmarshal(dAtA []byte) error
func (*InsertRequest) XXX_DiscardUnknown ¶
func (m *InsertRequest) XXX_DiscardUnknown()
func (*InsertRequest) XXX_Marshal ¶
func (m *InsertRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*InsertRequest) XXX_Merge ¶
func (m *InsertRequest) XXX_Merge(src proto.Message)
func (*InsertRequest) XXX_Size ¶
func (m *InsertRequest) XXX_Size() int
func (*InsertRequest) XXX_Unmarshal ¶
func (m *InsertRequest) XXX_Unmarshal(b []byte) error
type InsertResponse ¶
type InsertResponse struct {
Item Item `protobuf:"bytes,2,opt,name=item,proto3" json:"item"`
}
func (*InsertResponse) Descriptor ¶
func (*InsertResponse) Descriptor() ([]byte, []int)
func (*InsertResponse) GetItem ¶
func (m *InsertResponse) GetItem() Item
func (*InsertResponse) Marshal ¶
func (m *InsertResponse) Marshal() (dAtA []byte, err error)
func (*InsertResponse) MarshalToSizedBuffer ¶
func (m *InsertResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*InsertResponse) ProtoMessage ¶
func (*InsertResponse) ProtoMessage()
func (*InsertResponse) Reset ¶
func (m *InsertResponse) Reset()
func (*InsertResponse) Size ¶
func (m *InsertResponse) Size() (n int)
func (*InsertResponse) String ¶
func (m *InsertResponse) String() string
func (*InsertResponse) Unmarshal ¶
func (m *InsertResponse) Unmarshal(dAtA []byte) error
func (*InsertResponse) XXX_DiscardUnknown ¶
func (m *InsertResponse) XXX_DiscardUnknown()
func (*InsertResponse) XXX_Marshal ¶
func (m *InsertResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*InsertResponse) XXX_Merge ¶
func (m *InsertResponse) XXX_Merge(src proto.Message)
func (*InsertResponse) XXX_Size ¶
func (m *InsertResponse) XXX_Size() int
func (*InsertResponse) XXX_Unmarshal ¶
func (m *InsertResponse) XXX_Unmarshal(b []byte) error
type Item ¶
type Item struct { Index uint32 `protobuf:"varint,1,opt,name=index,proto3" json:"index,omitempty"` Value `protobuf:"bytes,2,opt,name=value,proto3,embedded=value" json:"value"` }
func (*Item) Descriptor ¶
func (*Item) ProtoMessage ¶
func (*Item) ProtoMessage()
func (*Item) XXX_DiscardUnknown ¶
func (m *Item) XXX_DiscardUnknown()
func (*Item) XXX_Unmarshal ¶
type ListClient ¶
type ListClient interface { // Size gets the number of elements in the list Size(ctx context.Context, in *SizeRequest, opts ...grpc.CallOption) (*SizeResponse, error) // Append appends a value to the list Append(ctx context.Context, in *AppendRequest, opts ...grpc.CallOption) (*AppendResponse, error) // Insert inserts a value at a specific index in the list Insert(ctx context.Context, in *InsertRequest, opts ...grpc.CallOption) (*InsertResponse, error) // Get gets the value at an index in the list Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetResponse, error) // Set sets the value at an index in the list Set(ctx context.Context, in *SetRequest, opts ...grpc.CallOption) (*SetResponse, error) // Remove removes an element from the list Remove(ctx context.Context, in *RemoveRequest, opts ...grpc.CallOption) (*RemoveResponse, error) // Clear removes all elements from the list 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) (List_EventsClient, error) // Elements streams all elements in the list Elements(ctx context.Context, in *ElementsRequest, opts ...grpc.CallOption) (List_ElementsClient, error) }
ListClient is the client API for List service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewListClient ¶
func NewListClient(cc *grpc.ClientConn) ListClient
type ListManagerClient ¶ added in v0.7.0
type ListManagerClient interface { OpenSession(ctx context.Context, in *OpenSessionRequest, opts ...grpc.CallOption) (*OpenSessionResponse, error) CloseSession(ctx context.Context, in *CloseSessionRequest, opts ...grpc.CallOption) (*CloseSessionResponse, error) }
ListManagerClient is the client API for ListManager service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewListManagerClient ¶ added in v0.7.0
func NewListManagerClient(cc *grpc.ClientConn) ListManagerClient
type ListManagerServer ¶ added in v0.7.0
type ListManagerServer interface { OpenSession(context.Context, *OpenSessionRequest) (*OpenSessionResponse, error) CloseSession(context.Context, *CloseSessionRequest) (*CloseSessionResponse, error) }
ListManagerServer is the server API for ListManager service.
type ListServer ¶
type ListServer interface { // Size gets the number of elements in the list Size(context.Context, *SizeRequest) (*SizeResponse, error) // Append appends a value to the list Append(context.Context, *AppendRequest) (*AppendResponse, error) // Insert inserts a value at a specific index in the list Insert(context.Context, *InsertRequest) (*InsertResponse, error) // Get gets the value at an index in the list Get(context.Context, *GetRequest) (*GetResponse, error) // Set sets the value at an index in the list Set(context.Context, *SetRequest) (*SetResponse, error) // Remove removes an element from the list Remove(context.Context, *RemoveRequest) (*RemoveResponse, error) // Clear removes all elements from the list Clear(context.Context, *ClearRequest) (*ClearResponse, error) // Events listens for change events Events(*EventsRequest, List_EventsServer) error // Elements streams all elements in the list Elements(*ElementsRequest, List_ElementsServer) error }
ListServer is the server API for List service.
type ListSessionOptions ¶
type ListSessionOptions struct { }
func (*ListSessionOptions) Descriptor ¶
func (*ListSessionOptions) Descriptor() ([]byte, []int)
func (*ListSessionOptions) Marshal ¶
func (m *ListSessionOptions) Marshal() (dAtA []byte, err error)
func (*ListSessionOptions) MarshalTo ¶
func (m *ListSessionOptions) MarshalTo(dAtA []byte) (int, error)
func (*ListSessionOptions) MarshalToSizedBuffer ¶
func (m *ListSessionOptions) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ListSessionOptions) ProtoMessage ¶
func (*ListSessionOptions) ProtoMessage()
func (*ListSessionOptions) Reset ¶
func (m *ListSessionOptions) Reset()
func (*ListSessionOptions) Size ¶
func (m *ListSessionOptions) Size() (n int)
func (*ListSessionOptions) String ¶
func (m *ListSessionOptions) String() string
func (*ListSessionOptions) Unmarshal ¶
func (m *ListSessionOptions) Unmarshal(dAtA []byte) error
func (*ListSessionOptions) XXX_DiscardUnknown ¶
func (m *ListSessionOptions) XXX_DiscardUnknown()
func (*ListSessionOptions) XXX_Marshal ¶
func (m *ListSessionOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ListSessionOptions) XXX_Merge ¶
func (m *ListSessionOptions) XXX_Merge(src proto.Message)
func (*ListSessionOptions) XXX_Size ¶
func (m *ListSessionOptions) XXX_Size() int
func (*ListSessionOptions) XXX_Unmarshal ¶
func (m *ListSessionOptions) XXX_Unmarshal(b []byte) error
type List_ElementsClient ¶
type List_ElementsClient interface { Recv() (*ElementsResponse, error) grpc.ClientStream }
type List_ElementsServer ¶
type List_ElementsServer interface { Send(*ElementsResponse) error grpc.ServerStream }
type List_EventsClient ¶
type List_EventsClient interface { Recv() (*EventsResponse, error) grpc.ClientStream }
type List_EventsServer ¶
type List_EventsServer interface { Send(*EventsResponse) error grpc.ServerStream }
type OpenSessionRequest ¶
type OpenSessionRequest struct { PrimitiveID github_com_atomix_atomix_api_go_atomix_primitive_v1.ID `` /* 158-byte string literal not displayed */ Options ListSessionOptions `protobuf:"bytes,2,opt,name=options,proto3" json:"options"` }
func (*OpenSessionRequest) Descriptor ¶
func (*OpenSessionRequest) Descriptor() ([]byte, []int)
func (*OpenSessionRequest) GetOptions ¶
func (m *OpenSessionRequest) GetOptions() ListSessionOptions
func (*OpenSessionRequest) GetPrimitiveID ¶
func (m *OpenSessionRequest) GetPrimitiveID() github_com_atomix_atomix_api_go_atomix_primitive_v1.ID
func (*OpenSessionRequest) Marshal ¶
func (m *OpenSessionRequest) Marshal() (dAtA []byte, err error)
func (*OpenSessionRequest) MarshalTo ¶
func (m *OpenSessionRequest) MarshalTo(dAtA []byte) (int, error)
func (*OpenSessionRequest) MarshalToSizedBuffer ¶
func (m *OpenSessionRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*OpenSessionRequest) ProtoMessage ¶
func (*OpenSessionRequest) ProtoMessage()
func (*OpenSessionRequest) Reset ¶
func (m *OpenSessionRequest) Reset()
func (*OpenSessionRequest) Size ¶
func (m *OpenSessionRequest) Size() (n int)
func (*OpenSessionRequest) String ¶
func (m *OpenSessionRequest) String() string
func (*OpenSessionRequest) Unmarshal ¶
func (m *OpenSessionRequest) Unmarshal(dAtA []byte) error
func (*OpenSessionRequest) XXX_DiscardUnknown ¶
func (m *OpenSessionRequest) XXX_DiscardUnknown()
func (*OpenSessionRequest) XXX_Marshal ¶
func (m *OpenSessionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*OpenSessionRequest) XXX_Merge ¶
func (m *OpenSessionRequest) XXX_Merge(src proto.Message)
func (*OpenSessionRequest) XXX_Size ¶
func (m *OpenSessionRequest) XXX_Size() int
func (*OpenSessionRequest) XXX_Unmarshal ¶
func (m *OpenSessionRequest) XXX_Unmarshal(b []byte) error
type OpenSessionResponse ¶
type OpenSessionResponse struct {
SessionID github_com_atomix_atomix_api_go_atomix_primitive_v1.SessionID `` /* 160-byte string literal not displayed */
}
func (*OpenSessionResponse) Descriptor ¶
func (*OpenSessionResponse) Descriptor() ([]byte, []int)
func (*OpenSessionResponse) GetSessionID ¶
func (m *OpenSessionResponse) GetSessionID() github_com_atomix_atomix_api_go_atomix_primitive_v1.SessionID
func (*OpenSessionResponse) Marshal ¶
func (m *OpenSessionResponse) Marshal() (dAtA []byte, err error)
func (*OpenSessionResponse) MarshalTo ¶
func (m *OpenSessionResponse) MarshalTo(dAtA []byte) (int, error)
func (*OpenSessionResponse) MarshalToSizedBuffer ¶
func (m *OpenSessionResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*OpenSessionResponse) ProtoMessage ¶
func (*OpenSessionResponse) ProtoMessage()
func (*OpenSessionResponse) Reset ¶
func (m *OpenSessionResponse) Reset()
func (*OpenSessionResponse) Size ¶
func (m *OpenSessionResponse) Size() (n int)
func (*OpenSessionResponse) String ¶
func (m *OpenSessionResponse) String() string
func (*OpenSessionResponse) Unmarshal ¶
func (m *OpenSessionResponse) Unmarshal(dAtA []byte) error
func (*OpenSessionResponse) XXX_DiscardUnknown ¶
func (m *OpenSessionResponse) XXX_DiscardUnknown()
func (*OpenSessionResponse) XXX_Marshal ¶
func (m *OpenSessionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*OpenSessionResponse) XXX_Merge ¶
func (m *OpenSessionResponse) XXX_Merge(src proto.Message)
func (*OpenSessionResponse) XXX_Size ¶
func (m *OpenSessionResponse) XXX_Size() int
func (*OpenSessionResponse) XXX_Unmarshal ¶
func (m *OpenSessionResponse) XXX_Unmarshal(b []byte) error
type Precondition ¶
type Precondition struct { // Types that are valid to be assigned to Precondition: // *Precondition_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) 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 RemoveRequest ¶
type RemoveRequest struct { Index uint32 `protobuf:"varint,2,opt,name=index,proto3" json:"index,omitempty"` Preconditions []Precondition `protobuf:"bytes,3,rep,name=preconditions,proto3" json:"preconditions"` }
func (*RemoveRequest) Descriptor ¶
func (*RemoveRequest) Descriptor() ([]byte, []int)
func (*RemoveRequest) GetIndex ¶
func (m *RemoveRequest) GetIndex() uint32
func (*RemoveRequest) GetPreconditions ¶
func (m *RemoveRequest) GetPreconditions() []Precondition
func (*RemoveRequest) Marshal ¶
func (m *RemoveRequest) Marshal() (dAtA []byte, err 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 {
Item Item `protobuf:"bytes,2,opt,name=item,proto3" json:"item"`
}
func (*RemoveResponse) Descriptor ¶
func (*RemoveResponse) Descriptor() ([]byte, []int)
func (*RemoveResponse) GetItem ¶
func (m *RemoveResponse) GetItem() Item
func (*RemoveResponse) Marshal ¶
func (m *RemoveResponse) Marshal() (dAtA []byte, err 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 SetRequest ¶
type SetRequest struct { Item Item `protobuf:"bytes,2,opt,name=item,proto3" json:"item"` Preconditions []Precondition `protobuf:"bytes,3,rep,name=preconditions,proto3" json:"preconditions"` }
func (*SetRequest) Descriptor ¶
func (*SetRequest) Descriptor() ([]byte, []int)
func (*SetRequest) GetItem ¶
func (m *SetRequest) GetItem() Item
func (*SetRequest) GetPreconditions ¶
func (m *SetRequest) GetPreconditions() []Precondition
func (*SetRequest) Marshal ¶
func (m *SetRequest) Marshal() (dAtA []byte, err error)
func (*SetRequest) MarshalToSizedBuffer ¶
func (m *SetRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SetRequest) ProtoMessage ¶
func (*SetRequest) ProtoMessage()
func (*SetRequest) Reset ¶
func (m *SetRequest) Reset()
func (*SetRequest) Size ¶
func (m *SetRequest) Size() (n int)
func (*SetRequest) String ¶
func (m *SetRequest) String() string
func (*SetRequest) Unmarshal ¶
func (m *SetRequest) Unmarshal(dAtA []byte) error
func (*SetRequest) XXX_DiscardUnknown ¶
func (m *SetRequest) XXX_DiscardUnknown()
func (*SetRequest) XXX_Marshal ¶
func (m *SetRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SetRequest) XXX_Merge ¶
func (m *SetRequest) XXX_Merge(src proto.Message)
func (*SetRequest) XXX_Size ¶
func (m *SetRequest) XXX_Size() int
func (*SetRequest) XXX_Unmarshal ¶
func (m *SetRequest) XXX_Unmarshal(b []byte) error
type SetResponse ¶
type SetResponse struct {
Item Item `protobuf:"bytes,2,opt,name=item,proto3" json:"item"`
}
func (*SetResponse) Descriptor ¶
func (*SetResponse) Descriptor() ([]byte, []int)
func (*SetResponse) GetItem ¶
func (m *SetResponse) GetItem() Item
func (*SetResponse) Marshal ¶
func (m *SetResponse) Marshal() (dAtA []byte, err error)
func (*SetResponse) MarshalToSizedBuffer ¶
func (m *SetResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SetResponse) ProtoMessage ¶
func (*SetResponse) ProtoMessage()
func (*SetResponse) Reset ¶
func (m *SetResponse) Reset()
func (*SetResponse) Size ¶
func (m *SetResponse) Size() (n int)
func (*SetResponse) String ¶
func (m *SetResponse) String() string
func (*SetResponse) Unmarshal ¶
func (m *SetResponse) Unmarshal(dAtA []byte) error
func (*SetResponse) XXX_DiscardUnknown ¶
func (m *SetResponse) XXX_DiscardUnknown()
func (*SetResponse) XXX_Marshal ¶
func (m *SetResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SetResponse) XXX_Merge ¶
func (m *SetResponse) XXX_Merge(src proto.Message)
func (*SetResponse) XXX_Size ¶
func (m *SetResponse) XXX_Size() int
func (*SetResponse) XXX_Unmarshal ¶
func (m *SetResponse) XXX_Unmarshal(b []byte) error
type 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) 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) 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 UnimplementedListManagerServer ¶ added in v0.7.0
type UnimplementedListManagerServer struct { }
UnimplementedListManagerServer can be embedded to have forward compatible implementations.
func (*UnimplementedListManagerServer) CloseSession ¶ added in v0.7.0
func (*UnimplementedListManagerServer) CloseSession(ctx context.Context, req *CloseSessionRequest) (*CloseSessionResponse, error)
func (*UnimplementedListManagerServer) OpenSession ¶ added in v0.7.0
func (*UnimplementedListManagerServer) OpenSession(ctx context.Context, req *OpenSessionRequest) (*OpenSessionResponse, error)
type UnimplementedListServer ¶
type UnimplementedListServer struct { }
UnimplementedListServer can be embedded to have forward compatible implementations.
func (*UnimplementedListServer) Append ¶
func (*UnimplementedListServer) Append(ctx context.Context, req *AppendRequest) (*AppendResponse, error)
func (*UnimplementedListServer) Clear ¶
func (*UnimplementedListServer) Clear(ctx context.Context, req *ClearRequest) (*ClearResponse, error)
func (*UnimplementedListServer) Elements ¶
func (*UnimplementedListServer) Elements(req *ElementsRequest, srv List_ElementsServer) error
func (*UnimplementedListServer) Events ¶
func (*UnimplementedListServer) Events(req *EventsRequest, srv List_EventsServer) error
func (*UnimplementedListServer) Get ¶
func (*UnimplementedListServer) Get(ctx context.Context, req *GetRequest) (*GetResponse, error)
func (*UnimplementedListServer) Insert ¶
func (*UnimplementedListServer) Insert(ctx context.Context, req *InsertRequest) (*InsertResponse, error)
func (*UnimplementedListServer) Remove ¶
func (*UnimplementedListServer) Remove(ctx context.Context, req *RemoveRequest) (*RemoveResponse, error)
func (*UnimplementedListServer) Set ¶
func (*UnimplementedListServer) Set(ctx context.Context, req *SetRequest) (*SetResponse, error)
func (*UnimplementedListServer) Size ¶
func (*UnimplementedListServer) 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 string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"` }
func (*Value) Descriptor ¶
func (*Value) ProtoMessage ¶
func (*Value) ProtoMessage()
func (*Value) XXX_DiscardUnknown ¶
func (m *Value) XXX_DiscardUnknown()