redis

package

v19.2.0 Latest Latest Go to latest Published: Jul 15, 2026 License: MIT Imports: 11 Imported by: 0

Documentation ¶

This section is empty.

This section is empty.

This section is empty.

type Backend struct {
	// contains filtered or unexported fields
}

func NewBackend(client rueidis.Client, keyPrefix string, batchSize int64) *Backend

func (b *Backend) Ack(ctx context.Context, topic, consumerGroup string, messageIDs ...string) error

func (b *Backend) DeleteConsumer(ctx context.Context, topic, consumerGroup, consumerName string) error

func (b *Backend) Publish(ctx context.Context, topic string, events ...*event.CloudEvent) ([]string, error)

func (b *Backend) Subscribe(ctx context.Context, topic, consumerGroup, consumerName string, eventTypes []string) iter.Seq2[pubsub.Message, error]