agency

type Cache interface {
	Reload(ctx context.Context, size int, clients Connections) (uint64, error)
	// Deprecated: Use Apply instead.
	// It can cause Read/Write error when state is reloaded.
	Data() (state.State, bool)
	// Apply applies a function to the current state. Returns true if function was applied
	Apply(f func(state.State)) bool
	DataDB() (state.DB, bool)
	CommitIndex() uint64
	// Health returns true when healthy object is available.
	Health() (Health, bool)
	// ShardsInSyncMap returns last in sync state of shards. If no state is available, false is returned.
	ShardsInSyncMap() (state.ShardsSyncStatus, bool)

	Invalidate()
}

type Config struct {
	LeaderId string `json:"leaderId"`

	CommitIndex uint64 `json:"commitIndex"`

	Configuration struct {
		ID string `json:"id"`
	} `json:"configuration"`
}

type Connections map[string]conn.Connection

type Health interface {
	// Healthy return nil when environment is considered as healthy.
	Healthy() error

	// Serving return nil when environment is considered as responsive, but not fully healthy.
	Serving() error

	// LeaderID returns a leader ID or empty string if a leader is not known.
	LeaderID() string

	CollectMetrics(m metrics.PushMetric)
}

type ReadRequest [][]string