ingest

Documentation

Index

• Constants
• func EdgeFunctionIngestWorkflow(ctx workflow.Context, in *EdgeFunctionIngestParams) error
• func NewWorker(c versioned.Interface, baseDir string) *worker
• func RegisterWorkflows(w tworker.Worker)
• func WorkflowID(o *v1alpha1.EdgeFunction) (string, error)
• type EdgeFunctionIngestParams
• type EdgeFunctionIngestResult

Constants

const (
	// MaxFileSize is the maximum size of the file that can be downloaded.
	MaxFileSize = 50 * 1024 * 1024 // 50MB
	// MaxErrorSize is the maximum size of the error message that can be returned.
	MaxErrorSize = 1024
)

const (
	EdgeFunctionIngestQueue = "EDGE_FUNC_INGEST_TASK_QUEUE"
)

const (
	InvalidInputError = "InvalidInputError"
)

Functions

func EdgeFunctionIngestWorkflow

func EdgeFunctionIngestWorkflow(ctx workflow.Context, in *EdgeFunctionIngestParams) error

EdgeFunctionIngestWorkflow is a Temporal workflow that ingests Edge Functions. The function code is

func NewWorker

func NewWorker(c versioned.Interface, baseDir string) *worker

NewWorker returns a new worker for Edge Functions Ingest queue.

func RegisterWorkflows

func RegisterWorkflows(w tworker.Worker)

RegisterWorkflows registers Edge Function workflows with the Temporal worker.

func WorkflowID

func WorkflowID(o *v1alpha1.EdgeFunction) (string, error)

WorkflowID returns a unique identifier for the Edge Function ingest workflow. Each workflow is uniquely identified by the Edge Function name and its code configuration.

Types

type EdgeFunctionIngestParams

type EdgeFunctionIngestParams struct {
	Obj *v1alpha1.EdgeFunction
}

type EdgeFunctionIngestResult

type EdgeFunctionIngestResult struct {
	AssetFilePath      string
	AssetFileCreatedAt metav1.Time
	Err                string
}