value

package
v0.8.0 Latest Latest
Warning

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

 Go to latest Published: Nov 21, 2021 License: Apache-2.0 Imports: 16 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthManager        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowManager          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupManager = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthPrimitive        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowPrimitive          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupPrimitive = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var Event_Type_name = map[int32]string{
	0: "NONE",
	1: "UPDATE",
}
View Source 
var Event_Type_value = map[string]int32{
	"NONE":   0,
	"UPDATE": 1,
}
View Source 
var ValueCacheStrategy_name = map[int32]string{
	0: "NEAR",
	1: "READ_THROUGH",
	2: "WRITE_THROUGH",
	3: "READ_THROUGH_WRITE_THROUGH",
}
View Source 
var ValueCacheStrategy_value = map[string]int32{
	"NEAR":                       0,
	"READ_THROUGH":               1,
	"WRITE_THROUGH":              2,
	"READ_THROUGH_WRITE_THROUGH": 3,
}

Functions

func RegisterValueManagerServer added in v0.7.0 

func RegisterValueManagerServer(s *grpc.Server, srv ValueManagerServer)

func RegisterValueServer 

func RegisterValueServer(s *grpc.Server, srv ValueServer)

Types

type CloseSessionRequest 

type CloseSessionRequest struct {
	SessionID github_com_atomix_atomix_api_go_atomix_primitive_v1.SessionID `` /* 160-byte string literal not displayed */
}

func (*CloseSessionRequest) Descriptor 

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

func (*CloseSessionRequest) GetSessionID 

func (m *CloseSessionRequest) GetSessionID() github_com_atomix_atomix_api_go_atomix_primitive_v1.SessionID

func (*CloseSessionRequest) Marshal 

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

func (*CloseSessionRequest) MarshalTo 

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

func (*CloseSessionRequest) MarshalToSizedBuffer 

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

func (*CloseSessionRequest) ProtoMessage 

func (*CloseSessionRequest) ProtoMessage()

func (*CloseSessionRequest) Reset 

func (m *CloseSessionRequest) Reset()

func (*CloseSessionRequest) Size 

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

func (*CloseSessionRequest) String 

func (m *CloseSessionRequest) String() string

func (*CloseSessionRequest) Unmarshal 

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

func (*CloseSessionRequest) XXX_DiscardUnknown 

func (m *CloseSessionRequest) XXX_DiscardUnknown()

func (*CloseSessionRequest) XXX_Marshal 

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

func (*CloseSessionRequest) XXX_Merge 

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

func (*CloseSessionRequest) XXX_Size 

func (m *CloseSessionRequest) XXX_Size() int

func (*CloseSessionRequest) XXX_Unmarshal 

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

type CloseSessionResponse 

type CloseSessionResponse struct {
}

func (*CloseSessionResponse) Descriptor 

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

func (*CloseSessionResponse) Marshal 

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

func (*CloseSessionResponse) MarshalTo 

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

func (*CloseSessionResponse) MarshalToSizedBuffer 

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

func (*CloseSessionResponse) ProtoMessage 

func (*CloseSessionResponse) ProtoMessage()

func (*CloseSessionResponse) Reset 

func (m *CloseSessionResponse) Reset()

func (*CloseSessionResponse) Size 

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

func (*CloseSessionResponse) String 

func (m *CloseSessionResponse) String() string

func (*CloseSessionResponse) Unmarshal 

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

func (*CloseSessionResponse) XXX_DiscardUnknown 

func (m *CloseSessionResponse) XXX_DiscardUnknown()

func (*CloseSessionResponse) XXX_Marshal 

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

func (*CloseSessionResponse) XXX_Merge 

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

func (*CloseSessionResponse) XXX_Size 

func (m *CloseSessionResponse) XXX_Size() int

func (*CloseSessionResponse) XXX_Unmarshal 

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

type Event 

type Event struct {
	Type  Event_Type `protobuf:"varint,1,opt,name=type,proto3,enum=atomix.primitive.value.v1.Event_Type" json:"type,omitempty"`
	Value Object     `protobuf:"bytes,2,opt,name=value,proto3" json:"value"`
}

func (*Event) Descriptor 

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

func (*Event) GetType 

func (m *Event) GetType() Event_Type

func (*Event) GetValue 

