controller

Oct 31, 2026

Changes in this version

+ const KindExperimentExpired

+ const KindExperimentKilled

+ const KindExperimentPromote

+ const KindExperimentRollback

+ const KindResolved

+ const KindRolloutAdvance

+ const KindRolloutAwaitingApproval

+ const KindRolloutComplete

+ const KindRolloutFrozen

+ const KindRolloutKilled

+ const KindRolloutPause

+ const KindRolloutRollback

+ const PagerDutyEventsURL

+ var DefaultRetry = RetryPolicy

+ var ErrUnusableKey = errors.New("webhook: HMAC secret shorter than 112 bits cannot be used in FIPS mode")

+ var EventKinds = []string

+ var PagerDutyPagingKinds = []string

+ func NotifyFlags(fs FlagSet, c *NotifyConfig)

+ func SignChecked(secret []byte, ts int64, body []byte) (string, error)

type Event

+ Resolved bool

+ func (e Event) DedupKey() string

+ func (e Event) Kind() string

+ func (e Event) PagerDutySeverity() string

+ type EventFilter map[string]bool

+ func ParseEventFilter(flag, spec string, allowResolved bool) (EventFilter, error)

+ func (f EventFilter) Allows(e Event) bool

+ type FlagSet interface

+ StringVar func(p *string, name, value, usage string)

type Notifiers

+ func (ns Notifiers) WriteMetrics(w io.Writer)

+ type NotifyConfig struct

+ PagerDutyEvents string

+ PagerDutyRoutingKeyFile string

+ PagerDutyURL string

+ Retry RetryPolicy

+ SlackEvents string

+ SlackURLFile string

+ TeamsEvents string

+ TeamsURLFile string

+ WebhookEvents string

+ WebhookSecretFile string

+ WebhookURLFile string

+ func (c NotifyConfig) Build() (Notifiers, error)

+ type PagerDuty struct

+ Client *http.Client

+ Retry RetryPolicy

+ RoutingKey string

+ Source string

+ URL string

+ func (PagerDuty) Name() string

+ func (p PagerDuty) Notify(ctx context.Context, e Event) error

+ type RetryPolicy struct

+ Attempts int

+ Base time.Duration

+ Budget time.Duration

+ MaxWait time.Duration

+ Now func() time.Time

+ Sleep func(ctx context.Context, d time.Duration) error

+ type Sink struct

+ Events EventFilter

+ Notifier Notifier

+ SinkName string

+ func (s *Sink) Name() string

+ func (s *Sink) Notify(ctx context.Context, e Event) error

+ func (s *Sink) ResolvesFor(trigger Event) bool

type Slack

+ Retry RetryPolicy

type StateLog

+ func (l *StateLog) Names() []string

+ type Teams struct

+ Client *http.Client

+ Retry RetryPolicy

+ URL string

+ func (Teams) Name() string

+ func (t Teams) Notify(ctx context.Context, e Event) error

type Webhook

+ Retry RetryPolicy

Oct 29, 2026

Changes in this version

type Controller

+ Governance func(ctx context.Context, org *policy.Org, r *policy.Rollout) (rollout.Governance, error)

type KillStore

+ func (s *KillStore) Freeze(ctx context.Context, by, reason string) (bool, error)

+ func (s *KillStore) Incident() (*KillRecord, error)

+ func (s *KillStore) Unfreeze(ctx context.Context, by, reason string) (bool, error)

Oct 24, 2026

Changes in this version

+ const EventIDHeader

+ const VerdictDocKind

type Controller

+ RolloutStates rollout.StateStore

+ VerdictDocs rollout.Docs

type Event

+ ID string

type GitWriter

+ func (w *GitWriter) FindPR(ctx context.Context, marker string) (string, bool, error)

type KillStore

+ func NewKillStore(ctx context.Context, o storage.Opener) (*KillStore, error)

+ type PRFinder interface

+ FindPR func(ctx context.Context, marker string) (url string, found bool, err error)

type StateLog

+ func OpenStateLogOn(ctx context.Context, o storage.Opener) (*StateLog, error)

Oct 3, 2026

Changes in this version

+ const ActionHold

+ const ActionKill

