beanstalkd

package
v0.0.0-...-beb54cf Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: May 1, 2020 License: MIT Imports: 4 Imported by: 0

Documentation

Index

Constants

View Source
const NetworkTcp = "tcp"

Variables

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

type Configuration struct {
	Addr  string
	Tubes []string
}

func NewConfiguration

func NewConfiguration() *Configuration

type TubeAdapter

type TubeAdapter struct {
	*gob.Tube
}

func (*TubeAdapter) Name

func (ta *TubeAdapter) Name() string

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL