coordinator

package
v0.9.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jul 13, 2026 License: MIT Imports: 9 Imported by: 0

Documentation

Overview

Package coordinator provides workflow orchestration for the statistics team.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func New

func New(cfg Config) *worker.Coordinator

New creates a new coordinator with all workers registered.

Types

type Config

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

Config configures the coordinator.

type StatsWorkflow

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

StatsWorkflow implements the statistics research workflow.

func NewStatsWorkflow

func NewStatsWorkflow(cfg *config.Config) *StatsWorkflow

NewStatsWorkflow creates a new statistics workflow.

func (*StatsWorkflow) Execute

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

Execute runs the statistics research workflow.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL