Documentation ¶
Index ¶
- type KafkaConnection
- type MessageProvider
- type Messenger
- func (m *Messenger) Close() error
- func (m *Messenger) GetActivation() (*types.ActivationMessage, error)
- func (m *Messenger) SendCompletion(activation *types.ActivationMessage, function *types.FunctionDoc, ...) error
- func (m *Messenger) SendResult(activation *types.ActivationMessage, function *types.FunctionDoc, ...) error
- func (m *Messenger) StartHealthPings(invokerNumber int) chan bool
- type NewReaderFunc
- type NewWriterFunc
- type Ping
- type Reader
- type Writer
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type KafkaConnection ¶
func NewKafkaConnection ¶
func NewKafkaConnection(network string, host string) (KafkaConnection, error)
type MessageProvider ¶
type MessageProvider interface { EnsureTopic(string) error WriteMessage(string, []byte) error ReadMessage(string) ([]byte, error) Close() error }
func NewFakeProvider ¶
func NewFakeProvider(conn KafkaConnection, writerFunc NewWriterFunc, readerFunc NewReaderFunc) MessageProvider
func NewMessageProvider ¶
func NewMessageProvider(host string) (MessageProvider, error)
type Messenger ¶
type Messenger struct {
// contains filtered or unexported fields
}
func (*Messenger) GetActivation ¶
func (m *Messenger) GetActivation() (*types.ActivationMessage, error)
func (*Messenger) SendCompletion ¶
func (m *Messenger) SendCompletion(activation *types.ActivationMessage, function *types.FunctionDoc, result interface{}) error
func (*Messenger) SendResult ¶
func (m *Messenger) SendResult(activation *types.ActivationMessage, function *types.FunctionDoc, result interface{}) error
func (*Messenger) StartHealthPings ¶
type NewReaderFunc ¶
type NewWriterFunc ¶
Source Files ¶
Click to show internal directories.
Click to hide internal directories.