log

package
v0.6.3 Latest Latest
Warning

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

 Go to latest Published: Apr 13, 2021 License: Apache-2.0 Imports: 20 Imported by: 0

Documentation

Index

Constants

View Source 
const Type = primitiveapi.PrimitiveType_LOG

Type is the log primitive type

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 ListenResponse_Type_name = map[int32]string{
	0: "NONE",
	1: "APPENDED",
	3: "REMOVED",
}
View Source 
var ListenResponse_Type_value = map[string]int32{
	"NONE":     0,
	"APPENDED": 1,
	"REMOVED":  3,
}
View Source 
var UpdateStatus_name = map[int32]string{
	0: "OK",
	1: "NOOP",
	2: "WRITE_LOCK",
	3: "PRECONDITION_FAILED",
}
View Source 
var UpdateStatus_value = map[string]int32{
	"OK":                  0,
	"NOOP":                1,
	"WRITE_LOCK":          2,
	"PRECONDITION_FAILED": 3,
}

Functions

func RegisterPrimitive 

func RegisterPrimitive(node *atomix.Node)

RegisterPrimitive registers the primitive on the given node

Types

type AppendRequest 

type AppendRequest struct {
	Index   uint64 `protobuf:"varint,1,opt,name=index,proto3" json:"index,omitempty"`
	Value   []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	IfEmpty bool   `protobuf:"varint,3,opt,name=if_empty,json=ifEmpty,proto3" json:"if_empty,omitempty"`
}

func (*AppendRequest) Descriptor 

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

func (*AppendRequest) GetIfEmpty 

func (m *AppendRequest) GetIfEmpty() bool

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) MarshalTo 

