Documentation ¶
Index ¶
- Variables
- type Gostalk
- func (this *Gostalk) Bury(jobId uint64, priority uint32) (err error)
- func (this *Gostalk) Delete(jobId uint64) (err error)
- func (this *Gostalk) Disconnect() (err error)
- func (this *Gostalk) Ignore(tubeName string) (int, error)
- func (this *Gostalk) Put(data []byte, priority uint32, delay time.Duration, ttr time.Duration) (uint64, error)
- func (this *Gostalk) Reserve() (*Job, error)
- func (this *Gostalk) ReserveWithTimeout(duration time.Duration) (*Job, error)
- func (this *Gostalk) Use(tubeName string) (err error)
- func (this *Gostalk) Watch(tubeName string) (int, error)
- type Job
Constants ¶
This section is empty.
Variables ¶
View Source
var ReaderSize = 65535
Functions ¶
This section is empty.
Types ¶
type Gostalk ¶
type Gostalk struct {
// contains filtered or unexported fields
}
func (*Gostalk) Disconnect ¶
Disconnects from the beanstalkd server
func (*Gostalk) Ignore ¶
Ignores the specified tube and returns the number of tubes being watched. Cannot ignore a tube if it's the only tube being watched
func (*Gostalk) Put ¶
func (this *Gostalk) Put(data []byte, priority uint32, delay time.Duration, ttr time.Duration) (uint64, error)
Put is is for any process that wants to insert a job into the queue. It takes the data, priority, delay, time to release
func (*Gostalk) Reserve ¶
Reserve waits for a job indefinitely from the server. Once the job has been received, it returns the job This is a blocking call.
func (*Gostalk) ReserveWithTimeout ¶
Click to show internal directories.
Click to hide internal directories.