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

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

Types

type Publisher

type Publisher interface {
	Send(ctx context.Context, m *pubsub.Message) error
	Shutdown(ctx context.Context) error
}

func Topic

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

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)