client

package

v0.2.0 Latest Latest Go to latest Published: Feb 28, 2017 License: BSD-3-Clause Imports: 1 Imported by: 0

Details

This section is empty.

This section is empty.

func Write(client Client, writer Writer, msg message.Msg) error

Write encapsulates the function of determining which function to call based on the msg.OP() and also wraps the function call with a Session.

type Client interface {
	Connect() (Session, error)
}

Client provides a standard interface for interacting with the underlying sources/sinks.

type Closer interface {
	Close()
}

Closer provides a standard interface for closing a client or session

type MessageChanFunc func(Session, chan struct{}) (chan message.Msg, error)

MessageChanFunc represents the func signature needed to send messages to downstream adaptors.

type NsFilterFunc func(string) bool

NsFilterFunc represents the func signature needed to filter while Read()ing.

type Reader interface {
	Read(NsFilterFunc) MessageChanFunc
}

Reader represents the ability to send messages down the pipe and is only needed for adaptors acting as a Source node.

type Session interface {
}

Session represents the connection to the underlying service.

type Writer interface {
	Write(message.Msg) func(Session) error
}

Writer represents all possible functions needing to be implemented to handle messages.