pubsub

Documentation

Index

• func BuildDescErrorMsg(desc string, err error) string
• func NewGooglePubSub(config *common_utils.BaseConfig) (c *pubsub.Client, err error)
• func SetRetryOrSetDataToDB(config *common_utils.BaseConfig, msg *pubsub.Message, cb func())
• type GooglePubSub
• type PubSubClient
  • func NewPubSubClient(config *common_utils.BaseConfig, pubSub GooglePubSub) PubSubClient
• type PubSubClientImpl
  • func (p *PubSubClientImpl) CheckTopicAndPublish(ctx context.Context, topicsName []string, orderingKey string, data any)
  • func (p *PubSubClientImpl) Close() error
  • func (p *PubSubClientImpl) CreateSubscriptionIfNotExists(ctx context.Context, id string, topic *pubsub.Topic) (*pubsub.Subscription, error)
  • func (p *PubSubClientImpl) CreateTopicIfNotExists(ctx context.Context, topicName string) (*pubsub.Topic, error)
  • func (p *PubSubClientImpl) PublishTopics(ctx context.Context, topics []*pubsub.Topic, data any, orderingKey string) error
  • func (p *PubSubClientImpl) PullMessages(ctx context.Context, id string, topic *pubsub.Topic, ...) error

Functions

func BuildDescErrorMsg

func BuildDescErrorMsg(desc string, err error) string

func NewGooglePubSub

func NewGooglePubSub(config *common_utils.BaseConfig) (c *pubsub.Client, err error)

func SetRetryOrSetDataToDB

func SetRetryOrSetDataToDB(config *common_utils.BaseConfig, msg *pubsub.Message, cb func())

Types

type GooglePubSub

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

type PubSubClient

type PubSubClient interface {
	CreateTopicIfNotExists(ctx context.Context, topicName string) (*pubsub.Topic, error)
	CreateSubscriptionIfNotExists(ctx context.Context, id string, topic *pubsub.Topic) (*pubsub.Subscription, error)
	PublishTopics(ctx context.Context, topics []*pubsub.Topic, data any, orderingKey string) error
	PullMessages(ctx context.Context, id string, topic *pubsub.Topic, callback func(ctx context.Context, msg *pubsub.Message)) error
	Close() error
	CheckTopicAndPublish(ctx context.Context, topicsName []string, orderingKey string, data any)
}

func NewPubSubClient

func NewPubSubClient(config *common_utils.BaseConfig, pubSub GooglePubSub) PubSubClient

type PubSubClientImpl

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

func (*PubSubClientImpl) CheckTopicAndPublish

func (p *PubSubClientImpl) CheckTopicAndPublish(
	ctx context.Context,
	topicsName []string,
	orderingKey string,
	data any,
)

func (*PubSubClientImpl) Close

func (p *PubSubClientImpl) Close() error

func (*PubSubClientImpl) CreateSubscriptionIfNotExists

func (p *PubSubClientImpl) CreateSubscriptionIfNotExists(ctx context.Context, id string, topic *pubsub.Topic) (*pubsub.Subscription, error)

func (*PubSubClientImpl) CreateTopicIfNotExists

func (p *PubSubClientImpl) CreateTopicIfNotExists(ctx context.Context, topicName string) (*pubsub.Topic, error)

func (*PubSubClientImpl) PublishTopics

func (p *PubSubClientImpl) PublishTopics(ctx context.Context, topics []*pubsub.Topic, data any, orderingKey string) error

func (*PubSubClientImpl) PullMessages

func (p *PubSubClientImpl) PullMessages(ctx context.Context, id string, topic *pubsub.Topic, callback func(ctx context.Context, msg *pubsub.Message)) error