bucket

package

v0.1.0 Latest Latest Go to latest Published: Mar 19, 2022 License: MIT Imports: 10 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/changsongl/delay-queue

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
type Bucket
- func New(s store.Store, l log.Logger, size uint64, name string) Bucket

Constants ¶

View Source

const (
	// DefaultMaxFetchNum default max fetching job from bucket
	DefaultMaxFetchNum uint64 = 20
)

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Bucket ¶

type Bucket interface {
	CreateJob(j *job.Job, isTTR bool) error
	GetBuckets() []uint64
	GetBucketJobs(bid uint64) ([]job.NameVersion, error)

	GetMaxFetchNum() uint64
	SetMaxFetchNum(num uint64)
}

Bucket interface to save jobs and repeat is searched for jobs which are ready to process

func New ¶

func New(s store.Store, l log.Logger, size uint64, name string) Bucket

New a Bucket interface object

Source Files ¶

View all Source files

bucket.go

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