interchange

type Client interface {
	Publisher
	Subscriber
}

type Message struct {
	Encoding codex.Codex
	Source   string
	// Meta   map[string]string
	Body interface{}
}

type Publisher interface {
	// Produce a message to the provided topic on the Arke hub.
	Publish(topic string, message Message) error
}

type Subscriber interface {
	// Subscribe to a given topic.
	Subscribe(name, topic string, lease time.Duration) (<-chan Message, error)
}