set

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 (
	ErrInvalidLengthSet        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowSet          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupSet = 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",
}
View Source 
var ResponseStatus_value = map[string]int32{
	"OK":         0,
	"NOOP":       1,
	"WRITE_LOCK": 2,
}

Functions

func RegisterSetServiceServer 

func RegisterSetServiceServer(s *grpc.Server, srv SetServiceServer)

Types

type AddRequest 

type AddRequest 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 (*AddRequest) Descriptor 

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

func (*AddRequest) GetHeader 

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

func (*AddRequest) GetValue 

func (m *AddRequest) GetValue() string

func (*AddRequest) Marshal 

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

func (*AddRequest) MarshalTo 

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

func (*AddRequest) MarshalToSizedBuffer 

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

func (*AddRequest) ProtoMessage 

func (*AddRequest) ProtoMessage()

func (*AddRequest) Reset 

func (m *AddRequest) Reset()

func (*AddRequest) Size 

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

func (*AddRequest) String 

func (m *AddRequest) String() string

func (*AddRequest) Unmarshal 

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

func (*AddRequest) XXX_DiscardUnknown 

func (m *AddRequest) XXX_DiscardUnknown()

func (*AddRequest) XXX_Marshal 

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

func (*AddRequest) XXX_Merge 

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

func (*AddRequest) XXX_Size 

func (m *AddRequest) XXX_Size() int

func (*AddRequest) XXX_Unmarshal 

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

type AddResponse 

type AddResponse 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.set.ResponseStatus" json:"status,omitempty"`
	Added  bool                    `protobuf:"varint,3,opt,name=added,proto3" json:"added,omitempty"`
}

func (*AddResponse) Descriptor 

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

func (*AddResponse) GetAdded 

func (m *AddResponse) GetAdded() bool

func (*AddResponse) GetHeader 

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

func (*AddResponse) GetStatus 

func (m *AddResponse) GetStatus() ResponseStatus

func (*AddResponse) Marshal 

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

func (*AddResponse) MarshalTo 

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

func (*AddResponse) MarshalToSizedBuffer 

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

func (*AddResponse) ProtoMessage 

func (*AddResponse) ProtoMessage()

func (*AddResponse) Reset 

func (m *AddResponse) Reset()

func (*AddResponse) Size 

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

func (*AddResponse) String 

func (m *AddResponse) String() string

func (*AddResponse) Unmarshal 

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

func (*AddResponse) XXX_DiscardUnknown 

func (m *AddResponse) XXX_DiscardUnknown()

func (*AddResponse) XXX_Marshal 

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

func (*AddResponse) XXX_Merge 

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

func (*AddResponse) XXX_Size 

func (m *AddResponse) XXX_Size() int

func (*AddResponse) XXX_Unmarshal 

func (m *AddResponse) 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.set.EventResponse_Type" json:"type,omitempty"`
	Value  string                  `protobuf:"bytes,3,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) 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 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 RemoveRequest 

type RemoveRequest 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 (*RemoveRequest) Descriptor 

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

func (*RemoveRequest) GetHeader 

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

func (*RemoveRequest) GetValue 

func (m *RemoveRequest) GetValue() string

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.set.ResponseStatus" json:"status,omitempty"`
	Removed bool                    `protobuf:"varint,3,opt,name=removed,proto3" json:"removed,omitempty"`
}

func (*RemoveResponse) Descriptor 

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

func (*RemoveResponse) GetHeader 

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

func (*RemoveResponse) GetRemoved 

func (m *RemoveResponse) GetRemoved() bool

func (*RemoveResponse) GetStatus 

func (m *RemoveResponse) GetStatus() ResponseStatus

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
)

func (ResponseStatus) EnumDescriptor 

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

func (ResponseStatus) String 

func (x ResponseStatus) String() string

type SetServiceClient 

