gps

Documentation

Overview

Package gps helps with Google Pubsub

Index

• func CreateTopic(ctx context.Context, pubSubPulisherClient *pubsub.PublisherClient, ...) error
• func GetTopicList(ctx context.Context, pubSubPulisherClient *pubsub.PublisherClient, ...) error
• func SetTopicRole(ctx context.Context, pubSubPulisherClient *pubsub.PublisherClient, ...) (err error)
• 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 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 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