Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type SinkerKeyExpirationListener ¶ added in v0.29.0
type SinkerKeyExpirationListener interface {
// SubscribeToKeyExpiration Listen to the sinker key expiration
SubscribeToKeyExpiration(ctx context.Context) error
// ReceiveMessage to be used to receive the message from the sinker key expiration, async
ReceiveMessage(ctx context.Context, message string) error
}
func NewSinkerKeyExpirationListener ¶ added in v0.29.0
func NewSinkerKeyExpirationListener(l *zap.Logger, cacheRedisClient *redis.Client, idleProducer producer.SinkIdleProducer) SinkerKeyExpirationListener
Source Files
Click to show internal directories.
Click to hide internal directories.