list

package
v0.5.3 Latest Latest
Warning

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

 Go to latest Published: Mar 16, 2021 License: Apache-2.0 Imports: 17 Imported by: 0

Documentation

Index

Constants

View Source 
const Type = primitiveapi.PrimitiveType_LIST

Type is the list primitive type

Variables

View Source 
var (
	ErrInvalidLengthList        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowList          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupList = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var ListenResponse_Type_name = map[int32]string{
	0: "NONE",
	1: "ADDED",
	2: "REMOVED",
}
View Source 
var ListenResponse_Type_value = map[string]int32{
	"NONE":    0,
	"ADDED":   1,
	"REMOVED": 2,
}
View Source 
var ResponseStatus_name = map[int32]string{
	0: "OK",
	1: "NOOP",
	2: "WRITE_LOCK",
	3: "OUT_OF_BOUNDS",
}
View Source 
var ResponseStatus_value = map[string]int32{
	"OK":            0,
	"NOOP":          1,
	"WRITE_LOCK":    2,
	"OUT_OF_BOUNDS": 3,
}

Functions

func RegisterPrimitive added in v0.3.0 

func RegisterPrimitive(node *atomix.Node)

RegisterPrimitive registers the primitive on the given node

Types

type AppendRequest 

type AppendRequest struct {
	Value string `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
}

func (*AppendRequest) Descriptor 

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

func (*AppendRequest) GetValue 

func (m *AppendRequest) GetValue() string

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 ResponseStatus `protobuf:"varint,1,opt,name=status,proto3,enum=atomix.list.service.ResponseStatus" json:"status,omitempty"`
}

func (*AppendResponse) Descriptor 

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

func (*AppendResponse) GetStatus 

func (m *AppendResponse) GetStatus() ResponseStatus

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 ContainsRequest 

type ContainsRequest struct {
	Value string `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
}

func (*ContainsRequest) Descriptor 

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

func (*ContainsRequest) GetValue 

func (m *ContainsRequest) GetValue() string

func (*ContainsRequest) Marshal 

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

func (*ContainsRequest) MarshalTo 

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

func (*ContainsRequest) MarshalToSizedBuffer 

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

func (*ContainsRequest) ProtoMessage 

func (*ContainsRequest) ProtoMessage()

func (*ContainsRequest) Reset 

func (m *ContainsRequest) Reset()

func (*ContainsRequest) Size 

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

func (*ContainsRequest) String 

func (m *ContainsRequest) String() string

func (*ContainsRequest) Unmarshal 

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

func (*ContainsRequest) XXX_DiscardUnknown 

func (m *ContainsRequest) XXX_DiscardUnknown()

func (*ContainsRequest) XXX_Marshal 

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

func (*ContainsRequest) XXX_Merge 

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

func (*ContainsRequest) XXX_Size 

func (m *ContainsRequest) XXX_Size() int

func (*ContainsRequest) XXX_Unmarshal 

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

type ContainsResponse 

type ContainsResponse struct {
	Contains bool `protobuf:"varint,1,opt,name=contains,proto3" json:"contains,omitempty"`
}

func (*ContainsResponse) Descriptor 

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

func (*ContainsResponse) GetContains 

func (m *ContainsResponse) GetContains() bool

func (*ContainsResponse) Marshal 

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

func (*ContainsResponse) MarshalTo 

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

func (*ContainsResponse) MarshalToSizedBuffer 

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

func (*ContainsResponse) ProtoMessage 

func (*ContainsResponse) ProtoMessage()

func (*ContainsResponse) Reset 

func (m *ContainsResponse) Reset()

func (*ContainsResponse) Size 

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

func (*ContainsResponse) String 

func (m *ContainsResponse) String() string

func (*ContainsResponse) Unmarshal 

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

func (*ContainsResponse) XXX_DiscardUnknown 

func (m *ContainsResponse) XXX_DiscardUnknown()

func (*ContainsResponse) XXX_Marshal 

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

func (*ContainsResponse) XXX_Merge 

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

func (*ContainsResponse) XXX_Size 

func (m *ContainsResponse) XXX_Size() int

func (*ContainsResponse) XXX_Unmarshal 

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

type GetRequest 

type GetRequest struct {
	Index uint32 `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() uint32

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 {
	Status ResponseStatus `protobuf:"varint,1,opt,name=status,proto3,enum=atomix.list.service.ResponseStatus" json:"status,omitempty"`
	Value  string         `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
}

func (*GetResponse) Descriptor 

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

func (*GetResponse) GetStatus 

func (m *GetResponse) GetStatus() ResponseStatus

func (*GetResponse) GetValue 

func (m *GetResponse) GetValue() string

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 InsertRequest 

type InsertRequest struct {
	Index uint32 `protobuf:"varint,1,opt,name=index,proto3" json:"index,omitempty"`
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
}

func (*InsertRequest) Descriptor 

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

func (*InsertRequest) GetIndex 

func (m *InsertRequest) GetIndex() uint32

func (*InsertRequest) GetValue 

func (m *InsertRequest) GetValue() string

func (*InsertRequest) Marshal 

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

func (*InsertRequest) MarshalTo 

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

func (*InsertRequest) MarshalToSizedBuffer 

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

func (*InsertRequest) ProtoMessage 

func (*InsertRequest) ProtoMessage()

func (*InsertRequest) Reset 

func (m *InsertRequest) Reset()

func (*InsertRequest) Size 

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

func (*InsertRequest) String 

func (m *InsertRequest) String() string

func (*InsertRequest) Unmarshal 

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

func (*InsertRequest) XXX_DiscardUnknown 

func (m *InsertRequest) XXX_DiscardUnknown()

func (*InsertRequest) XXX_Marshal 

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

func (*InsertRequest) XXX_Merge 

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

func (*InsertRequest) XXX_Size 

func (m *InsertRequest) XXX_Size() int

func (*InsertRequest) XXX_Unmarshal 

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

type InsertResponse 

type InsertResponse struct {
	Status ResponseStatus `protobuf:"varint,1,opt,name=status,proto3,enum=atomix.list.service.ResponseStatus" json:"status,omitempty"`
}

func (*InsertResponse) Descriptor 

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

func (*InsertResponse) GetStatus 

func (m *InsertResponse) GetStatus() ResponseStatus

func (*InsertResponse) Marshal 

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

func (*InsertResponse) MarshalTo 

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

func (*InsertResponse) MarshalToSizedBuffer 

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

func (*InsertResponse) ProtoMessage 

func (*InsertResponse) ProtoMessage()

func (*InsertResponse) Reset 

func (m *InsertResponse) Reset()

func (*InsertResponse) Size 

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

func (*InsertResponse) String 

func (m *InsertResponse) String() string

func (*InsertResponse) Unmarshal 

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

func (*InsertResponse) XXX_DiscardUnknown 

func (m *InsertResponse) XXX_DiscardUnknown()

func (*InsertResponse) XXX_Marshal 

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

func (*InsertResponse) XXX_Merge 

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

func (*InsertResponse) XXX_Size 

func (m *InsertResponse) XXX_Size() int

func (*InsertResponse) XXX_Unmarshal 

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

type IterateRequest 

type IterateRequest struct {
}

func (*IterateRequest) Descriptor 

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

func (*IterateRequest) Marshal 

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

func (*IterateRequest) MarshalTo 

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

func (*IterateRequest) MarshalToSizedBuffer 

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

func (*IterateRequest) ProtoMessage 

func (*IterateRequest) ProtoMessage()

func (*IterateRequest) Reset 

func (m *IterateRequest) Reset()

func (*IterateRequest) Size 

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

func (*IterateRequest) String 

func (m *IterateRequest) String() string

func (*IterateRequest) Unmarshal 

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

func (*IterateRequest) XXX_DiscardUnknown 

func (m *IterateRequest) XXX_DiscardUnknown()

func (*IterateRequest) XXX_Marshal 

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

func (*IterateRequest) XXX_Merge 

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

func (*IterateRequest) XXX_Size 

func (m *IterateRequest) XXX_Size() int

func (*IterateRequest) XXX_Unmarshal 

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

type IterateResponse 

type IterateResponse struct {
	Value string `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
}

func (*IterateResponse) Descriptor 

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

func (*IterateResponse) GetValue 

func (m *IterateResponse) GetValue() string

func (*IterateResponse) Marshal 

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

func (*IterateResponse) MarshalTo 

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

func (*IterateResponse) MarshalToSizedBuffer 

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

func (*IterateResponse) ProtoMessage 

func (*IterateResponse) ProtoMessage()

func (*IterateResponse) Reset 

func (m *IterateResponse) Reset()

func (*IterateResponse) Size 

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

func (*IterateResponse) String 

func (m *IterateResponse) String() string

func (*IterateResponse) Unmarshal 

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

func (*IterateResponse) XXX_DiscardUnknown 

func (m *IterateResponse) XXX_DiscardUnknown()

func (*IterateResponse) XXX_Marshal 

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

func (*IterateResponse) XXX_Merge 

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

func (*IterateResponse) XXX_Size 

func (m *IterateResponse) XXX_Size() int

func (*IterateResponse) XXX_Unmarshal 

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

type ListSnapshot 

type ListSnapshot struct {
	Values []string `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"`
}

List snapshot

func (*ListSnapshot) Descriptor 

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

func (*ListSnapshot) GetValues 

func (m *ListSnapshot) GetValues() []string

func (*ListSnapshot) Marshal 

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

func (*ListSnapshot) MarshalTo 

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

func (*ListSnapshot) MarshalToSizedBuffer 

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

func (*ListSnapshot) ProtoMessage 

func (*ListSnapshot) ProtoMessage()

func (*ListSnapshot) Reset 

func (m *ListSnapshot) Reset()

func (*ListSnapshot) Size 

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

func (*ListSnapshot) String 

func (m *ListSnapshot) String() string

func (*ListSnapshot) Unmarshal 

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

func (*ListSnapshot) XXX_DiscardUnknown 

func (m *ListSnapshot) XXX_DiscardUnknown()

func (*ListSnapshot) XXX_Marshal 

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

func (*ListSnapshot) XXX_Merge 

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

func (*ListSnapshot) XXX_Size 

func (m *ListSnapshot) XXX_Size() int

func (*ListSnapshot) XXX_Unmarshal 

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

type ListenRequest 

type ListenRequest struct {
	Replay bool `protobuf:"varint,1,opt,name=replay,proto3" json:"replay,omitempty"`
}

func (*ListenRequest) Descriptor 

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

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.list.service.ListenResponse_Type" json:"type,omitempty"`
	Index uint32              `protobuf:"varint,2,opt,name=index,proto3" json:"index,omitempty"`
	Value string              `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
}

func (*ListenResponse) Descriptor 

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

func (*ListenResponse) GetIndex 

func (m *ListenResponse) GetIndex() uint32

func (*ListenResponse) GetType 

func (m *ListenResponse) GetType() ListenResponse_Type

func (*ListenResponse) GetValue 

func (m *ListenResponse) GetValue() string

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_ADDED   ListenResponse_Type = 1
	ListenResponse_REMOVED ListenResponse_Type = 2
)

func (ListenResponse_Type) EnumDescriptor 

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

func (ListenResponse_Type) String 

func (x ListenResponse_Type) String() string

type Primitive added in v0.3.0 

type Primitive struct{}

Primitive is the counter primitive

func (*Primitive) NewService added in v0.3.0 

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

NewService creates a new list service

func (*Primitive) RegisterServer added in v0.3.0 

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

RegisterServer registers the list server with the protocol

type RemoveRequest 

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

func (*RemoveRequest) Descriptor 

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

func (*RemoveRequest) GetIndex 

func (m *RemoveRequest) GetIndex() uint32

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 ResponseStatus `protobuf:"varint,1,opt,name=status,proto3,enum=atomix.list.service.ResponseStatus" json:"status,omitempty"`
	Value  string         `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
}

