beanstalkd

type Beanstalkd struct {
	Endpoints []string
	Tube      string
}

type Conf struct {
	Beanstalkd
	Redis redis.RedisConf
}

type ConsumeHandle func(ctx context.Context, body []byte)

type ConsumerCluster struct {
	// contains filtered or unexported fields
}

type ConsumerOption func(*queueOptions)

type DelayPusher interface {
	io.Closer
	At(ctx context.Context, body []byte, at time.Time) (string, error)
	Delay(ctx context.Context, body []byte, delay time.Duration) (string, error)
	Revoke(ctx context.Context, ids string) error
}

type ProducerCluster struct {
	// contains filtered or unexported fields
}