# Functions
Consume start to consume from the destination.
CreateConsumerGroup creates consumer group based on cli.Context.
CreateConsumerGroupSecure creates consumer group based on cli.Context.
CreateDestination creates destination.
CreateDestinationSecure creates destination with security enabled.
DeleteConsumerGroup deletes the consumer group.
DeleteConsumerGroupSecure deletes the consumer group with security enabled.
DeleteDestination deletes the destination.
DeleteDestinationSecure deletes the destination with security enabled.
ExitIfError exit while err is not nil and print the calling stack also.
GetCClient return a cherami.Client.
GetCClientSecure return a cherami.Client with security enabled.
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 updates the consumer group.
UpdateConsumerGroupSecure updates the consumer group with security enabled.
UpdateDestination updates destination.
UpdateDestinationSecure updates destination with security enabled.
# Constants
ConsumerGroupType is the name for entity type for consumer group in listEntityOps.
1 day.
DefaultDelayMessageSeconds is the default value for delaying message.
DefaultLockTimeoutSeconds is the default value for lock timeout seconds.
DefaultMaxDeliveryCount is the default value for max delivery count.
DefaultPageSize is the default page size for data base access for command line.
DefaultSkipOlderMessageSeconds is the default value for skipping older message.
3 days.
DestinationType is the name for entity type for destination in listEntityOps.
MaxConsumedMessagesRetention is the maximum consumed retention.
MaxDelayMessageSeconds is the maximum value for delaying message.
MaxLockTimeoutSeconds is the maximum lock timeout seconds.
MaxMaxDeliveryCount is the maximum value for max delivery count.
MaxSkipOlderMessageSeconds is the maximum value for skipping older message.
MaxUnconsumedMessagesRetention is the maximum unconsumed retention.
MinConsumedMessagesRetention is the minimum consumed retention.
MinDelayMessageSeconds is the minimum value for delaying message.
MinLockTimeoutSeconds is the minimum lock timeout seconds.
MinMaxDeliveryCount is the minimum value for max delivery count.
MinSkipOlderMessageSeconds is the minimum value for skipping older message.
MinUnconsumedMessagesRetention is the minimum unconsumed retention.
MinUnconsumedMessagesRetentionForMultiZoneDest is the minimum unconsumed retention allowed.
UnknownUUID is the suffix added to a host when the host uuid does not exist in cassandra.
# Structs
GlobalOptions are options shared by most command line.