func (*RemoveResponse) Descriptor 

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

func (*RemoveResponse) GetStatus 

func (m *RemoveResponse) GetStatus() ResponseStatus

func (*RemoveResponse) GetValue 

func (m *RemoveResponse) GetValue() string

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 ResponseStatus 

type ResponseStatus int32
const (
	ResponseStatus_OK            ResponseStatus = 0
	ResponseStatus_NOOP          ResponseStatus = 1
	ResponseStatus_WRITE_LOCK    ResponseStatus = 2
	ResponseStatus_OUT_OF_BOUNDS ResponseStatus = 3
)

func (ResponseStatus) EnumDescriptor 

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

func (ResponseStatus) String 

func (x ResponseStatus) String() string

type Server 

type Server struct {
	*primitive.Server
}

Server is an implementation of MapServiceServer for the map primitive

func (*Server) Append 

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

Append adds a value to the end of the list

func (*Server) Clear 

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

Clear removes all indexes from the list

func (*Server) Close 

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

Close closes a session

func (*Server) Contains 

func (s *Server) Contains(ctx context.Context, request *api.ContainsRequest) (*api.ContainsResponse, error)

Contains checks whether the list contains a value

func (*Server) Create 

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

Create opens a new session

func (*Server) Events 

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

Events listens for list change events

