ps

Documentation

Index

• func CreateSubscription(args PubSubArguments) error
• func CreateTopic(args PubSubArguments) error
• func Publish(args PubSubArguments) error
• func Pull(args PubSubArguments) error
• func PullPush(args PubSubArguments) error
• type PubSubArguments
• type PubSubMessage

Functions

func CreateSubscription

func CreateSubscription(args PubSubArguments) error

func CreateTopic

func CreateTopic(args PubSubArguments) error

func Publish

func Publish(args PubSubArguments) error

func Pull

func Pull(args PubSubArguments) error

func PullPush

func PullPush(args PubSubArguments) error

Pull messages from a Subscription and Push them to an endpoint.

Types

type PubSubArguments

type PubSubArguments struct {
	Project            string
	File               string
	Topic              string
	Subscription       string
	UseEmulator        bool
	PushURL            string
	AlwaysACK          bool
	AbortOnError       bool
	SubscriptionFilter string
}

type PubSubMessage

type PubSubMessage struct {
	Message struct {
		Data       []byte            `json:"data,omitempty"`
		Attributes map[string]string `json:"attributes"`
		ID         string            `json:"id"`
	} `json:"message"`
	MessageId    string `json:"messageId"`
	Subscription string `json:"subscription"`
}

PubSubMessage is the payload of a Pub/Sub event. See the documentation for more details: https://cloud.google.com/pubsub/docs/reference/rest/v1/PubsubMessage