primitive

package
v0.3.3 Latest Latest
Warning

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

 Go to latest Published: Nov 17, 2020 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthMetadata        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowMetadata          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupMetadata = 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 PrimitiveType_name = map[int32]string{
	0:  "UNKNOWN",
	1:  "COUNTER",
	2:  "ELECTION",
	3:  "INDEXED_MAP",
	4:  "LEADER_LATCH",
	5:  "LIST",
	6:  "LOCK",
	7:  "LOG",
	8:  "MAP",
	9:  "SET",
	10: "VALUE",
}
View Source 
var PrimitiveType_value = map[string]int32{
	"UNKNOWN":      0,
	"COUNTER":      1,
	"ELECTION":     2,
	"INDEXED_MAP":  3,
	"LEADER_LATCH": 4,
	"LIST":         5,
	"LOCK":         6,
	"LOG":          7,
	"MAP":          8,
	"SET":          9,
	"VALUE":        10,
}

Functions

func RegisterPrimitiveServiceServer added in v0.2.0 

func RegisterPrimitiveServiceServer(s *grpc.Server, srv PrimitiveServiceServer)

Types

type CreatePrimitiveRequest added in v0.2.0 

type CreatePrimitiveRequest struct {
	Database  database.DatabaseId `protobuf:"bytes,1,opt,name=database,proto3" json:"database"`
	Primitive PrimitiveId         `protobuf:"bytes,2,opt,name=primitive,proto3" json:"primitive"`
	Type      PrimitiveType       `protobuf:"varint,3,opt,name=type,proto3,enum=atomix.primitive.PrimitiveType" json:"type,omitempty"`
}

CreatePrimitiveRequest is a request to create a primitive

func (*CreatePrimitiveRequest) Descriptor added in v0.2.0 

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

func (*CreatePrimitiveRequest) GetDatabase added in v0.2.0 

func (m *CreatePrimitiveRequest) GetDatabase() database.DatabaseId

func (*CreatePrimitiveRequest) GetPrimitive added in v0.2.0 

func (m *CreatePrimitiveRequest) GetPrimitive() PrimitiveId

func (*CreatePrimitiveRequest) GetType added in v0.2.0 

func (m *CreatePrimitiveRequest) GetType() PrimitiveType

func (*CreatePrimitiveRequest) Marshal added in v0.2.0 

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

func (*CreatePrimitiveRequest) MarshalTo added in v0.2.0 

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

func (*CreatePrimitiveRequest) MarshalToSizedBuffer added in v0.2.0 

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

func (*CreatePrimitiveRequest) ProtoMessage added in v0.2.0 

func (*CreatePrimitiveRequest) ProtoMessage()

func (*CreatePrimitiveRequest) Reset added in v0.2.0 

func (m *CreatePrimitiveRequest) Reset()

func (*CreatePrimitiveRequest) Size added in v0.2.0 

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

func (*CreatePrimitiveRequest) String added in v0.2.0 

func (m *CreatePrimitiveRequest) String() string

func (*CreatePrimitiveRequest) Unmarshal added in v0.2.0 

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

func (*CreatePrimitiveRequest) XXX_DiscardUnknown added in v0.2.0 

func (m *CreatePrimitiveRequest) XXX_DiscardUnknown()

func (*CreatePrimitiveRequest) XXX_Marshal added in v0.2.0 

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

func (*CreatePrimitiveRequest) XXX_Merge added in v0.2.0 

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

func (*CreatePrimitiveRequest) XXX_Size added in v0.2.0 

func (m *CreatePrimitiveRequest) XXX_Size() int

func (*CreatePrimitiveRequest) XXX_Unmarshal added in v0.2.0 

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

type CreatePrimitiveResponse added in v0.2.0 

type CreatePrimitiveResponse struct {
	Primitive PrimitiveMetadata `protobuf:"bytes,1,opt,name=primitive,proto3" json:"primitive"`
}

CreatePrimitiveResponse is a response for creating a primitive

func (*CreatePrimitiveResponse) Descriptor added in v0.2.0 

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

func (*CreatePrimitiveResponse) GetPrimitive added in v0.2.0 

func (m *CreatePrimitiveResponse) GetPrimitive() PrimitiveMetadata

func (*CreatePrimitiveResponse) Marshal added in v0.2.0 

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

func (*CreatePrimitiveResponse) MarshalTo added in v0.2.0 

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

