Documentation ¶
Index ¶
- Variables
- func RegisterPrimitiveServiceServer(s *grpc.Server, srv PrimitiveServiceServer)
- type CreatePrimitiveRequest
- func (*CreatePrimitiveRequest) Descriptor() ([]byte, []int)
- func (m *CreatePrimitiveRequest) GetDatabase() database.DatabaseId
- func (m *CreatePrimitiveRequest) GetPrimitive() PrimitiveId
- func (m *CreatePrimitiveRequest) GetType() PrimitiveType
- func (m *CreatePrimitiveRequest) Marshal() (dAtA []byte, err error)
- func (m *CreatePrimitiveRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *CreatePrimitiveRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*CreatePrimitiveRequest) ProtoMessage()
- func (m *CreatePrimitiveRequest) Reset()
- func (m *CreatePrimitiveRequest) Size() (n int)
- func (m *CreatePrimitiveRequest) String() string
- func (m *CreatePrimitiveRequest) Unmarshal(dAtA []byte) error
- func (m *CreatePrimitiveRequest) XXX_DiscardUnknown()
- func (m *CreatePrimitiveRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CreatePrimitiveRequest) XXX_Merge(src proto.Message)
- func (m *CreatePrimitiveRequest) XXX_Size() int
- func (m *CreatePrimitiveRequest) XXX_Unmarshal(b []byte) error
- type CreatePrimitiveResponse
- func (*CreatePrimitiveResponse) Descriptor() ([]byte, []int)
- func (m *CreatePrimitiveResponse) GetPrimitive() PrimitiveMetadata
- func (m *CreatePrimitiveResponse) Marshal() (dAtA []byte, err error)
- func (m *CreatePrimitiveResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *CreatePrimitiveResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*CreatePrimitiveResponse) ProtoMessage()
- func (m *CreatePrimitiveResponse) Reset()
- func (m *CreatePrimitiveResponse) Size() (n int)
- func (m *CreatePrimitiveResponse) String() string
- func (m *CreatePrimitiveResponse) Unmarshal(dAtA []byte) error
- func (m *CreatePrimitiveResponse) XXX_DiscardUnknown()
- func (m *CreatePrimitiveResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CreatePrimitiveResponse) XXX_Merge(src proto.Message)
- func (m *CreatePrimitiveResponse) XXX_Size() int
- func (m *CreatePrimitiveResponse) XXX_Unmarshal(b []byte) error
- type DeletePrimitiveRequest
- func (*DeletePrimitiveRequest) Descriptor() ([]byte, []int)
- func (m *DeletePrimitiveRequest) GetDatabase() database.DatabaseId
- func (m *DeletePrimitiveRequest) GetPrimitive() PrimitiveId
- func (m *DeletePrimitiveRequest) Marshal() (dAtA []byte, err error)
- func (m *DeletePrimitiveRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *DeletePrimitiveRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*DeletePrimitiveRequest) ProtoMessage()
- func (m *DeletePrimitiveRequest) Reset()
- func (m *DeletePrimitiveRequest) Size() (n int)
- func (m *DeletePrimitiveRequest) String() string
- func (m *DeletePrimitiveRequest) Unmarshal(dAtA []byte) error
- func (m *DeletePrimitiveRequest) XXX_DiscardUnknown()
- func (m *DeletePrimitiveRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DeletePrimitiveRequest) XXX_Merge(src proto.Message)
- func (m *DeletePrimitiveRequest) XXX_Size() int
- func (m *DeletePrimitiveRequest) XXX_Unmarshal(b []byte) error
- type DeletePrimitiveResponse
- func (*DeletePrimitiveResponse) Descriptor() ([]byte, []int)
- func (m *DeletePrimitiveResponse) GetPrimitive() PrimitiveMetadata
- func (m *DeletePrimitiveResponse) Marshal() (dAtA []byte, err error)
- func (m *DeletePrimitiveResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *DeletePrimitiveResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*DeletePrimitiveResponse) ProtoMessage()
- func (m *DeletePrimitiveResponse) Reset()
- func (m *DeletePrimitiveResponse) Size() (n int)
- func (m *DeletePrimitiveResponse) String() string
- func (m *DeletePrimitiveResponse) Unmarshal(dAtA []byte) error
- func (m *DeletePrimitiveResponse) XXX_DiscardUnknown()
- func (m *DeletePrimitiveResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DeletePrimitiveResponse) XXX_Merge(src proto.Message)
- func (m *DeletePrimitiveResponse) XXX_Size() int
- func (m *DeletePrimitiveResponse) XXX_Unmarshal(b []byte) error
- type GetPrimitiveRequest
- func (*GetPrimitiveRequest) Descriptor() ([]byte, []int)
- func (m *GetPrimitiveRequest) GetDatabase() database.DatabaseId
- func (m *GetPrimitiveRequest) GetPrimitive() PrimitiveId
- func (m *GetPrimitiveRequest) Marshal() (dAtA []byte, err error)
- func (m *GetPrimitiveRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *GetPrimitiveRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GetPrimitiveRequest) ProtoMessage()
- func (m *GetPrimitiveRequest) Reset()
- func (m *GetPrimitiveRequest) Size() (n int)
- func (m *GetPrimitiveRequest) String() string
- func (m *GetPrimitiveRequest) Unmarshal(dAtA []byte) error
- func (m *GetPrimitiveRequest) XXX_DiscardUnknown()
- func (m *GetPrimitiveRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetPrimitiveRequest) XXX_Merge(src proto.Message)
- func (m *GetPrimitiveRequest) XXX_Size() int
- func (m *GetPrimitiveRequest) XXX_Unmarshal(b []byte) error
- type GetPrimitiveResponse
- func (*GetPrimitiveResponse) Descriptor() ([]byte, []int)
- func (m *GetPrimitiveResponse) GetPrimitive() PrimitiveMetadata
- func (m *GetPrimitiveResponse) Marshal() (dAtA []byte, err error)
- func (m *GetPrimitiveResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *GetPrimitiveResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GetPrimitiveResponse) ProtoMessage()
- func (m *GetPrimitiveResponse) Reset()
- func (m *GetPrimitiveResponse) Size() (n int)
- func (m *GetPrimitiveResponse) String() string
- func (m *GetPrimitiveResponse) Unmarshal(dAtA []byte) error
- func (m *GetPrimitiveResponse) XXX_DiscardUnknown()
- func (m *GetPrimitiveResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetPrimitiveResponse) XXX_Merge(src proto.Message)
- func (m *GetPrimitiveResponse) XXX_Size() int
- func (m *GetPrimitiveResponse) XXX_Unmarshal(b []byte) error
- type GetPrimitivesRequest
- func (*GetPrimitivesRequest) Descriptor() ([]byte, []int)
- func (m *GetPrimitivesRequest) GetDatabase() *database.DatabaseId
- func (m *GetPrimitivesRequest) GetPrimitive() *PrimitiveId
- func (m *GetPrimitivesRequest) GetType() PrimitiveType
- func (m *GetPrimitivesRequest) Marshal() (dAtA []byte, err error)
- func (m *GetPrimitivesRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *GetPrimitivesRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GetPrimitivesRequest) ProtoMessage()
- func (m *GetPrimitivesRequest) Reset()
- func (m *GetPrimitivesRequest) Size() (n int)
- func (m *GetPrimitivesRequest) String() string
- func (m *GetPrimitivesRequest) Unmarshal(dAtA []byte) error
- func (m *GetPrimitivesRequest) XXX_DiscardUnknown()
- func (m *GetPrimitivesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetPrimitivesRequest) XXX_Merge(src proto.Message)
- func (m *GetPrimitivesRequest) XXX_Size() int
- func (m *GetPrimitivesRequest) XXX_Unmarshal(b []byte) error
- type GetPrimitivesResponse
- func (*GetPrimitivesResponse) Descriptor() ([]byte, []int)
- func (m *GetPrimitivesResponse) GetPrimitives() []PrimitiveMetadata
- func (m *GetPrimitivesResponse) Marshal() (dAtA []byte, err error)
- func (m *GetPrimitivesResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *GetPrimitivesResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GetPrimitivesResponse) ProtoMessage()
- func (m *GetPrimitivesResponse) Reset()
- func (m *GetPrimitivesResponse) Size() (n int)
- func (m *GetPrimitivesResponse) String() string
- func (m *GetPrimitivesResponse) Unmarshal(dAtA []byte) error
- func (m *GetPrimitivesResponse) XXX_DiscardUnknown()
- func (m *GetPrimitivesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetPrimitivesResponse) XXX_Merge(src proto.Message)
- func (m *GetPrimitivesResponse) XXX_Size() int
- func (m *GetPrimitivesResponse) XXX_Unmarshal(b []byte) error
- type PrimitiveId
- func (*PrimitiveId) Descriptor() ([]byte, []int)
- func (m *PrimitiveId) GetName() string
- func (m *PrimitiveId) GetNamespace() string
- func (m *PrimitiveId) Marshal() (dAtA []byte, err error)
- func (m *PrimitiveId) MarshalTo(dAtA []byte) (int, error)
- func (m *PrimitiveId) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*PrimitiveId) ProtoMessage()
- func (m *PrimitiveId) Reset()
- func (m *PrimitiveId) Size() (n int)
- func (m *PrimitiveId) String() string
- func (m *PrimitiveId) Unmarshal(dAtA []byte) error
- func (m *PrimitiveId) XXX_DiscardUnknown()
- func (m *PrimitiveId) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PrimitiveId) XXX_Merge(src proto.Message)
- func (m *PrimitiveId) XXX_Size() int
- func (m *PrimitiveId) XXX_Unmarshal(b []byte) error
- type PrimitiveMetadata
- func (*PrimitiveMetadata) Descriptor() ([]byte, []int)
- func (m *PrimitiveMetadata) GetDatabase() database.DatabaseId
- func (m *PrimitiveMetadata) GetPrimitive() PrimitiveId
- func (m *PrimitiveMetadata) GetType() PrimitiveType
- func (m *PrimitiveMetadata) Marshal() (dAtA []byte, err error)
- func (m *PrimitiveMetadata) MarshalTo(dAtA []byte) (int, error)
- func (m *PrimitiveMetadata) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*PrimitiveMetadata) ProtoMessage()
- func (m *PrimitiveMetadata) Reset()
- func (m *PrimitiveMetadata) Size() (n int)
- func (m *PrimitiveMetadata) String() string
- func (m *PrimitiveMetadata) Unmarshal(dAtA []byte) error
- func (m *PrimitiveMetadata) XXX_DiscardUnknown()
- func (m *PrimitiveMetadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PrimitiveMetadata) XXX_Merge(src proto.Message)
- func (m *PrimitiveMetadata) XXX_Size() int
- func (m *PrimitiveMetadata) XXX_Unmarshal(b []byte) error
- type PrimitiveServiceClient
- type PrimitiveServiceServer
- type PrimitiveType
- type UnimplementedPrimitiveServiceServer
- func (*UnimplementedPrimitiveServiceServer) CreatePrimitive(ctx context.Context, req *CreatePrimitiveRequest) (*CreatePrimitiveResponse, error)
- func (*UnimplementedPrimitiveServiceServer) DeletePrimitive(ctx context.Context, req *DeletePrimitiveRequest) (*DeletePrimitiveResponse, error)
- func (*UnimplementedPrimitiveServiceServer) GetPrimitive(ctx context.Context, req *GetPrimitiveRequest) (*GetPrimitiveResponse, error)
- func (*UnimplementedPrimitiveServiceServer) GetPrimitives(ctx context.Context, req *GetPrimitivesRequest) (*GetPrimitivesResponse, error)
Constants ¶
This section is empty.
Variables ¶
var ( ErrInvalidLengthMetadata = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowMetadata = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupMetadata = fmt.Errorf("proto: unexpected end of group") )
var ( ErrInvalidLengthPrimitive = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowPrimitive = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupPrimitive = fmt.Errorf("proto: unexpected end of group") )
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",
}
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)