Versions in this module Expand all Collapse all v0 v0.1.1 Jan 25, 2023 Changes in this version + var EdgeService_ServiceDesc = grpc.ServiceDesc + var File_pbcmdb_pbcmdb_proto protoreflect.FileDescriptor + var File_pbcmdb_service_proto protoreflect.FileDescriptor + var Method_name = map[int32]string + var Method_value = map[string]int32 + var VertexService_ServiceDesc = grpc.ServiceDesc + func RegisterEdgeServiceServer(s grpc.ServiceRegistrar, srv EdgeServiceServer) + func RegisterVertexServiceServer(s grpc.ServiceRegistrar, srv VertexServiceServer) + type EdgeServiceClient interface + Create func(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error) + Read func(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error) + Remove func(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error) + Update func(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error) + func NewEdgeServiceClient(cc grpc.ClientConnInterface) EdgeServiceClient + type EdgeServiceServer interface + Create func(context.Context, *Request) (*Response, error) + Read func(context.Context, *Request) (*Response, error) + Remove func(context.Context, *Request) (*Response, error) + Update func(context.Context, *Request) (*Response, error) + type LinkMessage struct + Method Method + Name string + Payload []byte + To string + Type string + func (*LinkMessage) Descriptor() ([]byte, []int) + func (*LinkMessage) ProtoMessage() + func (x *LinkMessage) GetMethod() Method + func (x *LinkMessage) GetName() string + func (x *LinkMessage) GetPayload() []byte + func (x *LinkMessage) GetTo() string + func (x *LinkMessage) GetType() string + func (x *LinkMessage) ProtoReflect() protoreflect.Message + func (x *LinkMessage) Reset() + func (x *LinkMessage) String() string + type Meta struct + Id string + Key string + Rev string + func (*Meta) Descriptor() ([]byte, []int) + func (*Meta) ProtoMessage() + func (x *Meta) GetId() string + func (x *Meta) GetKey() string + func (x *Meta) GetRev() string + func (x *Meta) ProtoReflect() protoreflect.Message + func (x *Meta) Reset() + func (x *Meta) String() string + type Method int32 + const Method_CREATE + const Method_CREATE_CHILD + const Method_CREATE_TRIGGER + const Method_DELETE + const Method_DELETE_TRIGGER + const Method_UPDATE + func (Method) Descriptor() protoreflect.EnumDescriptor + func (Method) EnumDescriptor() ([]byte, []int) + func (Method) Type() protoreflect.EnumType + func (x Method) Enum() *Method + func (x Method) Number() protoreflect.EnumNumber + func (x Method) String() string + type ObjectMessage struct + Functions []*pbtypes.FunctionMessage + Method Method + Name string + Payload []byte + Type string + func (*ObjectMessage) Descriptor() ([]byte, []int) + func (*ObjectMessage) ProtoMessage() + func (x *ObjectMessage) GetFunctions() []*pbtypes.FunctionMessage + func (x *ObjectMessage) GetMethod() Method + func (x *ObjectMessage) GetName() string + func (x *ObjectMessage) GetPayload() []byte + func (x *ObjectMessage) GetType() string + func (x *ObjectMessage) ProtoReflect() protoreflect.Message + func (x *ObjectMessage) Reset() + func (x *ObjectMessage) String() string + type RegisterFunctionMessage struct + Async bool + FunctionMessage *pbtypes.FunctionMessage + Id string + func (*RegisterFunctionMessage) Descriptor() ([]byte, []int) + func (*RegisterFunctionMessage) ProtoMessage() + func (x *RegisterFunctionMessage) GetAsync() bool + func (x *RegisterFunctionMessage) GetFunctionMessage() *pbtypes.FunctionMessage + func (x *RegisterFunctionMessage) GetId() string + func (x *RegisterFunctionMessage) ProtoReflect() protoreflect.Message + func (x *RegisterFunctionMessage) Reset() + func (x *RegisterFunctionMessage) String() string + type RegisterLinkMessage struct + Async bool + Id string + LinkMessage *LinkMessage + func (*RegisterLinkMessage) Descriptor() ([]byte, []int) + func (*RegisterLinkMessage) ProtoMessage() + func (x *RegisterLinkMessage) GetAsync() bool + func (x *RegisterLinkMessage) GetId() string + func (x *RegisterLinkMessage) GetLinkMessage() *LinkMessage + func (x *RegisterLinkMessage) ProtoReflect() protoreflect.Message + func (x *RegisterLinkMessage) Reset() + func (x *RegisterLinkMessage) String() string + type RegisterMessage struct + FunctionMessages []*RegisterFunctionMessage + LinkMessages []*RegisterLinkMessage + ObjectMessages []*RegisterObjectMessage + TypeMessages []*RegisterTypeMessage + func (*RegisterMessage) Descriptor() ([]byte, []int) + func (*RegisterMessage) ProtoMessage() + func (x *RegisterMessage) GetFunctionMessages() []*RegisterFunctionMessage + func (x *RegisterMessage) GetLinkMessages() []*RegisterLinkMessage + func (x *RegisterMessage) GetObjectMessages() []*RegisterObjectMessage + func (x *RegisterMessage) GetTypeMessages() []*RegisterTypeMessage + func (x *RegisterMessage) ProtoReflect() protoreflect.Message + func (x *RegisterMessage) Reset() + func (x *RegisterMessage) String() string + type RegisterObjectMessage struct + Async bool + Id string + ObjectMessage *ObjectMessage + Router bool + func (*RegisterObjectMessage) Descriptor() ([]byte, []int) + func (*RegisterObjectMessage) ProtoMessage() + func (x *RegisterObjectMessage) GetAsync() bool + func (x *RegisterObjectMessage) GetId() string + func (x *RegisterObjectMessage) GetObjectMessage() *ObjectMessage + func (x *RegisterObjectMessage) GetRouter() bool + func (x *RegisterObjectMessage) ProtoReflect() protoreflect.Message + func (x *RegisterObjectMessage) Reset() + func (x *RegisterObjectMessage) String() string + type RegisterTypeMessage struct + Async bool + Id string + Router bool + TypeMessage *TypeMessage + func (*RegisterTypeMessage) Descriptor() ([]byte, []int) + func (*RegisterTypeMessage) ProtoMessage() + func (x *RegisterTypeMessage) GetAsync() bool + func (x *RegisterTypeMessage) GetId() string + func (x *RegisterTypeMessage) GetRouter() bool + func (x *RegisterTypeMessage) GetTypeMessage() *TypeMessage + func (x *RegisterTypeMessage) ProtoReflect() protoreflect.Message + func (x *RegisterTypeMessage) Reset() + func (x *RegisterTypeMessage) String() string + type Request struct + Collection string + Key string + Payload []byte + func (*Request) Descriptor() ([]byte, []int) + func (*Request) ProtoMessage() + func (x *Request) GetCollection() string + func (x *Request) GetKey() string + func (x *Request) GetPayload() []byte + func (x *Request) ProtoReflect() protoreflect.Message + func (x *Request) Reset() + func (x *Request) String() string + type Response struct + Meta *Meta + Payload []byte + func (*Response) Descriptor() ([]byte, []int) + func (*Response) ProtoMessage() + func (x *Response) GetMeta() *Meta + func (x *Response) GetPayload() []byte + func (x *Response) ProtoReflect() protoreflect.Message + func (x *Response) Reset() + func (x *Response) String() string + type Trigger struct + FunctionType *pbtypes.FunctionType + Type string + func (*Trigger) Descriptor() ([]byte, []int) + func (*Trigger) ProtoMessage() + func (x *Trigger) GetFunctionType() *pbtypes.FunctionType + func (x *Trigger) GetType() string + func (x *Trigger) ProtoReflect() protoreflect.Message + func (x *Trigger) Reset() + func (x *Trigger) String() string + type TypeMessage struct + Functions []*pbtypes.FunctionMessage + Method Method + Name string + Payload []byte + func (*TypeMessage) Descriptor() ([]byte, []int) + func (*TypeMessage) ProtoMessage() + func (x *TypeMessage) GetFunctions() []*pbtypes.FunctionMessage + func (x *TypeMessage) GetMethod() Method + func (x *TypeMessage) GetName() string + func (x *TypeMessage) GetPayload() []byte + func (x *TypeMessage) ProtoReflect() protoreflect.Message + func (x *TypeMessage) Reset() + func (x *TypeMessage) String() string + type UnimplementedEdgeServiceServer struct + func (UnimplementedEdgeServiceServer) Create(context.Context, *Request) (*Response, error) + func (UnimplementedEdgeServiceServer) Read(context.Context, *Request) (*Response, error) + func (UnimplementedEdgeServiceServer) Remove(context.Context, *Request) (*Response, error) + func (UnimplementedEdgeServiceServer) Update(context.Context, *Request) (*Response, error) + type UnimplementedVertexServiceServer struct + func (UnimplementedVertexServiceServer) Create(context.Context, *Request) (*Response, error) + func (UnimplementedVertexServiceServer) Read(context.Context, *Request) (*Response, error) + func (UnimplementedVertexServiceServer) Remove(context.Context, *Request) (*Response, error) + func (UnimplementedVertexServiceServer) Update(context.Context, *Request) (*Response, error) + type UnsafeEdgeServiceServer interface + type UnsafeVertexServiceServer interface + type VertexServiceClient interface + Create func(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error) + Read func(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error) + Remove func(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error) + Update func(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error) + func NewVertexServiceClient(cc grpc.ClientConnInterface) VertexServiceClient + type VertexServiceServer interface + Create func(context.Context, *Request) (*Response, error) + Read func(context.Context, *Request) (*Response, error) + Remove func(context.Context, *Request) (*Response, error) + Update func(context.Context, *Request) (*Response, error)