pbcmdb

package
v0.1.1 Latest Latest
Warning

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

Go to latest
Published: Jan 25, 2023 License: Apache-2.0 Imports: 9 Imported by: 11

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	Method_name = map[int32]string{
		0: "CREATE",
		1: "CREATE_CHILD",
		2: "UPDATE",
		3: "DELETE",
		4: "CREATE_TRIGGER",
		5: "DELETE_TRIGGER",
	}
	Method_value = map[string]int32{
		"CREATE":         0,
		"CREATE_CHILD":   1,
		"UPDATE":         2,
		"DELETE":         3,
		"CREATE_TRIGGER": 4,
		"DELETE_TRIGGER": 5,
	}
)

Enum value maps for Method.

View Source
var EdgeService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "org.listware.sdk.pbcmdb.EdgeService",
	HandlerType: (*EdgeServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Create",
			Handler:    _EdgeService_Create_Handler,
		},
		{
			MethodName: "Read",
			Handler:    _EdgeService_Read_Handler,
		},
		{
			MethodName: "Update",
			Handler:    _EdgeService_Update_Handler,
		},
		{
			MethodName: "Remove",
			Handler:    _EdgeService_Remove_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "pbcmdb/service.proto",
}

EdgeService_ServiceDesc is the grpc.ServiceDesc for EdgeService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source
var File_pbcmdb_pbcmdb_proto protoreflect.FileDescriptor
View Source
var File_pbcmdb_service_proto protoreflect.FileDescriptor
View Source
var VertexService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "org.listware.sdk.pbcmdb.VertexService",
	HandlerType: (*VertexServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Create",
			Handler:    _VertexService_Create_Handler,
		},
		{
			MethodName: "Read",
			Handler:    _VertexService_Read_Handler,
		},
		{
			MethodName: "Update",
			Handler:    _VertexService_Update_Handler,
		},
		{
			MethodName: "Remove",
			Handler:    _VertexService_Remove_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "pbcmdb/service.proto",
}

VertexService_ServiceDesc is the grpc.ServiceDesc for VertexService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterEdgeServiceServer

func RegisterEdgeServiceServer(s grpc.ServiceRegistrar, srv EdgeServiceServer)

func RegisterVertexServiceServer

func RegisterVertexServiceServer(s grpc.ServiceRegistrar, srv VertexServiceServer)

Types

type EdgeServiceClient

type EdgeServiceClient interface {
	Create(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error)
	Read(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error)
	Update(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error)
	Remove(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error)
}

EdgeServiceClient is the client API for EdgeService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

type EdgeServiceServer

type EdgeServiceServer interface {
	Create(context.Context, *Request) (*Response, error)
	Read(context.Context, *Request) (*Response, error)
	Update(context.Context, *Request) (*Response, error)
	Remove(context.Context, *Request) (*Response, error)
	// contains filtered or unexported methods
}

EdgeServiceServer is the server API for EdgeService service. All implementations must embed UnimplementedEdgeServiceServer for forward compatibility

type LinkMessage

