Documentation
      ¶
    
    
  
    
  
    Index ¶
- Constants
 - func DoBuildWorkflow(ctx workflow.Context, in *MiddlewareIngestParams) error
 - func StartBuildWorkflow(ctx workflow.Context, in *MiddlewareIngestParams) error
 - type 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 ¶
      View Source
      
  
const (
	MiddlewareIngestQueue = "MIDDLEWARE_INGEST_TASK_QUEUE"
)
    Variables ¶
This section is empty.
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 (*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
}
     Click to show internal directories. 
   Click to hide internal directories.