pubsubmessaging

Oct 9, 2021

Changes in this version

type ServicePubSub

+ EDIMemberCoverLinking func(ctx context.Context, data dto.LinkCoverPubSubMessage) error

type ServicePubSubMessaging

+ func (ps *ServicePubSubMessaging) EDIMemberCoverLinking(ctx context.Context, data dto.LinkCoverPubSubMessage) error

Jul 28, 2021

Changes in this version

+ const ServiceName

+ const TopicVersion

+ type ServicePubSub interface

+ AddEngagementPubsubNameSpace func(topic string) string

+ AddPubSubNamespace func(topicName string) string

+ EnsureSubscriptionsExist func(ctx context.Context) error

+ EnsureTopicsExist func(ctx context.Context, topicIDs []string) error

+ NotifyCoverLinking func(ctx context.Context, data dto.LinkCoverPubSubMessage) error

+ NotifyCreateContact func(ctx context.Context, contact domain.CRMContact) error

+ NotifyCreateCustomer func(ctx context.Context, data dto.CustomerPubSubMessage) error

+ NotifyCreateSupplier func(ctx context.Context, data dto.SupplierPubSubMessage) error

+ NotifyUpdateContact func(ctx context.Context, contact domain.CRMContact) error

+ PublishToPubsub func(ctx context.Context, topicID string, payload []byte) error

+ ReceivePubSubPushMessages func(w http.ResponseWriter, r *http.Request)

+ SubscriptionIDs func() map[string]string

+ TopicIDs func() []string

+ type ServicePubSubMessaging struct

+ func NewServicePubSubMessaging(client *pubsub.Client, ext extension.BaseExtension, erp erp.AccountingUsecase, ...) (*ServicePubSubMessaging, error)

+ func (ps *ServicePubSubMessaging) NotifyCoverLinking(ctx context.Context, data dto.LinkCoverPubSubMessage) error

+ func (ps *ServicePubSubMessaging) NotifyCreateContact(ctx context.Context, contact domain.CRMContact) error

+ func (ps *ServicePubSubMessaging) NotifyCreateCustomer(ctx context.Context, data dto.CustomerPubSubMessage) error

+ func (ps *ServicePubSubMessaging) NotifyCreateSupplier(ctx context.Context, data dto.SupplierPubSubMessage) error

+ func (ps *ServicePubSubMessaging) NotifyUpdateContact(ctx context.Context, contact domain.CRMContact) error

+ func (ps ServicePubSubMessaging) AddEngagementPubsubNameSpace(topic string) string

+ func (ps ServicePubSubMessaging) AddPubSubNamespace(topicName string) string

+ func (ps ServicePubSubMessaging) EnsureSubscriptionsExist(ctx context.Context) error

+ func (ps ServicePubSubMessaging) EnsureTopicsExist(ctx context.Context, topicIDs []string) error

+ func (ps ServicePubSubMessaging) PublishToPubsub(ctx context.Context, topicID string, payload []byte) error

+ func (ps ServicePubSubMessaging) ReceivePubSubPushMessages(w http.ResponseWriter, r *http.Request)

+ func (ps ServicePubSubMessaging) SubscriptionIDs() map[string]string

+ func (ps ServicePubSubMessaging) TopicIDs() []string