Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Message ¶
type Message[T any] struct { // contains filtered or unexported fields }
func (*Message[T]) LastViewedAt ¶
type Subscription ¶
type Subscription[T any] struct { // contains filtered or unexported fields }
func (*Subscription[T]) Name ¶
func (s *Subscription[T]) Name() string
func (*Subscription[T]) Subscribe ¶
func (s *Subscription[T]) Subscribe(ctx context.Context, consumer func(*Message[T]))
func (*Subscription[T]) Topic ¶
func (s *Subscription[T]) Topic() *Topic[T]
type Topic ¶
type Topic[T any] struct { // contains filtered or unexported fields }
func (*Topic[T]) NewSubscription ¶
func (t *Topic[T]) NewSubscription(name string) *Subscription[T]
func (*Topic[T]) Subscriptions ¶
func (t *Topic[T]) Subscriptions() map[string]*Subscription[T]
Click to show internal directories.
Click to hide internal directories.