common

package

v0.2.0 Latest Latest Go to latest Published: Feb 6, 2017 License: MIT Imports: 25 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/azylman/cherami-server

Links

Open Source Insights

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 ¶

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 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

Source Files ¶

View all Source files

lib.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL