pubsub

type Backend interface {
	// Publish sends data to channel and returns the authority's subscriber count, without confirming processing.
	Publish(context.Context, Channel, []byte) (uint64, error)
	// Subscribe establishes a ready stream over the exact channels using limits to bound buffering.
	Subscribe(context.Context, []Channel, Limits) (Stream, error)
}

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

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

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

type Config struct {
	Namespace                                                     keyspace.Namespace
	MaxDeclarations, MaxKeyBytes, MaxConcurrent, MaxSubscriptions int
	Timeout                                                       time.Duration
	Buffer                                                        Limits
}

type ConnectionName string

type Declaration[K, V any] struct {
	// contains filtered or unexported fields
}

type Delivery[K, V any] struct {
	Key   K
	Value V
}

type Gap struct {
	Cause    error
	Attempts int
}

type KeyedSubscription[K, V any] struct {
	// contains filtered or unexported fields
}

type Limits struct{ Messages, Bytes, PayloadBytes, Channels int }

type Message struct {
	Channel Channel
	Data    []byte
}

type Name string

type NamedBroker struct {
	Name  ConnectionName
	Value *Broker
}

type Stats struct {
	Operations, Subscriptions int
	Closing                   bool
}

type Stream interface {
	// Next waits for the next owned message. Cancellation ends this wait without closing the stream.
	Next(context.Context) (Message, error)
	// Close ends the subscription and unblocks reads; ctx bounds the shutdown wait.
	Close(context.Context) error
	// Done closes after the stream's adapter work exits.
	Done() <-chan struct{}
	// Err returns the terminal subscription error.
	Err() error
}

type Subscription[V any] struct {
	// contains filtered or unexported fields
}

type SupervisePolicy struct {
	InitialBackoff, MaxBackoff time.Duration
}

type Topic[K, V any] struct {
	// contains filtered or unexported fields
}

type Version uint32