coordinator

package

v0.10.0 Latest Latest Go to latest Published: Aug 10, 2026 License: MIT Imports: 9 Imported by: 0

Details

Package coordinator provides workflow orchestration for the statistics team.

This section is empty.

This section is empty.

func New(cfg Config) *worker.Coordinator

New creates a new coordinator with all workers registered.

type Config struct {
	AppConfig *config.Config
	AgentOps  *worker.AgentOpsConfig
}

Config configures the coordinator.

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

StatsWorkflow implements the statistics research workflow.

func NewStatsWorkflow(cfg *config.Config) *StatsWorkflow

NewStatsWorkflow creates a new statistics workflow.

func (w *StatsWorkflow) Execute(ctx context.Context, input map[string]any, dispatcher worker.WorkerDispatcher) (map[string]any, error)

Execute runs the statistics research workflow.