type LinkMessage struct {
	Method  Method `protobuf:"varint,1,opt,name=method,proto3,enum=org.listware.sdk.pbcmdb.Method" json:"method,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"`
	To      string `protobuf:"bytes,4,opt,name=to,proto3" json:"to,omitempty"`
	Payload []byte `protobuf:"bytes,5,opt,name=payload,proto3" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

func (*LinkMessage) Descriptor deprecated

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

Deprecated: Use LinkMessage.ProtoReflect.Descriptor instead.

func (*LinkMessage) GetMethod

func (x *LinkMessage) GetMethod() Method

func (*LinkMessage) GetName

func (x *LinkMessage) GetName() string

func (*LinkMessage) GetPayload

func (x *LinkMessage) GetPayload() []byte

func (*LinkMessage) GetTo

func (x *LinkMessage) GetTo() string

func (*LinkMessage) GetType

func (x *LinkMessage) GetType() string

func (*LinkMessage) ProtoMessage

func (*LinkMessage) ProtoMessage()

func (*LinkMessage) ProtoReflect

func (x *LinkMessage) ProtoReflect() protoreflect.Message

func (*LinkMessage) Reset

func (x *LinkMessage) Reset()

func (*LinkMessage) String

func (x *LinkMessage) String() string

type Meta

type Meta struct {
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Id  string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	Rev string `protobuf:"bytes,3,opt,name=rev,proto3" json:"rev,omitempty"`
	// contains filtered or unexported fields
}

func (*Meta) Descriptor deprecated

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

Deprecated: Use Meta.ProtoReflect.Descriptor instead.

func (*Meta) GetId

func (x *Meta) GetId() string

func (*Meta) GetKey

func (x *Meta) GetKey() string

func (*Meta) GetRev

func (x *Meta) GetRev() string

func (*Meta) ProtoMessage

func (*Meta) ProtoMessage()

func (*Meta) ProtoReflect

func (x *Meta) ProtoReflect() protoreflect.Message

func (*Meta) Reset

func (x *Meta) Reset()

func (*Meta) String

func (x *Meta) String() string

type Method

type Method int32
const (
	Method_CREATE         Method = 0
	Method_CREATE_CHILD   Method = 1
	Method_UPDATE         Method = 2
	Method_DELETE         Method = 3
	Method_CREATE_TRIGGER Method = 4
	Method_DELETE_TRIGGER Method = 5
)

func (Method) Descriptor

func (Method) Descriptor() protoreflect.EnumDescriptor

func (Method) Enum

func (x Method) Enum() *Method

func (Method) EnumDescriptor deprecated

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

Deprecated: Use Method.Descriptor instead.

func (Method) Number

func (x Method) Number() protoreflect.EnumNumber

func (Method) String

func (x Method) String() string

func (Method) Type

func (Method) Type() protoreflect.EnumType

type ObjectMessage

type ObjectMessage struct {
	Method  Method `protobuf:"varint,1,opt,name=method,proto3,enum=org.listware.sdk.pbcmdb.Method" json:"method,omitempty"`
	Type    string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	Name    string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	Payload []byte `protobuf:"bytes,4,opt,name=payload,proto3" json:"payload,omitempty"`
	// add links from func to object uuid
	Functions []*pbtypes.FunctionMessage `protobuf:"bytes,5,rep,name=functions,proto3" json:"functions,omitempty"`
	// contains filtered or unexported fields
}

func (*ObjectMessage) Descriptor deprecated

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

Deprecated: Use ObjectMessage.ProtoReflect.Descriptor instead.

func (*ObjectMessage) GetFunctions

func (x *ObjectMessage) GetFunctions() []*pbtypes.FunctionMessage

func (*ObjectMessage) GetMethod

func (x *ObjectMessage) GetMethod() Method

func (*ObjectMessage) GetName

func (x *ObjectMessage) GetName() string

func (*ObjectMessage) GetPayload

func (x *ObjectMessage) GetPayload() []byte

func (*ObjectMessage) GetType

func (x *ObjectMessage) GetType() string

func (*ObjectMessage) ProtoMessage

func (*ObjectMessage) ProtoMessage()

func (*ObjectMessage) ProtoReflect

func (x *ObjectMessage) ProtoReflect() protoreflect.Message

func (*ObjectMessage) Reset

func (x *ObjectMessage) Reset()

func (*ObjectMessage) String

func (x *ObjectMessage) String() string

type RegisterFunctionMessage

type RegisterFunctionMessage struct {
	Id              string                   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Async           bool                     `protobuf:"varint,2,opt,name=async,proto3" json:"async,omitempty"`
	FunctionMessage *pbtypes.FunctionMessage `protobuf:"bytes,4,opt,name=function_message,json=functionMessage,proto3" json:"function_message,omitempty"`
	// contains filtered or unexported fields
}

func (*RegisterFunctionMessage) Descriptor deprecated

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

Deprecated: Use RegisterFunctionMessage.ProtoReflect.Descriptor instead.

func (*RegisterFunctionMessage) GetAsync

func (x *RegisterFunctionMessage) GetAsync() bool

func (*RegisterFunctionMessage) GetFunctionMessage

func (x *RegisterFunctionMessage) GetFunctionMessage() *pbtypes.FunctionMessage

func (*RegisterFunctionMessage) GetId

func (x *RegisterFunctionMessage) GetId() string

func (*RegisterFunctionMessage) ProtoMessage

func (*RegisterFunctionMessage) ProtoMessage()

func (*RegisterFunctionMessage) ProtoReflect

func (x *RegisterFunctionMessage) ProtoReflect() protoreflect.Message

func (*RegisterFunctionMessage) Reset

func (x *RegisterFunctionMessage) Reset()

func (*RegisterFunctionMessage) String

func (x *RegisterFunctionMessage) String() string

type RegisterLinkMessage

type RegisterLinkMessage struct {
	Id          string       `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Async       bool         `protobuf:"varint,2,opt,name=async,proto3" json:"async,omitempty"`
	LinkMessage *LinkMessage `protobuf:"bytes,4,opt,name=link_message,json=linkMessage,proto3" json:"link_message,omitempty"`
	// contains filtered or unexported fields
}

