driver

package

v0.3.20 Latest Latest Go to latest Published: Jun 5, 2026 License: Apache-2.0 Imports: 13 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Driver interface {
	common.Daemon
	model.PubsubDriver
}

Driver defines the interface for subscription storage and event delivery.

func NewKafka(brokers []string, groupID string, log log.Logger) (Driver, error)

func NewMemory(log log.Logger) Driver

func NewRedis(client *redis.Client, log log.Logger) (Driver, error)