coordinator

type Client interface {
	execution.Dispatcher

	// Dispatch sends a task to the coordinator
	Dispatch(ctx context.Context, task *coordinatorv1.Task) error

	// Poll retrieves a task from the coordinator.
	Poll(ctx context.Context, policy backoff.RetryPolicy, req *coordinatorv1.PollRequest) (*coordinatorv1.Task, error)

	// GetWorkers retrieves the list of workers from the coordinator
	GetWorkers(ctx context.Context) ([]*coordinatorv1.WorkerInfo, error)

	// Heartbeat sends a heartbeat to the coordinator
	Heartbeat(ctx context.Context, req *coordinatorv1.HeartbeatRequest) error

	// Metrics returns the metrics for the coordinator client
	Metrics() Metrics
}

type Config struct {
	// TLS configuration
	Insecure      bool   // Use insecure connection (default: true)
	CertFile      string // Client certificate
	KeyFile       string // Client key
	CAFile        string // CA certificate
	SkipTLSVerify bool   // Skip server certificate verification

	// Timeouts
	DialTimeout    time.Duration // Connection timeout (default: 10s)
	RequestTimeout time.Duration // Per-request timeout (default: 5m)

	// Retry configuration
	MaxRetries    int           // Max dispatch retries (default: 3)
	RetryInterval time.Duration // Base retry interval (default: 1s)
}

type Handler struct {
	coordinatorv1.UnimplementedCoordinatorServiceServer
	// contains filtered or unexported fields
}

type Metrics struct {
	FailCount        int   // Total number of failures
	IsConnected      bool  // Whether the client is currently connected
	ConsecutiveFails int   // Number of consecutive failures
	LastError        error // Last error encountered
}

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