Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type PubSubIterator ¶
type PubSubIterator struct {
// contains filtered or unexported fields
}
func NewPubSubIterator ¶
NewPubSubIterator creates a new instance of redis pubsub iterator and starts listening for new messages on channel
func (*PubSubIterator) HasNext ¶
func (i *PubSubIterator) HasNext() bool
HasNext returns whether there are any more records to be returned or when the error is to be returned by the Next function
func (*PubSubIterator) Stop ¶
func (i *PubSubIterator) Stop() error
Stop sends a kill signal to tomb, converting the tomb status to Dying giving go routines time to gracefully stop execution
type StreamIterator ¶
type StreamIterator struct {
// contains filtered or unexported fields
}
func NewStreamIterator ¶
func NewStreamIterator(ctx context.Context, client redis.Conn, key string, pollingInterval time.Duration, position sdk.Position, ) (*StreamIterator, error)
NewStreamIterator creates a new instance of redis stream iterator and starts polling redis stream for new changes using the last record id of last successful row read, in a separate go routine
func (*StreamIterator) HasNext ¶
func (i *StreamIterator) HasNext() bool
HasNext returns whether there are any more records to be returned
Click to show internal directories.
Click to hide internal directories.