worker

Documentation

Index

• Constants
• type CheckStateActivityParam
• type CheckStateWorkflowParam
• type Worker
  • func NewWorker(r repository.Repository) Worker
• type WriteDestinationActivityParam
• type WriteDestinationWorkflowParam

Constants

const TaskQueue = "connector-backend"

TaskQueue is the task queue name for connector-backend

Types

type CheckStateActivityParam

type CheckStateActivityParam struct {
	ImageName       string
	ContainerName   string
	ConnectorConfig []byte
}

CheckStateActivityParam represents the parameters for CheckStateActivity

type CheckStateWorkflowParam

type CheckStateWorkflowParam struct {
	OwnerPermalink     string
	ConnectorPermalink string
	ImageName          string
	ContainerName      string
	ConnectorType      datamodel.ConnectorType
}

CheckStateWorkflowParam represents the parameters for CheckStateWorkflow

type Worker

type Worker interface {
	CheckStateWorkflow(ctx workflow.Context, param *CheckStateWorkflowParam) error
	CheckStateActivity(ctx context.Context, param *CheckStateActivityParam) (exitCode, error)
	WriteDestinationWorkflow(ctx workflow.Context, param *WriteDestinationWorkflowParam) error
	WriteDestinationActivity(ctx context.Context, param *WriteDestinationActivityParam) (exitCode, error)
}

Worker interface

func NewWorker

func NewWorker(r repository.Repository) Worker

NewWorker initiates a temporal worker for workflow and activity definition

type WriteDestinationActivityParam

type WriteDestinationActivityParam struct {
	ImageName                string
	ContainerName            string
	ConnectorConfig          []byte
	ConfiguredAirbyteCatalog []byte
	AirbyteMessages          []byte
}

WriteDestinationActivityParam represents the parameters for WriteDestinationActivity

type WriteDestinationWorkflowParam

type WriteDestinationWorkflowParam struct {
	OwnerPermalink           string
	ConnectorPermalink       string
	ImageName                string
	ContainerName            string
	ConfiguredAirbyteCatalog []byte
	AirbyteMessages          []byte
}

WriteDestinationWorkflowParam represents the parameters for WriteDestinationWorkflow