package
0.2.1
Repository: https://github.com/codepope/transporter.git
Documentation: pkg.go.dev

# Functions

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

# Variables

ErrInvalidCert represents the error returned when a specified certificate was not valid.

# Structs

ConnectError wraps the underlying error when a failure occurs dialing the database.
InvalidTimeoutError wraps the underlying error when the provided is not parsable time.ParseDuration.
InvalidURIError wraps the underlying error when the provided URI is not parsable by mgo.
Mock can be used for mocking tests that need no actual client or Session.
MockErr can be used for mocking tests that need no actual client or Session.
MockSession can be used for mocking tests the do not need to use anything in the Session.
MockWriter can be used to count the number of messages sent to Write.
VersionError represents any failure in attempting to obtain the version from the provided uri.

# Interfaces

Client provides a standard interface for interacting with the underlying sources/sinks.
Closer provides a standard interface for closing a client or session.
Reader represents the ability to send messages down the pipe and is only needed for adaptors acting as a Source node.
Session represents the connection to the underlying service.
Writer represents all possible functions needing to be implemented to handle messages.

# Type aliases

MessageChanFunc represents the func signature needed to send messages to downstream adaptors.
NsFilterFunc represents the func signature needed to filter while Read()ing.