Consume start to consume from the destination.

CreateConsumerGroup create consumer group based on cli.Context.

CreateDestination create destination.

DeleteConsumerGroup delete the consumer group based on Cli.Context.

DeleteDestination delete the destination based on Cli.Context.

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

GetCClient return a cherami.Client.

GetConsumerGroupState unloads the CG based on cli.Context.

GetDestinationState unloads the Destination based on cli.Context.

GetMClient return a metadata.Client.

Jsonify return the json string based on the obj.

ListAllConsumerGroups lists all loaded CGs in memory of the outputhost.

ListAllLoadedDestinations lists all loaded Destinations in memory of the inputhost.

ListConsumerGroups return the consumer groups based on the destination provided.

ListDestinations return destinations based on the Cli.Context.

MergeDLQForConsumerGroup return the consumer group information.

Publish start to pusblish to the destination provided.

PurgeDLQForConsumerGroup return the consumer group information.

ReadCgBacklog reads the CG back log.

ReadConsumerGroup return the consumer group information.

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

ReadDlq return the info for dlq dest and related consumer group.

ReadMessage implement for show msg command line.

SealConsistencyCheck implement for show msg command line.

StoreGetAddressFromTimestamp sends a GetAddressFromTimestamp request to the specified store.

StoreIsExtentSealed checks if an extent is sealed on the specified store.

StoreListExtents sends a request to the specified store to get a list of extents.

StorePurgeMessages sends a purge command for an extent to the specified store.

StoreSealExtent sends a SealExtent request for an extent on a storehost.

UnloadConsumerGroup unloads the CG based on cli.Context.

UnloadDestination unloads the Destination based on cli.Context.

UpdateConsumerGroup update the consumer group based on cli.Context.

UpdateDestination update destination based on cli.

ConsumerGroupType is the name for entity type for consumer group in listEntityOps.

DefaultPageSize is the default page size for data base access for command line.

DestinationType is the name for entity type for destination in listEntityOps.

MinUnconsumedMessagesRetentionForMultiZoneDest is the minimum unconsumed retention allowed.

UnknownUUID is the suffix added to a host when the host uuid does not exist in cassandra.

GlobalOptions are options shared by most command line.