api

Documentation

Index

• Constants
• func NewService(config config.Config, client uclient.UnifiedClient, logger log.Logger) *gin.Engine
• type ApiService
  • func NewApiService(config config.Config, client uclient.UnifiedClient, taskQueue string, ...) (ApiService, error)

Constants

const InfoHealthCheck = "/info/healthcheck"

const WorkflowConfigUpdateApiPath = "/api/v1/workflow/config/update"

const WorkflowGetApiPath = "/api/v1/workflow/get"

const WorkflowGetDataObjectsApiPath = "/api/v1/workflow/dataobjects/get"

const WorkflowGetSearchAttributesApiPath = "/api/v1/workflow/searchattributes/get"

const WorkflowGetWithWaitApiPath = "/api/v1/workflow/getWithWait"

const WorkflowInternalDumpApiPath = "/api/v1/workflow/internal/dump"

const WorkflowResetApiPath = "/api/v1/workflow/reset"

const WorkflowRpcApiPath = "/api/v1/workflow/rpc"

const WorkflowSearchApiPath = "/api/v1/workflow/search"

const WorkflowSignalApiPath = "/api/v1/workflow/signal"

const WorkflowSkipTimerApiPath = "/api/v1/workflow/timer/skip"

const WorkflowStartApiPath = "/api/v1/workflow/start"

const WorkflowStopApiPath = "/api/v1/workflow/stop"

const WorkflowWaitForStateCompletionApiPath = "/api/v1/workflow/waitForStateCompletion"

Functions

func NewService

func NewService(config config.Config, client uclient.UnifiedClient, logger log.Logger) *gin.Engine

NewService returns a new router.

Types

type ApiService

type ApiService interface {
	ApiV1WorkflowStartPost(ctx context.Context, request iwfidl.WorkflowStartRequest) (*iwfidl.WorkflowStartResponse, *errors.ErrorAndStatus)
	ApiV1WorkflowWaitForStateCompletion(ctx context.Context, request iwfidl.WorkflowWaitForStateCompletionRequest) (*iwfidl.WorkflowWaitForStateCompletionResponse, *errors.ErrorAndStatus)
	ApiV1WorkflowSignalPost(ctx context.Context, request iwfidl.WorkflowSignalRequest) *errors.ErrorAndStatus
	ApiV1WorkflowStopPost(ctx context.Context, request iwfidl.WorkflowStopRequest) *errors.ErrorAndStatus
	ApiV1WorkflowConfigUpdate(ctx context.Context, request iwfidl.WorkflowConfigUpdateRequest) *errors.ErrorAndStatus
	ApiV1WorkflowGetQueryAttributesPost(ctx context.Context, request iwfidl.WorkflowGetDataObjectsRequest) (*iwfidl.WorkflowGetDataObjectsResponse, *errors.ErrorAndStatus)
	ApiV1WorkflowGetSearchAttributesPost(ctx context.Context, request iwfidl.WorkflowGetSearchAttributesRequest) (*iwfidl.WorkflowGetSearchAttributesResponse, *errors.ErrorAndStatus)
	ApiV1WorkflowGetPost(ctx context.Context, request iwfidl.WorkflowGetRequest) (*iwfidl.WorkflowGetResponse, *errors.ErrorAndStatus)
	ApiV1WorkflowGetWithWaitPost(ctx context.Context, request iwfidl.WorkflowGetRequest) (*iwfidl.WorkflowGetResponse, *errors.ErrorAndStatus)
	ApiV1WorkflowSearchPost(ctx context.Context, request iwfidl.WorkflowSearchRequest) (*iwfidl.WorkflowSearchResponse, *errors.ErrorAndStatus)
	ApiV1WorkflowRpcPost(ctx context.Context, request iwfidl.WorkflowRpcRequest) (*iwfidl.WorkflowRpcResponse, *errors.ErrorAndStatus)
	ApiV1WorkflowResetPost(ctx context.Context, request iwfidl.WorkflowResetRequest) (*iwfidl.WorkflowResetResponse, *errors.ErrorAndStatus)
	ApiV1WorkflowSkipTimerPost(ctx context.Context, request iwfidl.WorkflowSkipTimerRequest) *errors.ErrorAndStatus
	ApiV1WorkflowDumpPost(ctx context.Context, request iwfidl.WorkflowDumpRequest) (*iwfidl.WorkflowDumpResponse, *errors.ErrorAndStatus)
	ApiInfoHealth(ctx context.Context) *iwfidl.HealthInfo
	Close()
}

func NewApiService

func NewApiService(
	config config.Config, client uclient.UnifiedClient, taskQueue string, logger log.Logger,
) (ApiService, error)