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 Subscription(logger log.Logger, cfg *service.Config) (*pubsub.Subscription, error)
• func Topic(logger log.Logger, cfg *service.Config) (*pubsub.Topic, error)

Functions

func Subscription

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

func Topic

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