natsrpc

package

Go to main page

Versions in this module

v1

v1.1.1026

Apr 9, 2024

v1.1.1024

Apr 8, 2024

v1.1.1020

Apr 8, 2024

v1.1.1016

Apr 8, 2024

v1.1.1010

Apr 5, 2024

v1.1.1003

Apr 5, 2024

v1.1.999

Apr 5, 2024

v1.1.995

Apr 4, 2024

v1.1.991

Apr 4, 2024

v1.1.978

Apr 3, 2024

v1.1.975

Mar 29, 2024

v1.1.973

Mar 28, 2024

v1.1.969

Mar 28, 2024

v1.1.965

Mar 28, 2024

v1.1.961

Mar 28, 2024

v1.1.957

Mar 28, 2024

v1.1.953

Mar 28, 2024

v1.1.949

Mar 28, 2024

v1.1.947

Mar 28, 2024

v1.1.933

Mar 26, 2024

v1.1.929

Mar 20, 2024

v1.1.927

Mar 19, 2024

Changes in this version

type Shar

+ ResolveWorkflow func(ctx context.Context, req *model.ResolveWorkflowRequest) (*model.ResolveWorkflowResponse, error)

type SharClient

+ func (c *SharClient) ResolveWorkflow(ctx context.Context, req *model.ResolveWorkflowRequest) (*model.ResolveWorkflowResponse, error)

v1.1.913

Mar 14, 2024

v1.1.889

Mar 6, 2024

v1.1.885

Mar 6, 2024

v1.1.882

Mar 1, 2024

v1.1.876

Feb 28, 2024

v1.1.863

Feb 28, 2024

v1.1.856

Feb 27, 2024

v1.1.848

Feb 27, 2024

v1.1.835

Feb 21, 2024

v1.1.799

Feb 7, 2024

v1.1.797

Feb 5, 2024

Changes in this version

type Shar

+ GetJob func(ctx context.Context, req *model.GetJobRequest) (*model.GetJobResponse, error)

type SharClient

+ func (c *SharClient) GetJob(ctx context.Context, req *model.GetJobRequest) (*model.GetJobResponse, error)

v1.1.785

Jan 22, 2024

v1.1.763

Dec 20, 2023

v1.1.759

Dec 11, 2023

v1.1.755

Dec 11, 2023

v1.1.754

Dec 11, 2023

Changes in this version

type Shar

+ Log func(ctx context.Context, req *model.LogRequest) (*model.LogResponse, error)

type SharClient

+ func (c *SharClient) Log(ctx context.Context, req *model.LogRequest) (*model.LogResponse, error)

v1.1.732

Nov 21, 2023

v1.1.731

Nov 19, 2023

Changes in this version

type Shar

+ Heartbeat func(ctx context.Context, req *model.HeartbeatRequest) (*model.HeartbeatResponse, error)

type SharClient

+ func (c *SharClient) Heartbeat(ctx context.Context, req *model.HeartbeatRequest) (*model.HeartbeatResponse, error)

v1.1.729

Nov 16, 2023

v1.1.728

Nov 16, 2023

v1.1.726

Nov 16, 2023

v1.1.725

Nov 16, 2023

Changes in this version

+ type Shar interface

+ CancelProcessInstance func(ctx context.Context, req *model.CancelProcessInstanceRequest) (*model.CancelProcessInstanceResponse, error)

+ CompleteManualTask func(ctx context.Context, req *model.CompleteManualTaskRequest) (*model.CompleteManualTaskResponse, error)

+ CompleteSendMessageTask func(ctx context.Context, req *model.CompleteSendMessageRequest) (*model.CompleteSendMessageResponse, error)

+ CompleteServiceTask func(ctx context.Context, req *model.CompleteServiceTaskRequest) (*model.CompleteServiceTaskResponse, error)

+ CompleteUserTask func(ctx context.Context, req *model.CompleteUserTaskRequest) (*model.CompleteUserTaskResponse, error)

+ DeprecateServiceTask func(ctx context.Context, req *model.DeprecateServiceTaskRequest) (*model.DeprecateServiceTaskResponse, error)

+ GetProcessHistory func(ctx context.Context, req *model.GetProcessHistoryRequest) (*model.GetProcessHistoryResponse, error)

+ GetProcessInstanceStatus func(ctx context.Context, req *model.GetProcessInstanceStatusRequest) (*model.GetProcessInstanceStatusResponse, error)

+ GetTaskSpec func(ctx context.Context, req *model.GetTaskSpecRequest) (*model.GetTaskSpecResponse, error)

+ GetTaskSpecUsage func(ctx context.Context, req *model.GetTaskSpecUsageRequest) (*model.GetTaskSpecUsageResponse, error)

+ GetTaskSpecVersions func(ctx context.Context, req *model.GetTaskSpecVersionsRequest) (*model.GetTaskSpecVersionsResponse, error)

+ GetUserTask func(ctx context.Context, req *model.GetUserTaskRequest) (*model.GetUserTaskResponse, error)

+ GetVersionInfo func(ctx context.Context, req *model.GetVersionInfoRequest) (*model.GetVersionInfoResponse, error)

+ GetWorkflow func(ctx context.Context, req *model.GetWorkflowRequest) (*model.GetWorkflowResponse, error)

+ GetWorkflowVersions func(ctx context.Context, req *model.GetWorkflowVersionsRequest) (*model.GetWorkflowVersionsResponse, error)

+ HandleWorkflowError func(ctx context.Context, req *model.HandleWorkflowErrorRequest) (*model.HandleWorkflowErrorResponse, error)

+ LaunchProcess func(ctx context.Context, req *model.LaunchWorkflowRequest) (*model.LaunchWorkflowResponse, error)

+ ListExecution func(ctx context.Context, req *model.ListExecutionRequest) (*model.ListExecutionResponse, error)

+ ListExecutionProcesses func(ctx context.Context, req *model.ListExecutionProcessesRequest) (*model.ListExecutionProcessesResponse, error)

+ ListTaskSpecUIDs func(ctx context.Context, req *model.ListTaskSpecUIDsRequest) (*model.ListTaskSpecUIDsResponse, error)

+ ListUserTaskIDs func(ctx context.Context, req *model.ListUserTasksRequest) (*model.ListUserTasksResponse, error)

+ ListWorkflows func(ctx context.Context, req *model.ListWorkflowsRequest) (*model.ListWorkflowsResponse, error)

+ RegisterTask func(ctx context.Context, req *model.RegisterTaskRequest) (*model.RegisterTaskResponse, error)

+ SendMessage func(ctx context.Context, req *model.SendMessageRequest) (*model.SendMessageResponse, error)

+ StoreWorkflow func(ctx context.Context, req *model.StoreWorkflowRequest) (*model.StoreWorkflowResponse, error)

+ type SharClient struct

+ func NewSharClient(serverNatsConnection *nats.Conn, middleware []core.Handler, ...) SharClient

+ func (c *SharClient) CancelProcessInstance(ctx context.Context, req *model.CancelProcessInstanceRequest) (*model.CancelProcessInstanceResponse, error)

+ func (c *SharClient) CompleteManualTask(ctx context.Context, req *model.CompleteManualTaskRequest) (*model.CompleteManualTaskResponse, error)

+ func (c *SharClient) CompleteSendMessageTask(ctx context.Context, req *model.CompleteSendMessageRequest) (*model.CompleteSendMessageResponse, error)

+ func (c *SharClient) CompleteServiceTask(ctx context.Context, req *model.CompleteServiceTaskRequest) (*model.CompleteServiceTaskResponse, error)

+ func (c *SharClient) CompleteUserTask(ctx context.Context, req *model.CompleteUserTaskRequest) (*model.CompleteUserTaskResponse, error)

+ func (c *SharClient) DeprecateServiceTask(ctx context.Context, req *model.DeprecateServiceTaskRequest) (*model.DeprecateServiceTaskResponse, error)

+ func (c *SharClient) GetProcessHistory(ctx context.Context, req *model.GetProcessHistoryRequest) (*model.GetProcessHistoryResponse, error)

+ func (c *SharClient) GetProcessInstanceStatus(ctx context.Context, req *model.GetProcessInstanceStatusRequest) (*model.GetProcessInstanceStatusResponse, error)

+ func (c *SharClient) GetTaskSpec(ctx context.Context, req *model.GetTaskSpecRequest) (*model.GetTaskSpecResponse, error)

+ func (c *SharClient) GetTaskSpecUsage(ctx context.Context, req *model.GetTaskSpecUsageRequest) (*model.GetTaskSpecUsageResponse, error)

+ func (c *SharClient) GetTaskSpecVersions(ctx context.Context, req *model.GetTaskSpecVersionsRequest) (*model.GetTaskSpecVersionsResponse, error)

+ func (c *SharClient) GetUserTask(ctx context.Context, req *model.GetUserTaskRequest) (*model.GetUserTaskResponse, error)

+ func (c *SharClient) GetVersionInfo(ctx context.Context, req *model.GetVersionInfoRequest) (*model.GetVersionInfoResponse, error)

+ func (c *SharClient) GetWorkflow(ctx context.Context, req *model.GetWorkflowRequest) (*model.GetWorkflowResponse, error)

+ func (c *SharClient) GetWorkflowVersions(ctx context.Context, req *model.GetWorkflowVersionsRequest) (*model.GetWorkflowVersionsResponse, error)

+ func (c *SharClient) HandleWorkflowError(ctx context.Context, req *model.HandleWorkflowErrorRequest) (*model.HandleWorkflowErrorResponse, error)

+ func (c *SharClient) LaunchProcess(ctx context.Context, req *model.LaunchWorkflowRequest) (*model.LaunchWorkflowResponse, error)

+ func (c *SharClient) ListExecution(ctx context.Context, req *model.ListExecutionRequest) (*model.ListExecutionResponse, error)

+ func (c *SharClient) ListExecutionProcesses(ctx context.Context, req *model.ListExecutionProcessesRequest) (*model.ListExecutionProcessesResponse, error)

+ func (c *SharClient) ListTaskSpecUIDs(ctx context.Context, req *model.ListTaskSpecUIDsRequest) (*model.ListTaskSpecUIDsResponse, error)

+ func (c *SharClient) ListUserTaskIDs(ctx context.Context, req *model.ListUserTasksRequest) (*model.ListUserTasksResponse, error)

+ func (c *SharClient) ListWorkflows(ctx context.Context, req *model.ListWorkflowsRequest) (*model.ListWorkflowsResponse, error)

+ func (c *SharClient) RegisterTask(ctx context.Context, req *model.RegisterTaskRequest) (*model.RegisterTaskResponse, error)

+ func (c *SharClient) SendMessage(ctx context.Context, req *model.SendMessageRequest) (*model.SendMessageResponse, error)

+ func (c *SharClient) StoreWorkflow(ctx context.Context, req *model.StoreWorkflowRequest) (*model.StoreWorkflowResponse, error)

+ type SharServer struct

+ func NewSharServer(server Shar, panicRecovery bool) *SharServer

+ func (s *SharServer) Listen(con *nats.Conn, middleware []core.Handler, errorHandler core.ErrorHandler) error

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