primitive

package
v0.4.10 Latest Latest
Warning

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

 Go to latest Published: Mar 4, 2022 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

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 ResponseError_Type_name = map[int32]string{
	0:  "UNKNOWN",
	1:  "CANCELED",
	2:  "NOT_FOUND",
	3:  "ALREADY_EXISTS",
	4:  "UNAUTHORIZED",
	5:  "FORBIDDEN",
	6:  "CONFLICT",
	7:  "INVALID",
	8:  "UNAVAILABLE",
	9:  "NOT_SUPPORTED",
	10: "TIMEOUT",
	11: "INTERNAL",
}
View Source 
var ResponseError_Type_value = map[string]int32{
	"UNKNOWN":        0,
	"CANCELED":       1,
	"NOT_FOUND":      2,
	"ALREADY_EXISTS": 3,
	"UNAUTHORIZED":   4,
	"FORBIDDEN":      5,
	"CONFLICT":       6,
	"INVALID":        7,
	"UNAVAILABLE":    8,
	"NOT_SUPPORTED":  9,
	"TIMEOUT":        10,
	"INTERNAL":       11,
}

Functions

func RegisterPrimitiveServer 

func RegisterPrimitiveServer(s *grpc.Server, srv PrimitiveServer)

Types

type CloseRequest 

type CloseRequest struct {
	Headers RequestHeaders `protobuf:"bytes,1,opt,name=headers,proto3" json:"headers"`
}

func (*CloseRequest) Descriptor 

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

func (*CloseRequest) GetHeaders 

func (m *CloseRequest) GetHeaders() RequestHeaders

func (*CloseRequest) Marshal 

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

func (*CloseRequest) MarshalTo 

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

func (*CloseRequest) MarshalToSizedBuffer 

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

func (*CloseRequest) ProtoMessage 

func (*CloseRequest) ProtoMessage()

func (*CloseRequest) Reset 

func (m *CloseRequest) Reset()

func (*CloseRequest) Size 

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

func (*CloseRequest) String 

func (m *CloseRequest) String() string

func (*CloseRequest) Unmarshal 

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

func (*CloseRequest) XXX_DiscardUnknown 

func (m *CloseRequest) XXX_DiscardUnknown()

func (*CloseRequest) XXX_Marshal 

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

func (*CloseRequest) XXX_Merge 

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

func (*CloseRequest) XXX_Size 

func (m *CloseRequest) XXX_Size() int

func (*CloseRequest) XXX_Unmarshal 

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

type CloseResponse 

type CloseResponse struct {
	Headers ResponseHeaders `protobuf:"bytes,1,opt,name=headers,proto3" json:"headers"`
}

func (*CloseResponse) Descriptor 

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

func (*CloseResponse) GetHeaders 

func (m *CloseResponse) GetHeaders() ResponseHeaders

func (*CloseResponse) Marshal 

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

func (*CloseResponse) MarshalTo 

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

func (*CloseResponse) MarshalToSizedBuffer 

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

func (*CloseResponse) ProtoMessage 

func (*CloseResponse) ProtoMessage()

func (*CloseResponse) Reset 

func (m *CloseResponse) Reset()

func (*CloseResponse) Size 

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

func (*CloseResponse) String 

func (m *CloseResponse) String() string

func (*CloseResponse) Unmarshal 

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

func (*CloseResponse) XXX_DiscardUnknown 

func (m *CloseResponse) XXX_DiscardUnknown()

func (*CloseResponse) XXX_Marshal 

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

func (*CloseResponse) XXX_Merge 

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

func (*CloseResponse) XXX_Size 

func (m *CloseResponse) XXX_Size() int

func (*CloseResponse) XXX_Unmarshal 

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

type CreateRequest 

type CreateRequest struct {
	Headers RequestHeaders `protobuf:"bytes,1,opt,name=headers,proto3" json:"headers"`
}

func (*CreateRequest) Descriptor 

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

func (*CreateRequest) GetHeaders 

func (m *CreateRequest) GetHeaders() RequestHeaders

func (*CreateRequest) Marshal 

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

func (*CreateRequest) MarshalTo 

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

func (*CreateRequest) MarshalToSizedBuffer 

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

func (*CreateRequest) ProtoMessage 

func (*CreateRequest) ProtoMessage()

func (*CreateRequest) Reset 

func (m *CreateRequest) Reset()

func (*CreateRequest) Size 

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

func (*CreateRequest) String 

func (m *CreateRequest) String() string

func (*CreateRequest) Unmarshal 

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

func (*CreateRequest) XXX_DiscardUnknown 

func (m *CreateRequest) XXX_DiscardUnknown()

func (*CreateRequest) XXX_Marshal 

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

func (*CreateRequest) XXX_Merge 

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

func (*CreateRequest) XXX_Size 

func (m *CreateRequest) XXX_Size() int

func (*CreateRequest) XXX_Unmarshal 

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

type CreateResponse 

type CreateResponse struct {
	Headers ResponseHeaders `protobuf:"bytes,1,opt,name=headers,proto3" json:"headers"`
}

func (*CreateResponse) Descriptor 

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

func (*CreateResponse) GetHeaders 

func (m *CreateResponse) GetHeaders() ResponseHeaders

func (*CreateResponse) Marshal 

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

func (*CreateResponse) MarshalTo 

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

func (*CreateResponse) MarshalToSizedBuffer 

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

func (*CreateResponse) ProtoMessage 

func (*CreateResponse) ProtoMessage()

func (*CreateResponse) Reset 

func (m *CreateResponse) Reset()

func (*CreateResponse) Size 

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

func (*CreateResponse) String 

func (m *CreateResponse) String() string

func (*CreateResponse) Unmarshal 

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

func (*CreateResponse) XXX_DiscardUnknown 

func (m *CreateResponse) XXX_DiscardUnknown()

func (*CreateResponse) XXX_Marshal 

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

func (*CreateResponse) XXX_Merge 

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

func (*CreateResponse) XXX_Size 

func (m *CreateResponse) XXX_Size() int

func (*CreateResponse) XXX_Unmarshal 

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

type DeleteRequest 

type DeleteRequest struct {
	Headers RequestHeaders `protobuf:"bytes,1,opt,name=headers,proto3" json:"headers"`
}

func (*DeleteRequest) Descriptor 

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

func (*DeleteRequest) GetHeaders 

func (m *DeleteRequest) GetHeaders() RequestHeaders

func (*DeleteRequest) Marshal 

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

func (*DeleteRequest) MarshalTo 

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

func (*DeleteRequest) MarshalToSizedBuffer 

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

func (*DeleteRequest) ProtoMessage 

func (*DeleteRequest) ProtoMessage()

func (*DeleteRequest) Reset 

func (m *DeleteRequest) Reset()

func (*DeleteRequest) Size 

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

func (*DeleteRequest) String 

func (m *DeleteRequest) String() string

func (*DeleteRequest) Unmarshal 

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

func (*DeleteRequest) XXX_DiscardUnknown 

func (m *DeleteRequest) XXX_DiscardUnknown()

func (*DeleteRequest) XXX_Marshal 

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

func (*DeleteRequest) XXX_Merge 

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

func (*DeleteRequest) XXX_Size 

func (m *DeleteRequest) XXX_Size() int

func (*DeleteRequest) XXX_Unmarshal 

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

type DeleteResponse 

type DeleteResponse struct {
	Headers ResponseHeaders `protobuf:"bytes,1,opt,name=headers,proto3" json:"headers"`
}

func (*DeleteResponse) Descriptor 

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

func (*DeleteResponse) GetHeaders 

func (m *DeleteResponse) GetHeaders() ResponseHeaders

func (*DeleteResponse) Marshal 

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

func (*DeleteResponse) MarshalTo 

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

func (*DeleteResponse) MarshalToSizedBuffer 

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

func (*DeleteResponse) ProtoMessage 

func (*DeleteResponse) ProtoMessage()

func (*DeleteResponse) Reset 

func (m *DeleteResponse) Reset()

func (*DeleteResponse) Size 

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

func (*DeleteResponse) String 

func (m *DeleteResponse) String() string

func (*DeleteResponse) Unmarshal 

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

func (*DeleteResponse) XXX_DiscardUnknown 

func (m *DeleteResponse) XXX_DiscardUnknown()

func (*DeleteResponse) XXX_Marshal 

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

func (*DeleteResponse) XXX_Merge 

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

func (*DeleteResponse) XXX_Size 

func (m *DeleteResponse) XXX_Size() int

func (*DeleteResponse) XXX_Unmarshal 

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

type PrimitiveClient 

