Documentation ¶
Index ¶
- Variables
- func RegisterLogManagerServer(s *grpc.Server, srv LogManagerServer)
- func RegisterLogServer(s *grpc.Server, srv LogServer)
- type AppendRequest
- func (*AppendRequest) Descriptor() ([]byte, []int)
- func (m *AppendRequest) GetIndex() uint64
- func (m *AppendRequest) GetValue() []byte
- 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) GetEntry() Entry
- 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 EntriesRequest
- func (*EntriesRequest) Descriptor() ([]byte, []int)
- func (m *EntriesRequest) Marshal() (dAtA []byte, err error)
- func (m *EntriesRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *EntriesRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*EntriesRequest) ProtoMessage()
- func (m *EntriesRequest) Reset()
- func (m *EntriesRequest) Size() (n int)
- func (m *EntriesRequest) String() string
- func (m *EntriesRequest) Unmarshal(dAtA []byte) error
- func (m *EntriesRequest) XXX_DiscardUnknown()
- func (m *EntriesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *EntriesRequest) XXX_Merge(src proto.Message)
- func (m *EntriesRequest) XXX_Size() int
- func (m *EntriesRequest) XXX_Unmarshal(b []byte) error
- type EntriesResponse
- func (*EntriesResponse) Descriptor() ([]byte, []int)
- func (m *EntriesResponse) GetEntry() Entry
- func (m *EntriesResponse) Marshal() (dAtA []byte, err error)
- func (m *EntriesResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *EntriesResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*EntriesResponse) ProtoMessage()
- func (m *EntriesResponse) Reset()
- func (m *EntriesResponse) Size() (n int)
- func (m *EntriesResponse) String() string
- func (m *EntriesResponse) Unmarshal(dAtA []byte) error
- func (m *EntriesResponse) XXX_DiscardUnknown()
- func (m *EntriesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *EntriesResponse) XXX_Merge(src proto.Message)
- func (m *EntriesResponse) XXX_Size() int
- func (m *EntriesResponse) XXX_Unmarshal(b []byte) error
- type Entry
- func (*Entry) Descriptor() ([]byte, []int)
- func (m *Entry) GetIndex() uint64
- func (m *Entry) GetValue() []byte
- func (m *Entry) Marshal() (dAtA []byte, err error)
- func (m *Entry) MarshalTo(dAtA []byte) (int, error)
- func (m *Entry) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Entry) ProtoMessage()
- func (m *Entry) Reset()
- func (m *Entry) Size() (n int)
- func (m *Entry) String() string
- func (m *Entry) Unmarshal(dAtA []byte) error
- func (m *Entry) XXX_DiscardUnknown()
- func (m *Entry) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Entry) XXX_Merge(src proto.Message)
- func (m *Entry) XXX_Size() int
- func (m *Entry) XXX_Unmarshal(b []byte) error
- type Event
- func (*Event) Descriptor() ([]byte, []int)
- func (m *Event) GetEntry() Entry
- 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) GetIndex() uint64
- 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 FirstEntryRequest
- func (*FirstEntryRequest) Descriptor() ([]byte, []int)
- func (m *FirstEntryRequest) Marshal() (dAtA []byte, err error)
- func (m *FirstEntryRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *FirstEntryRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*FirstEntryRequest) ProtoMessage()
- func (m *FirstEntryRequest) Reset()
- func (m *FirstEntryRequest) Size() (n int)
- func (m *FirstEntryRequest) String() string
- func (m *FirstEntryRequest) Unmarshal(dAtA []byte) error
- func (m *FirstEntryRequest) XXX_DiscardUnknown()
- func (m *FirstEntryRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *FirstEntryRequest) XXX_Merge(src proto.Message)
- func (m *FirstEntryRequest) XXX_Size() int
- func (m *FirstEntryRequest) XXX_Unmarshal(b []byte) error
- type FirstEntryResponse
- func (*FirstEntryResponse) Descriptor() ([]byte, []int)
- func (m *FirstEntryResponse) GetEntry() Entry
- func (m *FirstEntryResponse) Marshal() (dAtA []byte, err error)
- func (m *FirstEntryResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *FirstEntryResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*FirstEntryResponse) ProtoMessage()
- func (m *FirstEntryResponse) Reset()
- func (m *FirstEntryResponse) Size() (n int)
- func (m *FirstEntryResponse) String() string
- func (m *FirstEntryResponse) Unmarshal(dAtA []byte) error
- func (m *FirstEntryResponse) XXX_DiscardUnknown()
- func (m *FirstEntryResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *FirstEntryResponse) XXX_Merge(src proto.Message)
- func (m *FirstEntryResponse) XXX_Size() int
- func (m *FirstEntryResponse) XXX_Unmarshal(b []byte) error
- type GetRequest
- func (*GetRequest) Descriptor() ([]byte, []int)
- func (m *GetRequest) GetIndex() uint64
- 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) GetEntry() Entry
- 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 LastEntryRequest
- func (*LastEntryRequest) Descriptor() ([]byte, []int)
- func (m *LastEntryRequest) Marshal() (dAtA []byte, err error)
- func (m *LastEntryRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *LastEntryRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*LastEntryRequest) ProtoMessage()
- func (m *LastEntryRequest) Reset()
- func (m *LastEntryRequest) Size() (n int)
- func (m *LastEntryRequest) String() string
- func (m *LastEntryRequest) Unmarshal(dAtA []byte) error
- func (m *LastEntryRequest) XXX_DiscardUnknown()
- func (m *LastEntryRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *LastEntryRequest) XXX_Merge(src proto.Message)
- func (m *LastEntryRequest) XXX_Size() int
- func (m *LastEntryRequest) XXX_Unmarshal(b []byte) error
- type LastEntryResponse
- func (*LastEntryResponse) Descriptor() ([]byte, []int)
- func (m *LastEntryResponse) GetEntry() Entry
- func (m *LastEntryResponse) Marshal() (dAtA []byte, err error)
- func (m *LastEntryResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *LastEntryResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*LastEntryResponse) ProtoMessage()
- func (m *LastEntryResponse) Reset()
- func (m *LastEntryResponse) Size() (n int)
- func (m *LastEntryResponse) String() string
- func (m *LastEntryResponse) Unmarshal(dAtA []byte) error
- func (m *LastEntryResponse) XXX_DiscardUnknown()
- func (m *LastEntryResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *LastEntryResponse) XXX_Merge(src proto.Message)
- func (m *LastEntryResponse) XXX_Size() int
- func (m *LastEntryResponse) XXX_Unmarshal(b []byte) error
- type LogClient
- type LogManagerClient
- type LogManagerServer
- type LogServer
- type LogSessionOptions
- func (*LogSessionOptions) Descriptor() ([]byte, []int)
- func (m *LogSessionOptions) Marshal() (dAtA []byte, err error)
- func (m *LogSessionOptions) MarshalTo(dAtA []byte) (int, error)
- func (m *LogSessionOptions) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*LogSessionOptions) ProtoMessage()
- func (m *LogSessionOptions) Reset()
- func (m *LogSessionOptions) Size() (n int)
- func (m *LogSessionOptions) String() string
- func (m *LogSessionOptions) Unmarshal(dAtA []byte) error
- func (m *LogSessionOptions) XXX_DiscardUnknown()
- func (m *LogSessionOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *LogSessionOptions) XXX_Merge(src proto.Message)
- func (m *LogSessionOptions) XXX_Size() int
- func (m *LogSessionOptions) XXX_Unmarshal(b []byte) error
- type Log_EntriesClient
- type Log_EntriesServer
- type Log_EventsClient
- type Log_EventsServer
- type NextEntryRequest
- func (*NextEntryRequest) Descriptor() ([]byte, []int)
- func (m *NextEntryRequest) GetIndex() uint64
- func (m *NextEntryRequest) Marshal() (dAtA []byte, err error)
- func (m *NextEntryRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *NextEntryRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*NextEntryRequest) ProtoMessage()
- func (m *NextEntryRequest) Reset()
- func (m *NextEntryRequest) Size() (n int)
- func (m *NextEntryRequest) String() string
- func (m *NextEntryRequest) Unmarshal(dAtA []byte) error
- func (m *NextEntryRequest) XXX_DiscardUnknown()
- func (m *NextEntryRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *NextEntryRequest) XXX_Merge(src proto.Message)
- func (m *NextEntryRequest) XXX_Size() int
- func (m *NextEntryRequest) XXX_Unmarshal(b []byte) error
- type NextEntryResponse
- func (*NextEntryResponse) Descriptor() ([]byte, []int)
- func (m *NextEntryResponse) GetEntry() Entry
- func (m *NextEntryResponse) Marshal() (dAtA []byte, err error)
- func (m *NextEntryResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *NextEntryResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*NextEntryResponse) ProtoMessage()
- func (m *NextEntryResponse) Reset()
- func (m *NextEntryResponse) Size() (n int)
- func (m *NextEntryResponse) String() string
- func (m *NextEntryResponse) Unmarshal(dAtA []byte) error
- func (m *NextEntryResponse) XXX_DiscardUnknown()
- func (m *NextEntryResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *NextEntryResponse) XXX_Merge(src proto.Message)
- func (m *NextEntryResponse) XXX_Size() int
- func (m *NextEntryResponse) XXX_Unmarshal(b []byte) error
- type OpenSessionRequest
- func (*OpenSessionRequest) Descriptor() ([]byte, []int)
- func (m *OpenSessionRequest) GetOptions() LogSessionOptions
- 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 PrevEntryRequest
- func (*PrevEntryRequest) Descriptor() ([]byte, []int)
- func (m *PrevEntryRequest) GetIndex() uint64
- func (m *PrevEntryRequest) Marshal() (dAtA []byte, err error)
- func (m *PrevEntryRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *PrevEntryRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*PrevEntryRequest) ProtoMessage()
- func (m *PrevEntryRequest) Reset()
- func (m *PrevEntryRequest) Size() (n int)
- func (m *PrevEntryRequest) String() string
- func (m *PrevEntryRequest) Unmarshal(dAtA []byte) error
- func (m *PrevEntryRequest) XXX_DiscardUnknown()
- func (m *PrevEntryRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PrevEntryRequest) XXX_Merge(src proto.Message)
- func (m *PrevEntryRequest) XXX_Size() int
- func (m *PrevEntryRequest) XXX_Unmarshal(b []byte) error
- type PrevEntryResponse
- func (*PrevEntryResponse) Descriptor() ([]byte, []int)
- func (m *PrevEntryResponse) GetEntry() Entry
- func (m *PrevEntryResponse) Marshal() (dAtA []byte, err error)
- func (m *PrevEntryResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *PrevEntryResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*PrevEntryResponse) ProtoMessage()
- func (m *PrevEntryResponse) Reset()
- func (m *PrevEntryResponse) Size() (n int)
- func (m *PrevEntryResponse) String() string
- func (m *PrevEntryResponse) Unmarshal(dAtA []byte) error
- func (m *PrevEntryResponse) XXX_DiscardUnknown()
- func (m *PrevEntryResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PrevEntryResponse) XXX_Merge(src proto.Message)
- func (m *PrevEntryResponse) XXX_Size() int
- func (m *PrevEntryResponse) XXX_Unmarshal(b []byte) error
- type RemoveRequest
- func (*RemoveRequest) Descriptor() ([]byte, []int)
- func (m *RemoveRequest) GetEntry() Entry
- 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) GetEntry() Entry
- 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 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_() int32
- 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 UnimplementedLogManagerServer
- type UnimplementedLogServer
- func (*UnimplementedLogServer) Append(ctx context.Context, req *AppendRequest) (*AppendResponse, error)
- func (*UnimplementedLogServer) Clear(ctx context.Context, req *ClearRequest) (*ClearResponse, error)
- func (*UnimplementedLogServer) Entries(req *EntriesRequest, srv Log_EntriesServer) error
- func (*UnimplementedLogServer) Events(req *EventsRequest, srv Log_EventsServer) error
- func (*UnimplementedLogServer) FirstEntry(ctx context.Context, req *FirstEntryRequest) (*FirstEntryResponse, error)
- func (*UnimplementedLogServer) Get(ctx context.Context, req *GetRequest) (*GetResponse, error)
- func (*UnimplementedLogServer) LastEntry(ctx context.Context, req *LastEntryRequest) (*LastEntryResponse, error)
- func (*UnimplementedLogServer) NextEntry(ctx context.Context, req *NextEntryRequest) (*NextEntryResponse, error)
- func (*UnimplementedLogServer) PrevEntry(ctx context.Context, req *PrevEntryRequest) (*PrevEntryResponse, error)
- func (*UnimplementedLogServer) Remove(ctx context.Context, req *RemoveRequest) (*RemoveResponse, error)
- func (*UnimplementedLogServer) Size(ctx context.Context, req *SizeRequest) (*SizeResponse, error)
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: "APPEND",
2: "REMOVE",
3: "REPLAY",
}
View Source
var Event_Type_value = map[string]int32{
"NONE": 0,
"APPEND": 1,
"REMOVE": 2,
"REPLAY": 3,
}
Functions ¶
func RegisterLogManagerServer ¶ added in v0.7.0
func RegisterLogManagerServer(s *grpc.Server, srv LogManagerServer)
func RegisterLogServer ¶
Types ¶
type AppendRequest ¶
type AppendRequest struct { Index uint64 `protobuf:"varint,2,opt,name=index,proto3" json:"index,omitempty"` Value []byte `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"` }
func (*AppendRequest) Descriptor ¶
func (*AppendRequest) Descriptor() ([]byte, []int)
func (*AppendRequest) GetIndex ¶
func (m *AppendRequest) GetIndex() uint64
func (*AppendRequest) GetValue ¶
func (m *AppendRequest) GetValue() []byte
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 {
Entry Entry `protobuf:"bytes,2,opt,name=entry,proto3" json:"entry"`
}
func (*AppendResponse) Descriptor ¶
func (*AppendResponse) Descriptor() ([]byte, []int)
func (*AppendResponse) GetEntry ¶
func (m *AppendResponse) GetEntry() Entry
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 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) 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) 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 { v1.ObjectMeta `protobuf:"bytes,1,opt,name=meta,proto3,embedded=meta" json:"meta"` Index uint64 `protobuf:"varint,2,opt,name=index,proto3" json:"index,omitempty"` Value []byte `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"` }
func (*Entry) Descriptor ¶
func (*Entry) ProtoMessage ¶
func (*Entry) ProtoMessage()
func (*Entry) XXX_DiscardUnknown ¶
func (m *Entry) XXX_DiscardUnknown()
func (*Entry) XXX_Marshal ¶
func (*Entry) XXX_Unmarshal ¶
type Event ¶
type Event struct { Type Event_Type `protobuf:"varint,1,opt,name=type,proto3,enum=atomix.primitive.log.v1.Event_Type" json:"type,omitempty"` Entry Entry `protobuf:"bytes,2,opt,name=entry,proto3" json:"entry"` }
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_APPEND 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"` Index uint64 `protobuf:"varint,3,opt,name=index,proto3" json:"index,omitempty"` }
func (*EventsRequest) Descriptor ¶
func (*EventsRequest) Descriptor() ([]byte, []int)
func (*EventsRequest) GetIndex ¶
func (m *EventsRequest) GetIndex() uint64
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 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"`
}
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 {
Index uint64 `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() uint64
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 {
Entry Entry `protobuf:"bytes,2,opt,name=entry,proto3" json:"entry"`
}
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) 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 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) 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"`
}
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 LogClient ¶
type LogClient interface { // Size returns the size of the log Size(ctx context.Context, in *SizeRequest, opts ...grpc.CallOption) (*SizeResponse, error) // Appends appends an entry into the log Append(ctx context.Context, in *AppendRequest, opts ...grpc.CallOption) (*AppendResponse, error) // Get gets the entry for an index Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetResponse, error) // FirstEntry gets the first entry in the log FirstEntry(ctx context.Context, in *FirstEntryRequest, opts ...grpc.CallOption) (*FirstEntryResponse, error) // LastEntry gets the last entry in the log LastEntry(ctx context.Context, in *LastEntryRequest, opts ...grpc.CallOption) (*LastEntryResponse, error) // PrevEntry gets the previous entry in the log PrevEntry(ctx context.Context, in *PrevEntryRequest, opts ...grpc.CallOption) (*PrevEntryResponse, error) // NextEntry gets the next entry in the log NextEntry(ctx context.Context, in *NextEntryRequest, opts ...grpc.CallOption) (*NextEntryResponse, error) // Remove removes an entry from the log Remove(ctx context.Context, in *RemoveRequest, opts ...grpc.CallOption) (*RemoveResponse, error) // Clear removes all entries from the log 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) (Log_EventsClient, error) // Entries lists all entries in the log Entries(ctx context.Context, in *EntriesRequest, opts ...grpc.CallOption) (Log_EntriesClient, error) }
LogClient is the client API for Log service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewLogClient ¶
func NewLogClient(cc *grpc.ClientConn) LogClient
type LogManagerClient ¶ added in v0.7.0
type LogManagerClient interface { OpenSession(ctx context.Context, in *OpenSessionRequest, opts ...grpc.CallOption) (*OpenSessionResponse, error) CloseSession(ctx context.Context, in *CloseSessionRequest, opts ...grpc.CallOption) (*CloseSessionResponse, error) }
LogManagerClient is the client API for LogManager service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewLogManagerClient ¶ added in v0.7.0
func NewLogManagerClient(cc *grpc.ClientConn) LogManagerClient
type LogManagerServer ¶ added in v0.7.0
type LogManagerServer interface { OpenSession(context.Context, *OpenSessionRequest) (*OpenSessionResponse, error) CloseSession(context.Context, *CloseSessionRequest) (*CloseSessionResponse, error) }
LogManagerServer is the server API for LogManager service.
type LogServer ¶
type LogServer interface { // Size returns the size of the log Size(context.Context, *SizeRequest) (*SizeResponse, error) // Appends appends an entry into the log Append(context.Context, *AppendRequest) (*AppendResponse, error) // Get gets the entry for an index Get(context.Context, *GetRequest) (*GetResponse, error) // FirstEntry gets the first entry in the log FirstEntry(context.Context, *FirstEntryRequest) (*FirstEntryResponse, error) // LastEntry gets the last entry in the log LastEntry(context.Context, *LastEntryRequest) (*LastEntryResponse, error) // PrevEntry gets the previous entry in the log PrevEntry(context.Context, *PrevEntryRequest) (*PrevEntryResponse, error) // NextEntry gets the next entry in the log NextEntry(context.Context, *NextEntryRequest) (*NextEntryResponse, error) // Remove removes an entry from the log Remove(context.Context, *RemoveRequest) (*RemoveResponse, error) // Clear removes all entries from the log Clear(context.Context, *ClearRequest) (*ClearResponse, error) // Events listens for change events Events(*EventsRequest, Log_EventsServer) error // Entries lists all entries in the log Entries(*EntriesRequest, Log_EntriesServer) error }
LogServer is the server API for Log service.
type LogSessionOptions ¶
type LogSessionOptions struct { }
func (*LogSessionOptions) Descriptor ¶
func (*LogSessionOptions) Descriptor() ([]byte, []int)
func (*LogSessionOptions) Marshal ¶
func (m *LogSessionOptions) Marshal() (dAtA []byte, err error)
func (*LogSessionOptions) MarshalTo ¶
func (m *LogSessionOptions) MarshalTo(dAtA []byte) (int, error)
func (*LogSessionOptions) MarshalToSizedBuffer ¶
func (m *LogSessionOptions) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*LogSessionOptions) ProtoMessage ¶
func (*LogSessionOptions) ProtoMessage()
func (*LogSessionOptions) Reset ¶
func (m *LogSessionOptions) Reset()
func (*LogSessionOptions) Size ¶
func (m *LogSessionOptions) Size() (n int)
func (*LogSessionOptions) String ¶
func (m *LogSessionOptions) String() string
func (*LogSessionOptions) Unmarshal ¶
func (m *LogSessionOptions) Unmarshal(dAtA []byte) error
func (*LogSessionOptions) XXX_DiscardUnknown ¶
func (m *LogSessionOptions) XXX_DiscardUnknown()
func (*LogSessionOptions) XXX_Marshal ¶
func (m *LogSessionOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*LogSessionOptions) XXX_Merge ¶
func (m *LogSessionOptions) XXX_Merge(src proto.Message)
func (*LogSessionOptions) XXX_Size ¶
func (m *LogSessionOptions) XXX_Size() int
func (*LogSessionOptions) XXX_Unmarshal ¶
func (m *LogSessionOptions) XXX_Unmarshal(b []byte) error
type Log_EntriesClient ¶
type Log_EntriesClient interface { Recv() (*EntriesResponse, error) grpc.ClientStream }
type Log_EntriesServer ¶
type Log_EntriesServer interface { Send(*EntriesResponse) error grpc.ServerStream }
type Log_EventsClient ¶
type Log_EventsClient interface { Recv() (*EventsResponse, error) grpc.ClientStream }
type Log_EventsServer ¶
type Log_EventsServer interface { Send(*EventsResponse) error grpc.ServerStream }
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) 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"`
}
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 LogSessionOptions `protobuf:"bytes,2,opt,name=options,proto3" json:"options"` }
func (*OpenSessionRequest) Descriptor ¶
func (*OpenSessionRequest) Descriptor() ([]byte, []int)
func (*OpenSessionRequest) GetOptions ¶
func (m *OpenSessionRequest) GetOptions() LogSessionOptions
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 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) 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"`
}
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 RemoveRequest ¶
type RemoveRequest struct {
Entry Entry `protobuf:"bytes,2,opt,name=entry,proto3" json:"entry"`
}
func (*RemoveRequest) Descriptor ¶
func (*RemoveRequest) Descriptor() ([]byte, []int)
func (*RemoveRequest) GetEntry ¶
func (m *RemoveRequest) GetEntry() Entry
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 {
Entry Entry `protobuf:"bytes,2,opt,name=entry,proto3" json:"entry"`
}
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) 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) 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_ int32 `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_() int32
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 UnimplementedLogManagerServer ¶ added in v0.7.0
type UnimplementedLogManagerServer struct { }
UnimplementedLogManagerServer can be embedded to have forward compatible implementations.
func (*UnimplementedLogManagerServer) CloseSession ¶ added in v0.7.0
func (*UnimplementedLogManagerServer) CloseSession(ctx context.Context, req *CloseSessionRequest) (*CloseSessionResponse, error)
func (*UnimplementedLogManagerServer) OpenSession ¶ added in v0.7.0
func (*UnimplementedLogManagerServer) OpenSession(ctx context.Context, req *OpenSessionRequest) (*OpenSessionResponse, error)
type UnimplementedLogServer ¶
type UnimplementedLogServer struct { }
UnimplementedLogServer can be embedded to have forward compatible implementations.
func (*UnimplementedLogServer) Append ¶
func (*UnimplementedLogServer) Append(ctx context.Context, req *AppendRequest) (*AppendResponse, error)
func (*UnimplementedLogServer) Clear ¶
func (*UnimplementedLogServer) Clear(ctx context.Context, req *ClearRequest) (*ClearResponse, error)
func (*UnimplementedLogServer) Entries ¶
func (*UnimplementedLogServer) Entries(req *EntriesRequest, srv Log_EntriesServer) error
func (*UnimplementedLogServer) Events ¶
func (*UnimplementedLogServer) Events(req *EventsRequest, srv Log_EventsServer) error
func (*UnimplementedLogServer) FirstEntry ¶
func (*UnimplementedLogServer) FirstEntry(ctx context.Context, req *FirstEntryRequest) (*FirstEntryResponse, error)
func (*UnimplementedLogServer) Get ¶
func (*UnimplementedLogServer) Get(ctx context.Context, req *GetRequest) (*GetResponse, error)
func (*UnimplementedLogServer) LastEntry ¶
func (*UnimplementedLogServer) LastEntry(ctx context.Context, req *LastEntryRequest) (*LastEntryResponse, error)
func (*UnimplementedLogServer) NextEntry ¶
func (*UnimplementedLogServer) NextEntry(ctx context.Context, req *NextEntryRequest) (*NextEntryResponse, error)
func (*UnimplementedLogServer) PrevEntry ¶
func (*UnimplementedLogServer) PrevEntry(ctx context.Context, req *PrevEntryRequest) (*PrevEntryResponse, error)
func (*UnimplementedLogServer) Remove ¶
func (*UnimplementedLogServer) Remove(ctx context.Context, req *RemoveRequest) (*RemoveResponse, error)
func (*UnimplementedLogServer) Size ¶
func (*UnimplementedLogServer) Size(ctx context.Context, req *SizeRequest) (*SizeResponse, error)
Click to show internal directories.
Click to hide internal directories.