Documentation
¶
Index ¶
- type Consumer
- type Message
- type Payload
- type Pipe
- type Producer
- type ReplicatedPipe
- type TestingConsumer
- func (c *TestingConsumer) ConsumeMessage(message Message) (err error)
- func (c *TestingConsumer) ExpectLastMessageFn(message Message) (fn func() error)
- func (c *TestingConsumer) ExpectMessagesByIdFn(expect map[string][]Message) (fn func() error)
- func (c *TestingConsumer) ExpectMessagesFn(expect ...Message) (fn func() error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Message ¶
type Message struct {
// contains filtered or unexported fields
}
Message encapsulates topic with given payload
type Payload ¶
type Payload struct {
// contains filtered or unexported fields
}
func NewPayload ¶
func NewPayload(v interface{}) (p Payload)
type Pipe ¶
type Pipe interface {
GetConsumer() (c Consumer)
}
Pipe consumes messages and pipes them to downstream
type ReplicatedPipe ¶
type ReplicatedPipe interface {
GetConsumers() (c []Consumer)
}
Replicated pipes messages to multiple pipes
type TestingConsumer ¶
type TestingConsumer struct {
// contains filtered or unexported fields
}
func NewTestingConsumer ¶
func NewTestingConsumer(ctx context.Context) (c *TestingConsumer)
func (*TestingConsumer) ConsumeMessage ¶
func (c *TestingConsumer) ConsumeMessage(message Message) (err error)
func (*TestingConsumer) ExpectLastMessageFn ¶
func (c *TestingConsumer) ExpectLastMessageFn(message Message) (fn func() error)
func (*TestingConsumer) ExpectMessagesByIdFn ¶
func (c *TestingConsumer) ExpectMessagesByIdFn(expect map[string][]Message) (fn func() error)
func (*TestingConsumer) ExpectMessagesFn ¶
func (c *TestingConsumer) ExpectMessagesFn(expect ...Message) (fn func() error)
Source Files
¶
Directories
Click to show internal directories.
Click to hide internal directories.