transport

Documentation

Index

• type Message
• type ReceivedMessage
• type Transport

Types

type Message

type Message interface {
	MarshallBinary() ([]byte, error)
	UnmarshallBinary([]byte) error
}

type ReceivedMessage

type ReceivedMessage struct {
	// Message contains the message content. It is nil when the Error field
	// is not nil.
	Message Message
	// Data contains an optional data associated with the message. A type of
	// the data is different depending on a transport implementation.
	Data interface{}
	// Error contains an optional error returned by transport.
	Error error
}

ReceivedMessage contains a Message received from Transport with an additional data.

type Transport

type Transport interface {
	// Broadcast sends a message with a given topic.
	Broadcast(topic string, message Message) error
	// Messages returns a channel that will deliver incoming messages.
	// In case of an error, error will be returned in a ReceivedMessage
	// structure.
	Messages(topic string) chan ReceivedMessage
	// Start starts listening for messages.
	Start() error
	// Wait waits until the context is canceled or until an error occurs.
	Wait() chan error
}

Transport is the interface for different implementations of a publish–subscribe messaging solutions for the Oracle network.