cli

package
v0.2.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Feb 6, 2017 License: MIT Imports: 3 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func Consume

func Consume(c *cli.Context)

Consume is used to consume from the given destination for the given CG

func CreateConsumerGroup

func CreateConsumerGroup(c *cli.Context, cliHelper scommon.CliHelper)

CreateConsumerGroup creates the CG

func CreateDestination

func CreateDestination(c *cli.Context, cliHelper scommon.CliHelper)

CreateDestination creates a destination

func DeleteConsumerGroup

func DeleteConsumerGroup(c *cli.Context)

DeleteConsumerGroup deletes the given CG

func DeleteDestination

func DeleteDestination(c *cli.Context)

DeleteDestination deletes the given destination

func ListConsumerGroups

func ListConsumerGroups(c *cli.Context)

ListConsumerGroups is used to list all CGs

func ListDestinations

func ListDestinations(c *cli.Context)

ListDestinations is used to list all destinations

func MergeDLQForConsumerGroup

func MergeDLQForConsumerGroup(c *cli.Context)

MergeDLQForConsumerGroup merges the DLQ for this CG

func Publish

func Publish(c *cli.Context)

Publish is used to publish to a given destination

func PurgeDLQForConsumerGroup

func PurgeDLQForConsumerGroup(c *cli.Context)

PurgeDLQForConsumerGroup purges the DLQ for this CG

func ReadCgBacklog

func ReadCgBacklog(c *cli.Context)

ReadCgBacklog reads cg backlog

func ReadConsumerGroup

func ReadConsumerGroup(c *cli.Context)

ReadConsumerGroup gets info about the CG

func ReadDestination

func ReadDestination(c *cli.Context)

ReadDestination is used to get info about the destination

func ReadDlq

func ReadDlq(c *cli.Context)

ReadDlq is used to get info about the DLQ destination

func ReadMessage

func ReadMessage(c *cli.Context)

ReadMessage is used to read a message

func UpdateConsumerGroup

func UpdateConsumerGroup(c *cli.Context)

UpdateConsumerGroup updates the CG

func UpdateDestination

func UpdateDestination(c *cli.Context)

UpdateDestination updates the destination

Types

This section is empty.

Jump to

Keyboard shortcuts

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