batch

package
v0.38.2 Latest Latest
Warning

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

Go to latest
Published: Jul 17, 2023 License: Apache-2.0 Imports: 17 Imported by: 0

Documentation

Index

Constants

View Source
const (
	BatchWorkflowName = "batch-workflow"
	BatchWorkflowID   = "batch-workflow"
	BatchActivityName = "batch-activity"
)

Variables

View Source
var ErrBatchStatusUnavailable = errors.New("batch status unavailable")

Functions

func BatchWorkflow

func BatchWorkflow(ctx temporalsdk_workflow.Context, params BatchWorkflowInput) error

func NewService

func NewService(logger logr.Logger, cc temporalsdk_client.Client, taskQueue string, completedDirs []string) *batchImpl

Types

type BatchActivity

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

func NewBatchActivity

func NewBatchActivity(batchsvc Service) *BatchActivity

func (*BatchActivity) Execute

func (a *BatchActivity) Execute(ctx context.Context, params BatchWorkflowInput) error

type BatchProgress

type BatchProgress struct {
	CurrentID uint
}

type BatchWorkflowInput

type BatchWorkflowInput struct {
	Path             string
	PipelineName     string
	ProcessingConfig string
	CompletedDir     string
	RetentionPeriod  *time.Duration
}

type Service

type Service interface {
	Submit(context.Context, *goabatch.SubmitPayload) (res *goabatch.BatchResult, err error)
	Status(context.Context) (res *goabatch.BatchStatusResult, err error)
	Hints(context.Context) (res *goabatch.BatchHintsResult, err error)
	InitProcessingWorkflow(ctx context.Context, req *collection.ProcessingWorkflowRequest) error
}

Directories

Path Synopsis
Package fake is a generated GoMock package.
Package fake is a generated GoMock package.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL