input_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: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type InputRedisQueueRule

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

func NewInputRedisQueueRule

func NewInputRedisQueueRule() *InputRedisQueueRule

func (*InputRedisQueueRule) Id

func (l *InputRedisQueueRule) Id() string

func (*InputRedisQueueRule) Infinity

func (l *InputRedisQueueRule) Infinity() bool

func (*InputRedisQueueRule) InfoSession

func (l *InputRedisQueueRule) InfoSession(id uint64) map[string]interface{}

func (*InputRedisQueueRule) Initialize

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

func (*InputRedisQueueRule) ListSession

func (l *InputRedisQueueRule) ListSession() []uint64

func (*InputRedisQueueRule) Run

func (l *InputRedisQueueRule) 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 (*InputRedisQueueRule) Stop

func (*InputRedisQueueRule) StopSession

func (l *InputRedisQueueRule) StopSession(id uint64)

type Option

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

type OptionLoop

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

type OptionSession

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

Jump to

Keyboard shortcuts

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