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