list

package
v0.0.0-...-4e5fb1c Latest Latest
Warning

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

Go to latest
Published: Jan 23, 2020 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

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 EventResponse_Type_name = map[int32]string{
	0: "NONE",
	1: "ADDED",
	2: "REMOVED",
}
View Source
var EventResponse_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 RegisterListServiceServer

func RegisterListServiceServer(s *grpc.Server, srv ListServiceServer)

Types

type AppendRequest

type AppendRequest struct {
	Header *headers.RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Value  string                 `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
}

func (*AppendRequest) Descriptor

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

func (*AppendRequest) GetHeader

func (m *AppendRequest) GetHeader() *headers.RequestHeader

func (*AppendRequest) 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 {
	Header *headers.ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Status ResponseStatus          `protobuf:"varint,2,opt,name=status,proto3,enum=atomix.list.ResponseStatus" json:"status,omitempty"`
}

func (*AppendResponse) Descriptor

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

func (*AppendResponse) GetHeader

func (m *AppendResponse) GetHeader() *headers.ResponseHeader

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 {
	Header *headers.RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
}

func (*ClearRequest) Descriptor

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

func (*ClearRequest) GetHeader

func (m *ClearRequest) GetHeader() *headers.RequestHeader

func (*ClearRequest) Marshal

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

func (*ClearRequest) 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 {
	Header *headers.ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
}

func (*ClearResponse) Descriptor

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

func (*ClearResponse) GetHeader

func (m *ClearResponse) GetHeader() *headers.ResponseHeader

func (*ClearResponse) Marshal

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

func (*ClearResponse) 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 CloseRequest

type CloseRequest struct {
	Header *headers.RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Delete bool                   `protobuf:"varint,2,opt,name=delete,proto3" json:"delete,omitempty"`
}

func (*CloseRequest) Descriptor

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

func (*CloseRequest) GetDelete

func (m *CloseRequest) GetDelete() bool

func (*CloseRequest) GetHeader

func (m *CloseRequest) GetHeader() *headers.RequestHeader

func (*CloseRequest) Marshal

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

func (*CloseRequest) MarshalTo

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

func (*CloseRequest) MarshalToSizedBuffer

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

func (*CloseRequest) ProtoMessage

func (*CloseRequest) ProtoMessage()

func (*CloseRequest) Reset

func (m *CloseRequest) Reset()

func (*CloseRequest) Size

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

func (*CloseRequest) String

func (m *CloseRequest) String() string

func (*CloseRequest) Unmarshal

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

func (*CloseRequest) XXX_DiscardUnknown

func (m *CloseRequest) XXX_DiscardUnknown()

func (*CloseRequest) XXX_Marshal

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

func (*CloseRequest) XXX_Merge

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

func (*CloseRequest) XXX_Size

func (m *CloseRequest) XXX_Size() int

func (*CloseRequest) XXX_Unmarshal

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

type CloseResponse

type CloseResponse struct {
	Header *headers.ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
}

func (*CloseResponse) Descriptor

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

func (*CloseResponse) GetHeader

func (m *CloseResponse) GetHeader() *headers.ResponseHeader

func (*CloseResponse) Marshal

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

func (*CloseResponse) MarshalTo

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

func (*CloseResponse) MarshalToSizedBuffer

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

func (*CloseResponse) ProtoMessage

func (*CloseResponse) ProtoMessage()

func (*CloseResponse) Reset

func (m *CloseResponse) Reset()

func (*CloseResponse) Size

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

func (*CloseResponse) String

func (m *CloseResponse) String() string

func (*CloseResponse) Unmarshal

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

func (*CloseResponse) XXX_DiscardUnknown

func (m *CloseResponse) XXX_DiscardUnknown()

func (*CloseResponse) XXX_Marshal

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

func (*CloseResponse) XXX_Merge

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

func (*CloseResponse) XXX_Size

func (m *CloseResponse) XXX_Size() int

func (*CloseResponse) XXX_Unmarshal

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

type ContainsRequest

type ContainsRequest struct {
	Header *headers.RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Value  string                 `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
}

func (*ContainsRequest) Descriptor

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

func (*ContainsRequest) GetHeader

func (m *ContainsRequest) GetHeader() *headers.RequestHeader

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 {
	Header   *headers.ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Contains bool                    `protobuf:"varint,2,opt,name=contains,proto3" json:"contains,omitempty"`
}

func (*ContainsResponse) Descriptor

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

func (*ContainsResponse) GetContains

