gps

Documentation

Overview

Package gps helps with Google Pubsub

Index

• func CreateTopic(ctx context.Context, pubSubPulisherClient *pubsub.PublisherClient, ...) error
• func GetPublishCallResult(ctx context.Context, publishResult *pubsub.PublishResult, ...)
• func GetTopicList(ctx context.Context, pubSubPulisherClient *pubsub.PublisherClient, ...) error
• func SetTopicRole(ctx context.Context, pubSubPulisherClient *pubsub.PublisherClient, ...) (err error)
• type PubSubMessage
• type TopicDeployment
  • func NewTopicDeployment() *TopicDeployment
  • func (topicDeployment *TopicDeployment) Deploy() (err error)

Functions

func CreateTopic

func CreateTopic(ctx context.Context, pubSubPulisherClient *pubsub.PublisherClient, topicListPointer *[]string, topicName string, projectID string) error

CreateTopic check if a topic already exist, if not create it

func GetPublishCallResult

func GetPublishCallResult(ctx context.Context, publishResult *pubsub.PublishResult, waitgroup *sync.WaitGroup, msgInfo string, pubSubErrNumber *uint64, pubSubMsgNumber *uint64, logEventEveryXPubSubMsg uint64)

GetPublishCallResult func to be used in go routine to scale pubsub event publish

func GetTopicList

func GetTopicList(ctx context.Context, pubSubPulisherClient *pubsub.PublisherClient, projectID string, topicListPointer *[]string) error

GetTopicList retreive the list of existing pubsub topics

func SetTopicRole

func SetTopicRole(ctx context.Context, pubSubPulisherClient *pubsub.PublisherClient, topicName string, member string, role iam.RoleName) (err error)

SetTopicRole check if a topic already exist, if not create it

Types

type PubSubMessage

type PubSubMessage struct {
	Data []byte `json:"data"`
}

PubSubMessage is the payload of a Pub/Sub event.

type TopicDeployment

type TopicDeployment struct {
	Core     *deploy.Core
	Settings struct {
		TopicName string
	}
}

TopicDeployment struct

func NewTopicDeployment

func NewTopicDeployment() *TopicDeployment

NewTopicDeployment create deployment structure

func (*TopicDeployment) Deploy

func (topicDeployment *TopicDeployment) Deploy() (err error)

Deploy topic