func (*Server) Get 

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

Get gets the value at a specific index

func (*Server) Insert 

func (s *Server) Insert(ctx context.Context, request *api.InsertRequest) (*api.InsertResponse, error)

Insert inserts a value at a specific index

func (*Server) Iterate 

func (s *Server) Iterate(request *api.IterateRequest, srv api.ListService_IterateServer) error

Iterate lists all the value in the list

func (*Server) Remove 

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

Remove removes an index from the list

func (*Server) Set 

func (s *Server) Set(ctx context.Context, request *api.SetRequest) (*api.SetResponse, error)

Set sets the value at a specific index

func (*Server) Size 

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

Size gets the number of elements in the list

type Service 

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

Service is a state machine for a list primitive

func (*Service) Append 

func (l *Service) Append(bytes []byte) ([]byte, error)

Append adds a value to the end of the list

func (*Service) Backup 

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

Backup takes a snapshot of the service

func (*Service) Clear 

func (l *Service) Clear(bytes []byte) ([]byte, error)

Clear removes all indexes from the list

func (*Service) Contains 

func (l *Service) Contains(bytes []byte) ([]byte, error)

Contains checks whether the list contains a value

func (*Service) Events 

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

Events registers a channel to send list change events

func (*Service) Get 

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

Get gets the value at a specific index in the list

