output_redis_queue

package
v0.0.9 Latest Latest
Warning

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

Go to latest
Published: Nov 24, 2024 License: GPL-3.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Option

type Option struct {
	RedisAddress  string `json:"redis_address"`
	RedisPassword string `json:"redis_password"`
	RedisDb       int    `json:"redis_db"`
}

type OptionSession

type OptionSession struct {
	Queue       string `json:"queue"`
	NextSuccess string `json:"next_success"`
	NextError   string `json:"next_error"`
}

type OutputRedisQueueRule

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

func NewOutputRedisQueueRule

func NewOutputRedisQueueRule() *OutputRedisQueueRule

func (*OutputRedisQueueRule) Id

func (l *OutputRedisQueueRule) Id() string

func (*OutputRedisQueueRule) Infinity

func (l *OutputRedisQueueRule) Infinity() bool

func (*OutputRedisQueueRule) Initialize

func (l *OutputRedisQueueRule) Initialize(ctx context.Context, optionRaw map[string]interface{}) error

func (*OutputRedisQueueRule) Run

func (l *OutputRedisQueueRule) Run(ctx context.Context, subscribeQueueInput func(ctx context.Context, callback queue.SubscribeFunction[*data.InputEngine]) error, pushQueueOutput func(ctx context.Context, input *data.OutputEngine) error)

func (*OutputRedisQueueRule) Stop

Jump to

Keyboard shortcuts

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