func (m *AppendRequest) MarshalTo(dAtA []byte) (int, 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 {
	Status    UpdateStatus `protobuf:"varint,1,opt,name=status,proto3,enum=atomix.log.service.UpdateStatus" json:"status,omitempty"`
	Index     uint64       `protobuf:"varint,2,opt,name=index,proto3" json:"index,omitempty"`
	Timestamp time.Time    `protobuf:"bytes,3,opt,name=timestamp,proto3,stdtime" json:"timestamp"`
}

func (*AppendResponse) Descriptor 

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

func (*AppendResponse) GetIndex 

func (m *AppendResponse) GetIndex() uint64

func (*AppendResponse) GetStatus 

func (m *AppendResponse) GetStatus() UpdateStatus

func (*AppendResponse) GetTimestamp 

func (m *AppendResponse) GetTimestamp() time.Time

func (*AppendResponse) Marshal 

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

func (*AppendResponse) MarshalTo 

func (m *AppendResponse) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

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

func (*ClearRequest) MarshalToSizedBuffer 

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

func (*ClearRequest) ProtoMessage 

func (*ClearRequest) ProtoMessage()

func (*ClearRequest) Reset 

func (m *ClearRequest) Reset()

func (*ClearRequest) Size 

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

func (*ClearRequest) String 

func (m *ClearRequest) String() string

func (*ClearRequest) Unmarshal 

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

func (*ClearRequest) XXX_DiscardUnknown 

func (m *ClearRequest) XXX_DiscardUnknown()

func (*ClearRequest) XXX_Marshal 

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

func (*ClearRequest) XXX_Merge 

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

func (*ClearRequest) XXX_Size 

func (m *ClearRequest) XXX_Size() int

func (*ClearRequest) XXX_Unmarshal 

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

type ClearResponse 

type ClearResponse struct {
}

func (*ClearResponse) Descriptor 

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

func (*ClearResponse) Marshal 

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

func (*ClearResponse) MarshalTo 

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

func (*ClearResponse) MarshalToSizedBuffer 

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

func (*ClearResponse) ProtoMessage 

func (*ClearResponse) ProtoMessage()

func (*ClearResponse) Reset 

func (m *ClearResponse) Reset()

func (*ClearResponse) Size 

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

func (*ClearResponse) String 

func (m *ClearResponse) String() string

func (*ClearResponse) Unmarshal 

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

func (*ClearResponse) XXX_DiscardUnknown 

func (m *ClearResponse) XXX_DiscardUnknown()

func (*ClearResponse) XXX_Marshal 

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

func (*ClearResponse) XXX_Merge 

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

func (*ClearResponse) XXX_Size 

func (m *ClearResponse) XXX_Size() int

func (*ClearResponse) XXX_Unmarshal 

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

type ContainsIndexRequest 

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

func (*ContainsIndexRequest) Descriptor 

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

func (*ContainsIndexRequest) GetIndex 

func (m *ContainsIndexRequest) GetIndex() uint64

func (*ContainsIndexRequest) Marshal 

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

func (*ContainsIndexRequest) MarshalTo 

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

func (*ContainsIndexRequest) MarshalToSizedBuffer 

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

func (*ContainsIndexRequest) ProtoMessage 

func (*ContainsIndexRequest) ProtoMessage()

func (*ContainsIndexRequest) Reset 

func (m *ContainsIndexRequest) Reset()

func (*ContainsIndexRequest) Size 

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

func (*ContainsIndexRequest) String 

func (m *ContainsIndexRequest) String() string

func (*ContainsIndexRequest) Unmarshal 

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

func (*ContainsIndexRequest) XXX_DiscardUnknown 

func (m *ContainsIndexRequest) XXX_DiscardUnknown()

func (*ContainsIndexRequest) XXX_Marshal 

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

func (*ContainsIndexRequest) XXX_Merge 

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

func (*ContainsIndexRequest) XXX_Size 

func (m *ContainsIndexRequest) XXX_Size() int

func (*ContainsIndexRequest) XXX_Unmarshal 

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

type ContainsIndexResponse 

type ContainsIndexResponse struct {
	ContainsIndex bool `protobuf:"varint,1,opt,name=contains_index,json=containsIndex,proto3" json:"contains_index,omitempty"`
}

func (*ContainsIndexResponse) Descriptor 

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

func (*ContainsIndexResponse) GetContainsIndex 

func (m *ContainsIndexResponse) GetContainsIndex() bool

func (*ContainsIndexResponse) Marshal 

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

func (*ContainsIndexResponse) MarshalTo 

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

func (*ContainsIndexResponse) MarshalToSizedBuffer 

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

func (*ContainsIndexResponse) ProtoMessage 

func (*ContainsIndexResponse) ProtoMessage()

func (*ContainsIndexResponse) Reset 

func (m *ContainsIndexResponse) Reset()

func (*ContainsIndexResponse) Size 

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

func (*ContainsIndexResponse) String 

func (m *ContainsIndexResponse) String() string

func (*ContainsIndexResponse) Unmarshal 

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

func (*ContainsIndexResponse) XXX_DiscardUnknown 

func (m *ContainsIndexResponse) XXX_DiscardUnknown()

func (*ContainsIndexResponse) XXX_Marshal 

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

func (*ContainsIndexResponse) XXX_Merge 

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

func (*ContainsIndexResponse) XXX_Size 

func (m *ContainsIndexResponse) XXX_Size() int

func (*ContainsIndexResponse) XXX_Unmarshal 

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

type EntriesRequest 

type EntriesRequest struct {
}

func (*EntriesRequest) Descriptor 

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

func (*EntriesRequest) Marshal 

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

func (*EntriesRequest) MarshalTo 

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

func (*EntriesRequest) MarshalToSizedBuffer 

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

func (*EntriesRequest) ProtoMessage 

func (*EntriesRequest) ProtoMessage()

func (*EntriesRequest) Reset 

func (m *EntriesRequest) Reset()

func (*EntriesRequest) Size 

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

func (*EntriesRequest) String 

func (m *EntriesRequest) String() string

func (*EntriesRequest) Unmarshal 

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

func (*EntriesRequest) XXX_DiscardUnknown 

func (m *EntriesRequest) XXX_DiscardUnknown()

func (*EntriesRequest) XXX_Marshal 

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

func (*EntriesRequest) XXX_Merge 

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

func (*EntriesRequest) XXX_Size 

func (m *EntriesRequest) XXX_Size() int

func (*EntriesRequest) XXX_Unmarshal 

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

type EntriesResponse 

type EntriesResponse struct {
	Index     uint64    `protobuf:"varint,1,opt,name=index,proto3" json:"index,omitempty"`
	Value     []byte    `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	Timestamp time.Time `protobuf:"bytes,3,opt,name=timestamp,proto3,stdtime" json:"timestamp"`
}

func (*EntriesResponse) Descriptor 

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

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) MarshalTo 

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

func (*EntriesResponse) MarshalToSizedBuffer 

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

func (*EntriesResponse) ProtoMessage 

func (*EntriesResponse) ProtoMessage()

func (*EntriesResponse) Reset 

func (m *EntriesResponse) Reset()

func (*EntriesResponse) Size 

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

func (*EntriesResponse) String 

func (m *EntriesResponse) String() string

func (*EntriesResponse) Unmarshal 

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

func (*EntriesResponse) XXX_DiscardUnknown 

func (m *EntriesResponse) XXX_DiscardUnknown()

func (*EntriesResponse) XXX_Marshal 

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

func (*EntriesResponse) XXX_Merge 

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

func (*EntriesResponse) XXX_Size 

func (m *EntriesResponse) XXX_Size() int

func (*EntriesResponse) XXX_Unmarshal 

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

type 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 {
	Index     uint64    `protobuf:"varint,1,opt,name=index,proto3" json:"index,omitempty"`
	Value     []byte    `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	Timestamp time.Time `protobuf:"bytes,3,opt,name=timestamp,proto3,stdtime" json:"timestamp"`
}

func (*FirstEntryResponse) Descriptor 

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

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 {
	Index uint64 `protobuf:"varint,1,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) MarshalTo 

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

func (*GetRequest) MarshalToSizedBuffer 

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

func (*GetRequest) ProtoMessage 

func (*GetRequest) ProtoMessage()

func (*GetRequest) Reset 

func (m *GetRequest) Reset()

func (*GetRequest) Size 

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

func (*GetRequest) String 

func (m *GetRequest) String() string

func (*GetRequest) Unmarshal 

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

func (*GetRequest) XXX_DiscardUnknown 

func (m *GetRequest) XXX_DiscardUnknown()

func (*GetRequest) XXX_Marshal 

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

func (*GetRequest) XXX_Merge 

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

func (*GetRequest) XXX_Size 

func (m *GetRequest) XXX_Size() int

func (*GetRequest) XXX_Unmarshal 

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

type GetResponse 

type GetResponse struct {
	Index     uint64    `protobuf:"varint,1,opt,name=index,proto3" json:"index,omitempty"`
	Value     []byte    `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	Timestamp time.Time `protobuf:"bytes,3,opt,name=timestamp,proto3,stdtime" json:"timestamp"`
}

func (*GetResponse) Descriptor 

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

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) MarshalTo 

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