func (*CreatePrimitiveResponse) MarshalToSizedBuffer added in v0.2.0 

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

func (*CreatePrimitiveResponse) ProtoMessage added in v0.2.0 

func (*CreatePrimitiveResponse) ProtoMessage()

func (*CreatePrimitiveResponse) Reset added in v0.2.0 

func (m *CreatePrimitiveResponse) Reset()

func (*CreatePrimitiveResponse) Size added in v0.2.0 

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

func (*CreatePrimitiveResponse) String added in v0.2.0 

func (m *CreatePrimitiveResponse) String() string

func (*CreatePrimitiveResponse) Unmarshal added in v0.2.0 

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

func (*CreatePrimitiveResponse) XXX_DiscardUnknown added in v0.2.0 

func (m *CreatePrimitiveResponse) XXX_DiscardUnknown()

func (*CreatePrimitiveResponse) XXX_Marshal added in v0.2.0 

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

func (*CreatePrimitiveResponse) XXX_Merge added in v0.2.0 

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

func (*CreatePrimitiveResponse) XXX_Size added in v0.2.0 

func (m *CreatePrimitiveResponse) XXX_Size() int

func (*CreatePrimitiveResponse) XXX_Unmarshal added in v0.2.0 

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

type DeletePrimitiveRequest added in v0.2.0 

type DeletePrimitiveRequest struct {
	Database  database.DatabaseId `protobuf:"bytes,1,opt,name=database,proto3" json:"database"`
	Primitive PrimitiveId         `protobuf:"bytes,2,opt,name=primitive,proto3" json:"primitive"`
}

DeletePrimitiveRequest is a request to delete a primitive

func (*DeletePrimitiveRequest) Descriptor added in v0.2.0 

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

func (*DeletePrimitiveRequest) GetDatabase added in v0.2.0 

func (m *DeletePrimitiveRequest) GetDatabase() database.DatabaseId

func (*DeletePrimitiveRequest) GetPrimitive added in v0.2.0 

func (m *DeletePrimitiveRequest) GetPrimitive() PrimitiveId

func (*DeletePrimitiveRequest) Marshal added in v0.2.0 

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

func (*DeletePrimitiveRequest) MarshalTo added in v0.2.0 

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

func (*DeletePrimitiveRequest) MarshalToSizedBuffer added in v0.2.0 

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

func (*DeletePrimitiveRequest) ProtoMessage added in v0.2.0 

func (*DeletePrimitiveRequest) ProtoMessage()

func (*DeletePrimitiveRequest) Reset added in v0.2.0 

func (m *DeletePrimitiveRequest) Reset()

func (*DeletePrimitiveRequest) Size added in v0.2.0 

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

func (*DeletePrimitiveRequest) String added in v0.2.0 

func (m *DeletePrimitiveRequest) String() string

func (*DeletePrimitiveRequest) Unmarshal added in v0.2.0 

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

func (*DeletePrimitiveRequest) XXX_DiscardUnknown added in v0.2.0 

func (m *DeletePrimitiveRequest) XXX_DiscardUnknown()

func (*DeletePrimitiveRequest) XXX_Marshal added in v0.2.0 

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

func (*DeletePrimitiveRequest) XXX_Merge added in v0.2.0 

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

func (*DeletePrimitiveRequest) XXX_Size added in v0.2.0 

func (m *DeletePrimitiveRequest) XXX_Size() int

func (*DeletePrimitiveRequest) XXX_Unmarshal added in v0.2.0 

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

type DeletePrimitiveResponse added in v0.2.0 

type DeletePrimitiveResponse struct {
	Primitive PrimitiveMetadata `protobuf:"bytes,1,opt,name=primitive,proto3" json:"primitive"`
}

DeletePrimitiveResponse is a response for deleting a primitive

func (*DeletePrimitiveResponse) Descriptor added in v0.2.0 

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

func (*DeletePrimitiveResponse) GetPrimitive added in v0.2.0 

func (m *DeletePrimitiveResponse) GetPrimitive() PrimitiveMetadata

func (*DeletePrimitiveResponse) Marshal added in v0.2.0 

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

func (*DeletePrimitiveResponse) MarshalTo added in v0.2.0 

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

func (*DeletePrimitiveResponse) MarshalToSizedBuffer added in v0.2.0 

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

func (*DeletePrimitiveResponse) ProtoMessage added in v0.2.0 

func (*DeletePrimitiveResponse) ProtoMessage()

