Documentation
¶
Index ¶
- type Option
- type OptionSession
- type OutputRedisQueueRule
- func (l *OutputRedisQueueRule) Id() string
- func (l *OutputRedisQueueRule) Infinity() bool
- func (l *OutputRedisQueueRule) Initialize(ctx context.Context, optionRaw map[string]interface{}) error
- func (l *OutputRedisQueueRule) Run(ctx context.Context, ...)
- func (l *OutputRedisQueueRule) Stop(ctx context.Context) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type OptionSession ¶
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)
Click to show internal directories.
Click to hide internal directories.