func (*GetResponse) MarshalToSizedBuffer 

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

func (*GetResponse) ProtoMessage 

func (*GetResponse) ProtoMessage()

func (*GetResponse) Reset 

func (m *GetResponse) Reset()

func (*GetResponse) Size 

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

func (*GetResponse) String 

func (m *GetResponse) String() string

func (*GetResponse) Unmarshal 

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

func (*GetResponse) XXX_DiscardUnknown 

func (m *GetResponse) XXX_DiscardUnknown()

func (*GetResponse) XXX_Marshal 

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

func (*GetResponse) XXX_Merge 

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

func (*GetResponse) XXX_Size 

func (m *GetResponse) XXX_Size() int

func (*GetResponse) XXX_Unmarshal 

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

type IndexRequest 

type IndexRequest struct {
}

func (*IndexRequest) Descriptor 

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

func (*IndexRequest) Marshal 

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

func (*IndexRequest) MarshalTo 

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

func (*IndexRequest) MarshalToSizedBuffer 

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

func (*IndexRequest) ProtoMessage 

func (*IndexRequest) ProtoMessage()

func (*IndexRequest) Reset 

func (m *IndexRequest) Reset()

func (*IndexRequest) Size 

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

func (*IndexRequest) String 

func (m *IndexRequest) String() string

func (*IndexRequest) Unmarshal 

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

func (*IndexRequest) XXX_DiscardUnknown 

func (m *IndexRequest) XXX_DiscardUnknown()

func (*IndexRequest) XXX_Marshal 

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

func (*IndexRequest) XXX_Merge 

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

func (*IndexRequest) XXX_Size 

func (m *IndexRequest) XXX_Size() int

func (*IndexRequest) XXX_Unmarshal 

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

type IndexResponse 

type IndexResponse struct {
	Key uint64 `protobuf:"varint,1,opt,name=key,proto3" json:"key,omitempty"`
}

func (*IndexResponse) Descriptor 

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

func (*IndexResponse) GetKey 

func (m *IndexResponse) GetKey() uint64

func (*IndexResponse) Marshal 

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

func (*IndexResponse) MarshalTo 

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

func (*IndexResponse) MarshalToSizedBuffer 

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

func (*IndexResponse) ProtoMessage 

func (*IndexResponse) ProtoMessage()

func (*IndexResponse) Reset 

func (m *IndexResponse) Reset()

func (*IndexResponse) Size 

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

func (*IndexResponse) String 

func (m *IndexResponse) String() string

func (*IndexResponse) Unmarshal 

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

func (*IndexResponse) XXX_DiscardUnknown 

func (m *IndexResponse) XXX_DiscardUnknown()

func (*IndexResponse) XXX_Marshal 

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

func (*IndexResponse) XXX_Merge 

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

func (*IndexResponse) XXX_Size 

func (m *IndexResponse) XXX_Size() int

func (*IndexResponse) XXX_Unmarshal 

func (m *IndexResponse) 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) MarshalTo 

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

func (*LastEntryRequest) MarshalToSizedBuffer 

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

func (*LastEntryRequest) ProtoMessage 

func (*LastEntryRequest) ProtoMessage()

func (*LastEntryRequest) Reset 

func (m *LastEntryRequest) Reset()

func (*LastEntryRequest) Size 

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

func (*LastEntryRequest) String 

func (m *LastEntryRequest) String() string

func (*LastEntryRequest) Unmarshal 

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

func (*LastEntryRequest) XXX_DiscardUnknown 

func (m *LastEntryRequest) XXX_DiscardUnknown()

func (*LastEntryRequest) XXX_Marshal 

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

func (*LastEntryRequest) XXX_Merge 

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

func (*LastEntryRequest) XXX_Size 

func (m *LastEntryRequest) XXX_Size() int

func (*LastEntryRequest) XXX_Unmarshal 

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

type LastEntryResponse 