+ const ActionNotify

+ const ActionPR

+ const ActionRollback

+ const Actor

+ const DefaultTickTimeout

+ const SignatureHeader

+ const TimestampHeader

+ const VerdictKilled

+ const WebhookTolerance

+ func Evidence(rep promote.Report) string

+ func Sign(secret []byte, ts int64, body []byte) string

+ func Verify(secret []byte, h http.Header, body []byte, now time.Time, ...) error

+ type Controller struct

+ Clock func() time.Time

+ Kill KillSwitch

+ KillCaveat string

+ Kills *KillStore

+ Log *slog.Logger

+ Metrics promote.MetricSource

+ Notifier Notifier

+ Org func() (*policy.Org, error)

+ PolicyDir string

+ RolloutStateDir string

+ State *StateLog

+ TickTimeout time.Duration

+ VerdictsPath string

+ Writer Writer

+ func (c *Controller) Run(ctx context.Context, interval time.Duration)

+ func (c *Controller) Tick(ctx context.Context) error

+ func (c *Controller) WriteMetrics(w io.Writer)

+ type Event struct

+ At time.Time

+ Axis string

+ Experiment string

+ KillError string

+ KillOutcome KillOutcome

+ Killed bool

+ PRError string

+ PRURL string

+ Reason string

+ Report promote.Report

+ Rollout string

+ Verdict promote.Verdict

+ func (e Event) Text() string

+ type GitWriter struct

+ Base string

+ Opener promote.PROpener

+ RepoDir string

+ Subdir string

+ func (w *GitWriter) ProposeRollout(ctx context.Context, plan func(string) (*promote.Change, error), ...) (string, error)

+ func (w *GitWriter) ProposeStatus(ctx context.Context, experiment, status, title, body string) (string, error)

+ type KillFunc func(ctx context.Context, experiment, by, reason string) (bool, error)

+ func (f KillFunc) Kill(ctx context.Context, experiment, by, reason string) (bool, error)

+ type KillOutcome string

+ const KillEnforced

+ const KillFailed

+ const KillNotConfigured

+ const KillNotGateway

+ const KillRecorded

+ type KillRecord struct

+ At time.Time

+ By string

+ Experiment string

+ Killed bool

+ Reason string

+ type KillStore struct

+ Now func() time.Time

+ func OpenKillStore(dir string) (*KillStore, error)

+ func (s *KillStore) Close() error

+ func (s *KillStore) Kill(ctx context.Context, experiment, by, reason string) (bool, error)

+ func (s *KillStore) Killed() ([]KillRecord, uint64, error)

+ func (s *KillStore) Unkill(ctx context.Context, experiment, by, reason string) (bool, error)

+ type KillSwitch interface

+ Kill func(ctx context.Context, experiment, by, reason string) (changed bool, err error)

+ type Named interface

+ Name func() string

+ type Notifier interface

+ Notify func(ctx context.Context, e Event) error

+ type Notifiers []Notifier

+ func NotifiersFromFiles(slackURLFile, webhookURLFile, webhookSecretFile string) (Notifiers, error)

+ func (ns Notifiers) Notify(ctx context.Context, e Event) error

+ type RolloutWriter interface

+ ProposeRollout func(ctx context.Context, plan func(dir string) (*promote.Change, error), ...) (prURL string, err error)

+ type Slack struct

+ Client *http.Client

+ URL string

+ func (Slack) Name() string

+ func (s Slack) Notify(ctx context.Context, e Event) error

+ type StateLog struct

+ func OpenStateLog(dir string) (*StateLog, error)

+ func (l *StateLog) Close() error

+ func (l *StateLog) Done(exp, verdict, action string) (string, bool)

+ func (l *StateLog) Record(exp, verdict, action, detail string, at time.Time) error

+ func (l *StateLog) Reset(exp string, at time.Time) error

+ type Webhook struct

+ Client *http.Client

+ Now func() time.Time

+ Secret []byte

+ URL string

+ func (Webhook) Name() string

+ func (w Webhook) Notify(ctx context.Context, e Event) error

+ type Writer interface

+ ProposeStatus func(ctx context.Context, experiment, status, title, body string) (prURL string, err error)