pubsub

package

v1.15.21 Latest Latest Go to latest Published: Dec 9, 2024 License: MIT Imports: 2 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type PubSub interface {
	Publish(topic string, message *gopubsub.Message) error
	Subscribe(topic string, handler gopubsub.Handler) error
}

PubSub ...

func New(ctx context.Context, ps gopubsub.PubSub) PubSub

New creates a pubsub at the given context.