Versions in this module Expand all Collapse all v0 v0.0.3 Apr 11, 2022 Changes in this version + type Message struct + func (m *Message[T]) Ack() + func (m *Message[T]) Body() T + func (m *Message[T]) CreatedAt() time.Time + func (m *Message[T]) ID() string + func (m *Message[T]) LastViewedAt() time.Time + func (m *Message[T]) Nack() + type Subscription struct + func (s *Subscription[T]) Name() string + func (s *Subscription[T]) Subscribe(ctx context.Context, consumer func(*Message[T])) + func (s *Subscription[T]) Topic() *Topic[T] + type Topic struct + func NewTopic(name string, concurrency int64, interval time.Duration, ttl time.Duration) *Topic[T] + func (t *Topic[T]) Name() string + func (t *Topic[T]) NewSubscription(name string) *Subscription[T] + func (t *Topic[T]) Publish(body T) + func (t *Topic[T]) Subscriptions() map[string]*Subscription[T]