pubsub

type GoogleProviderSettings struct {
	ProjectID          string
	CredentialsFile    string
	SubscriptionSuffix string
	CreateTopic        bool
	CreateSubscription bool
}

type IPubSub interface {
	Publish(ctx context.Context, topic string, msg []byte) error
	Subscribe(ctx context.Context, topic string, handler MsgHandler) (ISubscription, error)
	SubscribeChan(ctx context.Context, topic string, channel chan []byte) (ISubscription, error)
}

type ISubscription interface {
	Close() error
}

type MsgHandler func(msg []byte)

type NatsProviderSettings struct {
	URL      string
	Token    string
	User     string
	Password string
}

type ProviderType string

type Settings struct {
	Provider ProviderType
	Google   GoogleProviderSettings
	Nats     NatsProviderSettings
}