stream

Documentation

Overview

Package stream exposes gocloud.dev/pubsub and side-loads various packages to register implementations such as kafka or in-memory. Please refer to specific documentation for each implementation.

• https://gocloud.dev/howto/pubsub/publish/
• https://gocloud.dev/howto/pubsub/subscribe/

This package is designed as one import to bring in extra dependencies without requiring multiple projects to know what imports are needed.

Index

• func Topic(logger log.Logger, cfg *service.Config) (*pubsub.Topic, error)
• type Subscription
  • func OpenSubscription(logger log.Logger, cfg *service.Config) (Subscription, error)

Functions

func Topic

func Topic(logger log.Logger, cfg *service.Config) (*pubsub.Topic, error)

Types

type Subscription

type Subscription interface {
	Receive(ctx context.Context) (*pubsub.Message, error)
	Shutdown(ctx context.Context) error
}

func OpenSubscription

func OpenSubscription(logger log.Logger, cfg *service.Config) (Subscription, error)