Documentation
¶
Index ¶
- Variables
- func RegisterValueServiceServer(s *grpc.Server, srv ValueServiceServer)
- type CloseRequest
- func (*CloseRequest) Descriptor() ([]byte, []int)
- func (m *CloseRequest) GetDelete() bool
- func (m *CloseRequest) GetHeader() *headers.RequestHeader
- func (m *CloseRequest) Marshal() (dAtA []byte, err error)
- func (m *CloseRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *CloseRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*CloseRequest) ProtoMessage()
- func (m *CloseRequest) Reset()
- func (m *CloseRequest) Size() (n int)
- func (m *CloseRequest) String() string
- func (m *CloseRequest) Unmarshal(dAtA []byte) error
- func (m *CloseRequest) XXX_DiscardUnknown()
- func (m *CloseRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CloseRequest) XXX_Merge(src proto.Message)
- func (m *CloseRequest) XXX_Size() int
- func (m *CloseRequest) XXX_Unmarshal(b []byte) error
- type CloseResponse
- func (*CloseResponse) Descriptor() ([]byte, []int)
- func (m *CloseResponse) GetHeader() *headers.ResponseHeader
- func (m *CloseResponse) Marshal() (dAtA []byte, err error)
- func (m *CloseResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *CloseResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*CloseResponse) ProtoMessage()
- func (m *CloseResponse) Reset()
- func (m *CloseResponse) Size() (n int)
- func (m *CloseResponse) String() string
- func (m *CloseResponse) Unmarshal(dAtA []byte) error
- func (m *CloseResponse) XXX_DiscardUnknown()
- func (m *CloseResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CloseResponse) XXX_Merge(src proto.Message)
- func (m *CloseResponse) XXX_Size() int
- func (m *CloseResponse) XXX_Unmarshal(b []byte) error
- type CreateRequest
- func (*CreateRequest) Descriptor() ([]byte, []int)
- func (m *CreateRequest) GetHeader() *headers.RequestHeader
- func (m *CreateRequest) GetTimeout() *time.Duration
- func (m *CreateRequest) Marshal() (dAtA []byte, err error)
- func (m *CreateRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *CreateRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*CreateRequest) ProtoMessage()
- func (m *CreateRequest) Reset()
- func (m *CreateRequest) Size() (n int)
- func (m *CreateRequest) String() string
- func (m *CreateRequest) Unmarshal(dAtA []byte) error
- func (m *CreateRequest) XXX_DiscardUnknown()
- func (m *CreateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CreateRequest) XXX_Merge(src proto.Message)
- func (m *CreateRequest) XXX_Size() int
- func (m *CreateRequest) XXX_Unmarshal(b []byte) error
- type CreateResponse
- func (*CreateResponse) Descriptor() ([]byte, []int)
- func (m *CreateResponse) GetHeader() *headers.ResponseHeader
- func (m *CreateResponse) Marshal() (dAtA []byte, err error)
- func (m *CreateResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *CreateResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*CreateResponse) ProtoMessage()
- func (m *CreateResponse) Reset()
- func (m *CreateResponse) Size() (n int)
- func (m *CreateResponse) String() string
- func (m *CreateResponse) Unmarshal(dAtA []byte) error
- func (m *CreateResponse) XXX_DiscardUnknown()
- func (m *CreateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CreateResponse) XXX_Merge(src proto.Message)
- func (m *CreateResponse) XXX_Size() int
- func (m *CreateResponse) XXX_Unmarshal(b []byte) error
- type EventRequest
- func (*EventRequest) Descriptor() ([]byte, []int)
- func (m *EventRequest) GetHeader() *headers.RequestHeader
- func (m *EventRequest) Marshal() (dAtA []byte, err error)
- func (m *EventRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *EventRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*EventRequest) ProtoMessage()
- func (m *EventRequest) Reset()
- func (m *EventRequest) Size() (n int)
- func (m *EventRequest) String() string
- func (m *EventRequest) Unmarshal(dAtA []byte) error
- func (m *EventRequest) XXX_DiscardUnknown()
- func (m *EventRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *EventRequest) XXX_Merge(src proto.Message)
- func (m *EventRequest) XXX_Size() int
- func (m *EventRequest) XXX_Unmarshal(b []byte) error
- type EventResponse
- func (*EventResponse) Descriptor() ([]byte, []int)
- func (m *EventResponse) GetHeader() *headers.ResponseHeader
- func (m *EventResponse) GetNewValue() []byte
- func (m *EventResponse) GetNewVersion() uint64
- func (m *EventResponse) GetPreviousValue() []byte
- func (m *EventResponse) GetPreviousVersion() uint64
- func (m *EventResponse) GetType() EventResponse_Type
- func (m *EventResponse) Marshal() (dAtA []byte, err error)
- func (m *EventResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *EventResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*EventResponse) ProtoMessage()
- func (m *EventResponse) Reset()
- func (m *EventResponse) Size() (n int)
- func (m *EventResponse) String() string
- func (m *EventResponse) Unmarshal(dAtA []byte) error
- func (m *EventResponse) XXX_DiscardUnknown()
- func (m *EventResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *EventResponse) XXX_Merge(src proto.Message)
- func (m *EventResponse) XXX_Size() int
- func (m *EventResponse) XXX_Unmarshal(b []byte) error
- type EventResponse_Type
- type GetRequest
- func (*GetRequest) Descriptor() ([]byte, []int)
- func (m *GetRequest) GetHeader() *headers.RequestHeader
- func (m *GetRequest) Marshal() (dAtA []byte, err error)
- func (m *GetRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *GetRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GetRequest) ProtoMessage()
- func (m *GetRequest) Reset()
- func (m *GetRequest) Size() (n int)
- func (m *GetRequest) String() string
- func (m *GetRequest) Unmarshal(dAtA []byte) error
- func (m *GetRequest) XXX_DiscardUnknown()
- func (m *GetRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetRequest) XXX_Merge(src proto.Message)
- func (m *GetRequest) XXX_Size() int
- func (m *GetRequest) XXX_Unmarshal(b []byte) error
- type GetResponse
- func (*GetResponse) Descriptor() ([]byte, []int)
- func (m *GetResponse) GetHeader() *headers.ResponseHeader
- func (m *GetResponse) GetValue() []byte
- func (m *GetResponse) GetVersion() uint64
- func (m *GetResponse) Marshal() (dAtA []byte, err error)
- func (m *GetResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *GetResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GetResponse) ProtoMessage()
- func (m *GetResponse) Reset()
- func (m *GetResponse) Size() (n int)
- func (m *GetResponse) String() string
- func (m *GetResponse) Unmarshal(dAtA []byte) error
- func (m *GetResponse) XXX_DiscardUnknown()
- func (m *GetResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetResponse) XXX_Merge(src proto.Message)
- func (m *GetResponse) XXX_Size() int
- func (m *GetResponse) XXX_Unmarshal(b []byte) error
- type KeepAliveRequest
- func (*KeepAliveRequest) Descriptor() ([]byte, []int)
- func (m *KeepAliveRequest) GetHeader() *headers.RequestHeader
- func (m *KeepAliveRequest) Marshal() (dAtA []byte, err error)
- func (m *KeepAliveRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *KeepAliveRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*KeepAliveRequest) ProtoMessage()
- func (m *KeepAliveRequest) Reset()
- func (m *KeepAliveRequest) Size() (n int)
- func (m *KeepAliveRequest) String() string
- func (m *KeepAliveRequest) Unmarshal(dAtA []byte) error
- func (m *KeepAliveRequest) XXX_DiscardUnknown()
- func (m *KeepAliveRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *KeepAliveRequest) XXX_Merge(src proto.Message)
- func (m *KeepAliveRequest) XXX_Size() int
- func (m *KeepAliveRequest) XXX_Unmarshal(b []byte) error
- type KeepAliveResponse
- func (*KeepAliveResponse) Descriptor() ([]byte, []int)
- func (m *KeepAliveResponse) GetHeader() *headers.ResponseHeader
- func (m *KeepAliveResponse) Marshal() (dAtA []byte, err error)
- func (m *KeepAliveResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *KeepAliveResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*KeepAliveResponse) ProtoMessage()
- func (m *KeepAliveResponse) Reset()
- func (m *KeepAliveResponse) Size() (n int)
- func (m *KeepAliveResponse) String() string
- func (m *KeepAliveResponse) Unmarshal(dAtA []byte) error
- func (m *KeepAliveResponse) XXX_DiscardUnknown()
- func (m *KeepAliveResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *KeepAliveResponse) XXX_Merge(src proto.Message)
- func (m *KeepAliveResponse) XXX_Size() int
- func (m *KeepAliveResponse) XXX_Unmarshal(b []byte) error
- type SetRequest
- func (*SetRequest) Descriptor() ([]byte, []int)
- func (m *SetRequest) GetExpectValue() []byte
- func (m *SetRequest) GetExpectVersion() uint64
- func (m *SetRequest) GetHeader() *headers.RequestHeader
- func (m *SetRequest) GetValue() []byte
- func (m *SetRequest) Marshal() (dAtA []byte, err error)
- func (m *SetRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *SetRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*SetRequest) ProtoMessage()
- func (m *SetRequest) Reset()
- func (m *SetRequest) Size() (n int)
- func (m *SetRequest) String() string
- func (m *SetRequest) Unmarshal(dAtA []byte) error
- func (m *SetRequest) XXX_DiscardUnknown()
- func (m *SetRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SetRequest) XXX_Merge(src proto.Message)
- func (m *SetRequest) XXX_Size() int
- func (m *SetRequest) XXX_Unmarshal(b []byte) error
- type SetResponse
- func (*SetResponse) Descriptor() ([]byte, []int)
- func (m *SetResponse) GetHeader() *headers.ResponseHeader
- func (m *SetResponse) GetSucceeded() bool
- func (m *SetResponse) GetVersion() uint64
- func (m *SetResponse) Marshal() (dAtA []byte, err error)
- func (m *SetResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *SetResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*SetResponse) ProtoMessage()
- func (m *SetResponse) Reset()
- func (m *SetResponse) Size() (n int)
- func (m *SetResponse) String() string
- func (m *SetResponse) Unmarshal(dAtA []byte) error
- func (m *SetResponse) XXX_DiscardUnknown()
- func (m *SetResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SetResponse) XXX_Merge(src proto.Message)
- func (m *SetResponse) XXX_Size() int
- func (m *SetResponse) XXX_Unmarshal(b []byte) error
- type UnimplementedValueServiceServer
- func (*UnimplementedValueServiceServer) Close(ctx context.Context, req *CloseRequest) (*CloseResponse, error)
- func (*UnimplementedValueServiceServer) Create(ctx context.Context, req *CreateRequest) (*CreateResponse, error)
- func (*UnimplementedValueServiceServer) Events(req *EventRequest, srv ValueService_EventsServer) error
- func (*UnimplementedValueServiceServer) Get(ctx context.Context, req *GetRequest) (*GetResponse, error)
- func (*UnimplementedValueServiceServer) KeepAlive(ctx context.Context, req *KeepAliveRequest) (*KeepAliveResponse, error)
- func (*UnimplementedValueServiceServer) Set(ctx context.Context, req *SetRequest) (*SetResponse, error)
- type ValueServiceClient
- type ValueServiceServer
- type ValueService_EventsClient
- type ValueService_EventsServer
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrInvalidLengthValue = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowValue = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupValue = fmt.Errorf("proto: unexpected end of group") )
View Source
var EventResponse_Type_name = map[int32]string{
0: "UPDATED",
}
View Source
var EventResponse_Type_value = map[string]int32{
"UPDATED": 0,
}
Functions ¶
func RegisterValueServiceServer ¶
func RegisterValueServiceServer(s *grpc.Server, srv ValueServiceServer)
Types ¶
type CloseRequest ¶
type CloseRequest struct { Header *headers.RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` Delete bool `protobuf:"varint,2,opt,name=delete,proto3" json:"delete,omitempty"` }
func (*CloseRequest) Descriptor ¶
func (*CloseRequest) Descriptor() ([]byte, []int)
func (*CloseRequest) GetDelete ¶
func (m *CloseRequest) GetDelete() bool
func (*CloseRequest) GetHeader ¶
func (m *CloseRequest) GetHeader() *headers.RequestHeader
func (*CloseRequest) Marshal ¶
func (m *CloseRequest) Marshal() (dAtA []byte, err error)
func (*CloseRequest) MarshalToSizedBuffer ¶
func (m *CloseRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*CloseRequest) ProtoMessage ¶
func (*CloseRequest) ProtoMessage()
func (*CloseRequest) Reset ¶
func (m *CloseRequest) Reset()
func (*CloseRequest) Size ¶
func (m *CloseRequest) Size() (n int)
func (*CloseRequest) String ¶
func (m *CloseRequest) String() string
func (*CloseRequest) Unmarshal ¶
func (m *CloseRequest) Unmarshal(dAtA []byte) error
func (*CloseRequest) XXX_DiscardUnknown ¶
func (m *CloseRequest) XXX_DiscardUnknown()
func (*CloseRequest) XXX_Marshal ¶
func (m *CloseRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CloseRequest) XXX_Merge ¶
func (m *CloseRequest) XXX_Merge(src proto.Message)
func (*CloseRequest) XXX_Size ¶
func (m *CloseRequest) XXX_Size() int
func (*CloseRequest) XXX_Unmarshal ¶
func (m *CloseRequest) XXX_Unmarshal(b []byte) error
type CloseResponse ¶
type CloseResponse struct {
Header *headers.ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
}
func (*CloseResponse) Descriptor ¶
func (*CloseResponse) Descriptor() ([]byte, []int)
func (*CloseResponse) GetHeader ¶
func (m *CloseResponse) GetHeader() *headers.ResponseHeader
func (*CloseResponse) Marshal ¶
func (m *CloseResponse) Marshal() (dAtA []byte, err error)
func (*CloseResponse) MarshalToSizedBuffer ¶
func (m *CloseResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*CloseResponse) ProtoMessage ¶
func (*CloseResponse) ProtoMessage()
func (*CloseResponse) Reset ¶
func (m *CloseResponse) Reset()
func (*CloseResponse) Size ¶
func (m *CloseResponse) Size() (n int)
func (*CloseResponse) String ¶
func (m *CloseResponse) String() string
func (*CloseResponse) Unmarshal ¶
func (m *CloseResponse) Unmarshal(dAtA []byte) error
func (*CloseResponse) XXX_DiscardUnknown ¶
func (m *CloseResponse) XXX_DiscardUnknown()
func (*CloseResponse) XXX_Marshal ¶
func (m *CloseResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CloseResponse) XXX_Merge ¶
func (m *CloseResponse) XXX_Merge(src proto.Message)
func (*CloseResponse) XXX_Size ¶
func (m *CloseResponse) XXX_Size() int
func (*CloseResponse) XXX_Unmarshal ¶
func (m *CloseResponse) XXX_Unmarshal(b []byte) error
type CreateRequest ¶
type CreateRequest struct { Header *headers.RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` 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) MarshalToSizedBuffer ¶
func (m *CreateRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*CreateRequest) ProtoMessage ¶
func (*CreateRequest) ProtoMessage()
func (*CreateRequest) Reset ¶
func (m *CreateRequest) Reset()
func (*CreateRequest) Size ¶
func (m *CreateRequest) Size() (n int)
func (*CreateRequest) String ¶
func (m *CreateRequest) String() string
func (*CreateRequest) Unmarshal ¶
func (m *CreateRequest) Unmarshal(dAtA []byte) error
func (*CreateRequest) XXX_DiscardUnknown ¶
func (m *CreateRequest) XXX_DiscardUnknown()
func (*CreateRequest) XXX_Marshal ¶
func (m *CreateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CreateRequest) XXX_Merge ¶
func (m *CreateRequest) XXX_Merge(src proto.Message)
func (*CreateRequest) XXX_Size ¶
func (m *CreateRequest) XXX_Size() int
func (*CreateRequest) XXX_Unmarshal ¶
func (m *CreateRequest) XXX_Unmarshal(b []byte) error
type CreateResponse ¶
type CreateResponse struct {
Header *headers.ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
}
func (*CreateResponse) Descriptor ¶
func (*CreateResponse) Descriptor() ([]byte, []int)
func (*CreateResponse) GetHeader ¶
func (m *CreateResponse) GetHeader() *headers.ResponseHeader
func (*CreateResponse) Marshal ¶
func (m *CreateResponse) Marshal() (dAtA []byte, err error)
func (*CreateResponse) MarshalToSizedBuffer ¶
func (m *CreateResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*CreateResponse) ProtoMessage ¶
func (*CreateResponse) ProtoMessage()
func (*CreateResponse) Reset ¶
func (m *CreateResponse) Reset()
func (*CreateResponse) Size ¶
func (m *CreateResponse) Size() (n int)
func (*CreateResponse) String ¶
func (m *CreateResponse) String() string
func (*CreateResponse) Unmarshal ¶
func (m *CreateResponse) Unmarshal(dAtA []byte) error
func (*CreateResponse) XXX_DiscardUnknown ¶
func (m *CreateResponse) XXX_DiscardUnknown()
func (*CreateResponse) XXX_Marshal ¶
func (m *CreateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CreateResponse) XXX_Merge ¶
func (m *CreateResponse) XXX_Merge(src proto.Message)
func (*CreateResponse) XXX_Size ¶
func (m *CreateResponse) XXX_Size() int
func (*CreateResponse) XXX_Unmarshal ¶
func (m *CreateResponse) XXX_Unmarshal(b []byte) error
type EventRequest ¶
type EventRequest struct {
Header *headers.RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
}
func (*EventRequest) Descriptor ¶
func (*EventRequest) Descriptor() ([]byte, []int)
func (*EventRequest) GetHeader ¶
func (m *EventRequest) GetHeader() *headers.RequestHeader
func (*EventRequest) Marshal ¶
func (m *EventRequest) Marshal() (dAtA []byte, err error)
func (*EventRequest) MarshalToSizedBuffer ¶
func (m *EventRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*EventRequest) ProtoMessage ¶
func (*EventRequest) ProtoMessage()
func (*EventRequest) Reset ¶
func (m *EventRequest) Reset()
func (*EventRequest) Size ¶
func (m *EventRequest) Size() (n int)
func (*EventRequest) String ¶
func (m *EventRequest) String() string
func (*EventRequest) Unmarshal ¶
func (m *EventRequest) Unmarshal(dAtA []byte) error
func (*EventRequest) XXX_DiscardUnknown ¶
func (m *EventRequest) XXX_DiscardUnknown()
func (*EventRequest) XXX_Marshal ¶
func (m *EventRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*EventRequest) XXX_Merge ¶
func (m *EventRequest) XXX_Merge(src proto.Message)
func (*EventRequest) XXX_Size ¶
func (m *EventRequest) XXX_Size() int
func (*EventRequest) XXX_Unmarshal ¶
func (m *EventRequest) XXX_Unmarshal(b []byte) error
type EventResponse ¶
type EventResponse struct { Header *headers.ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` Type EventResponse_Type `protobuf:"varint,2,opt,name=type,proto3,enum=atomix.value.EventResponse_Type" json:"type,omitempty"` PreviousValue []byte `protobuf:"bytes,3,opt,name=previous_value,json=previousValue,proto3" json:"previous_value,omitempty"` PreviousVersion uint64 `protobuf:"varint,4,opt,name=previous_version,json=previousVersion,proto3" json:"previous_version,omitempty"` NewValue []byte `protobuf:"bytes,5,opt,name=new_value,json=newValue,proto3" json:"new_value,omitempty"` NewVersion uint64 `protobuf:"varint,6,opt,name=new_version,json=newVersion,proto3" json:"new_version,omitempty"` }
func (*EventResponse) Descriptor ¶
func (*EventResponse) Descriptor() ([]byte, []int)
func (*EventResponse) GetHeader ¶
func (m *EventResponse) GetHeader() *headers.ResponseHeader
func (*EventResponse) GetNewValue ¶
func (m *EventResponse) GetNewValue() []byte
func (*EventResponse) GetNewVersion ¶
func (m *EventResponse) GetNewVersion() uint64
func (*EventResponse) GetPreviousValue ¶
func (m *EventResponse) GetPreviousValue() []byte
func (*EventResponse) GetPreviousVersion ¶
func (m *EventResponse) GetPreviousVersion() uint64
func (*EventResponse) GetType ¶
func (m *EventResponse) GetType() EventResponse_Type
func (*EventResponse) Marshal ¶
func (m *EventResponse) Marshal() (dAtA []byte, err error)
func (*EventResponse) MarshalToSizedBuffer ¶
func (m *EventResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*EventResponse) ProtoMessage ¶
func (*EventResponse) ProtoMessage()
func (*EventResponse) Reset ¶
func (m *EventResponse) Reset()
func (*EventResponse) Size ¶
func (m *EventResponse) Size() (n int)
func (*EventResponse) String ¶
func (m *EventResponse) String() string
func (*EventResponse) Unmarshal ¶
func (m *EventResponse) Unmarshal(dAtA []byte) error
func (*EventResponse) XXX_DiscardUnknown ¶
func (m *EventResponse) XXX_DiscardUnknown()
func (*EventResponse) XXX_Marshal ¶
func (m *EventResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*EventResponse) XXX_Merge ¶
func (m *EventResponse) XXX_Merge(src proto.Message)
func (*EventResponse) XXX_Size ¶
func (m *EventResponse) XXX_Size() int
func (*EventResponse) XXX_Unmarshal ¶
func (m *EventResponse) XXX_Unmarshal(b []byte) error
type EventResponse_Type ¶
type EventResponse_Type int32
const (
EventResponse_UPDATED EventResponse_Type = 0
)
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"`
}
func (*GetRequest) Descriptor ¶
func (*GetRequest) Descriptor() ([]byte, []int)
func (*GetRequest) GetHeader ¶
func (m *GetRequest) GetHeader() *headers.RequestHeader
func (*GetRequest) Marshal ¶
func (m *GetRequest) Marshal() (dAtA []byte, err error)
func (*GetRequest) MarshalToSizedBuffer ¶
func (m *GetRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*GetRequest) ProtoMessage ¶
func (*GetRequest) ProtoMessage()
func (*GetRequest) Reset ¶
func (m *GetRequest) Reset()
func (*GetRequest) Size ¶
func (m *GetRequest) Size() (n int)
func (*GetRequest) String ¶
func (m *GetRequest) String() string
func (*GetRequest) Unmarshal ¶
func (m *GetRequest) Unmarshal(dAtA []byte) error
func (*GetRequest) XXX_DiscardUnknown ¶
func (m *GetRequest) XXX_DiscardUnknown()
func (*GetRequest) XXX_Marshal ¶
func (m *GetRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetRequest) XXX_Merge ¶
func (m *GetRequest) XXX_Merge(src proto.Message)
func (*GetRequest) XXX_Size ¶
func (m *GetRequest) XXX_Size() int
func (*GetRequest) XXX_Unmarshal ¶
func (m *GetRequest) XXX_Unmarshal(b []byte) error
type GetResponse ¶
type GetResponse struct { Header *headers.ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` Value []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"` Version uint64 `protobuf:"varint,3,opt,name=version,proto3" json:"version,omitempty"` }
func (*GetResponse) Descriptor ¶
func (*GetResponse) Descriptor() ([]byte, []int)
func (*GetResponse) GetHeader ¶
func (m *GetResponse) GetHeader() *headers.ResponseHeader
func (*GetResponse) GetValue ¶
func (m *GetResponse) GetValue() []byte
func (*GetResponse) GetVersion ¶
func (m *GetResponse) GetVersion() uint64
func (*GetResponse) Marshal ¶
func (m *GetResponse) Marshal() (dAtA []byte, err error)
func (*GetResponse) MarshalToSizedBuffer ¶
func (m *GetResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*GetResponse) ProtoMessage ¶
func (*GetResponse) ProtoMessage()
func (*GetResponse) Reset ¶
func (m *GetResponse) Reset()
func (*GetResponse) Size ¶
func (m *GetResponse) Size() (n int)
func (*GetResponse) String ¶
func (m *GetResponse) String() string
func (*GetResponse) Unmarshal ¶
func (m *GetResponse) Unmarshal(dAtA []byte) error
func (*GetResponse) XXX_DiscardUnknown ¶
func (m *GetResponse) XXX_DiscardUnknown()
func (*GetResponse) XXX_Marshal ¶
func (m *GetResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetResponse) XXX_Merge ¶
func (m *GetResponse) XXX_Merge(src proto.Message)
func (*GetResponse) XXX_Size ¶
func (m *GetResponse) XXX_Size() int
func (*GetResponse) XXX_Unmarshal ¶
func (m *GetResponse) XXX_Unmarshal(b []byte) error
type 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) 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 SetRequest ¶
type SetRequest struct { Header *headers.RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` ExpectVersion uint64 `protobuf:"varint,2,opt,name=expect_version,json=expectVersion,proto3" json:"expect_version,omitempty"` ExpectValue []byte `protobuf:"bytes,3,opt,name=expect_value,json=expectValue,proto3" json:"expect_value,omitempty"` Value []byte `protobuf:"bytes,4,opt,name=value,proto3" json:"value,omitempty"` }
func (*SetRequest) Descriptor ¶
func (*SetRequest) Descriptor() ([]byte, []int)
func (*SetRequest) GetExpectValue ¶
func (m *SetRequest) GetExpectValue() []byte
func (*SetRequest) GetExpectVersion ¶
func (m *SetRequest) GetExpectVersion() uint64
func (*SetRequest) GetHeader ¶
func (m *SetRequest) GetHeader() *headers.RequestHeader
func (*SetRequest) GetValue ¶
func (m *SetRequest) GetValue() []byte
func (*SetRequest) Marshal ¶
func (m *SetRequest) Marshal() (dAtA []byte, err 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"` Version uint64 `protobuf:"varint,2,opt,name=version,proto3" json:"version,omitempty"` Succeeded bool `protobuf:"varint,3,opt,name=succeeded,proto3" json:"succeeded,omitempty"` }
func (*SetResponse) Descriptor ¶
func (*SetResponse) Descriptor() ([]byte, []int)
func (*SetResponse) GetHeader ¶
func (m *SetResponse) GetHeader() *headers.ResponseHeader
func (*SetResponse) GetSucceeded ¶
func (m *SetResponse) GetSucceeded() bool
func (*SetResponse) GetVersion ¶
func (m *SetResponse) GetVersion() uint64
func (*SetResponse) Marshal ¶
func (m *SetResponse) Marshal() (dAtA []byte, err 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 UnimplementedValueServiceServer ¶
type UnimplementedValueServiceServer struct { }
UnimplementedValueServiceServer can be embedded to have forward compatible implementations.
func (*UnimplementedValueServiceServer) Close ¶
func (*UnimplementedValueServiceServer) Close(ctx context.Context, req *CloseRequest) (*CloseResponse, error)
func (*UnimplementedValueServiceServer) Create ¶
func (*UnimplementedValueServiceServer) Create(ctx context.Context, req *CreateRequest) (*CreateResponse, error)
func (*UnimplementedValueServiceServer) Events ¶
func (*UnimplementedValueServiceServer) Events(req *EventRequest, srv ValueService_EventsServer) error
func (*UnimplementedValueServiceServer) Get ¶
func (*UnimplementedValueServiceServer) Get(ctx context.Context, req *GetRequest) (*GetResponse, error)
func (*UnimplementedValueServiceServer) KeepAlive ¶
func (*UnimplementedValueServiceServer) KeepAlive(ctx context.Context, req *KeepAliveRequest) (*KeepAliveResponse, error)
func (*UnimplementedValueServiceServer) Set ¶
func (*UnimplementedValueServiceServer) Set(ctx context.Context, req *SetRequest) (*SetResponse, error)
type ValueServiceClient ¶
type ValueServiceClient 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) Set(ctx context.Context, in *SetRequest, opts ...grpc.CallOption) (*SetResponse, error) Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetResponse, error) Events(ctx context.Context, in *EventRequest, opts ...grpc.CallOption) (ValueService_EventsClient, error) }
ValueServiceClient is the client API for ValueService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewValueServiceClient ¶
func NewValueServiceClient(cc *grpc.ClientConn) ValueServiceClient
type ValueServiceServer ¶
type ValueServiceServer interface { Create(context.Context, *CreateRequest) (*CreateResponse, error) KeepAlive(context.Context, *KeepAliveRequest) (*KeepAliveResponse, error) Close(context.Context, *CloseRequest) (*CloseResponse, error) Set(context.Context, *SetRequest) (*SetResponse, error) Get(context.Context, *GetRequest) (*GetResponse, error) Events(*EventRequest, ValueService_EventsServer) error }
ValueServiceServer is the server API for ValueService service.
type ValueService_EventsClient ¶
type ValueService_EventsClient interface { Recv() (*EventResponse, error) grpc.ClientStream }
type ValueService_EventsServer ¶
type ValueService_EventsServer interface { Send(*EventResponse) error grpc.ServerStream }
Click to show internal directories.
Click to hide internal directories.