Documentation ¶
Index ¶
- Variables
- func RegisterLogServiceServer(s *grpc.Server, srv LogServiceServer)
- type AppendRequest
- func (*AppendRequest) Descriptor() ([]byte, []int)
- func (m *AppendRequest) GetHeader() *headers.RequestHeader
- 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) GetHeader() *headers.ResponseHeader
- func (m *AppendResponse) GetIndex() uint64
- func (m *AppendResponse) GetStatus() ResponseStatus
- func (m *AppendResponse) GetTimestamp() time.Time
- 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) GetHeader() *headers.RequestHeader
- 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) GetHeader() *headers.ResponseHeader
- 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 CloseRequest
- func (*CloseRequest) Descriptor() ([]byte, []int)
- func (m *CloseRequest) GetDelete() bool
- func (m *CloseRequest) GetHeader() *headers.RequestHeader
- func (m *CloseRequest) Marshal() (dAtA []byte, err error)
- func (m *CloseRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *CloseRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*CloseRequest) ProtoMessage()
- func (m *CloseRequest) Reset()
- func (m *CloseRequest) Size() (n int)
- func (m *CloseRequest) String() string
- func (m *CloseRequest) Unmarshal(dAtA []byte) error
- func (m *CloseRequest) XXX_DiscardUnknown()
- func (m *CloseRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CloseRequest) XXX_Merge(src proto.Message)
- func (m *CloseRequest) XXX_Size() int
- func (m *CloseRequest) XXX_Unmarshal(b []byte) error
- type CloseResponse
- func (*CloseResponse) Descriptor() ([]byte, []int)
- func (m *CloseResponse) GetHeader() *headers.ResponseHeader
- func (m *CloseResponse) Marshal() (dAtA []byte, err error)
- func (m *CloseResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *CloseResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*CloseResponse) ProtoMessage()
- func (m *CloseResponse) Reset()
- func (m *CloseResponse) Size() (n int)
- func (m *CloseResponse) String() string
- func (m *CloseResponse) Unmarshal(dAtA []byte) error
- func (m *CloseResponse) XXX_DiscardUnknown()
- func (m *CloseResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CloseResponse) XXX_Merge(src proto.Message)
- func (m *CloseResponse) XXX_Size() int
- func (m *CloseResponse) XXX_Unmarshal(b []byte) error
- type CreateRequest
- func (*CreateRequest) Descriptor() ([]byte, []int)
- func (m *CreateRequest) GetHeader() *headers.RequestHeader
- func (m *CreateRequest) Marshal() (dAtA []byte, err error)
- func (m *CreateRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *CreateRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*CreateRequest) ProtoMessage()
- func (m *CreateRequest) Reset()
- func (m *CreateRequest) Size() (n int)
- func (m *CreateRequest) String() string
- func (m *CreateRequest) Unmarshal(dAtA []byte) error
- func (m *CreateRequest) XXX_DiscardUnknown()
- func (m *CreateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CreateRequest) XXX_Merge(src proto.Message)
- func (m *CreateRequest) XXX_Size() int
- func (m *CreateRequest) XXX_Unmarshal(b []byte) error
- type CreateResponse
- func (*CreateResponse) Descriptor() ([]byte, []int)
- func (m *CreateResponse) GetHeader() *headers.ResponseHeader
- func (m *CreateResponse) Marshal() (dAtA []byte, err error)
- func (m *CreateResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *CreateResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*CreateResponse) ProtoMessage()
- func (m *CreateResponse) Reset()
- func (m *CreateResponse) Size() (n int)
- func (m *CreateResponse) String() string
- func (m *CreateResponse) Unmarshal(dAtA []byte) error
- func (m *CreateResponse) XXX_DiscardUnknown()
- func (m *CreateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CreateResponse) XXX_Merge(src proto.Message)
- func (m *CreateResponse) XXX_Size() int
- func (m *CreateResponse) XXX_Unmarshal(b []byte) error
- type EntriesRequest
- func (*EntriesRequest) Descriptor() ([]byte, []int)
- func (m *EntriesRequest) GetHeader() *headers.RequestHeader
- 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) GetHeader() *headers.ResponseHeader
- func (m *EntriesResponse) GetIndex() uint64
- func (m *EntriesResponse) GetTimestamp() time.Time
- func (m *EntriesResponse) GetValue() []byte
- 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 EventRequest
- func (*EventRequest) Descriptor() ([]byte, []int)
- func (m *EventRequest) GetHeader() *headers.RequestHeader
- func (m *EventRequest) GetIndex() uint64
- func (m *EventRequest) GetReplay() bool
- func (m *EventRequest) Marshal() (dAtA []byte, err error)
- func (m *EventRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *EventRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*EventRequest) ProtoMessage()
- func (m *EventRequest) Reset()
- func (m *EventRequest) Size() (n int)
- func (m *EventRequest) String() string
- func (m *EventRequest) Unmarshal(dAtA []byte) error
- func (m *EventRequest) XXX_DiscardUnknown()
- func (m *EventRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *EventRequest) XXX_Merge(src proto.Message)
- func (m *EventRequest) XXX_Size() int
- func (m *EventRequest) XXX_Unmarshal(b []byte) error
- type EventResponse
- func (*EventResponse) Descriptor() ([]byte, []int)
- func (m *EventResponse) GetHeader() *headers.ResponseHeader
- func (m *EventResponse) GetIndex() uint64
- func (m *EventResponse) GetTimestamp() time.Time
- func (m *EventResponse) GetType() EventResponse_Type
- func (m *EventResponse) GetValue() []byte
- func (m *EventResponse) Marshal() (dAtA []byte, err error)
- func (m *EventResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *EventResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*EventResponse) ProtoMessage()
- func (m *EventResponse) Reset()
- func (m *EventResponse) Size() (n int)
- func (m *EventResponse) String() string
- func (m *EventResponse) Unmarshal(dAtA []byte) error
- func (m *EventResponse) XXX_DiscardUnknown()
- func (m *EventResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *EventResponse) XXX_Merge(src proto.Message)
- func (m *EventResponse) XXX_Size() int
- func (m *EventResponse) XXX_Unmarshal(b []byte) error
- type EventResponse_Type
- type ExistsRequest
- func (*ExistsRequest) Descriptor() ([]byte, []int)
- func (m *ExistsRequest) GetHeader() *headers.RequestHeader
- func (m *ExistsRequest) GetIndex() uint64
- func (m *ExistsRequest) Marshal() (dAtA []byte, err error)
- func (m *ExistsRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *ExistsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ExistsRequest) ProtoMessage()
- func (m *ExistsRequest) Reset()
- func (m *ExistsRequest) Size() (n int)
- func (m *ExistsRequest) String() string
- func (m *ExistsRequest) Unmarshal(dAtA []byte) error
- func (m *ExistsRequest) XXX_DiscardUnknown()
- func (m *ExistsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ExistsRequest) XXX_Merge(src proto.Message)
- func (m *ExistsRequest) XXX_Size() int
- func (m *ExistsRequest) XXX_Unmarshal(b []byte) error
- type ExistsResponse
- func (*ExistsResponse) Descriptor() ([]byte, []int)
- func (m *ExistsResponse) GetContainsIndex() bool
- func (m *ExistsResponse) GetHeader() *headers.ResponseHeader
- func (m *ExistsResponse) Marshal() (dAtA []byte, err error)
- func (m *ExistsResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *ExistsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ExistsResponse) ProtoMessage()
- func (m *ExistsResponse) Reset()
- func (m *ExistsResponse) Size() (n int)
- func (m *ExistsResponse) String() string
- func (m *ExistsResponse) Unmarshal(dAtA []byte) error
- func (m *ExistsResponse) XXX_DiscardUnknown()
- func (m *ExistsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ExistsResponse) XXX_Merge(src proto.Message)
- func (m *ExistsResponse) XXX_Size() int
- func (m *ExistsResponse) XXX_Unmarshal(b []byte) error
- type FirstEntryRequest
- func (*FirstEntryRequest) Descriptor() ([]byte, []int)
- func (m *FirstEntryRequest) GetHeader() *headers.RequestHeader
- 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) GetHeader() *headers.ResponseHeader
- func (m *FirstEntryResponse) GetIndex() uint64
- func (m *FirstEntryResponse) GetTimestamp() time.Time
- func (m *FirstEntryResponse) GetValue() []byte
- 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) GetHeader() *headers.RequestHeader
- 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) GetHeader() *headers.ResponseHeader
- func (m *GetResponse) GetIndex() uint64
- func (m *GetResponse) GetTimestamp() time.Time
- func (m *GetResponse) GetValue() []byte
- 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) GetHeader() *headers.RequestHeader
- 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) GetHeader() *headers.ResponseHeader
- func (m *LastEntryResponse) GetIndex() uint64
- func (m *LastEntryResponse) GetTimestamp() time.Time
- func (m *LastEntryResponse) GetValue() []byte
- 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 LogServiceClient
- type LogServiceServer
- type LogService_EntriesClient
- type LogService_EntriesServer
- type LogService_EventsClient
- type LogService_EventsServer
- type NextEntryRequest
- func (*NextEntryRequest) Descriptor() ([]byte, []int)
- func (m *NextEntryRequest) GetHeader() *headers.RequestHeader
- 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) GetHeader() *headers.ResponseHeader
- func (m *NextEntryResponse) GetIndex() uint64
- func (m *NextEntryResponse) GetTimestamp() time.Time
- func (m *NextEntryResponse) GetValue() []byte
- 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 PrevEntryRequest
- func (*PrevEntryRequest) Descriptor() ([]byte, []int)
- func (m *PrevEntryRequest) GetHeader() *headers.RequestHeader
- 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) GetHeader() *headers.ResponseHeader
- func (m *PrevEntryResponse) GetIndex() uint64
- func (m *PrevEntryResponse) GetTimestamp() time.Time
- func (m *PrevEntryResponse) GetValue() []byte
- 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) GetHeader() *headers.RequestHeader
- func (m *RemoveRequest) GetIndex() uint64
- func (m *RemoveRequest) GetTimestamp() time.Time
- func (m *RemoveRequest) GetValue() []byte
- 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) GetHeader() *headers.ResponseHeader
- func (m *RemoveResponse) GetIndex() uint64
- func (m *RemoveResponse) GetPreviousValue() []byte
- func (m *RemoveResponse) GetStatus() ResponseStatus
- 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 ResponseStatus
- type SizeRequest
- func (*SizeRequest) Descriptor() ([]byte, []int)
- func (m *SizeRequest) GetHeader() *headers.RequestHeader
- 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) GetHeader() *headers.ResponseHeader
- 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 UnimplementedLogServiceServer
- func (*UnimplementedLogServiceServer) Append(ctx context.Context, req *AppendRequest) (*AppendResponse, error)
- func (*UnimplementedLogServiceServer) Clear(ctx context.Context, req *ClearRequest) (*ClearResponse, error)
- func (*UnimplementedLogServiceServer) Close(ctx context.Context, req *CloseRequest) (*CloseResponse, error)
- func (*UnimplementedLogServiceServer) Create(ctx context.Context, req *CreateRequest) (*CreateResponse, error)
- func (*UnimplementedLogServiceServer) Entries(req *EntriesRequest, srv LogService_EntriesServer) error
- func (*UnimplementedLogServiceServer) Events(req *EventRequest, srv LogService_EventsServer) error
- func (*UnimplementedLogServiceServer) Exists(ctx context.Context, req *ExistsRequest) (*ExistsResponse, error)
- func (*UnimplementedLogServiceServer) FirstEntry(ctx context.Context, req *FirstEntryRequest) (*FirstEntryResponse, error)
- func (*UnimplementedLogServiceServer) Get(ctx context.Context, req *GetRequest) (*GetResponse, error)
- func (*UnimplementedLogServiceServer) LastEntry(ctx context.Context, req *LastEntryRequest) (*LastEntryResponse, error)
- func (*UnimplementedLogServiceServer) NextEntry(ctx context.Context, req *NextEntryRequest) (*NextEntryResponse, error)
- func (*UnimplementedLogServiceServer) PrevEntry(ctx context.Context, req *PrevEntryRequest) (*PrevEntryResponse, error)
- func (*UnimplementedLogServiceServer) Remove(ctx context.Context, req *RemoveRequest) (*RemoveResponse, error)
- func (*UnimplementedLogServiceServer) Size(ctx context.Context, req *SizeRequest) (*SizeResponse, error)
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrInvalidLengthLog = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowLog = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupLog = fmt.Errorf("proto: unexpected end of group") )
View Source
var EventResponse_Type_name = map[int32]string{
0: "NONE",
1: "APPENDED",
2: "REMOVED",
}
View Source
var EventResponse_Type_value = map[string]int32{
"NONE": 0,
"APPENDED": 1,
"REMOVED": 2,
}
View Source
var ResponseStatus_name = map[int32]string{
0: "OK",
1: "NOOP",
2: "WRITE_LOCK",
3: "PRECONDITION_FAILED",
}
View Source
var ResponseStatus_value = map[string]int32{
"OK": 0,
"NOOP": 1,
"WRITE_LOCK": 2,
"PRECONDITION_FAILED": 3,
}
Functions ¶
func RegisterLogServiceServer ¶
func RegisterLogServiceServer(s *grpc.Server, srv LogServiceServer)
Types ¶
type AppendRequest ¶
type AppendRequest struct { Header *headers.RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` 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) GetHeader ¶
func (m *AppendRequest) GetHeader() *headers.RequestHeader
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 { Header *headers.ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` Status ResponseStatus `protobuf:"varint,2,opt,name=status,proto3,enum=atomix.log.ResponseStatus" json:"status,omitempty"` Index uint64 `protobuf:"varint,3,opt,name=index,proto3" json:"index,omitempty"` Timestamp time.Time `protobuf:"bytes,4,opt,name=timestamp,proto3,stdtime" json:"timestamp"` }
func (*AppendResponse) Descriptor ¶
func (*AppendResponse) Descriptor() ([]byte, []int)
func (*AppendResponse) GetHeader ¶
func (m *AppendResponse) GetHeader() *headers.ResponseHeader
func (*AppendResponse) GetIndex ¶
func (m *AppendResponse) GetIndex() uint64
func (*AppendResponse) GetStatus ¶
func (m *AppendResponse) GetStatus() ResponseStatus
func (*AppendResponse) GetTimestamp ¶
func (m *AppendResponse) GetTimestamp() time.Time
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 {
Header *headers.RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
}
func (*ClearRequest) Descriptor ¶
func (*ClearRequest) Descriptor() ([]byte, []int)
func (*ClearRequest) GetHeader ¶
func (m *ClearRequest) GetHeader() *headers.RequestHeader
func (*ClearRequest) Marshal ¶
func (m *ClearRequest) Marshal() (dAtA []byte, err error)
func (*ClearRequest) MarshalToSizedBuffer ¶
func (m *ClearRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ClearRequest) ProtoMessage ¶
func (*ClearRequest) ProtoMessage()
func (*ClearRequest) Reset ¶
func (m *ClearRequest) Reset()
func (*ClearRequest) Size ¶
func (m *ClearRequest) Size() (n int)
func (*ClearRequest) String ¶
func (m *ClearRequest) String() string
func (*ClearRequest) Unmarshal ¶
func (m *ClearRequest) Unmarshal(dAtA []byte) error
func (*ClearRequest) XXX_DiscardUnknown ¶
func (m *ClearRequest) XXX_DiscardUnknown()
func (*ClearRequest) XXX_Marshal ¶
func (m *ClearRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ClearRequest) XXX_Merge ¶
func (m *ClearRequest) XXX_Merge(src proto.Message)
func (*ClearRequest) XXX_Size ¶
func (m *ClearRequest) XXX_Size() int
func (*ClearRequest) XXX_Unmarshal ¶
func (m *ClearRequest) XXX_Unmarshal(b []byte) error
type ClearResponse ¶
type ClearResponse struct {
Header *headers.ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
}
func (*ClearResponse) Descriptor ¶
func (*ClearResponse) Descriptor() ([]byte, []int)
func (*ClearResponse) GetHeader ¶
func (m *ClearResponse) GetHeader() *headers.ResponseHeader
func (*ClearResponse) Marshal ¶
func (m *ClearResponse) Marshal() (dAtA []byte, err error)
func (*ClearResponse) MarshalToSizedBuffer ¶
func (m *ClearResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ClearResponse) ProtoMessage ¶
func (*ClearResponse) ProtoMessage()
func (*ClearResponse) Reset ¶
func (m *ClearResponse) Reset()
func (*ClearResponse) Size ¶
func (m *ClearResponse) Size() (n int)
func (*ClearResponse) String ¶
func (m *ClearResponse) String() string
func (*ClearResponse) Unmarshal ¶
func (m *ClearResponse) Unmarshal(dAtA []byte) error
func (*ClearResponse) XXX_DiscardUnknown ¶
func (m *ClearResponse) XXX_DiscardUnknown()
func (*ClearResponse) XXX_Marshal ¶
func (m *ClearResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ClearResponse) XXX_Merge ¶
func (m *ClearResponse) XXX_Merge(src proto.Message)
func (*ClearResponse) XXX_Size ¶
func (m *ClearResponse) XXX_Size() int
func (*ClearResponse) XXX_Unmarshal ¶
func (m *ClearResponse) XXX_Unmarshal(b []byte) error
type CloseRequest ¶
type CloseRequest struct { Header *headers.RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` Delete bool `protobuf:"varint,2,opt,name=delete,proto3" json:"delete,omitempty"` }
func (*CloseRequest) Descriptor ¶
func (*CloseRequest) Descriptor() ([]byte, []int)
func (*CloseRequest) GetDelete ¶
func (m *CloseRequest) GetDelete() bool
func (*CloseRequest) GetHeader ¶
func (m *CloseRequest) GetHeader() *headers.RequestHeader
func (*CloseRequest) Marshal ¶
func (m *CloseRequest) Marshal() (dAtA []byte, err error)
func (*CloseRequest) MarshalToSizedBuffer ¶
func (m *CloseRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*CloseRequest) ProtoMessage ¶
func (*CloseRequest) ProtoMessage()
func (*CloseRequest) Reset ¶
func (m *CloseRequest) Reset()
func (*CloseRequest) Size ¶
func (m *CloseRequest) Size() (n int)
func (*CloseRequest) String ¶
func (m *CloseRequest) String() string
func (*CloseRequest) Unmarshal ¶
func (m *CloseRequest) Unmarshal(dAtA []byte) error
func (*CloseRequest) XXX_DiscardUnknown ¶
func (m *CloseRequest) XXX_DiscardUnknown()
func (*CloseRequest) XXX_Marshal ¶
func (m *CloseRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CloseRequest) XXX_Merge ¶
func (m *CloseRequest) XXX_Merge(src proto.Message)
func (*CloseRequest) XXX_Size ¶
func (m *CloseRequest) XXX_Size() int
func (*CloseRequest) XXX_Unmarshal ¶
func (m *CloseRequest) XXX_Unmarshal(b []byte) error
type CloseResponse ¶
type CloseResponse struct {
Header *headers.ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
}
func (*CloseResponse) Descriptor ¶
func (*CloseResponse) Descriptor() ([]byte, []int)
func (*CloseResponse) GetHeader ¶
func (m *CloseResponse) GetHeader() *headers.ResponseHeader
func (*CloseResponse) Marshal ¶
func (m *CloseResponse) Marshal() (dAtA []byte, err error)
func (*CloseResponse) MarshalToSizedBuffer ¶
func (m *CloseResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*CloseResponse) ProtoMessage ¶
func (*CloseResponse) ProtoMessage()
func (*CloseResponse) Reset ¶
func (m *CloseResponse) Reset()
func (*CloseResponse) Size ¶
func (m *CloseResponse) Size() (n int)
func (*CloseResponse) String ¶
func (m *CloseResponse) String() string
func (*CloseResponse) Unmarshal ¶
func (m *CloseResponse) Unmarshal(dAtA []byte) error
func (*CloseResponse) XXX_DiscardUnknown ¶
func (m *CloseResponse) XXX_DiscardUnknown()
func (*CloseResponse) XXX_Marshal ¶
func (m *CloseResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CloseResponse) XXX_Merge ¶
func (m *CloseResponse) XXX_Merge(src proto.Message)
func (*CloseResponse) XXX_Size ¶
func (m *CloseResponse) XXX_Size() int
func (*CloseResponse) XXX_Unmarshal ¶
func (m *CloseResponse) XXX_Unmarshal(b []byte) error
type CreateRequest ¶
type CreateRequest struct {
Header *headers.RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
}
func (*CreateRequest) Descriptor ¶
func (*CreateRequest) Descriptor() ([]byte, []int)
func (*CreateRequest) GetHeader ¶
func (m *CreateRequest) GetHeader() *headers.RequestHeader
func (*CreateRequest) Marshal ¶
func (m *CreateRequest) Marshal() (dAtA []byte, err error)
func (*CreateRequest) MarshalToSizedBuffer ¶
func (m *CreateRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*CreateRequest) ProtoMessage ¶
func (*CreateRequest) ProtoMessage()
func (*CreateRequest) Reset ¶
func (m *CreateRequest) Reset()
func (*CreateRequest) Size ¶
func (m *CreateRequest) Size() (n int)
func (*CreateRequest) String ¶
func (m *CreateRequest) String() string
func (*CreateRequest) Unmarshal ¶
func (m *CreateRequest) Unmarshal(dAtA []byte) error
func (*CreateRequest) XXX_DiscardUnknown ¶
func (m *CreateRequest) XXX_DiscardUnknown()
func (*CreateRequest) XXX_Marshal ¶
func (m *CreateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CreateRequest) XXX_Merge ¶
func (m *CreateRequest) XXX_Merge(src proto.Message)
func (*CreateRequest) XXX_Size ¶
func (m *CreateRequest) XXX_Size() int
func (*CreateRequest) XXX_Unmarshal ¶
func (m *CreateRequest) XXX_Unmarshal(b []byte) error
type CreateResponse ¶
type CreateResponse struct {
Header *headers.ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
}
func (*CreateResponse) Descriptor ¶
func (*CreateResponse) Descriptor() ([]byte, []int)
func (*CreateResponse) GetHeader ¶
func (m *CreateResponse) GetHeader() *headers.ResponseHeader
func (*CreateResponse) Marshal ¶
func (m *CreateResponse) Marshal() (dAtA []byte, err error)
func (*CreateResponse) MarshalToSizedBuffer ¶
func (m *CreateResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*CreateResponse) ProtoMessage ¶
func (*CreateResponse) ProtoMessage()
func (*CreateResponse) Reset ¶
func (m *CreateResponse) Reset()
func (*CreateResponse) Size ¶
func (m *CreateResponse) Size() (n int)
func (*CreateResponse) String ¶
func (m *CreateResponse) String() string
func (*CreateResponse) Unmarshal ¶
func (m *CreateResponse) Unmarshal(dAtA []byte) error
func (*CreateResponse) XXX_DiscardUnknown ¶
func (m *CreateResponse) XXX_DiscardUnknown()
func (*CreateResponse) XXX_Marshal ¶
func (m *CreateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CreateResponse) XXX_Merge ¶
func (m *CreateResponse) XXX_Merge(src proto.Message)
func (*CreateResponse) XXX_Size ¶
func (m *CreateResponse) XXX_Size() int
func (*CreateResponse) XXX_Unmarshal ¶
func (m *CreateResponse) XXX_Unmarshal(b []byte) error
type EntriesRequest ¶
type EntriesRequest struct {
Header *headers.RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
}
func (*EntriesRequest) Descriptor ¶
func (*EntriesRequest) Descriptor() ([]byte, []int)
func (*EntriesRequest) GetHeader ¶
func (m *EntriesRequest) GetHeader() *headers.RequestHeader
func (*EntriesRequest) Marshal ¶
func (m *EntriesRequest) Marshal() (dAtA []byte, err error)
func (*EntriesRequest) MarshalToSizedBuffer ¶
func (m *EntriesRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*EntriesRequest) ProtoMessage ¶
func (*EntriesRequest) ProtoMessage()
func (*EntriesRequest) Reset ¶
func (m *EntriesRequest) Reset()
func (*EntriesRequest) Size ¶
func (m *EntriesRequest) Size() (n int)
func (*EntriesRequest) String ¶
func (m *EntriesRequest) String() string
func (*EntriesRequest) Unmarshal ¶
func (m *EntriesRequest) Unmarshal(dAtA []byte) error
func (*EntriesRequest) XXX_DiscardUnknown ¶
func (m *EntriesRequest) XXX_DiscardUnknown()
func (*EntriesRequest) XXX_Marshal ¶
func (m *EntriesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*EntriesRequest) XXX_Merge ¶
func (m *EntriesRequest) XXX_Merge(src proto.Message)
func (*EntriesRequest) XXX_Size ¶
func (m *EntriesRequest) XXX_Size() int
func (*EntriesRequest) XXX_Unmarshal ¶
func (m *EntriesRequest) XXX_Unmarshal(b []byte) error
type EntriesResponse ¶
type EntriesResponse struct { Header *headers.ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` Index uint64 `protobuf:"varint,2,opt,name=index,proto3" json:"index,omitempty"` Value []byte `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"` Timestamp time.Time `protobuf:"bytes,4,opt,name=timestamp,proto3,stdtime" json:"timestamp"` }
func (*EntriesResponse) Descriptor ¶
func (*EntriesResponse) Descriptor() ([]byte, []int)
func (*EntriesResponse) GetHeader ¶
func (m *EntriesResponse) GetHeader() *headers.ResponseHeader
func (*EntriesResponse) GetIndex ¶
func (m *EntriesResponse) GetIndex() uint64
func (*EntriesResponse) GetTimestamp ¶
func (m *EntriesResponse) GetTimestamp() time.Time
func (*EntriesResponse) GetValue ¶
func (m *EntriesResponse) GetValue() []byte
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 EventRequest ¶
type EventRequest struct { Header *headers.RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` Replay bool `protobuf:"varint,2,opt,name=replay,proto3" json:"replay,omitempty"` Index uint64 `protobuf:"varint,3,opt,name=index,proto3" json:"index,omitempty"` }
func (*EventRequest) Descriptor ¶
func (*EventRequest) Descriptor() ([]byte, []int)
func (*EventRequest) GetHeader ¶
func (m *EventRequest) GetHeader() *headers.RequestHeader
func (*EventRequest) GetIndex ¶
func (m *EventRequest) GetIndex() uint64
func (*EventRequest) GetReplay ¶
func (m *EventRequest) GetReplay() bool
func (*EventRequest) Marshal ¶
func (m *EventRequest) Marshal() (dAtA []byte, err error)
func (*EventRequest) MarshalToSizedBuffer ¶
func (m *EventRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*EventRequest) ProtoMessage ¶
func (*EventRequest) ProtoMessage()
func (*EventRequest) Reset ¶
func (m *EventRequest) Reset()
func (*EventRequest) Size ¶
func (m *EventRequest) Size() (n int)
func (*EventRequest) String ¶
func (m *EventRequest) String() string
func (*EventRequest) Unmarshal ¶
func (m *EventRequest) Unmarshal(dAtA []byte) error
func (*EventRequest) XXX_DiscardUnknown ¶
func (m *EventRequest) XXX_DiscardUnknown()
func (*EventRequest) XXX_Marshal ¶
func (m *EventRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*EventRequest) XXX_Merge ¶
func (m *EventRequest) XXX_Merge(src proto.Message)
func (*EventRequest) XXX_Size ¶
func (m *EventRequest) XXX_Size() int
func (*EventRequest) XXX_Unmarshal ¶
func (m *EventRequest) XXX_Unmarshal(b []byte) error
type EventResponse ¶
type EventResponse struct { Header *headers.ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` Type EventResponse_Type `protobuf:"varint,2,opt,name=type,proto3,enum=atomix.log.EventResponse_Type" json:"type,omitempty"` Index uint64 `protobuf:"varint,3,opt,name=index,proto3" json:"index,omitempty"` Value []byte `protobuf:"bytes,4,opt,name=value,proto3" json:"value,omitempty"` Timestamp time.Time `protobuf:"bytes,5,opt,name=timestamp,proto3,stdtime" json:"timestamp"` }
func (*EventResponse) Descriptor ¶
func (*EventResponse) Descriptor() ([]byte, []int)
func (*EventResponse) GetHeader ¶
func (m *EventResponse) GetHeader() *headers.ResponseHeader
func (*EventResponse) GetIndex ¶
func (m *EventResponse) GetIndex() uint64
func (*EventResponse) GetTimestamp ¶
func (m *EventResponse) GetTimestamp() time.Time
func (*EventResponse) GetType ¶
func (m *EventResponse) GetType() EventResponse_Type
func (*EventResponse) GetValue ¶
func (m *EventResponse) GetValue() []byte
func (*EventResponse) Marshal ¶
func (m *EventResponse) Marshal() (dAtA []byte, err error)
func (*EventResponse) MarshalToSizedBuffer ¶
func (m *EventResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*EventResponse) ProtoMessage ¶
func (*EventResponse) ProtoMessage()
func (*EventResponse) Reset ¶
func (m *EventResponse) Reset()
func (*EventResponse) Size ¶
func (m *EventResponse) Size() (n int)
func (*EventResponse) String ¶
func (m *EventResponse) String() string
func (*EventResponse) Unmarshal ¶
func (m *EventResponse) Unmarshal(dAtA []byte) error
func (*EventResponse) XXX_DiscardUnknown ¶
func (m *EventResponse) XXX_DiscardUnknown()
func (*EventResponse) XXX_Marshal ¶
func (m *EventResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*EventResponse) XXX_Merge ¶
func (m *EventResponse) XXX_Merge(src proto.Message)
func (*EventResponse) XXX_Size ¶
func (m *EventResponse) XXX_Size() int
func (*EventResponse) XXX_Unmarshal ¶
func (m *EventResponse) XXX_Unmarshal(b []byte) error
type EventResponse_Type ¶
type EventResponse_Type int32
const ( EventResponse_NONE EventResponse_Type = 0 EventResponse_APPENDED EventResponse_Type = 1 EventResponse_REMOVED EventResponse_Type = 2 )
func (EventResponse_Type) EnumDescriptor ¶
func (EventResponse_Type) EnumDescriptor() ([]byte, []int)
func (EventResponse_Type) String ¶
func (x EventResponse_Type) String() string
type ExistsRequest ¶
type ExistsRequest struct { Header *headers.RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` Index uint64 `protobuf:"varint,2,opt,name=index,proto3" json:"index,omitempty"` }
func (*ExistsRequest) Descriptor ¶
func (*ExistsRequest) Descriptor() ([]byte, []int)
func (*ExistsRequest) GetHeader ¶
func (m *ExistsRequest) GetHeader() *headers.RequestHeader
func (*ExistsRequest) GetIndex ¶
func (m *ExistsRequest) GetIndex() uint64
func (*ExistsRequest) Marshal ¶
func (m *ExistsRequest) Marshal() (dAtA []byte, err error)
func (*ExistsRequest) MarshalToSizedBuffer ¶
func (m *ExistsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ExistsRequest) ProtoMessage ¶
func (*ExistsRequest) ProtoMessage()
func (*ExistsRequest) Reset ¶
func (m *ExistsRequest) Reset()
func (*ExistsRequest) Size ¶
func (m *ExistsRequest) Size() (n int)
func (*ExistsRequest) String ¶
func (m *ExistsRequest) String() string
func (*ExistsRequest) Unmarshal ¶
func (m *ExistsRequest) Unmarshal(dAtA []byte) error
func (*ExistsRequest) XXX_DiscardUnknown ¶
func (m *ExistsRequest) XXX_DiscardUnknown()
func (*ExistsRequest) XXX_Marshal ¶
func (m *ExistsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ExistsRequest) XXX_Merge ¶
func (m *ExistsRequest) XXX_Merge(src proto.Message)
func (*ExistsRequest) XXX_Size ¶
func (m *ExistsRequest) XXX_Size() int
func (*ExistsRequest) XXX_Unmarshal ¶
func (m *ExistsRequest) XXX_Unmarshal(b []byte) error
type ExistsResponse ¶
type ExistsResponse struct { Header *headers.ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` ContainsIndex bool `protobuf:"varint,2,opt,name=contains_index,json=containsIndex,proto3" json:"contains_index,omitempty"` }
func (*ExistsResponse) Descriptor ¶
func (*ExistsResponse) Descriptor() ([]byte, []int)
func (*ExistsResponse) GetContainsIndex ¶
func (m *ExistsResponse) GetContainsIndex() bool
func (*ExistsResponse) GetHeader ¶
func (m *ExistsResponse) GetHeader() *headers.ResponseHeader
func (*ExistsResponse) Marshal ¶
func (m *ExistsResponse) Marshal() (dAtA []byte, err error)
func (*ExistsResponse) MarshalToSizedBuffer ¶
func (m *ExistsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ExistsResponse) ProtoMessage ¶
func (*ExistsResponse) ProtoMessage()
func (*ExistsResponse) Reset ¶
func (m *ExistsResponse) Reset()
func (*ExistsResponse) Size ¶
func (m *ExistsResponse) Size() (n int)
func (*ExistsResponse) String ¶
func (m *ExistsResponse) String() string
func (*ExistsResponse) Unmarshal ¶
func (m *ExistsResponse) Unmarshal(dAtA []byte) error
func (*ExistsResponse) XXX_DiscardUnknown ¶
func (m *ExistsResponse) XXX_DiscardUnknown()
func (*ExistsResponse) XXX_Marshal ¶
func (m *ExistsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ExistsResponse) XXX_Merge ¶
func (m *ExistsResponse) XXX_Merge(src proto.Message)
func (*ExistsResponse) XXX_Size ¶
func (m *ExistsResponse) XXX_Size() int
func (*ExistsResponse) XXX_Unmarshal ¶
func (m *ExistsResponse) XXX_Unmarshal(b []byte) error
type FirstEntryRequest ¶
type FirstEntryRequest struct {
Header *headers.RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
}
func (*FirstEntryRequest) Descriptor ¶
func (*FirstEntryRequest) Descriptor() ([]byte, []int)
func (*FirstEntryRequest) GetHeader ¶
func (m *FirstEntryRequest) GetHeader() *headers.RequestHeader
func (*FirstEntryRequest) Marshal ¶
func (m *FirstEntryRequest) Marshal() (dAtA []byte, err error)
func (*FirstEntryRequest) MarshalTo ¶
func (m *FirstEntryRequest) MarshalTo(dAtA []byte) (int, error)
func (*FirstEntryRequest) MarshalToSizedBuffer ¶
func (m *FirstEntryRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*FirstEntryRequest) ProtoMessage ¶
func (*FirstEntryRequest) ProtoMessage()
func (*FirstEntryRequest) Reset ¶
func (m *FirstEntryRequest) Reset()
func (*FirstEntryRequest) Size ¶
func (m *FirstEntryRequest) Size() (n int)
func (*FirstEntryRequest) String ¶
func (m *FirstEntryRequest) String() string
func (*FirstEntryRequest) Unmarshal ¶
func (m *FirstEntryRequest) Unmarshal(dAtA []byte) error
func (*FirstEntryRequest) XXX_DiscardUnknown ¶
func (m *FirstEntryRequest) XXX_DiscardUnknown()
func (*FirstEntryRequest) XXX_Marshal ¶
func (m *FirstEntryRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*FirstEntryRequest) XXX_Merge ¶
func (m *FirstEntryRequest) XXX_Merge(src proto.Message)
func (*FirstEntryRequest) XXX_Size ¶
func (m *FirstEntryRequest) XXX_Size() int
func (*FirstEntryRequest) XXX_Unmarshal ¶
func (m *FirstEntryRequest) XXX_Unmarshal(b []byte) error
type FirstEntryResponse ¶
type FirstEntryResponse struct { Header *headers.ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` Index uint64 `protobuf:"varint,2,opt,name=index,proto3" json:"index,omitempty"` Value []byte `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"` Timestamp time.Time `protobuf:"bytes,4,opt,name=timestamp,proto3,stdtime" json:"timestamp"` }
func (*FirstEntryResponse) Descriptor ¶
func (*FirstEntryResponse) Descriptor() ([]byte, []int)
func (*FirstEntryResponse) GetHeader ¶
func (m *FirstEntryResponse) GetHeader() *headers.ResponseHeader
func (*FirstEntryResponse) GetIndex ¶
func (m *FirstEntryResponse) GetIndex() uint64
func (*FirstEntryResponse) GetTimestamp ¶
func (m *FirstEntryResponse) GetTimestamp() time.Time
func (*FirstEntryResponse) GetValue ¶
func (m *FirstEntryResponse) GetValue() []byte
func (*FirstEntryResponse) Marshal ¶
func (m *FirstEntryResponse) Marshal() (dAtA []byte, err error)
func (*FirstEntryResponse) MarshalTo ¶
func (m *FirstEntryResponse) MarshalTo(dAtA []byte) (int, error)
func (*FirstEntryResponse) MarshalToSizedBuffer ¶
func (m *FirstEntryResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*FirstEntryResponse) ProtoMessage ¶
func (*FirstEntryResponse) ProtoMessage()
func (*FirstEntryResponse) Reset ¶
func (m *FirstEntryResponse) Reset()
func (*FirstEntryResponse) Size ¶
func (m *FirstEntryResponse) Size() (n int)
func (*FirstEntryResponse) String ¶
func (m *FirstEntryResponse) String() string
func (*FirstEntryResponse) Unmarshal ¶
func (m *FirstEntryResponse) Unmarshal(dAtA []byte) error
func (*FirstEntryResponse) XXX_DiscardUnknown ¶
func (m *FirstEntryResponse) XXX_DiscardUnknown()
func (*FirstEntryResponse) XXX_Marshal ¶
func (m *FirstEntryResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*FirstEntryResponse) XXX_Merge ¶
func (m *FirstEntryResponse) XXX_Merge(src proto.Message)
func (*FirstEntryResponse) XXX_Size ¶
func (m *FirstEntryResponse) XXX_Size() int
func (*FirstEntryResponse) XXX_Unmarshal ¶
func (m *FirstEntryResponse) XXX_Unmarshal(b []byte) error
type GetRequest ¶
type GetRequest struct { Header *headers.RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` Index uint64 `protobuf:"varint,2,opt,name=index,proto3" json:"index,omitempty"` }
func (*GetRequest) Descriptor ¶
func (*GetRequest) Descriptor() ([]byte, []int)
func (*GetRequest) GetHeader ¶
func (m *GetRequest) GetHeader() *headers.RequestHeader
func (*GetRequest) GetIndex ¶
func (m *GetRequest) GetIndex() 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 { Header *headers.ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` Index uint64 `protobuf:"varint,2,opt,name=index,proto3" json:"index,omitempty"` Value []byte `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"` Timestamp time.Time `protobuf:"bytes,5,opt,name=timestamp,proto3,stdtime" json:"timestamp"` }
func (*GetResponse) Descriptor ¶
func (*GetResponse) Descriptor() ([]byte, []int)
func (*GetResponse) GetHeader ¶
func (m *GetResponse) GetHeader() *headers.ResponseHeader
func (*GetResponse) GetIndex ¶
func (m *GetResponse) GetIndex() uint64
func (*GetResponse) GetTimestamp ¶
func (m *GetResponse) GetTimestamp() time.Time
func (*GetResponse) GetValue ¶
func (m *GetResponse) GetValue() []byte
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 {
Header *headers.RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
}
func (*LastEntryRequest) Descriptor ¶
func (*LastEntryRequest) Descriptor() ([]byte, []int)
func (*LastEntryRequest) GetHeader ¶
func (m *LastEntryRequest) GetHeader() *headers.RequestHeader
func (*LastEntryRequest) Marshal ¶
func (m *LastEntryRequest) Marshal() (dAtA []byte, err error)
func (*LastEntryRequest) MarshalToSizedBuffer ¶
func (m *LastEntryRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*LastEntryRequest) ProtoMessage ¶
func (*LastEntryRequest) ProtoMessage()
func (*LastEntryRequest) Reset ¶
func (m *LastEntryRequest) Reset()
func (*LastEntryRequest) Size ¶
func (m *LastEntryRequest) Size() (n int)
func (*LastEntryRequest) String ¶
func (m *LastEntryRequest) String() string
func (*LastEntryRequest) Unmarshal ¶
func (m *LastEntryRequest) Unmarshal(dAtA []byte) error
func (*LastEntryRequest) XXX_DiscardUnknown ¶
func (m *LastEntryRequest) XXX_DiscardUnknown()
func (*LastEntryRequest) XXX_Marshal ¶
func (m *LastEntryRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*LastEntryRequest) XXX_Merge ¶
func (m *LastEntryRequest) XXX_Merge(src proto.Message)
func (*LastEntryRequest) XXX_Size ¶
func (m *LastEntryRequest) XXX_Size() int
func (*LastEntryRequest) XXX_Unmarshal ¶
func (m *LastEntryRequest) XXX_Unmarshal(b []byte) error
type LastEntryResponse ¶
type LastEntryResponse struct { Header *headers.ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` Index uint64 `protobuf:"varint,2,opt,name=index,proto3" json:"index,omitempty"` Value []byte `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"` Timestamp time.Time `protobuf:"bytes,4,opt,name=timestamp,proto3,stdtime" json:"timestamp"` }
func (*LastEntryResponse) Descriptor ¶
func (*LastEntryResponse) Descriptor() ([]byte, []int)
func (*LastEntryResponse) GetHeader ¶
func (m *LastEntryResponse) GetHeader() *headers.ResponseHeader
func (*LastEntryResponse) GetIndex ¶
func (m *LastEntryResponse) GetIndex() uint64
func (*LastEntryResponse) GetTimestamp ¶
func (m *LastEntryResponse) GetTimestamp() time.Time
func (*LastEntryResponse) GetValue ¶
func (m *LastEntryResponse) GetValue() []byte
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 LogServiceClient ¶
type LogServiceClient interface { // Create creates a log Create(ctx context.Context, in *CreateRequest, opts ...grpc.CallOption) (*CreateResponse, error) // Close closes a log Close(ctx context.Context, in *CloseRequest, opts ...grpc.CallOption) (*CloseResponse, error) // Size returns the size of the log Size(ctx context.Context, in *SizeRequest, opts ...grpc.CallOption) (*SizeResponse, error) // Exists checks whether an index exists in the log Exists(ctx context.Context, in *ExistsRequest, opts ...grpc.CallOption) (*ExistsResponse, 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 *EventRequest, opts ...grpc.CallOption) (LogService_EventsClient, error) // Entries lists all entries in the log Entries(ctx context.Context, in *EntriesRequest, opts ...grpc.CallOption) (LogService_EntriesClient, error) }
LogServiceClient is the client API for LogService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewLogServiceClient ¶
func NewLogServiceClient(cc *grpc.ClientConn) LogServiceClient
type LogServiceServer ¶
type LogServiceServer interface { // Create creates a log Create(context.Context, *CreateRequest) (*CreateResponse, error) // Close closes a log Close(context.Context, *CloseRequest) (*CloseResponse, error) // Size returns the size of the log Size(context.Context, *SizeRequest) (*SizeResponse, error) // Exists checks whether an index exists in the log Exists(context.Context, *ExistsRequest) (*ExistsResponse, 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(*EventRequest, LogService_EventsServer) error // Entries lists all entries in the log Entries(*EntriesRequest, LogService_EntriesServer) error }
LogServiceServer is the server API for LogService service.
type LogService_EntriesClient ¶
type LogService_EntriesClient interface { Recv() (*EntriesResponse, error) grpc.ClientStream }
type LogService_EntriesServer ¶
type LogService_EntriesServer interface { Send(*EntriesResponse) error grpc.ServerStream }
type LogService_EventsClient ¶
type LogService_EventsClient interface { Recv() (*EventResponse, error) grpc.ClientStream }
type LogService_EventsServer ¶
type LogService_EventsServer interface { Send(*EventResponse) error grpc.ServerStream }
type NextEntryRequest ¶
type NextEntryRequest struct { Header *headers.RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` Index uint64 `protobuf:"varint,2,opt,name=index,proto3" json:"index,omitempty"` }
func (*NextEntryRequest) Descriptor ¶
func (*NextEntryRequest) Descriptor() ([]byte, []int)
func (*NextEntryRequest) GetHeader ¶
func (m *NextEntryRequest) GetHeader() *headers.RequestHeader
func (*NextEntryRequest) GetIndex ¶
func (m *NextEntryRequest) GetIndex() 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 { Header *headers.ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` Index uint64 `protobuf:"varint,2,opt,name=index,proto3" json:"index,omitempty"` Value []byte `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"` Timestamp time.Time `protobuf:"bytes,4,opt,name=timestamp,proto3,stdtime" json:"timestamp"` }
func (*NextEntryResponse) Descriptor ¶
func (*NextEntryResponse) Descriptor() ([]byte, []int)
func (*NextEntryResponse) GetHeader ¶
func (m *NextEntryResponse) GetHeader() *headers.ResponseHeader
func (*NextEntryResponse) GetIndex ¶
func (m *NextEntryResponse) GetIndex() uint64
func (*NextEntryResponse) GetTimestamp ¶
func (m *NextEntryResponse) GetTimestamp() time.Time
func (*NextEntryResponse) GetValue ¶
func (m *NextEntryResponse) GetValue() []byte
func (*NextEntryResponse) Marshal ¶
func (m *NextEntryResponse) Marshal() (dAtA []byte, err error)
func (*NextEntryResponse) MarshalTo ¶
func (m *NextEntryResponse) MarshalTo(dAtA []byte) (int, error)
func (*NextEntryResponse) MarshalToSizedBuffer ¶
func (m *NextEntryResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*NextEntryResponse) ProtoMessage ¶
func (*NextEntryResponse) ProtoMessage()
func (*NextEntryResponse) Reset ¶
func (m *NextEntryResponse) Reset()
func (*NextEntryResponse) Size ¶
func (m *NextEntryResponse) Size() (n int)
func (*NextEntryResponse) String ¶
func (m *NextEntryResponse) String() string
func (*NextEntryResponse) Unmarshal ¶
func (m *NextEntryResponse) Unmarshal(dAtA []byte) error
func (*NextEntryResponse) XXX_DiscardUnknown ¶
func (m *NextEntryResponse) XXX_DiscardUnknown()
func (*NextEntryResponse) XXX_Marshal ¶
func (m *NextEntryResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*NextEntryResponse) XXX_Merge ¶
func (m *NextEntryResponse) XXX_Merge(src proto.Message)
func (*NextEntryResponse) XXX_Size ¶
func (m *NextEntryResponse) XXX_Size() int
func (*NextEntryResponse) XXX_Unmarshal ¶
func (m *NextEntryResponse) XXX_Unmarshal(b []byte) error
type PrevEntryRequest ¶
type PrevEntryRequest struct { Header *headers.RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` Index uint64 `protobuf:"varint,2,opt,name=index,proto3" json:"index,omitempty"` }
func (*PrevEntryRequest) Descriptor ¶
func (*PrevEntryRequest) Descriptor() ([]byte, []int)
func (*PrevEntryRequest) GetHeader ¶
func (m *PrevEntryRequest) GetHeader() *headers.RequestHeader
func (*PrevEntryRequest) GetIndex ¶
func (m *PrevEntryRequest) GetIndex() 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 { Header *headers.ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` Index uint64 `protobuf:"varint,2,opt,name=index,proto3" json:"index,omitempty"` Value []byte `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"` Timestamp time.Time `protobuf:"bytes,4,opt,name=timestamp,proto3,stdtime" json:"timestamp"` }
func (*PrevEntryResponse) Descriptor ¶
func (*PrevEntryResponse) Descriptor() ([]byte, []int)
func (*PrevEntryResponse) GetHeader ¶
func (m *PrevEntryResponse) GetHeader() *headers.ResponseHeader
func (*PrevEntryResponse) GetIndex ¶
func (m *PrevEntryResponse) GetIndex() uint64
func (*PrevEntryResponse) GetTimestamp ¶
func (m *PrevEntryResponse) GetTimestamp() time.Time
func (*PrevEntryResponse) GetValue ¶
func (m *PrevEntryResponse) GetValue() []byte
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 { Header *headers.RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` Index uint64 `protobuf:"varint,2,opt,name=index,proto3" json:"index,omitempty"` Value []byte `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"` Timestamp time.Time `protobuf:"bytes,4,opt,name=timestamp,proto3,stdtime" json:"timestamp"` }
func (*RemoveRequest) Descriptor ¶
func (*RemoveRequest) Descriptor() ([]byte, []int)
func (*RemoveRequest) GetHeader ¶
func (m *RemoveRequest) GetHeader() *headers.RequestHeader
func (*RemoveRequest) GetIndex ¶
func (m *RemoveRequest) GetIndex() uint64
func (*RemoveRequest) GetTimestamp ¶
func (m *RemoveRequest) GetTimestamp() time.Time
func (*RemoveRequest) GetValue ¶
func (m *RemoveRequest) GetValue() []byte
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 { Header *headers.ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` Status ResponseStatus `protobuf:"varint,2,opt,name=status,proto3,enum=atomix.log.ResponseStatus" json:"status,omitempty"` Index uint64 `protobuf:"varint,3,opt,name=index,proto3" json:"index,omitempty"` PreviousValue []byte `protobuf:"bytes,4,opt,name=previous_value,json=previousValue,proto3" json:"previous_value,omitempty"` }
func (*RemoveResponse) Descriptor ¶
func (*RemoveResponse) Descriptor() ([]byte, []int)
func (*RemoveResponse) GetHeader ¶
func (m *RemoveResponse) GetHeader() *headers.ResponseHeader
func (*RemoveResponse) GetIndex ¶
func (m *RemoveResponse) GetIndex() uint64
func (*RemoveResponse) GetPreviousValue ¶
func (m *RemoveResponse) GetPreviousValue() []byte
func (*RemoveResponse) GetStatus ¶
func (m *RemoveResponse) GetStatus() ResponseStatus
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 ResponseStatus ¶
type ResponseStatus int32
const ( ResponseStatus_OK ResponseStatus = 0 ResponseStatus_NOOP ResponseStatus = 1 ResponseStatus_WRITE_LOCK ResponseStatus = 2 ResponseStatus_PRECONDITION_FAILED ResponseStatus = 3 )
func (ResponseStatus) EnumDescriptor ¶
func (ResponseStatus) EnumDescriptor() ([]byte, []int)
func (ResponseStatus) String ¶
func (x ResponseStatus) String() string
type SizeRequest ¶
type SizeRequest struct {
Header *headers.RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
}
func (*SizeRequest) Descriptor ¶
func (*SizeRequest) Descriptor() ([]byte, []int)
func (*SizeRequest) GetHeader ¶
func (m *SizeRequest) GetHeader() *headers.RequestHeader
func (*SizeRequest) Marshal ¶
func (m *SizeRequest) Marshal() (dAtA []byte, err error)
func (*SizeRequest) MarshalToSizedBuffer ¶
func (m *SizeRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SizeRequest) ProtoMessage ¶
func (*SizeRequest) ProtoMessage()
func (*SizeRequest) Reset ¶
func (m *SizeRequest) Reset()
func (*SizeRequest) Size ¶
func (m *SizeRequest) Size() (n int)
func (*SizeRequest) String ¶
func (m *SizeRequest) String() string
func (*SizeRequest) Unmarshal ¶
func (m *SizeRequest) Unmarshal(dAtA []byte) error
func (*SizeRequest) XXX_DiscardUnknown ¶
func (m *SizeRequest) XXX_DiscardUnknown()
func (*SizeRequest) XXX_Marshal ¶
func (m *SizeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SizeRequest) XXX_Merge ¶
func (m *SizeRequest) XXX_Merge(src proto.Message)
func (*SizeRequest) XXX_Size ¶
func (m *SizeRequest) XXX_Size() int
func (*SizeRequest) XXX_Unmarshal ¶
func (m *SizeRequest) XXX_Unmarshal(b []byte) error
type SizeResponse ¶
type SizeResponse struct { Header *headers.ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` Size_ int32 `protobuf:"varint,2,opt,name=size,proto3" json:"size,omitempty"` }
func (*SizeResponse) Descriptor ¶
func (*SizeResponse) Descriptor() ([]byte, []int)
func (*SizeResponse) GetHeader ¶
func (m *SizeResponse) GetHeader() *headers.ResponseHeader
func (*SizeResponse) GetSize_ ¶
func (m *SizeResponse) GetSize_() int32
func (*SizeResponse) Marshal ¶
func (m *SizeResponse) Marshal() (dAtA []byte, err error)
func (*SizeResponse) 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 UnimplementedLogServiceServer ¶
type UnimplementedLogServiceServer struct { }
UnimplementedLogServiceServer can be embedded to have forward compatible implementations.
func (*UnimplementedLogServiceServer) Append ¶
func (*UnimplementedLogServiceServer) Append(ctx context.Context, req *AppendRequest) (*AppendResponse, error)
func (*UnimplementedLogServiceServer) Clear ¶
func (*UnimplementedLogServiceServer) Clear(ctx context.Context, req *ClearRequest) (*ClearResponse, error)
func (*UnimplementedLogServiceServer) Close ¶
func (*UnimplementedLogServiceServer) Close(ctx context.Context, req *CloseRequest) (*CloseResponse, error)
func (*UnimplementedLogServiceServer) Create ¶
func (*UnimplementedLogServiceServer) Create(ctx context.Context, req *CreateRequest) (*CreateResponse, error)
func (*UnimplementedLogServiceServer) Entries ¶
func (*UnimplementedLogServiceServer) Entries(req *EntriesRequest, srv LogService_EntriesServer) error
func (*UnimplementedLogServiceServer) Events ¶
func (*UnimplementedLogServiceServer) Events(req *EventRequest, srv LogService_EventsServer) error
func (*UnimplementedLogServiceServer) Exists ¶
func (*UnimplementedLogServiceServer) Exists(ctx context.Context, req *ExistsRequest) (*ExistsResponse, error)
func (*UnimplementedLogServiceServer) FirstEntry ¶
func (*UnimplementedLogServiceServer) FirstEntry(ctx context.Context, req *FirstEntryRequest) (*FirstEntryResponse, error)
func (*UnimplementedLogServiceServer) Get ¶
func (*UnimplementedLogServiceServer) Get(ctx context.Context, req *GetRequest) (*GetResponse, error)
func (*UnimplementedLogServiceServer) LastEntry ¶
func (*UnimplementedLogServiceServer) LastEntry(ctx context.Context, req *LastEntryRequest) (*LastEntryResponse, error)
func (*UnimplementedLogServiceServer) NextEntry ¶
func (*UnimplementedLogServiceServer) NextEntry(ctx context.Context, req *NextEntryRequest) (*NextEntryResponse, error)
func (*UnimplementedLogServiceServer) PrevEntry ¶
func (*UnimplementedLogServiceServer) PrevEntry(ctx context.Context, req *PrevEntryRequest) (*PrevEntryResponse, error)
func (*UnimplementedLogServiceServer) Remove ¶
func (*UnimplementedLogServiceServer) Remove(ctx context.Context, req *RemoveRequest) (*RemoveResponse, error)
func (*UnimplementedLogServiceServer) Size ¶
func (*UnimplementedLogServiceServer) Size(ctx context.Context, req *SizeRequest) (*SizeResponse, error)
Click to show internal directories.
Click to hide internal directories.