kv

type Bus interface {
	// Publish sends payload to every subscriber of channel, including in other processes.
	Publish(ctx context.Context, channel, payload string) error
	// Subscribe returns a stream of payloads published to channel until ctx is cancelled (then it is closed).
	Subscribe(ctx context.Context, channel string) (<-chan string, error)
	// Close releases resources.
	Close() error
}

type Entry struct {
	Key   string
	Value []byte
	TTL   time.Duration
}

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

type Keys interface {
	// Current returns the key that seals new records. The slice is a fresh copy the caller owns and clears.
	Current() (id string, key []byte)
	// Lookup returns the key with the given ID, for opening. The slice is a fresh copy the caller owns and
	// clears.
	Lookup(id string) (key []byte, ok bool)
}

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

type Store interface {
	// Get returns the value for key. found is false when the key is absent or expired.
	Get(ctx context.Context, key string) (value []byte, found bool, err error)

	// Set stores value under key with an optional TTL (0 = no expiry), overwriting any existing value.
	Set(ctx context.Context, key string, value []byte, ttl time.Duration) error

	// SetIfAbsent stores value under key only if the key is absent or expired, atomically, and reports whether
	// it did: of concurrent calls for one key across all replicas exactly one gets set = true. TTL as for Set.
	SetIfAbsent(ctx context.Context, key string, value []byte, ttl time.Duration) (set bool, err error)

	// SetMany writes all entries atomically (one transaction), used to keep a record and its
	// secondary-index keys consistent.
	SetMany(ctx context.Context, entries ...Entry) error

	// Take atomically returns and deletes key — single-use semantics for authorization-code exchange. found is false when the key is absent or expired.
	Take(ctx context.Context, key string) (value []byte, found bool, err error)

	// Delete removes key. No error if it doesn't exist.
	Delete(ctx context.Context, key string) error

	// Keys returns all non-expired keys with the given prefix, sorted. The prefix is matched
	// literally (callers use wildcard-free namespace prefixes).
	Keys(ctx context.Context, prefix string) ([]string, error)

	// Cleanup removes expired entries and returns the count removed.
	Cleanup(ctx context.Context) (removed int, err error)

	// Close releases resources; subsequent calls return ErrClosed.
	Close() error
}