Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type PubSub ¶
type PubSub interface { // Publish publishes the object to the channel by name Publish(channel string, obj interface{}) error // Subscribe subscribes to the given channel Subscribe(ctx context.Context, channel string, handler func(obj interface{})) error Close() }
PubSub is used to asynchronously pass messages between routines.
Click to show internal directories.
Click to hide internal directories.