pubsub

type Config struct {
	App       string // app namespace prefix
	Namespace string

	Provider Provider

	HealthInterval time.Duration
	SendTimeout    time.Duration
	ChannelSize    int
}

type Consumer interface {
	// Subscribe(ctx context.Context, topics ...string) error
	// Publish(ctx context.Context, topics ...string) error
	Close() error
}

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

type Option interface {
	Apply(*Config)
}

type OptionFunc func(*Config)

type Provider string

type PubSub interface {
	Publisher
	Subscriber
}

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

type PublishOption interface {
	Apply(*PublishConfig)
}

type PublishOptionFunc func(*PublishConfig)

type Publisher interface {
	// Publish message to topic
	Publish(ctx context.Context, topic string, payload []byte, options ...PublishOption) error
}

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

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

type SubscribeOption interface {
	Apply(*SubscribeConfig)
}

type SubscribeOptionFunc func(*SubscribeConfig)

type Subscriber interface {
	// Subscribe consumer to process the topic with payload, this should be blocking operation.
	Subscribe(ctx context.Context, topic string, handler func(payload []byte) error, options ...SubscribeOption) Consumer
}