func (m *Event) GetValue() Object

func (*Event) Marshal 

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

func (*Event) MarshalTo 

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

func (*Event) MarshalToSizedBuffer 

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

func (*Event) ProtoMessage 

func (*Event) ProtoMessage()

func (*Event) Reset 

func (m *Event) Reset()

func (*Event) Size 

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

func (*Event) String 

func (m *Event) String() string

func (*Event) Unmarshal 

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

func (*Event) XXX_DiscardUnknown 

func (m *Event) XXX_DiscardUnknown()

func (*Event) XXX_Marshal 

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

func (*Event) XXX_Merge 

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

func (*Event) XXX_Size 

func (m *Event) XXX_Size() int

func (*Event) XXX_Unmarshal 

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

type Event_Type 

type Event_Type int32
const (
	Event_NONE   Event_Type = 0
	Event_UPDATE Event_Type = 1
)

func (Event_Type) EnumDescriptor 

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

func (Event_Type) String 

func (x Event_Type) String() string

type EventsRequest 

type EventsRequest struct {
}

func (*EventsRequest) Descriptor 

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

func (*EventsRequest) Marshal 

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

func (*EventsRequest) MarshalTo 

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

func (*EventsRequest) MarshalToSizedBuffer 

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

func (*EventsRequest) ProtoMessage 

func (*EventsRequest) ProtoMessage()

func (*EventsRequest) Reset 

func (m *EventsRequest) Reset()

func (*EventsRequest) Size 

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

func (*EventsRequest) String 

func (m *EventsRequest) String() string

func (*EventsRequest) Unmarshal 

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

func (*EventsRequest) XXX_DiscardUnknown 

func (m *EventsRequest) XXX_DiscardUnknown()

func (*EventsRequest) XXX_Marshal 

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

func (*EventsRequest) XXX_Merge 

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

func (*EventsRequest) XXX_Size 

func (m *EventsRequest) XXX_Size() int

func (*EventsRequest) XXX_Unmarshal 

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

type EventsResponse 

type EventsResponse struct {
	Event Event `protobuf:"bytes,2,opt,name=event,proto3" json:"event"`
}

func (*EventsResponse) Descriptor 

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

func (*EventsResponse) GetEvent 

func (m *EventsResponse) GetEvent() Event

func (*EventsResponse) Marshal 

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

func (*EventsResponse) MarshalTo 

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

func (*EventsResponse) MarshalToSizedBuffer 

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

func (*EventsResponse) ProtoMessage 

func (*EventsResponse) ProtoMessage()

func (*EventsResponse) Reset 

func (m *EventsResponse) Reset()

func (*EventsResponse) Size 

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

func (*EventsResponse) String 

func (m *EventsResponse) String() string

func (*EventsResponse) Unmarshal 

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

func (*EventsResponse) XXX_DiscardUnknown 

func (m *EventsResponse) XXX_DiscardUnknown()

func (*EventsResponse) XXX_Marshal 

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

func (*EventsResponse) XXX_Merge 

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

func (*EventsResponse) XXX_Size 

func (m *EventsResponse) XXX_Size() int

func (*EventsResponse) XXX_Unmarshal 

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

type GetRequest 

type GetRequest struct {
}

func (*GetRequest) Descriptor 

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

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 {
	Value Object `protobuf:"bytes,2,opt,name=value,proto3" json:"value"`
}

func (*GetResponse) Descriptor 

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

func (*GetResponse) GetValue 

func (m *GetResponse) GetValue() Object

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 Object 

type Object struct {
	v1.ObjectMeta `protobuf:"bytes,1,opt,name=meta,proto3,embedded=meta" json:"meta"`
	Value         []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
}

func (*Object) Descriptor 

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

func (*Object) GetValue 

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

func (*Object) Marshal 

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

func (*Object) MarshalTo 

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

func (*Object) MarshalToSizedBuffer 

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

func (*Object) ProtoMessage 

func (*Object) ProtoMessage()

func (*Object) Reset 

func (m *Object) Reset()

func (*Object) Size 

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

func (*Object) String 

func (m *Object) String() string

func (*Object) Unmarshal 

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

func (*Object) XXX_DiscardUnknown 

func (m *Object) XXX_DiscardUnknown()

func (*Object) XXX_Marshal 

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

