activity

package

v1.6.1 Latest Latest Go to latest Published: Jul 3, 2025 License: MIT Imports: 5 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type PipelineActivity struct {
	schema.Pipeline
	ActivityID string
}

type RuntimeActivity struct {
	Timeout time.Duration
	// contains filtered or unexported fields
}

func NewRuntimeActivity(workerGroup string, timeout time.Duration, notifications chan<- schema.PipelineStatus) *RuntimeActivity

func (r *RuntimeActivity) NotifyUpdate(id string)

func (r *RuntimeActivity) RegisterPipeline(pipeline schema.Pipeline) (activity PipelineActivity)

func (r *RuntimeActivity) Status(id string) *RuntimeStatus

type RuntimeStatus struct {
	schema.PipelineStatus

	sync.Mutex
	// contains filtered or unexported fields
}

func (r *RuntimeStatus) ClearTimeout()

func (r *RuntimeStatus) ResetTimeout(timeout time.Duration)