func (*Service) Insert 

func (l *Service) Insert(bytes []byte) ([]byte, error)

Insert inserts a value at a specific index in the list

func (*Service) Iterate 

func (l *Service) Iterate(bytes []byte, stream primitive.Stream)

Iterate sends all current values on the given channel

func (*Service) Remove 

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

Remove removes an index from the list

func (*Service) Restore 

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

Restore restores the service from a snapshot

func (*Service) Set 

func (l *Service) Set(bytes []byte) ([]byte, error)

Set sets the value at a specific index in the list

func (*Service) Size 

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

Size gets the size of the list

type SetRequest 

type SetRequest struct {
	Index uint32 `protobuf:"varint,1,opt,name=index,proto3" json:"index,omitempty"`
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
}

func (*SetRequest) Descriptor 

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

func (*SetRequest) GetIndex 

func (m *SetRequest) GetIndex() uint32

func (*SetRequest) GetValue 

func (m *SetRequest) GetValue() string

func (*SetRequest) Marshal 

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

func (*SetRequest) MarshalTo 

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

func (*SetRequest) MarshalToSizedBuffer 

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

func (*SetRequest) ProtoMessage 

func (*SetRequest) ProtoMessage()

func (*SetRequest) Reset 

func (m *SetRequest) Reset()

func (*SetRequest) Size 

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

func (*SetRequest) String 

func (m *SetRequest) String() string

func (*SetRequest) Unmarshal 

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

func (*SetRequest) XXX_DiscardUnknown 

func (m *SetRequest) XXX_DiscardUnknown()

func (*SetRequest) XXX_Marshal 

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

func (*SetRequest) XXX_Merge 

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

func (*SetRequest) XXX_Size 

func (m *SetRequest) XXX_Size() int

func (*SetRequest) XXX_Unmarshal 

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

type SetResponse 

type SetResponse struct {
	Status ResponseStatus `protobuf:"varint,1,opt,name=status,proto3,enum=atomix.list.service.ResponseStatus" json:"status,omitempty"`
}

func (*SetResponse) Descriptor 

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

func (*SetResponse) GetStatus 

func (m *SetResponse) GetStatus() ResponseStatus

func (*SetResponse) Marshal 

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

func (*SetResponse) MarshalTo 

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

func (*SetResponse) MarshalToSizedBuffer 

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

func (*SetResponse) ProtoMessage 

func (*SetResponse) ProtoMessage()

func (*SetResponse) Reset 

func (m *SetResponse) Reset()

func (*SetResponse) Size 

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

func (*SetResponse) String 

func (m *SetResponse) String() string

func (*SetResponse) Unmarshal 

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

func (*SetResponse) XXX_DiscardUnknown 

func (m *SetResponse) XXX_DiscardUnknown()

func (*SetResponse) XXX_Marshal 

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

func (*SetResponse) XXX_Merge 

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

func (*SetResponse) XXX_Size 

func (m *SetResponse) XXX_Size() int

func (*SetResponse) XXX_Unmarshal 

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

type SizeRequest 

type SizeRequest struct {
}

func (*SizeRequest) Descriptor 

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

func (*SizeRequest) Marshal 

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

func (*SizeRequest) MarshalTo 

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

func (*SizeRequest) MarshalToSizedBuffer 

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

func (*SizeRequest) ProtoMessage 

func (*SizeRequest) ProtoMessage()

func (*SizeRequest) Reset 

func (m *SizeRequest) Reset()

func (*SizeRequest) Size 

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

func (*SizeRequest) String 

func (m *SizeRequest) String() string

func (*SizeRequest) Unmarshal 

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

func (*SizeRequest) XXX_DiscardUnknown 

func (m *SizeRequest) XXX_DiscardUnknown()

func (*SizeRequest) XXX_Marshal 

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

func (*SizeRequest) XXX_Merge 

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

func (*SizeRequest) XXX_Size 

func (m *SizeRequest) XXX_Size() int

func (*SizeRequest) XXX_Unmarshal 

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

type SizeResponse 

type SizeResponse struct {
	Size_ uint32 `protobuf:"varint,1,opt,name=size,proto3" json:"size,omitempty"`
}

func (*SizeResponse) Descriptor 

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

func (*SizeResponse) GetSize_ 

func (m *SizeResponse) GetSize_() uint32

func (*SizeResponse) Marshal 

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

func (*SizeResponse) MarshalTo 

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

func (*SizeResponse) MarshalToSizedBuffer 

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

func (*SizeResponse) ProtoMessage 

func (*SizeResponse) ProtoMessage()

func (*SizeResponse) Reset 

func (m *SizeResponse) Reset()

func (*SizeResponse) Size 

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

func (*SizeResponse) String 

func (m *SizeResponse) String() string

func (*SizeResponse) Unmarshal 

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

func (*SizeResponse) XXX_DiscardUnknown 

func (m *SizeResponse) XXX_DiscardUnknown()

func (*SizeResponse) XXX_Marshal 

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

func (*SizeResponse) XXX_Merge 

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

func (*SizeResponse) XXX_Size 

func (m *SizeResponse) XXX_Size() int

func (*SizeResponse) XXX_Unmarshal 

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

type UnlistenRequest 

type UnlistenRequest struct {
	StreamId int64 `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() int64

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

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.