worker

Documentation

Index

• Constants
• type CheckActivityParam
• type CheckWorkflowParam
• type Worker
  • func NewWorker(r repository.Repository, dc *client.Client) Worker
• type WriteActivityParam
• type WriteWorkflowParam

Constants

const Namespace = "connector-backend"

Namespace is the Temporal namespace for connector-backend

const TaskQueue = "connector-backend"

TaskQueue is the Temporal task queue name for connector-backend

Types

type CheckActivityParam

type CheckActivityParam struct {
	ImageName       string
	ContainerName   string
	ConfigFileName  string
	ConnectorConfig []byte
}

CheckActivityParam represents the parameters for CheckActivity

type CheckWorkflowParam

type CheckWorkflowParam struct {
	OwnerPermalink string
	ConnUID        string
	ImageName      string
	ContainerName  string
	ConfigFileName string
}

CheckWorkflowParam represents the parameters for CheckWorkflow

type Worker

type Worker interface {
	CheckWorkflow(ctx workflow.Context, param *CheckWorkflowParam) error
	CheckActivity(ctx context.Context, param *CheckActivityParam) (exitCode, error)
	WriteWorkflow(ctx workflow.Context, param *WriteWorkflowParam) error
	WriteActivity(ctx context.Context, param *WriteActivityParam) (exitCode, error)
}

Worker interface

func NewWorker

func NewWorker(r repository.Repository, dc *client.Client) Worker

NewWorker initiates a temporal worker for workflow and activity definition

type WriteActivityParam

type WriteActivityParam struct {
	ImageName                string
	ContainerName            string
	ConfigFileName           string
	CatalogFileName          string
	Pipeline                 string
	Indices                  []string
	ConnectorConfig          []byte
	ConfiguredAirbyteCatalog []byte
	AirbyteMessages          []byte
}

WriteActivityParam represents the parameters for WriteActivity

type WriteWorkflowParam

type WriteWorkflowParam struct {
	OwnerPermalink           string
	ConnectorPermalink       string
	ImageName                string
	ContainerName            string
	ConfigFileName           string
	CatalogFileName          string
	Pipeline                 string
	Indices                  []string
	ConfiguredAirbyteCatalog []byte
	AirbyteMessages          []byte
}

WriteWorkflowParam represents the parameters for WriteWorkflow