types

Sep 4, 2025

Changes in this version

type RedisStreamClient

+ DoneStream func(ctx context.Context, dataStreamName string) error

Aug 6, 2025

Changes in this version

+ const ExpiredEventPattern

+ const GroupSuffix

+ const InputSuffix

+ const KeyspacePatternForExpiredEvents

+ const LBSInput

+ const LockAlreadyTakenErrMsg

+ const MutexKeySep

+ const NotifyKeyspaceEventsCmd

+ const PendingMsgID

+ const PodIP

+ const PodName

+ const RedisConsumerPrefix

+ const StartFromNow

+ type RedisStreamClient interface

+ Claim func(ctx context.Context, kspNotification string) error

+ Done func() error

+ ID func() string

+ Init func(ctx context.Context) (outputChan <-chan notifs.RecoverableRedisNotification[any], err error)