Documentation ¶
Index ¶
Constants ¶
View Source
const ( NORMAL = 0 CLOSED = 1 )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Interceptor ¶
type Interceptor func(msg *easypubsub.Message, handler MessageHandler) error
func ChainInterceptor ¶
func ChainInterceptor(interceptors ...Interceptor) Interceptor
ChainInterceptor creates a single interceptor out of a chain of many interceptors. Execution is done in left-to-right order
type MessageHandler ¶
type MessageHandler func(msg *easypubsub.Message) error
type Option ¶
type Option func(o *options)
func WithInterceptors ¶
func WithInterceptors(interceptors ...Interceptor) Option
func WithLogger ¶
func WithLogger(logger easypubsub.Logger) Option
type Source ¶
type Source struct {
// contains filtered or unexported fields
}
func NewSource ¶
func NewSource(topic string, subscriber easypubsub.Subscriber) *Source
Click to show internal directories.
Click to hide internal directories.