natsrpc

package
v1.1.728 Latest Latest
Warning

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

 Go to latest Published: Nov 16, 2023 License: MIT Imports: 6 Imported by: 0

Documentation

Overview

Code generated by nats-proto-gen-go. DO NOT EDIT.

Code generated by nats-proto-gen-go. DO NOT EDIT.

Code generated by nats-proto-gen-go. DO NOT EDIT.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Shar 

type Shar interface {
	StoreWorkflow(ctx context.Context, req *model.StoreWorkflowRequest) (*model.StoreWorkflowResponse, error)
	CancelProcessInstance(ctx context.Context, req *model.CancelProcessInstanceRequest) (*model.CancelProcessInstanceResponse, error)
	LaunchProcess(ctx context.Context, req *model.LaunchWorkflowRequest) (*model.LaunchWorkflowResponse, error)
	ListWorkflows(ctx context.Context, req *model.ListWorkflowsRequest) (*model.ListWorkflowsResponse, error)
	ListExecutionProcesses(ctx context.Context, req *model.ListExecutionProcessesRequest) (*model.ListExecutionProcessesResponse, error)
	ListExecution(ctx context.Context, req *model.ListExecutionRequest) (*model.ListExecutionResponse, error)
	SendMessage(ctx context.Context, req *model.SendMessageRequest) (*model.SendMessageResponse, error)
	CompleteManualTask(ctx context.Context, req *model.CompleteManualTaskRequest) (*model.CompleteManualTaskResponse, error)
	CompleteServiceTask(ctx context.Context, req *model.CompleteServiceTaskRequest) (*model.CompleteServiceTaskResponse, error)
	CompleteUserTask(ctx context.Context, req *model.CompleteUserTaskRequest) (*model.CompleteUserTaskResponse, error)
	ListUserTaskIDs(ctx context.Context, req *model.ListUserTasksRequest) (*model.ListUserTasksResponse, error)
	GetUserTask(ctx context.Context, req *model.GetUserTaskRequest) (*model.GetUserTaskResponse, error)
	HandleWorkflowError(ctx context.Context, req *model.HandleWorkflowErrorRequest) (*model.HandleWorkflowErrorResponse, error)
	CompleteSendMessageTask(ctx context.Context, req *model.CompleteSendMessageRequest) (*model.CompleteSendMessageResponse, error)
	GetWorkflowVersions(ctx context.Context, req *model.GetWorkflowVersionsRequest) (*model.GetWorkflowVersionsResponse, error)
	GetWorkflow(ctx context.Context, req *model.GetWorkflowRequest) (*model.GetWorkflowResponse, error)
	GetProcessInstanceStatus(ctx context.Context, req *model.GetProcessInstanceStatusRequest) (*model.GetProcessInstanceStatusResponse, error)
	GetProcessHistory(ctx context.Context, req *model.GetProcessHistoryRequest) (*model.GetProcessHistoryResponse, error)
	GetVersionInfo(ctx context.Context, req *model.GetVersionInfoRequest) (*model.GetVersionInfoResponse, error)
	RegisterTask(ctx context.Context, req *model.RegisterTaskRequest) (*model.RegisterTaskResponse, error)
	GetTaskSpec(ctx context.Context, req *model.GetTaskSpecRequest) (*model.GetTaskSpecResponse, error)
	DeprecateServiceTask(ctx context.Context, req *model.DeprecateServiceTaskRequest) (*model.DeprecateServiceTaskResponse, error)
	GetTaskSpecVersions(ctx context.Context, req *model.GetTaskSpecVersionsRequest) (*model.GetTaskSpecVersionsResponse, error)
	GetTaskSpecUsage(ctx context.Context, req *model.GetTaskSpecUsageRequest) (*model.GetTaskSpecUsageResponse, error)
	ListTaskSpecUIDs(ctx context.Context, req *model.ListTaskSpecUIDsRequest) (*model.ListTaskSpecUIDsResponse, error)
}

Shar represents all of the API methods on the service.

type SharClient 

type SharClient struct {
	// contains filtered or unexported fields
}

Shar - The Shar service.

func NewSharClient 

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

NewSharClient - Creates a new client for Shar

func (*SharClient) CancelProcessInstance 

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

CancelProcessInstance - The CancelProcessInstance method.

func (*SharClient) CompleteManualTask 

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

CompleteManualTask - The CompleteManualTask method.

func (*SharClient) CompleteSendMessageTask 

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

CompleteSendMessageTask - The CompleteSendMessageTask method.

func (*SharClient) CompleteServiceTask 

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

CompleteServiceTask - The CompleteServiceTask method.

func (*SharClient) CompleteUserTask 

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

CompleteUserTask - The CompleteUserTask method.

func (*SharClient) DeprecateServiceTask 

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

DeprecateServiceTask - The DeprecateServiceTask method.

func (*SharClient) GetProcessHistory 

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

GetProcessHistory - The GetProcessHistory method.

func (*SharClient) GetProcessInstanceStatus 

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

GetProcessInstanceStatus - The GetProcessInstanceStatus method.

func (*SharClient) GetTaskSpec 

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

GetTaskSpec - The GetTaskSpec method.

func (*SharClient) GetTaskSpecUsage 

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

GetTaskSpecUsage - The GetTaskSpecUsage method.

func (*SharClient) GetTaskSpecVersions 

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

GetTaskSpecVersions - The GetTaskSpecVersions method.

func (*SharClient) GetUserTask 

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

GetUserTask - The GetUserTask method.

func (*SharClient) GetVersionInfo 

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

GetVersionInfo - The GetVersionInfo method.

func (*SharClient) GetWorkflow 

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

GetWorkflow - The GetWorkflow method.

func (*SharClient) GetWorkflowVersions 

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

GetWorkflowVersions - The GetWorkflowVersions method.

func (*SharClient) HandleWorkflowError 

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

HandleWorkflowError - The HandleWorkflowError method.

func (*SharClient) LaunchProcess 

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

LaunchProcess - The LaunchProcess method.

func (*SharClient) ListExecution 

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

ListExecution - The ListExecution method.

func (*SharClient) ListExecutionProcesses 

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

ListExecutionProcesses - The ListExecutionProcesses method.

func (*SharClient) ListTaskSpecUIDs 

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

ListTaskSpecUIDs - The ListTaskSpecUIDs method.

func (*SharClient) ListUserTaskIDs 

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

ListUserTaskIDs - The ListUserTaskIDs method.

func (*SharClient) ListWorkflows 

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

ListWorkflows - The ListWorkflows method.

func (*SharClient) RegisterTask 

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

RegisterTask - The RegisterTask method.

func (*SharClient) SendMessage 

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

SendMessage - The SendMessage method.

func (*SharClient) StoreWorkflow 

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

StoreWorkflow - The StoreWorkflow method.

type SharServer 

type SharServer struct {
	// contains filtered or unexported fields
}

SharServer - The Shar server.

func NewSharServer 

func NewSharServer(server Shar, panicRecovery bool) *SharServer

NewSharServer creates a new Shar server.

func (*SharServer) Listen 

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

Listen starts listening for incoming API requests.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.