common

package
v1.28.1 Latest Latest
Warning

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

 Go to latest Published: Nov 30, 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"
	// DefaultUnconsumedMessagesRetention is the default value for unconsumed messages retention
	DefaultUnconsumedMessagesRetention = 3 * 24 * 3600 // 3 days
	// DefaultConsumedMessagesRetention is the default value for consumed messages retention
	DefaultConsumedMessagesRetention = 1 * 24 * 3600 // 1 day
	// MinUnconsumedMessagesRetentionForMultiZoneDest is the minimum unconsumed retention allowed
	MinUnconsumedMessagesRetentionForMultiZoneDest = 3 * 24 * 3600
	// MinConsumedMessagesRetention is the minimum consumed retention
	MinConsumedMessagesRetention = 180
	// MaxConsumedMessagesRetention is the maximum consumed retention
	MaxConsumedMessagesRetention = 7 * 24 * 3600
	// MinUnconsumedMessagesRetention is the minimum unconsumed retention
	MinUnconsumedMessagesRetention = 180
	// MaxUnconsumedMessagesRetention is the maximum unconsumed retention
	MaxUnconsumedMessagesRetention = 7 * 24 * 3600
	// DefaultLockTimeoutSeconds is the default value for lock timeout seconds
	DefaultLockTimeoutSeconds = 60
	// MinLockTimeoutSeconds is the minimum lock timeout seconds
	MinLockTimeoutSeconds = 10
	// MaxLockTimeoutSeconds is the maximum lock timeout seconds
	MaxLockTimeoutSeconds = 3600
	// DefaultMaxDeliveryCount is the default value for max delivery count
	DefaultMaxDeliveryCount = 10
	// MinMaxDeliveryCount is the minimum value for max delivery count
	MinMaxDeliveryCount = 1
	// MaxMaxDeliveryCount is the maximum value for max delivery count
	MaxMaxDeliveryCount = 1000
	// DefaultSkipOlderMessageSeconds is the default value for skipping older message
	DefaultSkipOlderMessageSeconds = 0
	// MinSkipOlderMessageSeconds is the minimum value for skipping older message
	MinSkipOlderMessageSeconds = 1800
	// MaxSkipOlderMessageSeconds is the maximum value for skipping older message
	MaxSkipOlderMessageSeconds = 2 * 24 * 3600
	// DefaultDelayMessageSeconds is the default value for delaying message
	DefaultDelayMessageSeconds = 0
	// MinDelayMessageSeconds is the minimum value for delaying message
	MinDelayMessageSeconds = 0
	// MaxDelayMessageSeconds is the maximum value for delaying message
	MaxDelayMessageSeconds = 2 * 24 * 3600
)

Variables

This section is empty.

Functions

func Consume 

func Consume(c *cli.Context, serviceName string)

Consume start to consume from the destination

func CreateConsumerGroup 

func CreateConsumerGroup(c *cli.Context, cliHelper common.CliHelper, serviceName string)

CreateConsumerGroup creates consumer group based on cli.Context

func CreateConsumerGroupSecure added in v1.26.0 

func CreateConsumerGroupSecure(
	c *cli.Context,
	cliHelper common.CliHelper,
	serviceName string,
	authProvider ccli.AuthProvider,
)

CreateConsumerGroupSecure creates consumer group based on cli.Context

func CreateDestination 

func CreateDestination(c *cli.Context, cliHelper common.CliHelper, serviceName string)

CreateDestination creates destination

func CreateDestinationSecure added in v1.26.0 

func CreateDestinationSecure(
	c *cli.Context,
	cliHelper common.CliHelper,
	serviceName string,
	authProvider ccli.AuthProvider,
)

CreateDestinationSecure creates destination with security enabled

func DeleteConsumerGroup 

func DeleteConsumerGroup(c *cli.Context, serviceName string)

DeleteConsumerGroup deletes the consumer group

func DeleteConsumerGroupSecure added in v1.26.0 

func DeleteConsumerGroupSecure(c *cli.Context, serviceName string, authProvider ccli.AuthProvider)

DeleteConsumerGroupSecure deletes the consumer group with security enabled

func DeleteDestination 

func DeleteDestination(c *cli.Context, serviceName string)

DeleteDestination deletes the destination

func DeleteDestinationSecure added in v1.26.0 

func DeleteDestinationSecure(c *cli.Context, serviceName string, authProvider ccli.AuthProvider)

DeleteDestinationSecure deletes the destination with security enabled

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

func GetCClientSecure(c *cli.Context, serviceName string, authProvider ccli.AuthProvider) ccli.Client

GetCClientSecure return a cherami.Client with security enabled

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, serviceName string)

ListConsumerGroups return the consumer groups based on the destination provided

func ListDestinations 

func ListDestinations(c *cli.Context, serviceName string)

ListDestinations return destinations based on the Cli.Context

func MergeDLQForConsumerGroup 

func MergeDLQForConsumerGroup(c *cli.Context, serviceName string)

MergeDLQForConsumerGroup return the consumer group information

func Publish 

func Publish(c *cli.Context, serviceName string)

Publish start to pusblish to the destination provided

func PurgeDLQForConsumerGroup 

func PurgeDLQForConsumerGroup(c *cli.Context, serviceName string)

PurgeDLQForConsumerGroup return the consumer group information

func ReadCgBacklog 

func ReadCgBacklog(c *cli.Context, serviceName string)

ReadCgBacklog reads the CG back log

func ReadConsumerGroup 

func ReadConsumerGroup(c *cli.Context, serviceName string)

ReadConsumerGroup return the consumer group information

func ReadDestination 

func ReadDestination(c *cli.Context, serviceName string)

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

func ReadDlq 

func ReadDlq(c *cli.Context, serviceName string)

ReadDlq return the info for dlq dest and related consumer group

func ReadMessage 

func ReadMessage(c *cli.Context, serviceName string)

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, cliHelper common.CliHelper, serviceName string)

UpdateConsumerGroup updates the consumer group

func UpdateConsumerGroupSecure added in v1.26.0 

func UpdateConsumerGroupSecure(
	c *cli.Context,
	cliHelper common.CliHelper,
	serviceName string,
	authProvider ccli.AuthProvider,
)

UpdateConsumerGroupSecure updates the consumer group with security enabled

func UpdateDestination 

func UpdateDestination(c *cli.Context, cliHelper common.CliHelper, serviceName string)

UpdateDestination updates destination

func UpdateDestinationSecure added in v1.26.0 

func UpdateDestinationSecure(
	c *cli.Context,
	cliHelper common.CliHelper,
	serviceName string,
	authProvider ccli.AuthProvider,
)

UpdateDestinationSecure updates destination with security enabled

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.