qp

type Codec interface {
	// Marshal takes an object and creates a byte slice representation
	// of the object in the underlying data format.
	Marshal(object interface{}) ([]byte, error)
	// Unmarshal takes a bytes slice of data in the underlying data format
	// and decodes it into the provided object
	Unmarshal(data []byte, to interface{}) error
}

type DirectTransport interface {
	start.StartStopper
	// Send sends data on the channel.
	Send(channel string, data []byte) error
	// OnMessage binds the handler to the specified channel.
	// Only one handler can be associated with a given channel.
	// Multiple calls to OnMessage wiht the same channel will replace the previous handler.
	OnMessage(channel string, handler Handler) error
}

type Event struct {
	// From is the instance ID of the sender.
	From string `json:"from"`
	// Data is the payload of the event.
	Data interface{} `json:"data"`
}

type EventHandler interface {
	Handle(*Event)
}

type EventHandlerFunc func(*Event)

type Future struct {
	// contains filtered or unexported fields
}

type Handler interface {
	Handle(msg *Message)
}

type HandlerFunc func(msg *Message)

type Message struct {
	// The channel the Message came from.
	Source string
	// The data of the message.
	Data []byte
}

type PubSubTransport interface {
	start.StartStopper
	// Publish publishes data on the specified channel.
	Publish(channel string, data []byte) error
	// Subscribe binds the handler to the specified channel.
	// Only one handler can be associated with a given channel.
	// Multiple calls to Subscribe with the same channel will replace the previous handler.
	Subscribe(channel string, handler Handler) error
}

type Publisher interface {
	// Publish publishes the object on the specified channel.
	Publish(channel string, obj interface{}) error
}

type RequestID uint64

type Requester interface {
	// Issue issues the request and returns a Future from which you can
	// get the response.
	// The pipeline may be one or more endpoints. If it is more than one, each will receive
	// the message, in order, and have an opportunity to mutate it before it is dispatched
	// to the next endpoint in the pipeline.
	// The provided object will be serialized and send as the "data" field in the message.
	Issue(pipeline []string, obj interface{}) (*Future, error)
}

type Responder interface {
	// Handle binds a TransactionHandler to the specified channel.
	Handle(channel string, handler TransactionHandler) error
	// HandleFunc binds the specified function to the specified channel.
	HandleFunc(channel string, f TransactionHandlerFunc) error
}

type Signal struct{}

type Subscriber interface {
	// Subscribe binds the handler to the specified channel.
	Subscribe(channel string, handler EventHandler) error
	// SubscribeFunc binds the EventHandlerFunc to the specified channel.
	SubscribeFunc(channel string, fn EventHandlerFunc) error
}

type Transaction struct {
	// To is an array of destination addresses
	To []string `json:"to"`
	// From is an array of addresses encountered thus far
	From []string `json:"from"`
	// ID is a number identifying this message
	ID RequestID `json:"id"`
	// Data is an arbitrary data payload
	Data interface{} `json:"data"`
}

type TransactionHandler interface {
	Handle(req *Transaction) *Transaction
}

type TransactionHandlerFunc func(r *Transaction) *Transaction