type PrimitiveClient interface {
	// Create creates a primitive
	Create(ctx context.Context, in *CreateRequest, opts ...grpc.CallOption) (*CreateResponse, error)
	// Close closes a primitive
	Close(ctx context.Context, in *CloseRequest, opts ...grpc.CallOption) (*CloseResponse, error)
	// Delete deletes a primitive
	Delete(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*DeleteResponse, error)
}

PrimitiveClient is the client API for Primitive service.

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

func NewPrimitiveClient 

func NewPrimitiveClient(cc *grpc.ClientConn) PrimitiveClient

type PrimitiveId 

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

func (*PrimitiveId) Descriptor 

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

func (*PrimitiveId) GetName 

func (m *PrimitiveId) GetName() string

func (*PrimitiveId) GetNamespace 

func (m *PrimitiveId) GetNamespace() string

func (*PrimitiveId) GetType 

func (m *PrimitiveId) GetType() string

func (*PrimitiveId) Marshal 

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

func (*PrimitiveId) MarshalTo 

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

func (*PrimitiveId) MarshalToSizedBuffer 

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

func (*PrimitiveId) ProtoMessage 

func (*PrimitiveId) ProtoMessage()

func (*PrimitiveId) Reset 

func (m *PrimitiveId) Reset()

func (*PrimitiveId) Size 

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

func (*PrimitiveId) String 

func (m *PrimitiveId) String() string

func (*PrimitiveId) Unmarshal 

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

func (*PrimitiveId) XXX_DiscardUnknown 

func (m *PrimitiveId) XXX_DiscardUnknown()

func (*PrimitiveId) XXX_Marshal 

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

func (*PrimitiveId) XXX_Merge 

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

func (*PrimitiveId) XXX_Size 

func (m *PrimitiveId) XXX_Size() int

func (*PrimitiveId) XXX_Unmarshal 

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

type PrimitiveServer 

type PrimitiveServer interface {
	// Create creates a primitive
	Create(context.Context, *CreateRequest) (*CreateResponse, error)
	// Close closes a primitive
	Close(context.Context, *CloseRequest) (*CloseResponse, error)
	// Delete deletes a primitive
	Delete(context.Context, *DeleteRequest) (*DeleteResponse, error)
}

PrimitiveServer is the server API for Primitive service.

type RequestHeaders 

type RequestHeaders struct {
	PrimitiveID PrimitiveId     `protobuf:"bytes,1,opt,name=primitive_id,json=primitiveId,proto3" json:"primitive_id"`
	ClusterKey  string          `protobuf:"bytes,2,opt,name=cluster_key,json=clusterKey,proto3" json:"cluster_key,omitempty"`
	Timestamp   *meta.Timestamp `protobuf:"bytes,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
}

func (*RequestHeaders) Descriptor 

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

func (*RequestHeaders) GetClusterKey added in v0.4.3 

func (m *RequestHeaders) GetClusterKey() string

func (*RequestHeaders) GetPrimitiveID 

func (m *RequestHeaders) GetPrimitiveID() PrimitiveId

func (*RequestHeaders) GetTimestamp 

func (m *RequestHeaders) GetTimestamp() *meta.Timestamp

func (*RequestHeaders) Marshal 

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

func (*RequestHeaders) MarshalTo 

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

func (*RequestHeaders) MarshalToSizedBuffer 

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

func (*RequestHeaders) ProtoMessage 

func (*RequestHeaders) ProtoMessage()

func (*RequestHeaders) Reset 

func (m *RequestHeaders) Reset()

func (*RequestHeaders) Size 

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

func (*RequestHeaders) String 

func (m *RequestHeaders) String() string

func (*RequestHeaders) Unmarshal 

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

func (*RequestHeaders) XXX_DiscardUnknown 

func (m *RequestHeaders) XXX_DiscardUnknown()

func (*RequestHeaders) XXX_Marshal 

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

func (*RequestHeaders) XXX_Merge 

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

func (*RequestHeaders) XXX_Size 

func (m *RequestHeaders) XXX_Size() int

func (*RequestHeaders) XXX_Unmarshal 

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

type ResponseError added in v0.4.10 

type ResponseError struct {
	Type    ResponseError_Type `protobuf:"varint,1,opt,name=type,proto3,enum=atomix.primitive.ResponseError_Type" json:"type,omitempty"`
	Message string             `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
}

func (*ResponseError) Descriptor added in v0.4.10 

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

func (*ResponseError) GetMessage added in v0.4.10 

func (m *ResponseError) GetMessage() string

func (*ResponseError) GetType added in v0.4.10 

func (m *ResponseError) GetType() ResponseError_Type

func (*ResponseError) Marshal added in v0.4.10 

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

func (*ResponseError) MarshalTo added in v0.4.10 

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

func (*ResponseError) MarshalToSizedBuffer added in v0.4.10 

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

func (*ResponseError) ProtoMessage added in v0.4.10 

func (*ResponseError) ProtoMessage()

func (*ResponseError) Reset added in v0.4.10 

func (m *ResponseError) Reset()

func (*ResponseError) Size added in v0.4.10 

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

func (*ResponseError) String added in v0.4.10 

func (m *ResponseError) String() string

func (*ResponseError) Unmarshal added in v0.4.10 

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

func (*ResponseError) XXX_DiscardUnknown added in v0.4.10 

func (m *ResponseError) XXX_DiscardUnknown()

func (*ResponseError) XXX_Marshal added in v0.4.10 

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

func (*ResponseError) XXX_Merge added in v0.4.10 

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

func (*ResponseError) XXX_Size added in v0.4.10 

func (m *ResponseError) XXX_Size() int

func (*ResponseError) XXX_Unmarshal added in v0.4.10 

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

type ResponseError_Type added in v0.4.10 

type ResponseError_Type int32
const (
	ResponseError_UNKNOWN        ResponseError_Type = 0
	ResponseError_CANCELED       ResponseError_Type = 1
	ResponseError_NOT_FOUND      ResponseError_Type = 2
	ResponseError_ALREADY_EXISTS ResponseError_Type = 3
	ResponseError_UNAUTHORIZED   ResponseError_Type = 4
	ResponseError_FORBIDDEN      ResponseError_Type = 5
	ResponseError_CONFLICT       ResponseError_Type = 6
	ResponseError_INVALID        ResponseError_Type = 7
	ResponseError_UNAVAILABLE    ResponseError_Type = 8
	ResponseError_NOT_SUPPORTED  ResponseError_Type = 9
	ResponseError_TIMEOUT        ResponseError_Type = 10
	ResponseError_INTERNAL       ResponseError_Type = 11
)

func (ResponseError_Type) EnumDescriptor added in v0.4.10 

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

func (ResponseError_Type) String added in v0.4.10 

func (x ResponseError_Type) String() string

type ResponseHeaders 

type ResponseHeaders struct {
	Timestamp *meta.Timestamp `protobuf:"bytes,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
}

func (*ResponseHeaders) Descriptor 

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

func (*ResponseHeaders) GetTimestamp 

func (m *ResponseHeaders) GetTimestamp() *meta.Timestamp

func (*ResponseHeaders) Marshal 

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

func (*ResponseHeaders) MarshalTo 

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

func (*ResponseHeaders) MarshalToSizedBuffer 

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

func (*ResponseHeaders) ProtoMessage 

func (*ResponseHeaders) ProtoMessage()

func (*ResponseHeaders) Reset 

func (m *ResponseHeaders) Reset()

func (*ResponseHeaders) Size 

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

func (*ResponseHeaders) String 

func (m *ResponseHeaders) String() string

func (*ResponseHeaders) Unmarshal 

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

func (*ResponseHeaders) XXX_DiscardUnknown 

func (m *ResponseHeaders) XXX_DiscardUnknown()

func (*ResponseHeaders) XXX_Marshal 

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

func (*ResponseHeaders) XXX_Merge 

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

func (*ResponseHeaders) XXX_Size 

func (m *ResponseHeaders) XXX_Size() int

func (*ResponseHeaders) XXX_Unmarshal 

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

type UnimplementedPrimitiveServer 

type UnimplementedPrimitiveServer struct {
}

UnimplementedPrimitiveServer can be embedded to have forward compatible implementations.

func (*UnimplementedPrimitiveServer) Close 

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

func (*UnimplementedPrimitiveServer) Create 

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

func (*UnimplementedPrimitiveServer) Delete 

func (*UnimplementedPrimitiveServer) Delete(ctx context.Context, req *DeleteRequest) (*DeleteResponse, error)

Source Files

View all Source files

Directories

Path Synopsis
extensions
operation
partition
service

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.