type LastEntryResponse struct {
	Index     uint64    `protobuf:"varint,1,opt,name=index,proto3" json:"index,omitempty"`
	Value     []byte    `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	Timestamp time.Time `protobuf:"bytes,3,opt,name=timestamp,proto3,stdtime" json:"timestamp"`
}

func (*LastEntryResponse) Descriptor 

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

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 LinkedLogEntryValue 

type LinkedLogEntryValue struct {
	*LogEntryValue
	Prev *LinkedLogEntryValue
	Next *LinkedLogEntryValue
}

LinkedLogEntryValue is a doubly linked LogEntryValue

type ListenRequest 

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

func (*ListenRequest) Descriptor 

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

func (*ListenRequest) GetIndex 

func (m *ListenRequest) GetIndex() uint64

func (*ListenRequest) GetKey 

func (m *ListenRequest) GetKey() string

func (*ListenRequest) GetReplay 

func (m *ListenRequest) GetReplay() bool

func (*ListenRequest) Marshal 

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

func (*ListenRequest) MarshalTo 

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

func (*ListenRequest) MarshalToSizedBuffer 

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

func (*ListenRequest) ProtoMessage 

func (*ListenRequest) ProtoMessage()

func (*ListenRequest) Reset 

func (m *ListenRequest) Reset()

func (*ListenRequest) Size 

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

func (*ListenRequest) String 

func (m *ListenRequest) String() string

func (*ListenRequest) Unmarshal 

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

func (*ListenRequest) XXX_DiscardUnknown 

func (m *ListenRequest) XXX_DiscardUnknown()

func (*ListenRequest) XXX_Marshal 

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

func (*ListenRequest) XXX_Merge 

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

func (*ListenRequest) XXX_Size 

func (m *ListenRequest) XXX_Size() int

func (*ListenRequest) XXX_Unmarshal 

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

type ListenResponse 

type ListenResponse struct {
	Type      ListenResponse_Type `protobuf:"varint,1,opt,name=type,proto3,enum=atomix.log.service.ListenResponse_Type" json:"type,omitempty"`
	Index     uint64              `protobuf:"varint,2,opt,name=index,proto3" json:"index,omitempty"`
	Key       string              `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty"`
	Value     []byte              `protobuf:"bytes,4,opt,name=value,proto3" json:"value,omitempty"`
	Timestamp time.Time           `protobuf:"bytes,5,opt,name=timestamp,proto3,stdtime" json:"timestamp"`
	StreamId  int64               `protobuf:"varint,6,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty"`
}

func (*ListenResponse) Descriptor 

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

func (*ListenResponse) GetIndex 

func (m *ListenResponse) GetIndex() uint64

func (*ListenResponse) GetKey 

func (m *ListenResponse) GetKey() string

func (*ListenResponse) GetStreamId 

func (m *ListenResponse) GetStreamId() int64

func (*ListenResponse) GetTimestamp 

func (m *ListenResponse) GetTimestamp() time.Time

func (*ListenResponse) GetType 

func (m *ListenResponse) GetType() ListenResponse_Type

func (*ListenResponse) GetValue 

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

func (*ListenResponse) Marshal 

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

func (*ListenResponse) MarshalTo 

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

func (*ListenResponse) MarshalToSizedBuffer 

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

func (*ListenResponse) ProtoMessage 

func (*ListenResponse) ProtoMessage()

func (*ListenResponse) Reset 

func (m *ListenResponse) Reset()

func (*ListenResponse) Size 

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

func (*ListenResponse) String 

func (m *ListenResponse) String() string

func (*ListenResponse) Unmarshal 

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

func (*ListenResponse) XXX_DiscardUnknown 

func (m *ListenResponse) XXX_DiscardUnknown()

func (*ListenResponse) XXX_Marshal 

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

func (*ListenResponse) XXX_Merge 

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

func (*ListenResponse) XXX_Size 

func (m *ListenResponse) XXX_Size() int

func (*ListenResponse) XXX_Unmarshal 

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

type ListenResponse_Type 

type ListenResponse_Type int32
const (
	ListenResponse_NONE     ListenResponse_Type = 0
	ListenResponse_APPENDED ListenResponse_Type = 1
	ListenResponse_REMOVED  ListenResponse_Type = 3
)

func (ListenResponse_Type) EnumDescriptor 

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

func (ListenResponse_Type) String 

func (x ListenResponse_Type) String() string

type Listener 