func (*Object) XXX_Merge 

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

func (*Object) XXX_Size 

func (m *Object) XXX_Size() int

func (*Object) XXX_Unmarshal 

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

type OpenSessionRequest 

type OpenSessionRequest struct {
	PrimitiveID github_com_atomix_atomix_api_go_atomix_primitive_v1.ID `` /* 158-byte string literal not displayed */
	Options     ValueSessionOptions                                    `protobuf:"bytes,2,opt,name=options,proto3" json:"options"`
}

func (*OpenSessionRequest) Descriptor 

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

func (*OpenSessionRequest) GetOptions 

func (m *OpenSessionRequest) GetOptions() ValueSessionOptions

func (*OpenSessionRequest) GetPrimitiveID 

func (m *OpenSessionRequest) GetPrimitiveID() github_com_atomix_atomix_api_go_atomix_primitive_v1.ID

func (*OpenSessionRequest) Marshal 

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

func (*OpenSessionRequest) MarshalTo 

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

func (*OpenSessionRequest) MarshalToSizedBuffer 

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

func (*OpenSessionRequest) ProtoMessage 

func (*OpenSessionRequest) ProtoMessage()

func (*OpenSessionRequest) Reset 

func (m *OpenSessionRequest) Reset()

func (*OpenSessionRequest) Size 

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

func (*OpenSessionRequest) String 

func (m *OpenSessionRequest) String() string

func (*OpenSessionRequest) Unmarshal 

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

func (*OpenSessionRequest) XXX_DiscardUnknown 

func (m *OpenSessionRequest) XXX_DiscardUnknown()

func (*OpenSessionRequest) XXX_Marshal 

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

func (*OpenSessionRequest) XXX_Merge 

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

func (*OpenSessionRequest) XXX_Size 

func (m *OpenSessionRequest) XXX_Size() int

func (*OpenSessionRequest) XXX_Unmarshal 

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

type OpenSessionResponse 

type OpenSessionResponse struct {
	SessionID github_com_atomix_atomix_api_go_atomix_primitive_v1.SessionID `` /* 160-byte string literal not displayed */
}

func (*OpenSessionResponse) Descriptor 

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

func (*OpenSessionResponse) GetSessionID 

func (m *OpenSessionResponse) GetSessionID() github_com_atomix_atomix_api_go_atomix_primitive_v1.SessionID

func (*OpenSessionResponse) Marshal 

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

func (*OpenSessionResponse) MarshalTo 

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

func (*OpenSessionResponse) MarshalToSizedBuffer 

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

func (*OpenSessionResponse) ProtoMessage 

func (*OpenSessionResponse) ProtoMessage()

func (*OpenSessionResponse) Reset 

func (m *OpenSessionResponse) Reset()

func (*OpenSessionResponse) Size 

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

func (*OpenSessionResponse) String 

func (m *OpenSessionResponse) String() string

func (*OpenSessionResponse) Unmarshal 

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

func (*OpenSessionResponse) XXX_DiscardUnknown 

func (m *OpenSessionResponse) XXX_DiscardUnknown()

func (*OpenSessionResponse) XXX_Marshal 

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

func (*OpenSessionResponse) XXX_Merge 

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

func (*OpenSessionResponse) XXX_Size 

func (m *OpenSessionResponse) XXX_Size() int

func (*OpenSessionResponse) XXX_Unmarshal 

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

type Precondition 

type Precondition struct {
	// Types that are valid to be assigned to Precondition:
	//	*Precondition_Metadata
	Precondition isPrecondition_Precondition `protobuf_oneof:"precondition"`
}

func (*Precondition) Descriptor 

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

func (*Precondition) GetMetadata 

func (m *Precondition) GetMetadata() *v1.ObjectMeta

func (*Precondition) GetPrecondition 

func (m *Precondition) GetPrecondition() isPrecondition_Precondition

func (*Precondition) Marshal 

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

func (*Precondition) MarshalTo 

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

func (*Precondition) MarshalToSizedBuffer 

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

func (*Precondition) ProtoMessage 

func (*Precondition) ProtoMessage()

func (*Precondition) Reset 

func (m *Precondition) Reset()

func (*Precondition) Size 

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

func (*Precondition) String 

func (m *Precondition) String() string

func (*Precondition) Unmarshal 

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

