cluster

type Job struct {
	Name string
	Run  func(ctx context.Context)
}

type Leader struct {
	Store  Leadership
	Jobs   []Job
	Logger *zap.Logger

	// Retry is how often a follower tries to lead, and how often a leader
	// checks it still is. Ten seconds when zero.
	Retry time.Duration
	// contains filtered or unexported fields
}

type Leadership interface {
	TryLead(ctx context.Context, check time.Duration) (*state.Leadership, bool, error)
}

type LogOwner struct {
	Self        string
	Deployments interface {
		Runner(ctx context.Context, deploymentID string) (string, error)
		Waiting(ctx context.Context, deploymentID string) (bool, error)
	}
	Replicas interface {
		ByID(ctx context.Context, replicaID string) (state.Replica, bool, error)
	}

	// ClaimWait is how long to wait for a queued deploy to be claimed before
	// answering (O-32): until then nobody holds its log, and answering "this
	// replica" would follow a log another replica is about to write. A
	// minute when zero.
	ClaimWait time.Duration
}

type Member struct {
	Store        Store
	ID           string
	Hostname     string
	AdvertiseURL string
	Version      string
	Minter       *assertion.Minter
	Logger       *zap.Logger

	// Interval is how often to heartbeat; state.HeartbeatInterval if zero.
	Interval time.Duration
}

type Store interface {
	Register(ctx context.Context, rep state.Replica) error
	Heartbeat(ctx context.Context, replicaID string) (bool, error)
	Stop(ctx context.Context, replicaID string) error
	RestartPending(ctx context.Context, replicaID string) (bool, error)
	VerificationKeys(ctx context.Context, validity time.Duration) ([]state.Replica, error)
}

type Sweeper struct {
	Abandon []func(ctx context.Context) (int64, error)
	Prune   func(ctx context.Context) error
	Logger  *zap.Logger
	Every   time.Duration
}