func (m *ContainsResponse) GetContains() bool

func (*ContainsResponse) GetHeader

func (m *ContainsResponse) GetHeader() *headers.ResponseHeader

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 CreateRequest

type CreateRequest struct {
	Header  *headers.RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Timeout *time.Duration         `protobuf:"bytes,2,opt,name=timeout,proto3,stdduration" json:"timeout,omitempty"`
}

func (*CreateRequest) Descriptor

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

func (*CreateRequest) GetHeader

func (m *CreateRequest) GetHeader() *headers.RequestHeader

func (*CreateRequest) GetTimeout

func (m *CreateRequest) GetTimeout() *time.Duration

func (*CreateRequest) Marshal

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

func (*CreateRequest) MarshalTo

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

func (*CreateRequest) MarshalToSizedBuffer

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

func (*CreateRequest) ProtoMessage

func (*CreateRequest) ProtoMessage()

func (*CreateRequest) Reset

func (m *CreateRequest) Reset()

func (*CreateRequest) Size

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

func (*CreateRequest) String

func (m *CreateRequest) String() string

func (*CreateRequest) Unmarshal

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

func (*CreateRequest) XXX_DiscardUnknown

func (m *CreateRequest) XXX_DiscardUnknown()

func (*CreateRequest) XXX_Marshal

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

func (*CreateRequest) XXX_Merge

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

func (*CreateRequest) XXX_Size

func (m *CreateRequest) XXX_Size() int

func (*CreateRequest) XXX_Unmarshal

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

type CreateResponse

type CreateResponse struct {
	Header *headers.ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
}

func (*CreateResponse) Descriptor

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

func (*CreateResponse) GetHeader

func (m *CreateResponse) GetHeader() *headers.ResponseHeader

func (*CreateResponse) Marshal

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

func (*CreateResponse) MarshalTo

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

func (*CreateResponse) MarshalToSizedBuffer

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

func (*CreateResponse) ProtoMessage

func (*CreateResponse) ProtoMessage()

func (*CreateResponse) Reset

func (m *CreateResponse) Reset()

func (*CreateResponse) Size

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

func (*CreateResponse) String

func (m *CreateResponse) String() string

func (*CreateResponse) Unmarshal

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

func (*CreateResponse) XXX_DiscardUnknown

func (m *CreateResponse) XXX_DiscardUnknown()

func (*CreateResponse) XXX_Marshal

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

func (*CreateResponse) XXX_Merge

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

func (*CreateResponse) XXX_Size

func (m *CreateResponse) XXX_Size() int

func (*CreateResponse) XXX_Unmarshal

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

type EventRequest

type EventRequest struct {
	Header *headers.RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Replay bool                   `protobuf:"varint,2,opt,name=replay,proto3" json:"replay,omitempty"`
}

func (*EventRequest) Descriptor

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

func (*EventRequest) GetHeader

func (m *EventRequest) GetHeader() *headers.RequestHeader

func (*EventRequest) GetReplay

func (m *EventRequest) GetReplay() bool

func (*EventRequest) Marshal

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

func (*EventRequest) MarshalTo

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

func (*EventRequest) MarshalToSizedBuffer

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

func (*EventRequest) ProtoMessage

func (*EventRequest) ProtoMessage()

func (*EventRequest) Reset

func (m *EventRequest) Reset()

func (*EventRequest) Size

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

func (*EventRequest) String

func (m *EventRequest) String() string

func (*EventRequest) Unmarshal

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

func (*EventRequest) XXX_DiscardUnknown

func (m *EventRequest) XXX_DiscardUnknown()

func (*EventRequest) XXX_Marshal

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

func (*EventRequest) XXX_Merge

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

func (*EventRequest) XXX_Size

func (m *EventRequest) XXX_Size() int

func (*EventRequest) XXX_Unmarshal

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

type EventResponse

type EventResponse struct {
	Header *headers.ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Type   EventResponse_Type      `protobuf:"varint,2,opt,name=type,proto3,enum=atomix.list.EventResponse_Type" json:"type,omitempty"`
	Index  uint32                  `protobuf:"varint,3,opt,name=index,proto3" json:"index,omitempty"`
	Value  string                  `protobuf:"bytes,4,opt,name=value,proto3" json:"value,omitempty"`
}

func (*EventResponse) Descriptor

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

func (*EventResponse) GetHeader

func (m *EventResponse) GetHeader() *headers.ResponseHeader

func (*EventResponse) GetIndex

