Versions in this module Expand all Collapse all v0 v0.7.0 Mar 27, 2026 Changes in this version + const ElectionName + const LockTTL + func Provide(i *do.Injector) + type Migration interface + Identifier func() string + Run func(ctx context.Context, i *do.Injector) error + func AllMigrations() ([]Migration, error) + type ResultStore struct + func NewResultStore(client *clientv3.Client, root string) *ResultStore + func (s *ResultStore) Get(identifier string) storage.GetOp[*StoredResult] + func (s *ResultStore) Key(identifier string) string + func (s *ResultStore) Prefix() string + func (s *ResultStore) Put(item *StoredResult) storage.PutOp[*StoredResult] + type RevisionStore struct + func NewRevisionStore(client *clientv3.Client, root string) *RevisionStore + func (s *RevisionStore) Create(item *StoredRevision) storage.PutOp[*StoredRevision] + func (s *RevisionStore) Get() storage.GetOp[*StoredRevision] + func (s *RevisionStore) Key() string + func (s *RevisionStore) Update(item *StoredRevision) storage.PutOp[*StoredRevision] + func (s *RevisionStore) Watch() storage.WatchOp[*StoredRevision] + type Runner struct + func NewRunner(hostID string, store *Store, injector *do.Injector, ...) *Runner + func (r *Runner) Run(ctx context.Context) error + type Store struct + Result *ResultStore + Revision *RevisionStore + func NewStore(client *clientv3.Client, root string) *Store + type StoredResult struct + CompletedAt time.Time + Error string + Identifier string + RunByHostID string + RunByVersionInfo *version.Info + StartedAt time.Time + Successful bool + type StoredRevision struct + Identifier string v0.7.0-rc.1 Mar 25, 2026
Go to main page