pubsub

README

notification

Documentation

Index

• type Pubsub
  • func (pubsub *Pubsub) AsyncPublishApplyAddContact(ctx context.Context, event *contactevent.Event) error
  • func (pubsub *Pubsub) Init(configFilePath string) (err error)
  • func (pubsub *Pubsub) SendAsync(ctx context.Context, payload any) error

Types

type Pubsub

type Pubsub struct {
	Client               pulsar.Client
	DefaultEventProducer pulsar.Producer
}

func (*Pubsub) AsyncPublishApplyAddContact

func (pubsub *Pubsub) AsyncPublishApplyAddContact(ctx context.Context, event *contactevent.Event) error

func (*Pubsub) Init

func (pubsub *Pubsub) Init(configFilePath string) (err error)

func (*Pubsub) SendAsync

func (pubsub *Pubsub) SendAsync(ctx context.Context, payload any) error