func (m *EventResponse) GetIndex() uint32

func (*EventResponse) GetType

func (m *EventResponse) GetType() EventResponse_Type

func (*EventResponse) GetValue

func (m *EventResponse) GetValue() string

func (*EventResponse) Marshal

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

func (*EventResponse) MarshalTo

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

func (*EventResponse) MarshalToSizedBuffer

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

func (*EventResponse) ProtoMessage

func (*EventResponse) ProtoMessage()

func (*EventResponse) Reset

func (m *EventResponse) Reset()

func (*EventResponse) Size

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

func (*EventResponse) String

func (m *EventResponse) String() string

func (*EventResponse) Unmarshal

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

func (*EventResponse) XXX_DiscardUnknown

func (m *EventResponse) XXX_DiscardUnknown()

func (*EventResponse) XXX_Marshal

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

func (*EventResponse) XXX_Merge

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

func (*EventResponse) XXX_Size

func (m *EventResponse) XXX_Size() int

func (*EventResponse) XXX_Unmarshal

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

type EventResponse_Type

type EventResponse_Type int32
const (
	EventResponse_NONE    EventResponse_Type = 0
	EventResponse_ADDED   EventResponse_Type = 1
	EventResponse_REMOVED EventResponse_Type = 2
)

func (EventResponse_Type) EnumDescriptor

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

func (EventResponse_Type) String

func (x EventResponse_Type) String() string

type GetRequest

type GetRequest struct {
	Header *headers.RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Index  uint32                 `protobuf:"varint,2,opt,name=index,proto3" json:"index,omitempty"`
}

func (*GetRequest) Descriptor

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

func (*GetRequest) GetHeader

func (m *GetRequest) GetHeader() *headers.RequestHeader

func (*GetRequest) GetIndex

func (m *GetRequest) GetIndex() 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 {
	Header *headers.ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Status ResponseStatus          `protobuf:"varint,2,opt,name=status,proto3,enum=atomix.list.ResponseStatus" json:"status,omitempty"`
	Value  string                  `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
}

func (*GetResponse) Descriptor

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

func (*GetResponse) GetHeader

func (m *GetResponse) GetHeader() *headers.ResponseHeader

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 {
	Header *headers.RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,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 (*InsertRequest) Descriptor

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

func (*InsertRequest) GetHeader

func (m *InsertRequest) GetHeader() *headers.RequestHeader

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 {
	Header *headers.ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Status ResponseStatus          `protobuf:"varint,2,opt,name=status,proto3,enum=atomix.list.ResponseStatus" json:"status,omitempty"`
}

func (*InsertResponse) Descriptor

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

func (*InsertResponse) GetHeader

func (m *InsertResponse) GetHeader() *headers.ResponseHeader

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 {
	Header *headers.RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
}

func (*IterateRequest) Descriptor

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

func (*IterateRequest) GetHeader

func (m *IterateRequest) GetHeader() *headers.RequestHeader

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 {
	Header *headers.ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Value  string                  `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
}

func (*IterateResponse) Descriptor

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

func (*IterateResponse) GetHeader

func (m *IterateResponse) GetHeader() *headers.ResponseHeader

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 KeepAliveRequest

type KeepAliveRequest struct {
	Header *headers.RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
}

func (*KeepAliveRequest) Descriptor

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

func (*KeepAliveRequest) GetHeader

func (m *KeepAliveRequest) GetHeader() *headers.RequestHeader

func (*KeepAliveRequest) Marshal

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

func (*KeepAliveRequest) MarshalTo

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

func (*KeepAliveRequest) MarshalToSizedBuffer

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

func (*KeepAliveRequest) ProtoMessage

func (*KeepAliveRequest) ProtoMessage()

func (*KeepAliveRequest) Reset

func (m *KeepAliveRequest) Reset()

func (*KeepAliveRequest) Size

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

func (*KeepAliveRequest) String

func (m *KeepAliveRequest) String() string

func (*KeepAliveRequest) Unmarshal

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

func (*KeepAliveRequest) XXX_DiscardUnknown

func (m *KeepAliveRequest) XXX_DiscardUnknown()

func (*KeepAliveRequest) XXX_Marshal

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

func (*KeepAliveRequest) XXX_Merge

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

func (*KeepAliveRequest) XXX_Size

func (m *KeepAliveRequest) XXX_Size() int

func (*KeepAliveRequest) XXX_Unmarshal

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

type KeepAliveResponse

type KeepAliveResponse struct {
	Header *headers.ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
}

