pubsub

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

type Message struct {
	Topic string
	Data  []byte
}

type Option func(*options)

type PubSub interface {
	Publisher
	Subscriber
	// Close closes the pubsub instance and releases all resources.
	Close() error
}

type Publisher interface {
	// Publish publishes a message to a topic.
	// All subscribers to the topic will receive the message (fan-out).
	Publish(ctx context.Context, topic string, data []byte) error
}

type RedisConfig struct {
	// Client is the Redis client to use.
	// If nil, a client is created from the URL.
	// If both Client and URL are provided, Client takes precedence.
	Client *redis.Client

	// URL is the Redis URL to use.
	// If empty, the Redis client is not created.
	URL string

	// Prefix is the prefix to use for all topics.
	Prefix string
}

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

type Subscriber interface {
	// Subscribe subscribes to a topic and returns a channel for receiving messages.
	// The channel will be closed when the context is cancelled.
	Subscribe(ctx context.Context, topic string) (*Subscription, error)
}

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