beanstalkd

package

v1.4.0 Latest Latest Go to latest Published: Mar 3, 2026 License: Apache-2.0 Imports: 6 Imported by: 0

Details

Package beanstalkd provides a client wrapper for Beanstalkd job queue.

This section is empty.

This section is empty.

func New() result.Result[*BeanstalkdClient]

New creates a new BeanstalkdClient using config.Conf().Beanstalkd.

func NewFromConfig(cfg config.BeanstalkdConfig) result.Result[*BeanstalkdClient]

NewFromConfig creates a BeanstalkdClient from the given config.

type BeanstalkdClient struct {
	Conn *beanstalk.Conn
	Tube string
}

BeanstalkdClient wraps a beanstalk connection and tube for job queuing.

func (srv *BeanstalkdClient) Close()

Close closes the beanstalk connection.

func (srv *BeanstalkdClient) Send(content url.Values) result.VoidResult

Send encodes content as URL values and puts it into the configured tube.