type Listener struct {
	SessionId uint64 `protobuf:"varint,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	StreamId  uint64 `protobuf:"varint,2,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty"`
	Index     uint64 `protobuf:"varint,4,opt,name=index,proto3" json:"index,omitempty"`
}

Listener is a log listener

func (*Listener) Descriptor 

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

func (*Listener) GetIndex 

func (m *Listener) GetIndex() uint64

func (*Listener) GetSessionId 

func (m *Listener) GetSessionId() uint64

func (*Listener) GetStreamId 

func (m *Listener) GetStreamId() uint64

func (*Listener) Marshal 

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

func (*Listener) MarshalTo 

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

func (*Listener) MarshalToSizedBuffer 

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

func (*Listener) ProtoMessage 

func (*Listener) ProtoMessage()

func (*Listener) Reset 

func (m *Listener) Reset()

func (*Listener) Size 

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

func (*Listener) String 

func (m *Listener) String() string

func (*Listener) Unmarshal 

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

func (*Listener) XXX_DiscardUnknown 

func (m *Listener) XXX_DiscardUnknown()

func (*Listener) XXX_Marshal 

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

func (*Listener) XXX_Merge 

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

func (*Listener) XXX_Size 

func (m *Listener) XXX_Size() int

func (*Listener) XXX_Unmarshal 

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

type LogEntryValue 

type LogEntryValue struct {
	Index     uint64    `protobuf:"varint,1,opt,name=index,proto3" json:"index,omitempty"`
	Value     []byte    `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	Timestamp time.Time `protobuf:"bytes,3,opt,name=timestamp,proto3,stdtime" json:"timestamp"`
}

Log entry value

func (*LogEntryValue) Descriptor 

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

func (*LogEntryValue) GetIndex 

func (m *LogEntryValue) GetIndex() uint64

func (*LogEntryValue) GetTimestamp 

func (m *LogEntryValue) GetTimestamp() time.Time

func (*LogEntryValue) GetValue 

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

func (*LogEntryValue) Marshal 

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

func (*LogEntryValue) MarshalTo 

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

func (*LogEntryValue) MarshalToSizedBuffer 

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

func (*LogEntryValue) ProtoMessage 

func (*LogEntryValue) ProtoMessage()

func (*LogEntryValue) Reset 

func (m *LogEntryValue) Reset()

func (*LogEntryValue) Size 

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

func (*LogEntryValue) String 

func (m *LogEntryValue) String() string

func (*LogEntryValue) Unmarshal 

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

func (*LogEntryValue) XXX_DiscardUnknown 

func (m *LogEntryValue) XXX_DiscardUnknown()

func (*LogEntryValue) XXX_Marshal 

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

func (*LogEntryValue) XXX_Merge 

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

func (*LogEntryValue) XXX_Size 

func (m *LogEntryValue) XXX_Size() int

func (*LogEntryValue) XXX_Unmarshal 

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

type LogSnapshot 

type LogSnapshot struct {
	Index   uint64           `protobuf:"varint,1,opt,name=index,proto3" json:"index,omitempty"`
	Entries []*LogEntryValue `protobuf:"bytes,2,rep,name=entries,proto3" json:"entries,omitempty"`
}

Log snapshot

func (*LogSnapshot) Descriptor 

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

func (*LogSnapshot) GetEntries 

func (m *LogSnapshot) GetEntries() []*LogEntryValue

func (*LogSnapshot) GetIndex 

func (m *LogSnapshot) GetIndex() uint64

func (*LogSnapshot) Marshal 

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

func (*LogSnapshot) MarshalTo 

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

func (*LogSnapshot) MarshalToSizedBuffer 

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

func (*LogSnapshot) ProtoMessage 

func (*LogSnapshot) ProtoMessage()

func (*LogSnapshot) Reset 

func (m *LogSnapshot) Reset()

func (*LogSnapshot) Size 

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

func (*LogSnapshot) String 

func (m *LogSnapshot) String() string

func (*LogSnapshot) Unmarshal 

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

func (*LogSnapshot) XXX_DiscardUnknown 

func (m *LogSnapshot) XXX_DiscardUnknown()

func (*LogSnapshot) XXX_Marshal 

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

func (*LogSnapshot) XXX_Merge 

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

func (*LogSnapshot) XXX_Size 

func (m *LogSnapshot) XXX_Size() int

func (*LogSnapshot) XXX_Unmarshal 

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

type NextEntryRequest 

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

func (*NextEntryRequest) Descriptor 

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

func (*NextEntryRequest) GetIndex 

func (m *NextEntryRequest) GetIndex() uint64

func (*NextEntryRequest) Marshal 

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

func (*NextEntryRequest) MarshalTo 

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

func (*NextEntryRequest) MarshalToSizedBuffer 

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

func (*NextEntryRequest) ProtoMessage 

func (*NextEntryRequest) ProtoMessage()

func (*NextEntryRequest) Reset 

func (m *NextEntryRequest) Reset()

func (*NextEntryRequest) Size 

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

func (*NextEntryRequest) String 

func (m *NextEntryRequest) String() string

func (*NextEntryRequest) Unmarshal 

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

func (*NextEntryRequest) XXX_DiscardUnknown 

func (m *NextEntryRequest) XXX_DiscardUnknown()

func (*NextEntryRequest) XXX_Marshal 

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

func (*NextEntryRequest) XXX_Merge 

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

func (*NextEntryRequest) XXX_Size 

func (m *NextEntryRequest) XXX_Size() int

func (*NextEntryRequest) XXX_Unmarshal 

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

type NextEntryResponse 

type NextEntryResponse struct {
	Index     uint64    `protobuf:"varint,1,opt,name=index,proto3" json:"index,omitempty"`
	Value     []byte    `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	Timestamp time.Time `protobuf:"bytes,3,opt,name=timestamp,proto3,stdtime" json:"timestamp"`
}

func (*NextEntryResponse) Descriptor 

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

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

func (*PrevEntryRequest) Descriptor 

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

func (*PrevEntryRequest) GetIndex 

func (m *PrevEntryRequest) GetIndex() uint64

func (*PrevEntryRequest) Marshal 

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

func (*PrevEntryRequest) MarshalTo 

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

func (*PrevEntryRequest) MarshalToSizedBuffer 

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

func (*PrevEntryRequest) ProtoMessage 

func (*PrevEntryRequest) ProtoMessage()

func (*PrevEntryRequest) Reset 

func (m *PrevEntryRequest) Reset()

func (*PrevEntryRequest) Size 

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

func (*PrevEntryRequest) String 

func (m *PrevEntryRequest) String() string

func (*PrevEntryRequest) Unmarshal 

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

func (*PrevEntryRequest) XXX_DiscardUnknown 

func (m *PrevEntryRequest) XXX_DiscardUnknown()

func (*PrevEntryRequest) XXX_Marshal 

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

func (*PrevEntryRequest) XXX_Merge 

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

func (*PrevEntryRequest) XXX_Size 

func (m *PrevEntryRequest) XXX_Size() int

func (*PrevEntryRequest) XXX_Unmarshal 

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

type PrevEntryResponse 

type PrevEntryResponse struct {
	Index     uint64    `protobuf:"varint,1,opt,name=index,proto3" json:"index,omitempty"`
	Value     []byte    `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	Timestamp time.Time `protobuf:"bytes,3,opt,name=timestamp,proto3,stdtime" json:"timestamp"`
}

func (*PrevEntryResponse) Descriptor 

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

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 Primitive 

type Primitive struct{}

Primitive is the counter primitive

func (*Primitive) NewService 

func (p *Primitive) NewService(scheduler primitive.Scheduler, context primitive.ServiceContext) primitive.Service

NewService creates a new log service

func (*Primitive) RegisterServer 

func (p *Primitive) RegisterServer(server *grpc.Server, protocol primitive.Protocol)

RegisterServer registers the log server with the protocol

type RemoveRequest 

type RemoveRequest struct {
	Index uint64 `protobuf:"varint,1,opt,name=index,proto3" json:"index,omitempty"`
	Value []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
}

func (*RemoveRequest) Descriptor 

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

func (*RemoveRequest) GetIndex 

func (m *RemoveRequest) GetIndex() uint64

func (*RemoveRequest) GetValue 

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

func (*RemoveRequest) Marshal 

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

func (*RemoveRequest) MarshalTo 

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

func (*RemoveRequest) MarshalToSizedBuffer 

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

func (*RemoveRequest) ProtoMessage 

func (*RemoveRequest) ProtoMessage()

func (*RemoveRequest) Reset 

func (m *RemoveRequest) Reset()

func (*RemoveRequest) Size 

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

func (*RemoveRequest) String 

func (m *RemoveRequest) String() string

func (*RemoveRequest) Unmarshal 

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

func (*RemoveRequest) XXX_DiscardUnknown 

func (m *RemoveRequest) XXX_DiscardUnknown()

func (*RemoveRequest) XXX_Marshal 

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

func (*RemoveRequest) XXX_Merge 

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

func (*RemoveRequest) XXX_Size 

func (m *RemoveRequest) XXX_Size() int

func (*RemoveRequest) XXX_Unmarshal 

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

type RemoveResponse 

type RemoveResponse struct {
	Status        UpdateStatus `protobuf:"varint,1,opt,name=status,proto3,enum=atomix.log.service.UpdateStatus" json:"status,omitempty"`
	Index         uint64       `protobuf:"varint,2,opt,name=index,proto3" json:"index,omitempty"`
	PreviousValue []byte       `protobuf:"bytes,3,opt,name=previous_value,json=previousValue,proto3" json:"previous_value,omitempty"`
	Timestamp     time.Time    `protobuf:"bytes,4,opt,name=timestamp,proto3,stdtime" json:"timestamp"`
}

func (*RemoveResponse) Descriptor 

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

func (*RemoveResponse) GetIndex 

func (m *RemoveResponse) GetIndex() uint64

func (*RemoveResponse) GetPreviousValue 

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

func (*RemoveResponse) GetStatus 

func (m *RemoveResponse) GetStatus() UpdateStatus

func (*RemoveResponse) GetTimestamp 

func (m *RemoveResponse) GetTimestamp() time.Time

func (*RemoveResponse) Marshal 

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

func (*RemoveResponse) MarshalTo 

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

func (*RemoveResponse) MarshalToSizedBuffer 

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

func (*RemoveResponse) ProtoMessage 

func (*RemoveResponse) ProtoMessage()

func (*RemoveResponse) Reset 

func (m *RemoveResponse) Reset()

func (*RemoveResponse) Size 

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

func (*RemoveResponse) String 

func (m *RemoveResponse) String() string

func (*RemoveResponse) Unmarshal 

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

func (*RemoveResponse) XXX_DiscardUnknown 

func (m *RemoveResponse) XXX_DiscardUnknown()

func (*RemoveResponse) XXX_Marshal 

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

func (*RemoveResponse) XXX_Merge 

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

func (*RemoveResponse) XXX_Size 

func (m *RemoveResponse) XXX_Size() int

func (*RemoveResponse) XXX_Unmarshal 

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

type Server 

type Server struct {
	*primitive.Server
}

Server is an implementation of LogServiceServer for the log primitive

func (*Server) Append 

func (s *Server) Append(ctx context.Context, request *api.AppendRequest) (*api.AppendResponse, error)

Append appends a value to the end of the log

func (*Server) Clear 

func (s *Server) Clear(ctx context.Context, request *api.ClearRequest) (*api.ClearResponse, error)

Clear removes all keys from the log

func (*Server) Close 

func (s *Server) Close(ctx context.Context, request *api.CloseRequest) (*api.CloseResponse, error)

Close closes a session

func (*Server) Create 

func (s *Server) Create(ctx context.Context, request *api.CreateRequest) (*api.CreateResponse, error)

Create opens a new session

func (*Server) Entries 

func (s *Server) Entries(request *api.EntriesRequest, srv api.LogService_EntriesServer) error

Entries lists all entries currently in the log

func (*Server) Events 

func (s *Server) Events(request *api.EventRequest, srv api.LogService_EventsServer) error

Events listens for log change events

func (*Server) Exists 

func (s *Server) Exists(ctx context.Context, request *api.ExistsRequest) (*api.ExistsResponse, error)

Exists checks whether the log contains an index

func (*Server) FirstEntry 

func (s *Server) FirstEntry(ctx context.Context, request *api.FirstEntryRequest) (*api.FirstEntryResponse, error)

FirstEntry gets the first entry in the log

func (*Server) Get 

func (s *Server) Get(ctx context.Context, request *api.GetRequest) (*api.GetResponse, error)

Get gets the value of an index

func (*Server) LastEntry 

func (s *Server) LastEntry(ctx context.Context, request *api.LastEntryRequest) (*api.LastEntryResponse, error)

LastEntry gets the last entry in the log

func (*Server) NextEntry 

func (s *Server) NextEntry(ctx context.Context, request *api.NextEntryRequest) (*api.NextEntryResponse, error)

NextEntry gets the next entry in the log

func (*Server) PrevEntry 

func (s *Server) PrevEntry(ctx context.Context, request *api.PrevEntryRequest) (*api.PrevEntryResponse, error)

PrevEntry gets the previous entry in the log

func (*Server) Remove 

func (s *Server) Remove(ctx context.Context, request *api.RemoveRequest) (*api.RemoveResponse, error)

Remove removes a key from the log

func (*Server) Size 

func (s *Server) Size(ctx context.Context, request *api.SizeRequest) (*api.SizeResponse, error)

Size gets the number of entries in the log

type Service 

type Service struct {
	primitive.Service
	// contains filtered or unexported fields
}

Service is a state machine for a log primitive

func (*Service) Append 

func (m *Service) Append(value []byte) ([]byte, error)

Append appends a value to the end of the log

func (*Service) Backup 

func (m *Service) Backup(writer io.Writer) error

Backup takes a snapshot of the service

func (*Service) Clear 

func (m *Service) Clear(value []byte) ([]byte, error)

Clear removes all entries from the log

func (*Service) Entries 

func (m *Service) Entries(value []byte, stream primitive.Stream)

Entries returns a stream of entries to the client

func (*Service) Events 

func (m *Service) Events(bytes []byte, stream primitive.Stream)

Events sends change events to the client

func (*Service) Exists 

func (m *Service) Exists(bytes []byte) ([]byte, error)

Exists checks if the log contains an index

func (*Service) FirstEntry 

func (m *Service) FirstEntry(bytes []byte) ([]byte, error)

FirstEntry gets the first entry from the log

func (*Service) Get 

func (m *Service) Get(bytes []byte) ([]byte, error)

Get gets a value from the log

func (*Service) LastEntry 

func (m *Service) LastEntry(bytes []byte) ([]byte, error)

LastEntry gets the last entry from the log

func (*Service) NextEntry 

func (m *Service) NextEntry(bytes []byte) ([]byte, error)

NextEntry gets the next entry from the log

func (*Service) PrevEntry 

func (m *Service) PrevEntry(bytes []byte) ([]byte, error)

PrevEntry gets the previous entry from the log

func (*Service) Remove 

func (m *Service) Remove(bytes []byte) ([]byte, error)

Remove removes a key/value pair from the log

