Documentation ¶
Index ¶
- Variables
- func RegisterWorkflowServer(s grpc.ServiceRegistrar, srv WorkflowServer)
- type ExecuteRequest
- func (*ExecuteRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ExecuteRequest) GetId() string
- func (x *ExecuteRequest) GetInput() string
- func (x *ExecuteRequest) GetInstanceId() string
- func (x *ExecuteRequest) GetTaskInstanceId() string
- func (*ExecuteRequest) ProtoMessage()
- func (x *ExecuteRequest) ProtoReflect() protoreflect.Message
- func (x *ExecuteRequest) Reset()
- func (x *ExecuteRequest) String() string
- type ExecuteResponse
- type UnimplementedWorkflowServer
- type UnsafeWorkflowServer
- type WorkflowClient
- type WorkflowServer
Constants ¶
This section is empty.
Variables ¶
var File_workflow_proto protoreflect.FileDescriptor
var Workflow_ServiceDesc = grpc.ServiceDesc{ ServiceName: "eventmesh.workflow.api.protocol.Workflow", HandlerType: (*WorkflowServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Execute", Handler: _Workflow_Execute_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "workflow.proto", }
Workflow_ServiceDesc is the grpc.ServiceDesc for Workflow service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterWorkflowServer ¶
func RegisterWorkflowServer(s grpc.ServiceRegistrar, srv WorkflowServer)
Types ¶
type ExecuteRequest ¶
type ExecuteRequest struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` InstanceId string `protobuf:"bytes,2,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"` TaskInstanceId string `protobuf:"bytes,3,opt,name=task_instance_id,json=taskInstanceId,proto3" json:"task_instance_id,omitempty"` Input string `protobuf:"bytes,4,opt,name=input,proto3" json:"input,omitempty"` // contains filtered or unexported fields }
func (*ExecuteRequest) Descriptor
deprecated
func (*ExecuteRequest) Descriptor() ([]byte, []int)
Deprecated: Use ExecuteRequest.ProtoReflect.Descriptor instead.
func (*ExecuteRequest) GetId ¶
func (x *ExecuteRequest) GetId() string
func (*ExecuteRequest) GetInput ¶
func (x *ExecuteRequest) GetInput() string
func (*ExecuteRequest) GetInstanceId ¶
func (x *ExecuteRequest) GetInstanceId() string
func (*ExecuteRequest) GetTaskInstanceId ¶
func (x *ExecuteRequest) GetTaskInstanceId() string
func (*ExecuteRequest) ProtoMessage ¶
func (*ExecuteRequest) ProtoMessage()
func (*ExecuteRequest) ProtoReflect ¶
func (x *ExecuteRequest) ProtoReflect() protoreflect.Message
func (*ExecuteRequest) Reset ¶
func (x *ExecuteRequest) Reset()
func (*ExecuteRequest) String ¶
func (x *ExecuteRequest) String() string
type ExecuteResponse ¶
type ExecuteResponse struct { InstanceId string `protobuf:"bytes,1,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"` // contains filtered or unexported fields }
func (*ExecuteResponse) Descriptor
deprecated
func (*ExecuteResponse) Descriptor() ([]byte, []int)
Deprecated: Use ExecuteResponse.ProtoReflect.Descriptor instead.
func (*ExecuteResponse) GetInstanceId ¶
func (x *ExecuteResponse) GetInstanceId() string
func (*ExecuteResponse) ProtoMessage ¶
func (*ExecuteResponse) ProtoMessage()
func (*ExecuteResponse) ProtoReflect ¶
func (x *ExecuteResponse) ProtoReflect() protoreflect.Message
func (*ExecuteResponse) Reset ¶
func (x *ExecuteResponse) Reset()
func (*ExecuteResponse) String ¶
func (x *ExecuteResponse) String() string
type UnimplementedWorkflowServer ¶
type UnimplementedWorkflowServer struct { }
UnimplementedWorkflowServer must be embedded to have forward compatible implementations.
func (UnimplementedWorkflowServer) Execute ¶
func (UnimplementedWorkflowServer) Execute(context.Context, *ExecuteRequest) (*ExecuteResponse, error)
type UnsafeWorkflowServer ¶
type UnsafeWorkflowServer interface {
// contains filtered or unexported methods
}
UnsafeWorkflowServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to WorkflowServer will result in compilation errors.
type WorkflowClient ¶
type WorkflowClient interface {
Execute(ctx context.Context, in *ExecuteRequest, opts ...grpc.CallOption) (*ExecuteResponse, error)
}
WorkflowClient is the client API for Workflow 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 NewWorkflowClient ¶
func NewWorkflowClient(cc grpc.ClientConnInterface) WorkflowClient
type WorkflowServer ¶
type WorkflowServer interface { Execute(context.Context, *ExecuteRequest) (*ExecuteResponse, error) // contains filtered or unexported methods }
WorkflowServer is the server API for Workflow service. All implementations must embed UnimplementedWorkflowServer for forward compatibility