pubsub

Documentation

Index

• type HandlerFunc
• type PubSub

Types

type HandlerFunc

type HandlerFunc func(ctx context.Context, message []byte) error

HandlerFunc is pubsub subscriber handler function.

type PubSub

type PubSub interface {
	// Use to add pubsub middlewares.
	Use(middlewares ...func(HandlerFunc) HandlerFunc)
	// Publish message to specific topic/channel.
	Publish(ctx context.Context, topic string, message []byte) error
	// Subscribe to specific topic/channel.
	Subscribe(ctx context.Context, topic string, handlerFunc HandlerFunc) error
	// Close pubsub client connection.
	Close() error
}

PubSub is pubsub interface.

See usage example in example folder.