func (*Precondition) XXX_DiscardUnknown 

func (m *Precondition) XXX_DiscardUnknown()

func (*Precondition) XXX_Marshal 

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

func (*Precondition) XXX_Merge 

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

func (*Precondition) XXX_OneofWrappers 

func (*Precondition) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*Precondition) XXX_Size 

func (m *Precondition) XXX_Size() int

func (*Precondition) XXX_Unmarshal 

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

type Precondition_Metadata 

type Precondition_Metadata struct {
	Metadata *v1.ObjectMeta `protobuf:"bytes,1,opt,name=metadata,proto3,oneof" json:"metadata,omitempty"`
}

func (*Precondition_Metadata) MarshalTo 

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

func (*Precondition_Metadata) MarshalToSizedBuffer 

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

func (*Precondition_Metadata) Size 

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

type SetRequest 

type SetRequest struct {
	Value         Object         `protobuf:"bytes,2,opt,name=value,proto3" json:"value"`
	Preconditions []Precondition `protobuf:"bytes,3,rep,name=preconditions,proto3" json:"preconditions"`
}

func (*SetRequest) Descriptor 

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

func (*SetRequest) GetPreconditions 

func (m *SetRequest) GetPreconditions() []Precondition

func (*SetRequest) GetValue 

func (m *SetRequest) GetValue() Object

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 {
	Value Object `protobuf:"bytes,2,opt,name=value,proto3" json:"value"`
}

func (*SetResponse) Descriptor 

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

func (*SetResponse) GetValue 

func (m *SetResponse) GetValue() Object

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 UnimplementedValueManagerServer added in v0.7.0 

type UnimplementedValueManagerServer struct {
}

UnimplementedValueManagerServer can be embedded to have forward compatible implementations.

func (*UnimplementedValueManagerServer) CloseSession added in v0.7.0 

func (*UnimplementedValueManagerServer) CloseSession(ctx context.Context, req *CloseSessionRequest) (*CloseSessionResponse, error)

func (*UnimplementedValueManagerServer) OpenSession added in v0.7.0 

func (*UnimplementedValueManagerServer) OpenSession(ctx context.Context, req *OpenSessionRequest) (*OpenSessionResponse, error)

type UnimplementedValueServer 

type UnimplementedValueServer struct {
}

UnimplementedValueServer can be embedded to have forward compatible implementations.

func (*UnimplementedValueServer) Events 

func (*UnimplementedValueServer) Events(req *EventsRequest, srv Value_EventsServer) error

func (*UnimplementedValueServer) Get 

func (*UnimplementedValueServer) Get(ctx context.Context, req *GetRequest) (*GetResponse, error)

func (*UnimplementedValueServer) Set 

func (*UnimplementedValueServer) Set(ctx context.Context, req *SetRequest) (*SetResponse, error)

type ValueCacheOptions 

type ValueCacheOptions struct {
	Enabled  bool               `protobuf:"varint,1,opt,name=enabled,proto3" json:"enabled,omitempty"`
	Strategy ValueCacheStrategy `protobuf:"varint,2,opt,name=strategy,proto3,enum=atomix.primitive.value.v1.ValueCacheStrategy" json:"strategy,omitempty"`
}

func (*ValueCacheOptions) Descriptor 

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

func (*ValueCacheOptions) GetEnabled 

func (m *ValueCacheOptions) GetEnabled() bool

func (*ValueCacheOptions) GetStrategy 

func (m *ValueCacheOptions) GetStrategy() ValueCacheStrategy

func (*ValueCacheOptions) Marshal 

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

func (*ValueCacheOptions) MarshalTo 

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

func (*ValueCacheOptions) MarshalToSizedBuffer 

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

func (*ValueCacheOptions) ProtoMessage 

func (*ValueCacheOptions) ProtoMessage()

func (*ValueCacheOptions) Reset 

func (m *ValueCacheOptions) Reset()

func (*ValueCacheOptions) Size 

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

func (*ValueCacheOptions) String 

func (m *ValueCacheOptions) String() string

func (*ValueCacheOptions) Unmarshal 

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

func (*ValueCacheOptions) XXX_DiscardUnknown 

func (m *ValueCacheOptions) XXX_DiscardUnknown()

func (*ValueCacheOptions) XXX_Marshal 

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

