ingest

Documentation

Index

• Constants
• func DoBuildWorkflow(ctx workflow.Context, in *MiddlewareIngestParams) error
• func StartBuildWorkflow(ctx workflow.Context, in *MiddlewareIngestParams) error
• type IngestWorker
  • func NewIngestWorker(workDir string, db *serverdb.DB, w *watcher.Watcher) *IngestWorker
  • func (w *IngestWorker) BuildActivity(ctx context.Context, sha string, in *MiddlewareIngestParams) error
  • func (w *IngestWorker) FinalizeActivity(ctx context.Context, in *MiddlewareIngestParams, r *MiddlewareIngestResult) error
  • func (w *IngestWorker) PrepareGithubBuildActivity(ctx context.Context, in *MiddlewareIngestParams) (*MiddlewareIngestResult, error)
  • func (w *IngestWorker) PrepareLocalBuildActivity(ctx context.Context, in *MiddlewareIngestParams) (*MiddlewareIngestResult, error)
  • func (w *IngestWorker) UploadWasmOutputActivity(ctx context.Context, slug, sha string) error
• type MiddlewareIngestParams
• type MiddlewareIngestResult

Constants

const (
	MiddlewareIngestQueue = "MIDDLEWARE_INGEST_TASK_QUEUE"
)

Functions

func DoBuildWorkflow

func DoBuildWorkflow(ctx workflow.Context, in *MiddlewareIngestParams) error

DoBuildWorkflow is a workflow executes build Activities. Meant to be run async from a parent workflow that quits to release the API call.

func StartBuildWorkflow

func StartBuildWorkflow(ctx workflow.Context, in *MiddlewareIngestParams) error

StartBuildWorkflow spawns another async workflow to perform actual build and releases, and returns immediately to release the API call.

Types

type IngestWorker

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

IngestWorker runs build activities.

func NewIngestWorker

func NewIngestWorker(workDir string, db *serverdb.DB, w *watcher.Watcher) *IngestWorker

func (*IngestWorker) BuildActivity

func (w *IngestWorker) BuildActivity(ctx context.Context, sha string, in *MiddlewareIngestParams) error

func (*IngestWorker) FinalizeActivity

func (w *IngestWorker) FinalizeActivity(ctx context.Context, in *MiddlewareIngestParams, r *MiddlewareIngestResult) error

func (*IngestWorker) PrepareGithubBuildActivity

func (w *IngestWorker) PrepareGithubBuildActivity(
	ctx context.Context,
	in *MiddlewareIngestParams,
) (*MiddlewareIngestResult, error)

func (*IngestWorker) PrepareLocalBuildActivity

func (w *IngestWorker) PrepareLocalBuildActivity(
	ctx context.Context,
	in *MiddlewareIngestParams,
) (*MiddlewareIngestResult, error)

func (*IngestWorker) UploadWasmOutputActivity

func (w *IngestWorker) UploadWasmOutputActivity(ctx context.Context, slug, sha string) error

type MiddlewareIngestParams

type MiddlewareIngestParams struct {
	Slug string

	// Temporal can't unmarshal oneofs in protos so use bytes and unmarshal ourselves.
	Params *middlewarev1.MiddlewareIngestParams
}

type MiddlewareIngestResult

type MiddlewareIngestResult struct {
	// SHA256 of the build.
	// For local builds this is the hash of the build directory + params.
	// For GIT builds this is the hash of the commit + params.
	SHA string

	// Whether the build was previously cached (a build with SHA above exists in the store).
	Cached bool

	// Err is set if build fails midway.
	Err string
}