connection

type Channel interface {
	Name() string

	Put(body []byte, pri uint32, delay, ttr time.Duration) (id uint64, err error)
}

type Channels interface {
	Reserve(timeout time.Duration) (id uint64, body []byte, err error)
}

type Configuration struct {
	Tubes []string
	Url   string
}

type Connection struct {
	consumer.ConnectionHandler

	*Configuration
	// contains filtered or unexported fields
}

type Dialer interface {
	Dial(addr string, tubes []string) (consumer.ConnectionHandler, error)

	CreateChannels() Channels
	CreateChannel() Channel
}

type Handler interface {
	Init() error
	Close() error

	Config() *Configuration

	Dialer() Dialer
}