type SetServiceClient interface {
	Create(ctx context.Context, in *CreateRequest, opts ...grpc.CallOption) (*CreateResponse, error)
	KeepAlive(ctx context.Context, in *KeepAliveRequest, opts ...grpc.CallOption) (*KeepAliveResponse, error)
	Close(ctx context.Context, in *CloseRequest, opts ...grpc.CallOption) (*CloseResponse, error)
	Size(ctx context.Context, in *SizeRequest, opts ...grpc.CallOption) (*SizeResponse, error)
	Contains(ctx context.Context, in *ContainsRequest, opts ...grpc.CallOption) (*ContainsResponse, error)
	Add(ctx context.Context, in *AddRequest, opts ...grpc.CallOption) (*AddResponse, error)
	Remove(ctx context.Context, in *RemoveRequest, opts ...grpc.CallOption) (*RemoveResponse, error)
	Clear(ctx context.Context, in *ClearRequest, opts ...grpc.CallOption) (*ClearResponse, error)
	Events(ctx context.Context, in *EventRequest, opts ...grpc.CallOption) (SetService_EventsClient, error)
	Iterate(ctx context.Context, in *IterateRequest, opts ...grpc.CallOption) (SetService_IterateClient, error)
}

SetServiceClient is the client API for SetService service.

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

func NewSetServiceClient 

func NewSetServiceClient(cc *grpc.ClientConn) SetServiceClient

type SetServiceServer 

type SetServiceServer interface {
	Create(context.Context, *CreateRequest) (*CreateResponse, error)
	KeepAlive(context.Context, *KeepAliveRequest) (*KeepAliveResponse, error)
	Close(context.Context, *CloseRequest) (*CloseResponse, error)
	Size(context.Context, *SizeRequest) (*SizeResponse, error)
	Contains(context.Context, *ContainsRequest) (*ContainsResponse, error)
	Add(context.Context, *AddRequest) (*AddResponse, error)
	Remove(context.Context, *RemoveRequest) (*RemoveResponse, error)
	Clear(context.Context, *ClearRequest) (*ClearResponse, error)
	Events(*EventRequest, SetService_EventsServer) error
	Iterate(*IterateRequest, SetService_IterateServer) error
}

SetServiceServer is the server API for SetService service.

type SetService_EventsClient 

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

type SetService_EventsServer 

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

type SetService_IterateClient 

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

type SetService_IterateServer 

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

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 UnimplementedSetServiceServer 

type UnimplementedSetServiceServer struct {
}

UnimplementedSetServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedSetServiceServer) Add 

func (*UnimplementedSetServiceServer) Add(ctx context.Context, req *AddRequest) (*AddResponse, error)

func (*UnimplementedSetServiceServer) Clear 

func (*UnimplementedSetServiceServer) Clear(ctx context.Context, req *ClearRequest) (*ClearResponse, error)

func (*UnimplementedSetServiceServer) Close 

func (*UnimplementedSetServiceServer) Close(ctx context.Context, req *CloseRequest) (*CloseResponse, error)

func (*UnimplementedSetServiceServer) Contains 

func (*UnimplementedSetServiceServer) Contains(ctx context.Context, req *ContainsRequest) (*ContainsResponse, error)

func (*UnimplementedSetServiceServer) Create 

func (*UnimplementedSetServiceServer) Create(ctx context.Context, req *CreateRequest) (*CreateResponse, error)

func (*UnimplementedSetServiceServer) Events 

func (*UnimplementedSetServiceServer) Events(req *EventRequest, srv SetService_EventsServer) error

func (*UnimplementedSetServiceServer) Iterate 

func (*UnimplementedSetServiceServer) Iterate(req *IterateRequest, srv SetService_IterateServer) error

func (*UnimplementedSetServiceServer) KeepAlive 

func (*UnimplementedSetServiceServer) KeepAlive(ctx context.Context, req *KeepAliveRequest) (*KeepAliveResponse, error)

func (*UnimplementedSetServiceServer) Remove 

func (*UnimplementedSetServiceServer) Remove(ctx context.Context, req *RemoveRequest) (*RemoveResponse, error)

func (*UnimplementedSetServiceServer) Size 

func (*UnimplementedSetServiceServer) Size(ctx context.Context, req *SizeRequest) (*SizeResponse, 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.