func (*RegisterLinkMessage) Descriptor deprecated

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

Deprecated: Use RegisterLinkMessage.ProtoReflect.Descriptor instead.

func (*RegisterLinkMessage) GetAsync

func (x *RegisterLinkMessage) GetAsync() bool

func (*RegisterLinkMessage) GetId

func (x *RegisterLinkMessage) GetId() string

func (*RegisterLinkMessage) GetLinkMessage

func (x *RegisterLinkMessage) GetLinkMessage() *LinkMessage

func (*RegisterLinkMessage) ProtoMessage

func (*RegisterLinkMessage) ProtoMessage()

func (*RegisterLinkMessage) ProtoReflect

func (x *RegisterLinkMessage) ProtoReflect() protoreflect.Message

func (*RegisterLinkMessage) Reset

func (x *RegisterLinkMessage) Reset()

func (*RegisterLinkMessage) String

func (x *RegisterLinkMessage) String() string

type RegisterMessage

type RegisterMessage struct {
	TypeMessages     []*RegisterTypeMessage     `protobuf:"bytes,1,rep,name=type_messages,json=typeMessages,proto3" json:"type_messages,omitempty"`
	ObjectMessages   []*RegisterObjectMessage   `protobuf:"bytes,2,rep,name=object_messages,json=objectMessages,proto3" json:"object_messages,omitempty"`
	LinkMessages     []*RegisterLinkMessage     `protobuf:"bytes,3,rep,name=link_messages,json=linkMessages,proto3" json:"link_messages,omitempty"`
	FunctionMessages []*RegisterFunctionMessage `protobuf:"bytes,4,rep,name=function_messages,json=functionMessages,proto3" json:"function_messages,omitempty"`
	// contains filtered or unexported fields
}

func (*RegisterMessage) Descriptor deprecated

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

Deprecated: Use RegisterMessage.ProtoReflect.Descriptor instead.

func (*RegisterMessage) GetFunctionMessages

func (x *RegisterMessage) GetFunctionMessages() []*RegisterFunctionMessage

func (*RegisterMessage) GetLinkMessages

func (x *RegisterMessage) GetLinkMessages() []*RegisterLinkMessage

func (*RegisterMessage) GetObjectMessages

func (x *RegisterMessage) GetObjectMessages() []*RegisterObjectMessage

func (*RegisterMessage) GetTypeMessages

func (x *RegisterMessage) GetTypeMessages() []*RegisterTypeMessage

func (*RegisterMessage) ProtoMessage

func (*RegisterMessage) ProtoMessage()

func (*RegisterMessage) ProtoReflect

func (x *RegisterMessage) ProtoReflect() protoreflect.Message

func (*RegisterMessage) Reset

func (x *RegisterMessage) Reset()

func (*RegisterMessage) String

func (x *RegisterMessage) String() string

type RegisterObjectMessage

type RegisterObjectMessage struct {
	Id            string         `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Async         bool           `protobuf:"varint,2,opt,name=async,proto3" json:"async,omitempty"`
	Router        bool           `protobuf:"varint,3,opt,name=router,proto3" json:"router,omitempty"`
	ObjectMessage *ObjectMessage `protobuf:"bytes,4,opt,name=object_message,json=objectMessage,proto3" json:"object_message,omitempty"`
	// contains filtered or unexported fields
}

func (*RegisterObjectMessage) Descriptor deprecated

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

Deprecated: Use RegisterObjectMessage.ProtoReflect.Descriptor instead.

func (*RegisterObjectMessage) GetAsync

func (x *RegisterObjectMessage) GetAsync() bool

func (*RegisterObjectMessage) GetId

func (x *RegisterObjectMessage) GetId() string

func (*RegisterObjectMessage) GetObjectMessage

func (x *RegisterObjectMessage) GetObjectMessage() *ObjectMessage

func (*RegisterObjectMessage) GetRouter

func (x *RegisterObjectMessage) GetRouter() bool

func (*RegisterObjectMessage) ProtoMessage

func (*RegisterObjectMessage) ProtoMessage()

func (*RegisterObjectMessage) ProtoReflect

func (x *RegisterObjectMessage) ProtoReflect() protoreflect.Message

func (*RegisterObjectMessage) Reset

func (x *RegisterObjectMessage) Reset()

func (*RegisterObjectMessage) String

func (x *RegisterObjectMessage) String() string

type RegisterTypeMessage

type RegisterTypeMessage struct {
	Id          string       `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Async       bool         `protobuf:"varint,2,opt,name=async,proto3" json:"async,omitempty"`
	Router      bool         `protobuf:"varint,3,opt,name=router,proto3" json:"router,omitempty"`
	TypeMessage *TypeMessage `protobuf:"bytes,4,opt,name=type_message,json=typeMessage,proto3" json:"type_message,omitempty"`
	// contains filtered or unexported fields
}

func (*RegisterTypeMessage) Descriptor deprecated

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

Deprecated: Use RegisterTypeMessage.ProtoReflect.Descriptor instead.

func (*RegisterTypeMessage) GetAsync

func (x *RegisterTypeMessage) GetAsync() bool

func (*RegisterTypeMessage) GetId

func (x *RegisterTypeMessage) GetId() string

func (*RegisterTypeMessage) GetRouter

func (x *RegisterTypeMessage) GetRouter() bool

func (*RegisterTypeMessage) GetTypeMessage

func (x *RegisterTypeMessage) GetTypeMessage() *TypeMessage

func (*RegisterTypeMessage) ProtoMessage

func (*RegisterTypeMessage) ProtoMessage()

func (*RegisterTypeMessage) ProtoReflect

func (x *RegisterTypeMessage) ProtoReflect() protoreflect.Message

func (*RegisterTypeMessage) Reset

func (x *RegisterTypeMessage) Reset()

func (*RegisterTypeMessage) String

func (x *RegisterTypeMessage) String() string

type Request

