pubsub

Documentation

Index

• func New(projectId string, opt ...option.ClientOption) *pubsub.Client
• type ContactSourceDeletedPublisher
  • func NewContactSourceDeletedPublisher(topic *pubsub.Topic) *ContactSourceDeletedPublisher
  • func (publisher *ContactSourceDeletedPublisher) Publish(ctx context.Context, request models.ContactSourceDeleted) (err error)
• type PullContactSourcePublisher
  • func NewPullContactSourcePublisher(topic *pubsub.Topic) *PullContactSourcePublisher
  • func (publisher *PullContactSourcePublisher) Publish(ctx context.Context, request models.PullContactsRequest) (err error)

Functions

func New

func New(projectId string, opt ...option.ClientOption) *pubsub.Client

Types

type ContactSourceDeletedPublisher

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

func NewContactSourceDeletedPublisher

func NewContactSourceDeletedPublisher(topic *pubsub.Topic) *ContactSourceDeletedPublisher

func (*ContactSourceDeletedPublisher) Publish

func (publisher *ContactSourceDeletedPublisher) Publish(ctx context.Context, request models.ContactSourceDeleted) (err error)

type PullContactSourcePublisher

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

func NewPullContactSourcePublisher

func NewPullContactSourcePublisher(topic *pubsub.Topic) *PullContactSourcePublisher

func (*PullContactSourcePublisher) Publish

func (publisher *PullContactSourcePublisher) Publish(ctx context.Context, request models.PullContactsRequest) (err error)