google

type GooglePubSubClient struct {
	Client *pubsub.Client
}

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

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

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

type ListenHandler struct {
	Name         string
	Subscription string
	AutoAck      bool
	ConsumeFn    func(ctx context.Context, span trace.Span, msg any) error
}

type Provider struct {
	Config *ProviderConfig
	Client PubSubClient
	Tracer trace.Tracer
}

type ProviderConfig struct {
	GoogleProjectId string
	GoogleSaPath    string
}

type PubSubClient interface {
	CreateSubscription(ctx context.Context, id string, cfg pubsub.SubscriptionConfig) (Subscription, error)
	Subscription(id string) Subscription
	Topic(id string) Topic
	Close() error
}

type PublishResult interface {
	Get(ctx context.Context) (string, error)
}

type Subscription interface {
	ID() string
	Receive(ctx context.Context, f func(ctx context.Context, msg *pubsub.Message)) error
}

type Topic interface {
	Publish(ctx context.Context, msg *pubsub.Message) PublishResult
	GetInstance() *pubsub.Topic
}