type Request struct {
	Key        string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Collection string `protobuf:"bytes,2,opt,name=collection,proto3" json:"collection,omitempty"`
	Payload    []byte `protobuf:"bytes,3,opt,name=payload,proto3" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

func (*Request) Descriptor deprecated

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

Deprecated: Use Request.ProtoReflect.Descriptor instead.

func (*Request) GetCollection

func (x *Request) GetCollection() string

func (*Request) GetKey

func (x *Request) GetKey() string

func (*Request) GetPayload

func (x *Request) GetPayload() []byte

func (*Request) ProtoMessage

func (*Request) ProtoMessage()

func (*Request) ProtoReflect

func (x *Request) ProtoReflect() protoreflect.Message

func (*Request) Reset

func (x *Request) Reset()

func (*Request) String

func (x *Request) String() string

type Response

type Response struct {
	Meta    *Meta  `protobuf:"bytes,1,opt,name=meta,proto3" json:"meta,omitempty"`
	Payload []byte `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

func (*Response) Descriptor deprecated

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

Deprecated: Use Response.ProtoReflect.Descriptor instead.

func (*Response) GetMeta

func (x *Response) GetMeta() *Meta

func (*Response) GetPayload

func (x *Response) GetPayload() []byte

func (*Response) ProtoMessage

func (*Response) ProtoMessage()

func (*Response) ProtoReflect

func (x *Response) ProtoReflect() protoreflect.Message

func (*Response) Reset

func (x *Response) Reset()

func (*Response) String

func (x *Response) String() string

type Trigger

type Trigger struct {
	Type         string                `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	FunctionType *pbtypes.FunctionType `protobuf:"bytes,2,opt,name=function_type,proto3" json:"function_type,omitempty"`
	// contains filtered or unexported fields
}

func (*Trigger) Descriptor deprecated

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

Deprecated: Use Trigger.ProtoReflect.Descriptor instead.

func (*Trigger) GetFunctionType

func (x *Trigger) GetFunctionType() *pbtypes.FunctionType

func (*Trigger) GetType

func (x *Trigger) GetType() string

func (*Trigger) ProtoMessage

func (*Trigger) ProtoMessage()

func (*Trigger) ProtoReflect

func (x *Trigger) ProtoReflect() protoreflect.Message

func (*Trigger) Reset

func (x *Trigger) Reset()

func (*Trigger) String

func (x *Trigger) String() string

type TypeMessage

type TypeMessage struct {
	Method  Method `protobuf:"varint,1,opt,name=method,proto3,enum=org.listware.sdk.pbcmdb.Method" json:"method,omitempty"`
	Name    string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Payload []byte `protobuf:"bytes,3,opt,name=payload,proto3" json:"payload,omitempty"`
	// add links from func to object uuid
	Functions []*pbtypes.FunctionMessage `protobuf:"bytes,4,rep,name=functions,proto3" json:"functions,omitempty"`
	// contains filtered or unexported fields
}

func (*TypeMessage) Descriptor deprecated

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

Deprecated: Use TypeMessage.ProtoReflect.Descriptor instead.

func (*TypeMessage) GetFunctions

func (x *TypeMessage) GetFunctions() []*pbtypes.FunctionMessage

func (*TypeMessage) GetMethod

func (x *TypeMessage) GetMethod() Method

func (*TypeMessage) GetName

func (x *TypeMessage) GetName() string

func (*TypeMessage) GetPayload

func (x *TypeMessage) GetPayload() []byte

func (*TypeMessage) ProtoMessage

func (*TypeMessage) ProtoMessage()

func (*TypeMessage) ProtoReflect

func (x *TypeMessage) ProtoReflect() protoreflect.Message

func (*TypeMessage) Reset

func (x *TypeMessage) Reset()

func (*TypeMessage) String

func (x *TypeMessage) String() string

type UnimplementedEdgeServiceServer

type UnimplementedEdgeServiceServer struct {
}

UnimplementedEdgeServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedEdgeServiceServer) Create

func (UnimplementedEdgeServiceServer) Read

func (UnimplementedEdgeServiceServer) Remove

func (UnimplementedEdgeServiceServer) Update

type UnimplementedVertexServiceServer

type UnimplementedVertexServiceServer struct {
}

UnimplementedVertexServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedVertexServiceServer) Create

func (UnimplementedVertexServiceServer) Read

func (UnimplementedVertexServiceServer) Remove

func (UnimplementedVertexServiceServer) Update

type UnsafeEdgeServiceServer

type UnsafeEdgeServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeEdgeServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to EdgeServiceServer will result in compilation errors.

type UnsafeVertexServiceServer

type UnsafeVertexServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeVertexServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to VertexServiceServer will result in compilation errors.

type VertexServiceClient

type VertexServiceClient interface {
	Create(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error)
	Read(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error)
	Update(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error)
	Remove(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error)
}

VertexServiceClient is the client API for VertexService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

type VertexServiceServer

type VertexServiceServer interface {
	Create(context.Context, *Request) (*Response, error)
	Read(context.Context, *Request) (*Response, error)
	Update(context.Context, *Request) (*Response, error)
	Remove(context.Context, *Request) (*Response, error)
	// contains filtered or unexported methods
}

VertexServiceServer is the server API for VertexService service. All implementations must embed UnimplementedVertexServiceServer for forward compatibility

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL