worker

Documentation

Index

• Constants
• type ModelParams
• type Worker
  • func NewWorker(r repository.Repository, t triton.Triton, ...) Worker

Constants

const Namespace = "model-backend"

Namespace is the Temporal namespace for model-backend

const TaskQueue = "model-backend"

TaskQueue is the Temporal task queue name for model-backend

Types

type ModelParams

type ModelParams struct {
	Model datamodel.Model
	Owner string
}

type Worker

type Worker interface {
	DeployModelWorkflow(ctx workflow.Context, param *ModelParams) error
	DeployModelActivity(ctx context.Context, param *ModelParams) error
	UnDeployModelWorkflow(ctx workflow.Context, param *ModelParams) error
	UnDeployModelActivity(ctx context.Context, param *ModelParams) error
	CreateModelWorkflow(ctx workflow.Context, param *ModelParams) error
}

Worker interface

func NewWorker

func NewWorker(r repository.Repository, t triton.Triton, c controllerPB.ControllerPrivateServiceClient) Worker

NewWorker initiates a temporal worker for workflow and activity definition