func (*DeletePrimitiveResponse) Reset added in v0.2.0 

func (m *DeletePrimitiveResponse) Reset()

func (*DeletePrimitiveResponse) Size added in v0.2.0 

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

func (*DeletePrimitiveResponse) String added in v0.2.0 

func (m *DeletePrimitiveResponse) String() string

func (*DeletePrimitiveResponse) Unmarshal added in v0.2.0 

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

func (*DeletePrimitiveResponse) XXX_DiscardUnknown added in v0.2.0 

func (m *DeletePrimitiveResponse) XXX_DiscardUnknown()

func (*DeletePrimitiveResponse) XXX_Marshal added in v0.2.0 

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

func (*DeletePrimitiveResponse) XXX_Merge added in v0.2.0 

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

func (*DeletePrimitiveResponse) XXX_Size added in v0.2.0 

func (m *DeletePrimitiveResponse) XXX_Size() int

func (*DeletePrimitiveResponse) XXX_Unmarshal added in v0.2.0 

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

type GetPrimitiveRequest added in v0.2.0 

type GetPrimitiveRequest struct {
	Database  database.DatabaseId `protobuf:"bytes,1,opt,name=database,proto3" json:"database"`
	Primitive PrimitiveId         `protobuf:"bytes,2,opt,name=primitive,proto3" json:"primitive"`
}

GetPrimitiveRequest is a request for primitive metadata

func (*GetPrimitiveRequest) Descriptor added in v0.2.0 

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

func (*GetPrimitiveRequest) GetDatabase added in v0.2.0 

func (m *GetPrimitiveRequest) GetDatabase() database.DatabaseId

func (*GetPrimitiveRequest) GetPrimitive added in v0.2.0 

func (m *GetPrimitiveRequest) GetPrimitive() PrimitiveId

func (*GetPrimitiveRequest) Marshal added in v0.2.0 

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

func (*GetPrimitiveRequest) MarshalTo added in v0.2.0 

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

func (*GetPrimitiveRequest) MarshalToSizedBuffer added in v0.2.0 

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

func (*GetPrimitiveRequest) ProtoMessage added in v0.2.0 

func (*GetPrimitiveRequest) ProtoMessage()

func (*GetPrimitiveRequest) Reset added in v0.2.0 

func (m *GetPrimitiveRequest) Reset()

func (*GetPrimitiveRequest) Size added in v0.2.0 

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

func (*GetPrimitiveRequest) String added in v0.2.0 

func (m *GetPrimitiveRequest) String() string

func (*GetPrimitiveRequest) Unmarshal added in v0.2.0 

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

func (*GetPrimitiveRequest) XXX_DiscardUnknown added in v0.2.0 

func (m *GetPrimitiveRequest) XXX_DiscardUnknown()

func (*GetPrimitiveRequest) XXX_Marshal added in v0.2.0 

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

func (*GetPrimitiveRequest) XXX_Merge added in v0.2.0 

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

func (*GetPrimitiveRequest) XXX_Size added in v0.2.0 

func (m *GetPrimitiveRequest) XXX_Size() int

func (*GetPrimitiveRequest) XXX_Unmarshal added in v0.2.0 

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

type GetPrimitiveResponse added in v0.2.0 

type GetPrimitiveResponse struct {
	Primitive PrimitiveMetadata `protobuf:"bytes,1,opt,name=primitive,proto3" json:"primitive"`
}

GetPrimitiveResponse is a response containing primitive metadata

func (*GetPrimitiveResponse) Descriptor added in v0.2.0 

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

func (*GetPrimitiveResponse) GetPrimitive added in v0.2.0 

func (m *GetPrimitiveResponse) GetPrimitive() PrimitiveMetadata

func (*GetPrimitiveResponse) Marshal added in v0.2.0 

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

func (*GetPrimitiveResponse) MarshalTo added in v0.2.0 

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

func (*GetPrimitiveResponse) MarshalToSizedBuffer added in v0.2.0 

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

func (*GetPrimitiveResponse) ProtoMessage added in v0.2.0 

func (*GetPrimitiveResponse) ProtoMessage()

func (*GetPrimitiveResponse) Reset added in v0.2.0 

func (m *GetPrimitiveResponse) Reset()

func (*GetPrimitiveResponse) Size added in v0.2.0 

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

func (*GetPrimitiveResponse) String added in v0.2.0 

func (m *GetPrimitiveResponse) String() string

func (*GetPrimitiveResponse) Unmarshal added in v0.2.0 

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

func (*GetPrimitiveResponse) XXX_DiscardUnknown added in v0.2.0 

func (m *GetPrimitiveResponse) XXX_DiscardUnknown()

func (*GetPrimitiveResponse) XXX_Marshal added in v0.2.0 

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

func (*GetPrimitiveResponse) XXX_Merge added in v0.2.0 

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

func (*GetPrimitiveResponse) XXX_Size added in v0.2.0 

func (m *GetPrimitiveResponse) XXX_Size() int

func (*GetPrimitiveResponse) XXX_Unmarshal added in v0.2.0 

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

type GetPrimitivesRequest added in v0.2.0 

type GetPrimitivesRequest struct {
	Database  *database.DatabaseId `protobuf:"bytes,1,opt,name=database,proto3" json:"database,omitempty"`
	Primitive *PrimitiveId         `protobuf:"bytes,2,opt,name=primitive,proto3" json:"primitive,omitempty"`
	Type      PrimitiveType        `protobuf:"varint,3,opt,name=type,proto3,enum=atomix.primitive.PrimitiveType" json:"type,omitempty"`
}

GetPrimitivesRequest is a request for primitive metadata

func (*GetPrimitivesRequest) Descriptor added in v0.2.0 

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

func (*GetPrimitivesRequest) GetDatabase added in v0.2.0 

func (m *GetPrimitivesRequest) GetDatabase() *database.DatabaseId

func (*GetPrimitivesRequest) GetPrimitive added in v0.2.0 

func (m *GetPrimitivesRequest) GetPrimitive() *PrimitiveId

func (*GetPrimitivesRequest) GetType added in v0.2.0 

func (m *GetPrimitivesRequest) GetType() PrimitiveType

func (*GetPrimitivesRequest) Marshal added in v0.2.0 

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

func (*GetPrimitivesRequest) MarshalTo added in v0.2.0 

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

func (*GetPrimitivesRequest) MarshalToSizedBuffer added in v0.2.0 

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

func (*GetPrimitivesRequest) ProtoMessage added in v0.2.0 

func (*GetPrimitivesRequest) ProtoMessage()

func (*GetPrimitivesRequest) Reset added in v0.2.0 

func (m *GetPrimitivesRequest) Reset()

func (*GetPrimitivesRequest) Size added in v0.2.0 

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

func (*GetPrimitivesRequest) String added in v0.2.0 

func (m *GetPrimitivesRequest) String() string

func (*GetPrimitivesRequest) Unmarshal added in v0.2.0 

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

func (*GetPrimitivesRequest) XXX_DiscardUnknown added in v0.2.0 

func (m *GetPrimitivesRequest) XXX_DiscardUnknown()

func (*GetPrimitivesRequest) XXX_Marshal added in v0.2.0 

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

func (*GetPrimitivesRequest) XXX_Merge added in v0.2.0 

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

func (*GetPrimitivesRequest) XXX_Size added in v0.2.0 

func (m *GetPrimitivesRequest) XXX_Size() int

func (*GetPrimitivesRequest) XXX_Unmarshal added in v0.2.0 

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

type GetPrimitivesResponse added in v0.2.0 

type GetPrimitivesResponse struct {
	Primitives []PrimitiveMetadata `protobuf:"bytes,1,rep,name=primitives,proto3" json:"primitives"`
}

GetPrimitivesResponse is a response containing primitive metadata

func (*GetPrimitivesResponse) Descriptor added in v0.2.0 

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

func (*GetPrimitivesResponse) GetPrimitives added in v0.2.0 

func (m *GetPrimitivesResponse) GetPrimitives() []PrimitiveMetadata

func (*GetPrimitivesResponse) Marshal added in v0.2.0 

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

func (*GetPrimitivesResponse) MarshalTo added in v0.2.0 

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

func (*GetPrimitivesResponse) MarshalToSizedBuffer added in v0.2.0 

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

func (*GetPrimitivesResponse) ProtoMessage added in v0.2.0 

func (*GetPrimitivesResponse) ProtoMessage()

func (*GetPrimitivesResponse) Reset added in v0.2.0 

func (m *GetPrimitivesResponse) Reset()

func (*GetPrimitivesResponse) Size added in v0.2.0 

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

func (*GetPrimitivesResponse) String added in v0.2.0 

func (m *GetPrimitivesResponse) String() string

