availability

type Clock interface {
	Now() time.Time
}

type Config struct {
	FailureThreshold int
	OpenDuration     time.Duration
}

type KVStore interface {
	SetWithTTL(ctx context.Context, key string, value []byte, ttl time.Duration) error
	ScanWithPrefix(ctx context.Context, prefix string, limit int) ([]string, error)
	BatchGet(ctx context.Context, keys []string) (map[string][]byte, error)
}

type Offering struct {
	ProviderID      string
	ProviderModelID string
}

type Publisher interface {
	PublishAvailability(Snapshot) error
}

type Record struct {
	Offering           Offering
	State              State
	FailureKind        failure.Kind
	ConsecutiveFailure int
	OpenUntil          time.Time
}

type SharedConfig struct {
	// InstanceID names this replica's record. An empty value draws a
	// random identity.
	InstanceID string
	// TTL is the record lifetime in the shared store.
	TTL time.Duration
	// RefreshInterval is the shortest gap between two peer reads.
	RefreshInterval time.Duration
}

type Snapshot struct {
	Revision uint64
	Records  []Record
}

type State string

type Tracker struct {
	// contains filtered or unexported fields
}