Documentation ¶
Index ¶
- Variables
- func RegisterEdgeServiceServer(s grpc.ServiceRegistrar, srv EdgeServiceServer)
- func RegisterVertexServiceServer(s grpc.ServiceRegistrar, srv VertexServiceServer)
- type EdgeServiceClient
- type EdgeServiceServer
- type LinkMessage
- func (*LinkMessage) Descriptor() ([]byte, []int)deprecated
- 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 (*LinkMessage) ProtoMessage()
- func (x *LinkMessage) ProtoReflect() protoreflect.Message
- func (x *LinkMessage) Reset()
- func (x *LinkMessage) String() string
- type Meta
- type Method
- type ObjectMessage
- func (*ObjectMessage) Descriptor() ([]byte, []int)deprecated
- 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 (*ObjectMessage) ProtoMessage()
- func (x *ObjectMessage) ProtoReflect() protoreflect.Message
- func (x *ObjectMessage) Reset()
- func (x *ObjectMessage) String() string
- type RegisterFunctionMessage
- func (*RegisterFunctionMessage) Descriptor() ([]byte, []int)deprecated
- func (x *RegisterFunctionMessage) GetAsync() bool
- func (x *RegisterFunctionMessage) GetFunctionMessage() *pbtypes.FunctionMessage
- func (x *RegisterFunctionMessage) GetId() string
- func (*RegisterFunctionMessage) ProtoMessage()
- func (x *RegisterFunctionMessage) ProtoReflect() protoreflect.Message
- func (x *RegisterFunctionMessage) Reset()
- func (x *RegisterFunctionMessage) String() string
- type RegisterLinkMessage
- func (*RegisterLinkMessage) Descriptor() ([]byte, []int)deprecated
- func (x *RegisterLinkMessage) GetAsync() bool
- func (x *RegisterLinkMessage) GetId() string
- func (x *RegisterLinkMessage) GetLinkMessage() *LinkMessage
- func (*RegisterLinkMessage) ProtoMessage()
- func (x *RegisterLinkMessage) ProtoReflect() protoreflect.Message
- func (x *RegisterLinkMessage) Reset()
- func (x *RegisterLinkMessage) String() string
- type RegisterMessage
- func (*RegisterMessage) Descriptor() ([]byte, []int)deprecated
- func (x *RegisterMessage) GetFunctionMessages() []*RegisterFunctionMessage
- func (x *RegisterMessage) GetLinkMessages() []*RegisterLinkMessage
- func (x *RegisterMessage) GetObjectMessages() []*RegisterObjectMessage
- func (x *RegisterMessage) GetTypeMessages() []*RegisterTypeMessage
- func (*RegisterMessage) ProtoMessage()
- func (x *RegisterMessage) ProtoReflect() protoreflect.Message
- func (x *RegisterMessage) Reset()
- func (x *RegisterMessage) String() string
- type RegisterObjectMessage
- func (*RegisterObjectMessage) Descriptor() ([]byte, []int)deprecated
- func (x *RegisterObjectMessage) GetAsync() bool
- func (x *RegisterObjectMessage) GetId() string
- func (x *RegisterObjectMessage) GetObjectMessage() *ObjectMessage
- func (x *RegisterObjectMessage) GetRouter() bool
- func (*RegisterObjectMessage) ProtoMessage()
- func (x *RegisterObjectMessage) ProtoReflect() protoreflect.Message
- func (x *RegisterObjectMessage) Reset()
- func (x *RegisterObjectMessage) String() string
- type RegisterTypeMessage
- func (*RegisterTypeMessage) Descriptor() ([]byte, []int)deprecated
- func (x *RegisterTypeMessage) GetAsync() bool
- func (x *RegisterTypeMessage) GetId() string
- func (x *RegisterTypeMessage) GetRouter() bool
- func (x *RegisterTypeMessage) GetTypeMessage() *TypeMessage
- func (*RegisterTypeMessage) ProtoMessage()
- func (x *RegisterTypeMessage) ProtoReflect() protoreflect.Message
- func (x *RegisterTypeMessage) Reset()
- func (x *RegisterTypeMessage) String() string
- type Request
- func (*Request) Descriptor() ([]byte, []int)deprecated
- func (x *Request) GetCollection() string
- func (x *Request) GetKey() string
- func (x *Request) GetPayload() []byte
- func (*Request) ProtoMessage()
- func (x *Request) ProtoReflect() protoreflect.Message
- func (x *Request) Reset()
- func (x *Request) String() string
- type Response
- type Trigger
- type TypeMessage
- func (*TypeMessage) Descriptor() ([]byte, []int)deprecated
- func (x *TypeMessage) GetFunctions() []*pbtypes.FunctionMessage
- func (x *TypeMessage) GetMethod() Method
- func (x *TypeMessage) GetName() string
- func (x *TypeMessage) GetPayload() []byte
- func (*TypeMessage) ProtoMessage()
- func (x *TypeMessage) ProtoReflect() protoreflect.Message
- func (x *TypeMessage) Reset()
- func (x *TypeMessage) String() string
- type UnimplementedEdgeServiceServer
- 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
- 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
- type UnsafeVertexServiceServer
- type VertexServiceClient
- type VertexServiceServer
Constants ¶
This section is empty.
Variables ¶
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.
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)
var File_pbcmdb_pbcmdb_proto protoreflect.FileDescriptor
var File_pbcmdb_service_proto protoreflect.FileDescriptor
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.
func NewEdgeServiceClient ¶
func NewEdgeServiceClient(cc grpc.ClientConnInterface) EdgeServiceClient
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) ProtoMessage ¶
func (*Meta) ProtoMessage()
func (*Meta) ProtoReflect ¶
func (x *Meta) ProtoReflect() protoreflect.Message
type Method ¶
type Method int32
func (Method) Descriptor ¶
func (Method) Descriptor() protoreflect.EnumDescriptor
func (Method) EnumDescriptor
deprecated
func (Method) Number ¶
func (x Method) Number() protoreflect.EnumNumber
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) GetCollection ¶
func (*Request) GetPayload ¶
func (*Request) ProtoMessage ¶
func (*Request) ProtoMessage()
func (*Request) ProtoReflect ¶
func (x *Request) ProtoReflect() protoreflect.Message
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) GetPayload ¶
func (*Response) ProtoMessage ¶
func (*Response) ProtoMessage()
func (*Response) ProtoReflect ¶
func (x *Response) ProtoReflect() protoreflect.Message
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) GetFunctionType ¶
func (x *Trigger) GetFunctionType() *pbtypes.FunctionType
func (*Trigger) ProtoMessage ¶
func (*Trigger) ProtoMessage()
func (*Trigger) ProtoReflect ¶
func (x *Trigger) ProtoReflect() protoreflect.Message
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.
type UnimplementedVertexServiceServer ¶
type UnimplementedVertexServiceServer struct { }
UnimplementedVertexServiceServer must be embedded to have forward compatible implementations.
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.
func NewVertexServiceClient ¶
func NewVertexServiceClient(cc grpc.ClientConnInterface) VertexServiceClient
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