consumer

Documentation

Index

• type SinkerKeyExpirationListener
  • func NewSinkerKeyExpirationListener(l *zap.Logger, cacheRedisClient *redis.Client, ...) SinkerKeyExpirationListener

Types

type SinkerKeyExpirationListener

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

func NewSinkerKeyExpirationListener(l *zap.Logger, cacheRedisClient *redis.Client, idleProducer producer.SinkIdleProducer) SinkerKeyExpirationListener