pubsub

type Client interface {
	Close() error

	Publish(ctx context.Context, topic string, val string) error
	Subscribe(ctx context.Context, topic string) (<-chan string, error)
	Unsubscribe(ctx context.Context, ch <-chan string) error
}

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

type PostgresPubsubConnectionConfig struct {
	Uri                  string
	MinReconnectInterval time.Duration
	MaxReconnectInterval time.Duration
}