common

package
v1.19.0-rc1 Latest Latest
Warning

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

 Go to latest Published: Apr 19, 2017 License: MIT Imports: 27 Imported by: 24

Documentation

Index

Constants

View Source 
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
)

Variables

This section is empty.

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 GetConsumerGroupState added in v1.26.0 

func GetConsumerGroupState(c *cli.Context)

GetConsumerGroupState unloads the CG based on cli.Context

func GetDestinationState added in v1.26.0 

func GetDestinationState(c *cli.Context)

GetDestinationState unloads the Destination based on cli.Context

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 ListAllConsumerGroups added in v1.26.0 

func ListAllConsumerGroups(c *cli.Context)

ListAllConsumerGroups lists all loaded CGs in memory of the outputhost

func ListAllLoadedDestinations added in v1.26.0 

func ListAllLoadedDestinations(c *cli.Context)

ListAllLoadedDestinations lists all loaded Destinations in memory of the inputhost

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 SealConsistencyCheck added in v1.26.0 

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

SealConsistencyCheck implement for show msg command line

func StoreGetAddressFromTimestamp added in v1.26.0 

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

StoreGetAddressFromTimestamp sends a GetAddressFromTimestamp request to the specified store

func StoreIsExtentSealed added in v1.26.0 

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

StoreIsExtentSealed checks if an extent is sealed on the specified store

func StoreListExtents added in v1.26.0 

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

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

func StorePurgeMessages added in v1.26.0 

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

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

func StoreSealExtent added in v1.26.0 

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

StoreSealExtent sends a SealExtent request for an extent on a storehost

func UnloadConsumerGroup 

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

UnloadConsumerGroup unloads the CG based on cli.Context

func UnloadDestination added in v1.26.0 

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

UnloadDestination unloads the Destination 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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.