common

Documentation

Index

• Constants
• func Consume(c *cli.Context, cClient ccli.Client)
• func CreateConsumerGroup(c *cli.Context, cClient ccli.Client, cliHelper common.CliHelper)
• func CreateDestination(c *cli.Context, cClient ccli.Client, cliHelper common.CliHelper)
• func DeleteConsumerGroup(c *cli.Context, cClient ccli.Client)
• func DeleteDestination(c *cli.Context, cClient ccli.Client)
• func ExitIfError(err error)
• func GetCClient(c *cli.Context, serviceName string) ccli.Client
• func GetMClient(c *cli.Context, serviceName string) mcli.Client
• func Jsonify(obj thrift.TStruct) string
• func ListConsumerGroups(c *cli.Context, cClient ccli.Client)
• func ListDestinations(c *cli.Context, mClient mcli.Client)
• func MergeDLQForConsumerGroup(c *cli.Context, cClient ccli.Client)
• func Publish(c *cli.Context, cClient ccli.Client)
• func PurgeDLQForConsumerGroup(c *cli.Context, cClient ccli.Client)
• func ReadCgBacklog(c *cli.Context, cClient ccli.Client)
• func ReadConsumerGroup(c *cli.Context, mClient mcli.Client)
• func ReadDestination(c *cli.Context, mClient mcli.Client)
• func ReadDlq(c *cli.Context, mClient mcli.Client)
• func ReadMessage(c *cli.Context, mClient mcli.Client)
• func UnloadConsumerGroup(c *cli.Context, mClient mcli.Client)
• func UpdateConsumerGroup(c *cli.Context, cClient ccli.Client)
• func UpdateDestination(c *cli.Context, cClient ccli.Client, mClient mcli.Client)
• type GlobalOptions

Constants

const (
	// DefaultPageSize is the default page size for data base access for command line
	DefaultPageSize = 1000

	// UnknownUUID is the suffix added to a host when the host uuid does not exist in cassandra
	UnknownUUID = " UNKNOWN_HOST_UUID"
	// DestinationType is the name for entity type for destination in listEntityOps
	DestinationType = "DST"
	// ConsumerGroupType is the name for entity type for consumer group in listEntityOps
	ConsumerGroupType = "CG"
	// MinUnconsumedMessagesRetentionForMultiZoneDest is the minimum unconsumed retention allowed
	MinUnconsumedMessagesRetentionForMultiZoneDest = 3 * 24 * 3600
)

Functions

func Consume

func Consume(c *cli.Context, cClient ccli.Client)

Consume start to consume from the destination

func CreateConsumerGroup

func CreateConsumerGroup(c *cli.Context, cClient ccli.Client, cliHelper common.CliHelper)

CreateConsumerGroup create consumer group based on cli.Context

func CreateDestination

func CreateDestination(c *cli.Context, cClient ccli.Client, cliHelper common.CliHelper)

CreateDestination create destination

func DeleteConsumerGroup

func DeleteConsumerGroup(c *cli.Context, cClient ccli.Client)

DeleteConsumerGroup delete the consumer group based on Cli.Context

func DeleteDestination

func DeleteDestination(c *cli.Context, cClient ccli.Client)

DeleteDestination delete the destination based on Cli.Context

func ExitIfError

func ExitIfError(err error)

ExitIfError exit while err is not nil and print the calling stack also

func GetCClient

func GetCClient(c *cli.Context, serviceName string) ccli.Client

GetCClient return a cherami.Client

func GetMClient

func GetMClient(c *cli.Context, serviceName string) mcli.Client

GetMClient return a metadata.Client

func Jsonify

func Jsonify(obj thrift.TStruct) string

Jsonify return the json string based on the obj

func ListConsumerGroups

func ListConsumerGroups(c *cli.Context, cClient ccli.Client)

ListConsumerGroups return the consumer groups based on the destination provided

func ListDestinations

func ListDestinations(c *cli.Context, mClient mcli.Client)

ListDestinations return destinations based on the Cli.Context

func MergeDLQForConsumerGroup

func MergeDLQForConsumerGroup(c *cli.Context, cClient ccli.Client)

MergeDLQForConsumerGroup return the consumer group information

func Publish

func Publish(c *cli.Context, cClient ccli.Client)

Publish start to pusblish to the destination provided

func PurgeDLQForConsumerGroup

func PurgeDLQForConsumerGroup(c *cli.Context, cClient ccli.Client)

PurgeDLQForConsumerGroup return the consumer group information

func ReadCgBacklog

func ReadCgBacklog(c *cli.Context, cClient ccli.Client)

ReadCgBacklog reads the CG back log

func ReadConsumerGroup

func ReadConsumerGroup(c *cli.Context, mClient mcli.Client)

ReadConsumerGroup return the consumer group information

func ReadDestination

func ReadDestination(c *cli.Context, mClient mcli.Client)

ReadDestination return the detail for dest, and also consumer group for this dest

func ReadDlq

func ReadDlq(c *cli.Context, mClient mcli.Client)

ReadDlq return the info for dlq dest and related consumer group

func ReadMessage

func ReadMessage(c *cli.Context, mClient mcli.Client)

ReadMessage implement for show msg command line

func UnloadConsumerGroup

func UnloadConsumerGroup(c *cli.Context, mClient mcli.Client)

UnloadConsumerGroup unloads the CG based on cli.Context

func UpdateConsumerGroup

func UpdateConsumerGroup(c *cli.Context, cClient ccli.Client)

UpdateConsumerGroup update the consumer group based on cli.Context

func UpdateDestination

func UpdateDestination(c *cli.Context, cClient ccli.Client, mClient mcli.Client)

UpdateDestination update destination based on cli

Types

type GlobalOptions

type GlobalOptions struct {
	// contains filtered or unexported fields
}

GlobalOptions are options shared by most command line