Documentation ¶
Index ¶
Constants ¶
View Source
const NetworkTcp = "tcp"
Variables ¶
View Source
var WireSet = wire.NewSet(NewDialer, NewConfiguration)
Functions ¶
func NewDialer ¶
func NewDialer(config *Configuration) connection.Dialer
Types ¶
type BeanstakldDialer ¶
type BeanstakldDialer struct { *Configuration // contains filtered or unexported fields }
func (*BeanstakldDialer) CreateChannel ¶
func (b *BeanstakldDialer) CreateChannel() connection.Channel
func (*BeanstakldDialer) CreateChannels ¶
func (b *BeanstakldDialer) CreateChannels() connection.Channels
func (*BeanstakldDialer) Dial ¶
func (b *BeanstakldDialer) Dial(addr string, tubes []string) (consumer.ConnectionHandler, error)
type Configuration ¶
func NewConfiguration ¶
func NewConfiguration() *Configuration
type TubeAdapter ¶
func (*TubeAdapter) Name ¶
func (ta *TubeAdapter) Name() string
Click to show internal directories.
Click to hide internal directories.