Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Channel ¶ added in v0.6.0
type Channel interface { Publisher() Publisher Subscriber() Subscriber Processor(predicate func(message Message) bool) Channel }
func NewChannel ¶ added in v0.6.0
type Context ¶
type Context interface {
Result() Message
}
func NewConsumerContextWithMessage ¶ added in v0.6.0
type DefaultEventBus ¶
type DefaultEventBus struct {
// contains filtered or unexported fields
}
func (*DefaultEventBus) Channel ¶ added in v0.6.0
func (e *DefaultEventBus) Channel(address string) Channel
type EventBus ¶
func NewEventBus ¶
func NewEventBus() EventBus
type Headers ¶ added in v0.7.0
type Headers struct {
// contains filtered or unexported fields
}
func NewHeaders ¶ added in v0.7.0
func NewHeaders() Headers
type Message ¶
type Message struct { Data interface{} Options MessageOptions }
func CreateMessage ¶
func CreateMessage() Message
func (Message) SetOptions ¶
func (m Message) SetOptions(options MessageOptions) Message
type MessageOptions ¶
type MessageOptions struct {
// contains filtered or unexported fields
}
func NewMessageOptions ¶
func NewMessageOptions() MessageOptions
func (MessageOptions) Headers ¶ added in v0.7.0
func (op MessageOptions) Headers() Headers
func (MessageOptions) SetHeaders ¶ added in v0.7.0
func (op MessageOptions) SetHeaders(headers Headers) MessageOptions
type NetworkBus ¶ added in v0.7.0
func NewNetworkBus ¶ added in v0.7.0
func NewNetworkBus(bus EventBus, address, path string) NetworkBus
type Processor ¶ added in v0.7.0
type Processor interface {
// contains filtered or unexported methods
}
func NewProcessor ¶ added in v0.7.0
func NewProcessor() Processor
func NewProcessorWithPredicate ¶ added in v0.7.0
type Publisher ¶
type Publisher interface {
Publish(message Message)
}
func NewPublisher ¶ added in v0.6.0
type Subscriber ¶ added in v0.6.0
type Subscriber interface {
Listen(consumer func(context Context))
}
func NewSubscriber ¶ added in v0.6.0
func NewSubscriber(ch chan Message) Subscriber
Source Files ¶
Click to show internal directories.
Click to hide internal directories.