func (*ValueCacheOptions) XXX_Merge 

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

func (*ValueCacheOptions) XXX_Size 

func (m *ValueCacheOptions) XXX_Size() int

func (*ValueCacheOptions) XXX_Unmarshal 

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

type ValueCacheStrategy 

type ValueCacheStrategy int32
const (
	ValueCacheStrategy_NEAR                       ValueCacheStrategy = 0
	ValueCacheStrategy_READ_THROUGH               ValueCacheStrategy = 1
	ValueCacheStrategy_WRITE_THROUGH              ValueCacheStrategy = 2
	ValueCacheStrategy_READ_THROUGH_WRITE_THROUGH ValueCacheStrategy = 3
)

func (ValueCacheStrategy) EnumDescriptor 

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

func (ValueCacheStrategy) String 

func (x ValueCacheStrategy) String() string

type ValueClient 

type ValueClient interface {
	// Set sets the value
	Set(ctx context.Context, in *SetRequest, opts ...grpc.CallOption) (*SetResponse, error)
	// Get gets the value
	Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetResponse, error)
	// Events listens for value change events
	Events(ctx context.Context, in *EventsRequest, opts ...grpc.CallOption) (Value_EventsClient, error)
}

ValueClient is the client API for Value service.

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

func NewValueClient 

func NewValueClient(cc *grpc.ClientConn) ValueClient

type ValueManagerClient added in v0.7.0 

type ValueManagerClient interface {
	OpenSession(ctx context.Context, in *OpenSessionRequest, opts ...grpc.CallOption) (*OpenSessionResponse, error)
	CloseSession(ctx context.Context, in *CloseSessionRequest, opts ...grpc.CallOption) (*CloseSessionResponse, error)
}

ValueManagerClient is the client API for ValueManager service.

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

func NewValueManagerClient added in v0.7.0 

func NewValueManagerClient(cc *grpc.ClientConn) ValueManagerClient

type ValueManagerServer added in v0.7.0 

type ValueManagerServer interface {
	OpenSession(context.Context, *OpenSessionRequest) (*OpenSessionResponse, error)
	CloseSession(context.Context, *CloseSessionRequest) (*CloseSessionResponse, error)
}

ValueManagerServer is the server API for ValueManager service.

type ValueServer 

type ValueServer interface {
	// Set sets the value
	Set(context.Context, *SetRequest) (*SetResponse, error)
	// Get gets the value
	Get(context.Context, *GetRequest) (*GetResponse, error)
	// Events listens for value change events
	Events(*EventsRequest, Value_EventsServer) error
}

ValueServer is the server API for Value service.

type ValueSessionOptions 

type ValueSessionOptions struct {
	Cache ValueCacheOptions `protobuf:"bytes,1,opt,name=cache,proto3" json:"cache"`
}

func (*ValueSessionOptions) Descriptor 

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

func (*ValueSessionOptions) GetCache 

func (m *ValueSessionOptions) GetCache() ValueCacheOptions

func (*ValueSessionOptions) Marshal 

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

func (*ValueSessionOptions) MarshalTo 

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

func (*ValueSessionOptions) MarshalToSizedBuffer 

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

func (*ValueSessionOptions) ProtoMessage 

func (*ValueSessionOptions) ProtoMessage()

func (*ValueSessionOptions) Reset 

func (m *ValueSessionOptions) Reset()

func (*ValueSessionOptions) Size 

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

func (*ValueSessionOptions) String 

func (m *ValueSessionOptions) String() string

func (*ValueSessionOptions) Unmarshal 

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

func (*ValueSessionOptions) XXX_DiscardUnknown 

func (m *ValueSessionOptions) XXX_DiscardUnknown()

func (*ValueSessionOptions) XXX_Marshal 

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

func (*ValueSessionOptions) XXX_Merge 

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

func (*ValueSessionOptions) XXX_Size 

func (m *ValueSessionOptions) XXX_Size() int

func (*ValueSessionOptions) XXX_Unmarshal 

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

type Value_EventsClient 

type Value_EventsClient interface {
	Recv() (*EventsResponse, error)
	grpc.ClientStream
}

type Value_EventsServer 

type Value_EventsServer interface {
	Send(*EventsResponse) error
	grpc.ServerStream
}

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.