Documentation
¶
Index ¶
- type InputRedisQueueRule
- func (l *InputRedisQueueRule) Id() string
- func (l *InputRedisQueueRule) Infinity() bool
- func (l *InputRedisQueueRule) InfoSession(id uint64) map[string]interface{}
- func (l *InputRedisQueueRule) Initialize(ctx context.Context, optionRaw map[string]interface{}) error
- func (l *InputRedisQueueRule) ListSession() []uint64
- func (l *InputRedisQueueRule) Run(ctx context.Context, ...)
- func (l *InputRedisQueueRule) Stop(ctx context.Context) error
- func (l *InputRedisQueueRule) StopSession(id uint64)
- type Option
- type OptionLoop
- type OptionSession
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) StopSession ¶
func (l *InputRedisQueueRule) StopSession(id uint64)
type OptionLoop ¶
type OptionLoop struct {
// contains filtered or unexported fields
}
type OptionSession ¶
Click to show internal directories.
Click to hide internal directories.