func (*GetPrimitivesResponse) Unmarshal added in v0.2.0 

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

func (*GetPrimitivesResponse) XXX_DiscardUnknown added in v0.2.0 

func (m *GetPrimitivesResponse) XXX_DiscardUnknown()

func (*GetPrimitivesResponse) XXX_Marshal added in v0.2.0 

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

func (*GetPrimitivesResponse) XXX_Merge added in v0.2.0 

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

func (*GetPrimitivesResponse) XXX_Size added in v0.2.0 

func (m *GetPrimitivesResponse) XXX_Size() int

func (*GetPrimitivesResponse) XXX_Unmarshal added in v0.2.0 

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

type PrimitiveId added in v0.2.0 

type PrimitiveId struct {
	Name      string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
}

Namespaced primitive identifier

func (*PrimitiveId) Descriptor added in v0.2.0 

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

func (*PrimitiveId) GetName added in v0.2.0 

func (m *PrimitiveId) GetName() string

func (*PrimitiveId) GetNamespace added in v0.2.0 

func (m *PrimitiveId) GetNamespace() string

func (*PrimitiveId) Marshal added in v0.2.0 

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

func (*PrimitiveId) MarshalTo added in v0.2.0 

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

func (*PrimitiveId) MarshalToSizedBuffer added in v0.2.0 

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

func (*PrimitiveId) ProtoMessage added in v0.2.0 

func (*PrimitiveId) ProtoMessage()

func (*PrimitiveId) Reset added in v0.2.0 

func (m *PrimitiveId) Reset()

func (*PrimitiveId) Size added in v0.2.0 

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

func (*PrimitiveId) String added in v0.2.0 

func (m *PrimitiveId) String() string

func (*PrimitiveId) Unmarshal added in v0.2.0 

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

func (*PrimitiveId) XXX_DiscardUnknown added in v0.2.0 

func (m *PrimitiveId) XXX_DiscardUnknown()

func (*PrimitiveId) XXX_Marshal added in v0.2.0 

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

func (*PrimitiveId) XXX_Merge added in v0.2.0 

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

func (*PrimitiveId) XXX_Size added in v0.2.0 

func (m *PrimitiveId) XXX_Size() int

func (*PrimitiveId) XXX_Unmarshal added in v0.2.0 

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

type PrimitiveMetadata added in v0.2.0 

type PrimitiveMetadata struct {
	Database  database.DatabaseId `protobuf:"bytes,1,opt,name=database,proto3" json:"database"`
	Primitive PrimitiveId         `protobuf:"bytes,2,opt,name=primitive,proto3" json:"primitive"`
	Type      PrimitiveType       `protobuf:"varint,3,opt,name=type,proto3,enum=atomix.primitive.PrimitiveType" json:"type,omitempty"`
}

PrimitiveMetadata indicates the type and name of a primitive

func (*PrimitiveMetadata) Descriptor added in v0.2.0 

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

func (*PrimitiveMetadata) GetDatabase added in v0.2.0 

func (m *PrimitiveMetadata) GetDatabase() database.DatabaseId

func (*PrimitiveMetadata) GetPrimitive added in v0.2.0 

func (m *PrimitiveMetadata) GetPrimitive() PrimitiveId

func (*PrimitiveMetadata) GetType added in v0.2.0 

func (m *PrimitiveMetadata) GetType() PrimitiveType

func (*PrimitiveMetadata) Marshal added in v0.2.0 

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

func (*PrimitiveMetadata) MarshalTo added in v0.2.0 

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

func (*PrimitiveMetadata) MarshalToSizedBuffer added in v0.2.0 

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

func (*PrimitiveMetadata) ProtoMessage added in v0.2.0 

func (*PrimitiveMetadata) ProtoMessage()

func (*PrimitiveMetadata) Reset added in v0.2.0 

func (m *PrimitiveMetadata) Reset()

func (*PrimitiveMetadata) Size added in v0.2.0 

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

func (*PrimitiveMetadata) String added in v0.2.0 

func (m *PrimitiveMetadata) String() string

func (*PrimitiveMetadata) Unmarshal added in v0.2.0 

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

func (*PrimitiveMetadata) XXX_DiscardUnknown added in v0.2.0 

func (m *PrimitiveMetadata) XXX_DiscardUnknown()

func (*PrimitiveMetadata) XXX_Marshal added in v0.2.0 

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

func (*PrimitiveMetadata) XXX_Merge added in v0.2.0 

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