func (*KeepAliveResponse) Descriptor

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

func (*KeepAliveResponse) GetHeader

func (m *KeepAliveResponse) GetHeader() *headers.ResponseHeader

func (*KeepAliveResponse) Marshal

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

func (*KeepAliveResponse) MarshalTo

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

func (*KeepAliveResponse) MarshalToSizedBuffer

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

func (*KeepAliveResponse) ProtoMessage

func (*KeepAliveResponse) ProtoMessage()

func (*KeepAliveResponse) Reset

func (m *KeepAliveResponse) Reset()

func (*KeepAliveResponse) Size

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

func (*KeepAliveResponse) String

func (m *KeepAliveResponse) String() string

func (*KeepAliveResponse) Unmarshal

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

func (*KeepAliveResponse) XXX_DiscardUnknown

func (m *KeepAliveResponse) XXX_DiscardUnknown()

func (*KeepAliveResponse) XXX_Marshal

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

func (*KeepAliveResponse) XXX_Merge

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

func (*KeepAliveResponse) XXX_Size

func (m *KeepAliveResponse) XXX_Size() int

func (*KeepAliveResponse) XXX_Unmarshal

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

type ListServiceClient

ListServiceClient is the client API for ListService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewListServiceClient

func NewListServiceClient(cc *grpc.ClientConn) ListServiceClient

type ListService_EventsClient

type ListService_EventsClient interface {
	Recv() (*EventResponse, error)
	grpc.ClientStream
}

type ListService_EventsServer

type ListService_EventsServer interface {
	Send(*EventResponse) error
	grpc.ServerStream
}

type ListService_IterateClient

type ListService_IterateClient interface {
	Recv() (*IterateResponse, error)
	grpc.ClientStream
}

type ListService_IterateServer

type ListService_IterateServer interface {
	Send(*IterateResponse) error
	grpc.ServerStream
}

type RemoveRequest

type RemoveRequest struct {
	Header *headers.RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Index  uint32                 `protobuf:"varint,2,opt,name=index,proto3" json:"index,omitempty"`
}

func (*RemoveRequest) Descriptor

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

func (*RemoveRequest) GetHeader

func (m *RemoveRequest) GetHeader() *headers.RequestHeader

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

func (*RemoveResponse) Descriptor

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

func (*RemoveResponse) GetHeader

func (m *RemoveResponse) GetHeader() *headers.ResponseHeader

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 SetRequest

type SetRequest struct {
	Header *headers.RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,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 (*SetRequest) Descriptor

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

func (*SetRequest) GetHeader

func (m *SetRequest) GetHeader() *headers.RequestHeader

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 {
	Header *headers.ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Status ResponseStatus          `protobuf:"varint,2,opt,name=status,proto3,enum=atomix.list.ResponseStatus" json:"status,omitempty"`
}

func (*SetResponse) Descriptor

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

func (*SetResponse) GetHeader

func (m *SetResponse) GetHeader() *headers.ResponseHeader

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 {
	Header *headers.RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
}

func (*SizeRequest) Descriptor

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

func (*SizeRequest) GetHeader

func (m *SizeRequest) GetHeader() *headers.RequestHeader

func (*SizeRequest) Marshal

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

func (*SizeRequest) 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 {
	Header *headers.ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Size_  int32                   `protobuf:"varint,2,opt,name=size,proto3" json:"size,omitempty"`
}

func (*SizeResponse) Descriptor

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

func (*SizeResponse) GetHeader

func (m *SizeResponse) GetHeader() *headers.ResponseHeader

func (*SizeResponse) GetSize_

func (m *SizeResponse) GetSize_() int32

func (*SizeResponse) Marshal

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

func (*SizeResponse) 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 UnimplementedListServiceServer

type UnimplementedListServiceServer struct {
}

UnimplementedListServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedListServiceServer) Append

func (*UnimplementedListServiceServer) Clear

func (*UnimplementedListServiceServer) Close

func (*UnimplementedListServiceServer) Contains

func (*UnimplementedListServiceServer) Create

func (*UnimplementedListServiceServer) Events

func (*UnimplementedListServiceServer) Get

func (*UnimplementedListServiceServer) Insert

func (*UnimplementedListServiceServer) Iterate

func (*UnimplementedListServiceServer) KeepAlive

func (*UnimplementedListServiceServer) Remove

func (*UnimplementedListServiceServer) Set

func (*UnimplementedListServiceServer) Size

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL