input_redis_queue_extend

package
v0.0.8-beta3 Latest Latest
Warning

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

Go to latest
Published: Jun 5, 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 InputRedisQueueExtendRule

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

func NewInputRedisQueueExtendRule

func NewInputRedisQueueExtendRule() *InputRedisQueueExtendRule

func (*InputRedisQueueExtendRule) Id

func (*InputRedisQueueExtendRule) Infinity

func (l *InputRedisQueueExtendRule) Infinity() bool

func (*InputRedisQueueExtendRule) InfoSession

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

func (*InputRedisQueueExtendRule) Initialize

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

func (*InputRedisQueueExtendRule) ListSession

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

func (*InputRedisQueueExtendRule) Run

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

func (*InputRedisQueueExtendRule) StopSession

func (l *InputRedisQueueExtendRule) StopSession(id uint64)

type OptionLoop

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

type OptionSession

type OptionSession struct {
	Queue         string `json:"queue"`
	RedisAddress  string `json:"redis_address"`
	RedisPassword string `json:"redis_password"`
	RedisDb       int    `json:"redis_db"`
	NextSuccess   string `json:"next_success"`
	NextError     string `json:"next_error"`
}

type RedisSessionInfo

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

Jump to

Keyboard shortcuts

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