cli

Documentation

Index

• func Consume(c *cli.Context)
• func CreateConsumerGroup(c *cli.Context, cliHelper scommon.CliHelper)
• func CreateConsumerGroupSecure(c *cli.Context, cliHelper scommon.CliHelper, ...)
• func CreateDestination(c *cli.Context, cliHelper scommon.CliHelper)
• func CreateDestinationSecure(c *cli.Context, cliHelper scommon.CliHelper, ...)
• func DeleteConsumerGroup(c *cli.Context)
• func DeleteConsumerGroupSecure(c *cli.Context, authProvider cherami2.AuthProvider)
• func DeleteDestination(c *cli.Context)
• func DeleteDestinationSecure(c *cli.Context, authProvider cherami2.AuthProvider)
• func ListConsumerGroups(c *cli.Context)
• func ListDestinations(c *cli.Context)
• func MergeDLQForConsumerGroup(c *cli.Context)
• func Publish(c *cli.Context)
• func PurgeDLQForConsumerGroup(c *cli.Context)
• func ReadCgBacklog(c *cli.Context)
• func ReadConsumerGroup(c *cli.Context)
• func ReadDestination(c *cli.Context)
• func ReadDlq(c *cli.Context)
• func ReadMessage(c *cli.Context)
• func UpdateConsumerGroup(c *cli.Context, cliHelper scommon.CliHelper)
• func UpdateConsumerGroupSecure(c *cli.Context, cliHelper scommon.CliHelper, ...)
• func UpdateDestination(c *cli.Context, cliHelper scommon.CliHelper)
• func UpdateDestinationSecure(c *cli.Context, cliHelper scommon.CliHelper, ...)

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 CreateConsumerGroupSecure

func CreateConsumerGroupSecure(c *cli.Context, cliHelper scommon.CliHelper, authProvider cherami2.AuthProvider)

CreateConsumerGroupSecure creates the CG with security enabled

func CreateDestination

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

CreateDestination creates a destination

func CreateDestinationSecure

func CreateDestinationSecure(c *cli.Context, cliHelper scommon.CliHelper, authProvider cherami2.AuthProvider)

CreateDestinationSecure creates a destination with security enabled

func DeleteConsumerGroup

func DeleteConsumerGroup(c *cli.Context)

DeleteConsumerGroup deletes the given CG

func DeleteConsumerGroupSecure

func DeleteConsumerGroupSecure(c *cli.Context, authProvider cherami2.AuthProvider)

DeleteConsumerGroupSecure deletes the given CG with security enabled

func DeleteDestination

func DeleteDestination(c *cli.Context)

DeleteDestination deletes the given destination

func DeleteDestinationSecure

func DeleteDestinationSecure(c *cli.Context, authProvider cherami2.AuthProvider)

DeleteDestinationSecure deletes the given destination with security enabled

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, cliHelper scommon.CliHelper)

UpdateConsumerGroup updates the CG

func UpdateConsumerGroupSecure

func UpdateConsumerGroupSecure(c *cli.Context, cliHelper scommon.CliHelper, authProvider cherami2.AuthProvider)

UpdateConsumerGroupSecure updates the CG with security enabled

func UpdateDestination

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

UpdateDestination updates the destination

func UpdateDestinationSecure

func UpdateDestinationSecure(c *cli.Context, cliHelper scommon.CliHelper, authProvider cherami2.AuthProvider)

UpdateDestinationSecure updates the destination with security enabled