cloud_pubsub

Documentation

Index

• type CloudPublisher
  • func (cp *CloudPublisher) PublishMessage(ctx context.Context, pubSubData Data) (messageID string, err error)
• type CloudSubscriber
  • func (s *CloudSubscriber) Receive(ctx context.Context, callback func(ctx context.Context, msg *pubsub.Message)) error
• type Data
• type Publisher
  • func NewCloudPublisher(projectID, topicID, credentialsJSON string) (Publisher, error)
• type Subscriber
  • func NewCloudSubscriber(projectID, subscriptionID, credentialsJSON string) (Subscriber, error)
  • func NewCloudSubscriberWithLimit(projectID, subscriptionID, credentialsJSON string, ...) (Subscriber, error)

Types

type CloudPublisher

type CloudPublisher struct {
	ProjectID string
	TopicID   string
	Client    *pubsub.Client
}

func (*CloudPublisher) PublishMessage

func (cp *CloudPublisher) PublishMessage(ctx context.Context, pubSubData Data) (messageID string, err error)

type CloudSubscriber

type CloudSubscriber struct {
	ProjectID      string
	SubscriptionID string
	Subscription   *pubsub.Subscription
}

func (*CloudSubscriber) Receive

func (s *CloudSubscriber) Receive(ctx context.Context, callback func(ctx context.Context, msg *pubsub.Message)) error

type Data

type Data struct {
	Id          string
	Publisher   string
	Action      string
	RequestTime string
	Data        interface{}
}

type Publisher

type Publisher interface {
	PublishMessage(ctx context.Context, data Data) (messageID string, err error)
}

func NewCloudPublisher

func NewCloudPublisher(projectID, topicID, credentialsJSON string) (Publisher, error)

type Subscriber

type Subscriber interface {
	Receive(context.Context, func(ctx context.Context, msg *pubsub.Message)) error
}

func NewCloudSubscriber

func NewCloudSubscriber(projectID, subscriptionID, credentialsJSON string) (Subscriber, error)

func NewCloudSubscriberWithLimit

func NewCloudSubscriberWithLimit(projectID, subscriptionID, credentialsJSON string, maxOutstandingMessages, numGoroutines int) (Subscriber, error)