output_redis_extend_queue

package
v0.0.8-beta Latest Latest
Warning

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

 Go to latest Published: May 11, 2024 License: GPL-3.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type OptionSession 

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

type OutputRedisQueueExtendRule 

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

func NewOutputRedisQueueExtendRule 

func NewOutputRedisQueueExtendRule() *OutputRedisQueueExtendRule

func (*OutputRedisQueueExtendRule) Id 

func (l *OutputRedisQueueExtendRule) Id() string

func (*OutputRedisQueueExtendRule) Infinity 

func (l *OutputRedisQueueExtendRule) Infinity() bool

func (*OutputRedisQueueExtendRule) Initialize 

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

func (*OutputRedisQueueExtendRule) Run 

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

func (l *OutputRedisQueueExtendRule) Stop(ctx context.Context) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.