gps

package

v0.4.5 Latest Latest Go to latest Published: Aug 2, 2022 License: Apache-2.0 Imports: 16 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/BrunoReboul/ram

Links

Open Source Insights

Documentation ¶

Overview ¶

Package gps helps with Google Pubsub

Index ¶

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

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func CheckTopicRole ¶ added in v0.1.2

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

CheckTopicRole check if a role exist on a topic

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 ¶ added in v0.1.0

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

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 ¶ added in v0.0.35

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

SetTopicRole set a role on a topic

Types ¶

type PubSubMessage ¶ added in v0.1.0

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

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL