pubsub

Jun 26, 2023

Changes in this version

type SubscriptionConfig

+ MaxConcurrency int

Jun 2, 2023

Changes in this version

+ func MethodHandler(handler func(s SvcStruct, ctx context.Context, msg T) error) (_ func(ctx context.Context, msg T) error)

May 17, 2023

Changes in this version

type TopicConfig

+ OrderingAttribute string

May 5, 2023

Changes in this version

type DeliveryGuarantee

+ const ExactlyOnce

Apr 21, 2023

Changes in this version

+ func TopicRef(topic *Topic[T]) (_ P)

+ type Publisher interface

+ Meta func() TopicMeta

+ Publish func(ctx context.Context, msg T) (id string, err error)

type Subscription

+ func (*Subscription[T]) Config() (_ SubscriptionConfig[T])

+ func (*Subscription[T]) Meta() (_ SubscriptionMeta[T])

+ type SubscriptionMeta struct

+ Config SubscriptionConfig[T]

+ Name string

+ Topic TopicMeta

type Topic

+ func (*Topic[T]) Meta() (_ TopicMeta)

+ type TopicMeta struct

+ Config TopicConfig

+ Name string

+ type TopicPerms interface

+ Meta func() TopicMeta

Jul 13, 2022

Changes in this version

+ const InfiniteRetries

+ const NoRetries

+ type DeliveryGuarantee int

+ const AtLeastOnce

+ type RetryPolicy struct

+ MaxBackoff time.Duration

+ MaxRetries int

+ MinBackoff time.Duration

+ type Subscription struct

+ func NewSubscription(topic *Topic[T], name string, subscriptionCfg SubscriptionConfig[T]) *Subscription[T]

+ type SubscriptionConfig struct

+ AckDeadline time.Duration

+ Handler func(ctx context.Context, msg T) error

+ MessageRetention time.Duration

+ RetryPolicy *RetryPolicy

+ type Topic struct

+ func NewTopic(name string, cfg TopicConfig) *Topic[T]

+ func (*Topic[T]) Publish(ctx context.Context, msg T) (id string, err error)

+ type TopicConfig struct

+ DeliveryGuarantee DeliveryGuarantee