delayqueue

package
v1.0.0 Latest Latest
Warning

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

Go to latest
Published: Mar 31, 2022 License: Apache-2.0 Imports: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	// unable to determine the min ts
	UnknownTs = int64(-1)
	// indecated no pending msg now
	MaxTs      = int64(math.MaxInt64)
	BucketName = []byte("delayqueue")
)

Functions

func Builder

func Builder(cfgKey string) func(*engine.Engine) (interface{}, error)

Types

type BboltConfig

type BboltConfig struct {
	Path string `json:"path"`
}

type Config

type Config struct {
	Nats   *NatsConfig        `json:"nats"`
	Bbolt  *BboltConfig       `json:"bbolt"`
	Logger *zap.SugaredLogger `json:"-"`
}

type DelayQueue

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

func New

func New(cfg *Config) (*DelayQueue, error)

func (*DelayQueue) Close

func (me *DelayQueue) Close() error

type NatsConfig

type NatsConfig struct {
	Url          string `json:"url"`
	Username     string `json:"username"`
	Password     string `json:"password"`
	StreamName   string `json:"streamName"`
	ConsumerName string `json:"consumerName"`
	Subject      string `json:"subject"`
}

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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