tasks

package

v0.0.0-...-6d882ad Latest Latest Go to latest Published: Oct 7, 2019 License: ISC Imports: 13 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/koenbollen/pubsubcat

Links

Open Source Insights

Documentation ¶

Index ¶

func CleanTopic(ctx context.Context, client *pubsub.Client, params CleanParams) error
func ListSubscriptions(ctx context.Context, client *pubsub.Client, topicID string) error
func ListTopics(ctx context.Context, client *pubsub.Client, recursive bool) error
func Pipe(ctx context.Context, client *pubsub.Client, params PipeParams) error
func Publish(ctx context.Context, client *pubsub.Client, params PublishParams) error
func Subscribe(ctx context.Context, client *pubsub.Client, params SubscribeParams) error
type CleanParams
type PipeParams
type PublishParams
type SubscribeParams

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func CleanTopic ¶

func CleanTopic(ctx context.Context, client *pubsub.Client, params CleanParams) error

CleanTopic will look at all subscriptions in the given topic and remove old pubsubcat temporary topics.

func ListSubscriptions ¶

func ListSubscriptions(ctx context.Context, client *pubsub.Client, topicID string) error

ListSubscriptions outputs the request topic and all it's subscriptions

func ListTopics ¶

func ListTopics(ctx context.Context, client *pubsub.Client, recursive bool) error

ListTopics outputs all the topics fetched from the pubsub.Client.

func Pipe ¶

func Pipe(ctx context.Context, client *pubsub.Client, params PipeParams) error

Pipe will create a random subscription on inTopicID and forward all messages to the given outTopicID.

func Publish ¶

func Publish(ctx context.Context, client *pubsub.Client, params PublishParams) error

Publish lines read from os.Stdin to the given topic using the given client.

func Subscribe(ctx context.Context, client *pubsub.Client, params SubscribeParams) error

Subscribe will connect to pubsub, created a temporary subscription on the given topic and listens for message to output to Stdout.

Cancel the given context to stop.

Types ¶

type CleanParams ¶

type CleanParams struct {
	Verbosity int
	TopicID   string
}

CleanParams allows config over the Clean task.

type PipeParams ¶

type PipeParams struct {
	Verbosity  int
	InTopicID  string
	OutTopicID string
	Blocking   bool
	Count      int
	NoCleanup  bool
}

PipeParams allows config over the Pipe task.

type PublishParams ¶

type PublishParams struct {
	Verbosity  int
	TopicID    string
	Blocking   bool
	Attributes []string
}

PublishParams allows config over the Publish task.

type SubscribeParams ¶

type SubscribeParams struct {
	Verbosity      int
	TopicID        string
	SubscriptionID string
	Count          int
	NoCleanup      bool
}

SubscribeParams allows config over the Subscribe task.

Source Files ¶

View all Source files

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