Versions in this module Expand all Collapse all v2 v2.0.2 Jul 2, 2026 v2.0.1 Jun 29, 2026 Changes in this version + type Inspector interface + ListPublishers func() []PublisherInfo + ListSubscribers func() []SubscriberInfo + type Manager interface + AddPublisher func(ctx context.Context, reference string, queueURL string) error + AddSubscriber func(ctx context.Context, reference string, queueURL string, ...) error + Close func(ctx context.Context) error + DiscardPublisher func(ctx context.Context, reference string) error + DiscardSubscriber func(ctx context.Context, reference string) error + GetPublisher func(reference string) (Publisher, error) + GetSubscriber func(reference string) (Subscriber, error) + Init func(ctx context.Context) error + Publish func(ctx context.Context, reference string, payload any, ...) error + func NewQueueManager(_ context.Context, workPool workerpool.Manager) Manager + type Publisher interface + As func(i any) bool + Init func(ctx context.Context) error + Initiated func() bool + Publish func(ctx context.Context, payload any, headers ...map[string]string) error + Ref func() string + Stop func(ctx context.Context) error + type PublisherInfo struct + Initiated bool + Reference string + URL string + type SubscribeWorker interface + Handle func(ctx context.Context, metadata map[string]string, message []byte) error + type Subscriber interface + As func(i any) bool + Init func(ctx context.Context) error + Initiated func() bool + IsIdle func() bool + Metrics func() SubscriberMetrics + Receive func(ctx context.Context) (*pubsub.Message, error) + Ref func() string + State func() SubscriberState + Stop func(ctx context.Context) error + URI func() string + type SubscriberInfo struct + Initiated bool + Reference string + State SubscriberState + URL string + type SubscriberMetrics interface + AverageProcessingTime func() time.Duration + IdleTime func(state SubscriberState) time.Duration + IsIdle func(state SubscriberState) bool + type SubscriberState int32 + const SubscriberStateInError + const SubscriberStateProcessing + const SubscriberStateWaiting Other modules containing this package github.com/pitabwire/frame
Go to main page