interfaces

type Discoverer interface {
	// NewServers returns a channel that is used to notify Rafty that there is a
	// new list of servers available. Although not required, it is better that
	// notifications are sent only when the list of servers has changed.
	NewServers() chan struct{}

	// GetServers returns the current list of servers.
	GetServers() []raft.Server
}

type Distributor[T any, T2 Work[T]] interface {
	Distribute(servers []raft.Server, works []T2) map[raft.ServerID][]T2
}

type Finalizer interface {
	Done() chan struct{}
}

type Foreman[T any, T2 Work[T]] interface {
	// Start is called on the process that has been elected as the leader by the
	// Raft Cluster.
	Start()

	// Stop is called in the event we lose leadership.
	Stop()

	// NewWorks returns a channel that is used to notify Rafty that there is new
	// works available.
	NewWorks() chan struct{}

	// GetWorks returns the current list of work.
	GetWorks() []T2
}

type Logger interface {
	Tracef(format string, fields ...interface{})
	Debugf(format string, fields ...interface{})
	Infof(format string, fields ...interface{})
	Warnf(format string, fields ...interface{})
	Errorf(format string, fields ...interface{})
}

type Work[T any] interface {
	ID() string
	Object() T
	Equals(T) bool
}

type Works[T any, T2 Work[T]] interface {
	GetWorks() []T2
}