func (*PrimitiveMetadata) XXX_Size added in v0.2.0 

func (m *PrimitiveMetadata) XXX_Size() int

func (*PrimitiveMetadata) XXX_Unmarshal added in v0.2.0 

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

type PrimitiveServiceClient added in v0.2.0 

type PrimitiveServiceClient interface {
	// CreatePrimitive creates a new primitive
	CreatePrimitive(ctx context.Context, in *CreatePrimitiveRequest, opts ...grpc.CallOption) (*CreatePrimitiveResponse, error)
	// GetPrimitive returns a primitive in the system
	GetPrimitive(ctx context.Context, in *GetPrimitiveRequest, opts ...grpc.CallOption) (*GetPrimitiveResponse, error)
	// GetPrimitives returns a list of primitives in the system
	GetPrimitives(ctx context.Context, in *GetPrimitivesRequest, opts ...grpc.CallOption) (*GetPrimitivesResponse, error)
	// DeletePrimitive deletes a primitive
	DeletePrimitive(ctx context.Context, in *DeletePrimitiveRequest, opts ...grpc.CallOption) (*DeletePrimitiveResponse, error)
}

PrimitiveServiceClient is the client API for PrimitiveService service.

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

func NewPrimitiveServiceClient added in v0.2.0 

func NewPrimitiveServiceClient(cc *grpc.ClientConn) PrimitiveServiceClient

type PrimitiveServiceServer added in v0.2.0 

type PrimitiveServiceServer interface {
	// CreatePrimitive creates a new primitive
	CreatePrimitive(context.Context, *CreatePrimitiveRequest) (*CreatePrimitiveResponse, error)
	// GetPrimitive returns a primitive in the system
	GetPrimitive(context.Context, *GetPrimitiveRequest) (*GetPrimitiveResponse, error)
	// GetPrimitives returns a list of primitives in the system
	GetPrimitives(context.Context, *GetPrimitivesRequest) (*GetPrimitivesResponse, error)
	// DeletePrimitive deletes a primitive
	DeletePrimitive(context.Context, *DeletePrimitiveRequest) (*DeletePrimitiveResponse, error)
}

PrimitiveServiceServer is the server API for PrimitiveService service.

type PrimitiveType 

type PrimitiveType int32

PrimitiveType is a primitive type 

const (
	PrimitiveType_UNKNOWN      PrimitiveType = 0
	PrimitiveType_COUNTER      PrimitiveType = 1
	PrimitiveType_ELECTION     PrimitiveType = 2
	PrimitiveType_INDEXED_MAP  PrimitiveType = 3
	PrimitiveType_LEADER_LATCH PrimitiveType = 4
	PrimitiveType_LIST         PrimitiveType = 5
	PrimitiveType_LOCK         PrimitiveType = 6
	PrimitiveType_LOG          PrimitiveType = 7
	PrimitiveType_MAP          PrimitiveType = 8
	PrimitiveType_SET          PrimitiveType = 9
	PrimitiveType_VALUE        PrimitiveType = 10
)

func (PrimitiveType) EnumDescriptor 

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

func (PrimitiveType) String 

func (x PrimitiveType) String() string

type UnimplementedPrimitiveServiceServer added in v0.2.0 

type UnimplementedPrimitiveServiceServer struct {
}

UnimplementedPrimitiveServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedPrimitiveServiceServer) CreatePrimitive added in v0.2.0 

func (*UnimplementedPrimitiveServiceServer) CreatePrimitive(ctx context.Context, req *CreatePrimitiveRequest) (*CreatePrimitiveResponse, error)

func (*UnimplementedPrimitiveServiceServer) DeletePrimitive added in v0.2.0 

func (*UnimplementedPrimitiveServiceServer) DeletePrimitive(ctx context.Context, req *DeletePrimitiveRequest) (*DeletePrimitiveResponse, error)

func (*UnimplementedPrimitiveServiceServer) GetPrimitive added in v0.2.0 

func (*UnimplementedPrimitiveServiceServer) GetPrimitive(ctx context.Context, req *GetPrimitiveRequest) (*GetPrimitiveResponse, error)

func (*UnimplementedPrimitiveServiceServer) GetPrimitives added in v0.2.0 

func (*UnimplementedPrimitiveServiceServer) GetPrimitives(ctx context.Context, req *GetPrimitivesRequest) (*GetPrimitivesResponse, 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.