func (*Service) Restore 

func (m *Service) Restore(reader io.Reader) error

Restore restores the service from a snapshot

func (*Service) Size 

func (m *Service) Size(bytes []byte) ([]byte, error)

Size returns the size of the log

type SizeRequest 

type SizeRequest struct {
}

func (*SizeRequest) Descriptor 

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

func (*SizeRequest) Marshal 

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

func (*SizeRequest) MarshalTo 

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

func (*SizeRequest) MarshalToSizedBuffer 

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

func (*SizeRequest) ProtoMessage 

func (*SizeRequest) ProtoMessage()

func (*SizeRequest) Reset 

func (m *SizeRequest) Reset()

func (*SizeRequest) Size 

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

func (*SizeRequest) String 

func (m *SizeRequest) String() string

func (*SizeRequest) Unmarshal 

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

func (*SizeRequest) XXX_DiscardUnknown 

func (m *SizeRequest) XXX_DiscardUnknown()

func (*SizeRequest) XXX_Marshal 

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

func (*SizeRequest) XXX_Merge 

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

func (*SizeRequest) XXX_Size 

func (m *SizeRequest) XXX_Size() int

func (*SizeRequest) XXX_Unmarshal 

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

type SizeResponse 

type SizeResponse struct {
	Size_ int32 `protobuf:"varint,1,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) MarshalTo 

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

func (*SizeResponse) MarshalToSizedBuffer 

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

func (*SizeResponse) ProtoMessage 

func (*SizeResponse) ProtoMessage()

func (*SizeResponse) Reset 

func (m *SizeResponse) Reset()

func (*SizeResponse) Size 

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

func (*SizeResponse) String 

func (m *SizeResponse) String() string

func (*SizeResponse) Unmarshal 

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

func (*SizeResponse) XXX_DiscardUnknown 

func (m *SizeResponse) XXX_DiscardUnknown()

func (*SizeResponse) XXX_Marshal 

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

func (*SizeResponse) XXX_Merge 

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

func (*SizeResponse) XXX_Size 

func (m *SizeResponse) XXX_Size() int

func (*SizeResponse) XXX_Unmarshal 

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

type UnlistenRequest 

type UnlistenRequest struct {
	StreamId uint64 `protobuf:"varint,1,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty"`
}

func (*UnlistenRequest) Descriptor 

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

func (*UnlistenRequest) GetStreamId 

func (m *UnlistenRequest) GetStreamId() uint64

func (*UnlistenRequest) Marshal 

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

func (*UnlistenRequest) MarshalTo 

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

func (*UnlistenRequest) MarshalToSizedBuffer 

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

func (*UnlistenRequest) ProtoMessage 

func (*UnlistenRequest) ProtoMessage()

func (*UnlistenRequest) Reset 

func (m *UnlistenRequest) Reset()

func (*UnlistenRequest) Size 

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

func (*UnlistenRequest) String 

func (m *UnlistenRequest) String() string

func (*UnlistenRequest) Unmarshal 

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

func (*UnlistenRequest) XXX_DiscardUnknown 

func (m *UnlistenRequest) XXX_DiscardUnknown()

func (*UnlistenRequest) XXX_Marshal 

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

func (*UnlistenRequest) XXX_Merge 

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

func (*UnlistenRequest) XXX_Size 

func (m *UnlistenRequest) XXX_Size() int

func (*UnlistenRequest) XXX_Unmarshal 

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

type UnlistenResponse 

type UnlistenResponse struct {
}

func (*UnlistenResponse) Descriptor 

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

func (*UnlistenResponse) Marshal 

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

func (*UnlistenResponse) MarshalTo 

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

func (*UnlistenResponse) MarshalToSizedBuffer 

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

func (*UnlistenResponse) ProtoMessage 

func (*UnlistenResponse) ProtoMessage()

func (*UnlistenResponse) Reset 

func (m *UnlistenResponse) Reset()

func (*UnlistenResponse) Size 

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

func (*UnlistenResponse) String 

func (m *UnlistenResponse) String() string

func (*UnlistenResponse) Unmarshal 

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

func (*UnlistenResponse) XXX_DiscardUnknown 

func (m *UnlistenResponse) XXX_DiscardUnknown()

func (*UnlistenResponse) XXX_Marshal 

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

func (*UnlistenResponse) XXX_Merge 

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

func (*UnlistenResponse) XXX_Size 

func (m *UnlistenResponse) XXX_Size() int

func (*UnlistenResponse) XXX_Unmarshal 

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

type UpdateStatus 

type UpdateStatus int32
const (
	UpdateStatus_OK                  UpdateStatus = 0
	UpdateStatus_NOOP                UpdateStatus = 1
	UpdateStatus_WRITE_LOCK          UpdateStatus = 2
	UpdateStatus_PRECONDITION_FAILED UpdateStatus = 3
)

func (UpdateStatus) EnumDescriptor 

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

func (UpdateStatus) String 

func (x UpdateStatus) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

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