admin

Documentation

Index

• func Consume(c *cli.Context)
• func CreateConsumerGroup(c *cli.Context, cliHelper common.CliHelper)
• func CreateDestination(c *cli.Context, cliHelper common.CliHelper)
• func DeleteConsumerGroup(c *cli.Context)
• func DeleteDestination(c *cli.Context)
• func DeleteServiceConfig(c *cli.Context)
• func GetCgState(c *cli.Context)
• func GetDestinationState(c *cli.Context)
• func GetServiceConfig(c *cli.Context)
• func HostAddr2uuid(c *cli.Context)
• func ListAllCgs(c *cli.Context)
• func ListAllDestinations(c *cli.Context)
• func ListAllLoadedDestinations(c *cli.Context)
• func ListConsumerGroupExtents(c *cli.Context)
• func ListConsumerGroups(c *cli.Context)
• func ListDestinations(c *cli.Context)
• func ListEntityOps(c *cli.Context)
• func ListExtents(c *cli.Context)
• func ListHosts(c *cli.Context)
• func Publish(c *cli.Context)
• func ReadCgAckID(c *cli.Context)
• func ReadCgBacklog(c *cli.Context)
• func ReadCgQueue(c *cli.Context)
• func ReadConsumerGroup(c *cli.Context)
• func ReadDestQueue(c *cli.Context)
• func ReadDestination(c *cli.Context)
• func ReadDlq(c *cli.Context)
• func ReadExtent(c *cli.Context)
• func ReadMessage(c *cli.Context)
• func ReadStoreHost(c *cli.Context)
• func SealConsistencyCheck(c *cli.Context)
• func SetServiceConfig(c *cli.Context)
• func StoreGetAddressFromTimestamp(c *cli.Context)
• func StoreIsExtentSealed(c *cli.Context)
• func StoreListExtents(c *cli.Context)
• func StorePurgeMessages(c *cli.Context)
• func StoreSealExtent(c *cli.Context)
• func UUID2hostAddr(c *cli.Context)
• func UnloadConsumerGroup(c *cli.Context)
• func UnloadDestination(c *cli.Context)
• func UpdateConsumerGroup(c *cli.Context)
• func UpdateDestination(c *cli.Context)

Functions

func Consume

func Consume(c *cli.Context)

Consume consumes message

func CreateConsumerGroup

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

CreateConsumerGroup creates a consumer group

func CreateDestination

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

CreateDestination creates a destination

func DeleteConsumerGroup

func DeleteConsumerGroup(c *cli.Context)

DeleteConsumerGroup deletes a consumer group

func DeleteDestination

func DeleteDestination(c *cli.Context)

DeleteDestination deletes a destination

func DeleteServiceConfig

func DeleteServiceConfig(c *cli.Context)

DeleteServiceConfig deletes the service config items matching the given criteria

func GetCgState

func GetCgState(c *cli.Context)

GetCgState gets the cg state on the given outputhost

func GetDestinationState

func GetDestinationState(c *cli.Context)

GetDestinationState gets the destination state on the given inputhost

func GetServiceConfig

func GetServiceConfig(c *cli.Context)

GetServiceConfig prints the config items matching the given input criteria.

func HostAddr2uuid

func HostAddr2uuid(c *cli.Context)

HostAddr2uuid returns the uuid based on a host port information

func ListAllCgs

func ListAllCgs(c *cli.Context)

ListAllCgs unloads the CG on the given outputhost

func ListAllDestinations

func ListAllDestinations(c *cli.Context)

ListAllDestinations lists all the destinations, user can choose deleted status too

func ListAllLoadedDestinations

func ListAllLoadedDestinations(c *cli.Context)

ListAllLoadedDestinations unloads the destination on the given inputhost

func ListConsumerGroupExtents

func ListConsumerGroupExtents(c *cli.Context)

ListConsumerGroupExtents lists all the consumer group extents

func ListConsumerGroups

func ListConsumerGroups(c *cli.Context)

ListConsumerGroups lists the consumer groups of matching names

func ListDestinations

func ListDestinations(c *cli.Context)

ListDestinations lists the destinations of matching names

func ListEntityOps

func ListEntityOps(c *cli.Context)

ListEntityOps lists all CRUD ops related with the destination

func ListExtents

func ListExtents(c *cli.Context)

ListExtents lists all the extents of a destination

func ListHosts

func ListHosts(c *cli.Context)

ListHosts lists all the hosts and roles in the current deployment

func Publish

func Publish(c *cli.Context)

Publish publishs messages

func ReadCgAckID

func ReadCgAckID(c *cli.Context)

ReadCgAckID parses cg ack id

func ReadCgBacklog

func ReadCgBacklog(c *cli.Context)

ReadCgBacklog reads cg backlog

func ReadCgQueue

func ReadCgQueue(c *cli.Context)

ReadCgQueue shows the detailed information of a cg

func ReadConsumerGroup

func ReadConsumerGroup(c *cli.Context)

ReadConsumerGroup reads properties of a consumer group

func ReadDestQueue

func ReadDestQueue(c *cli.Context)

ReadDestQueue shows the detailed information of destination queue

func ReadDestination

func ReadDestination(c *cli.Context)

ReadDestination reads a destination

func ReadDlq

func ReadDlq(c *cli.Context)

ReadDlq read Dlq properties

func ReadExtent

func ReadExtent(c *cli.Context)

ReadExtent shows the detailed information of an extent

func ReadMessage

func ReadMessage(c *cli.Context)

ReadMessage read a message from store directly

func ReadStoreHost

func ReadStoreHost(c *cli.Context)

ReadStoreHost reads the store host metadata from metastore

func SealConsistencyCheck

func SealConsistencyCheck(c *cli.Context)

SealConsistencyCheck iterates through every sealed extent for every destination and checks to see if the corresponding replicas have been sealed.

func SetServiceConfig

func SetServiceConfig(c *cli.Context)

SetServiceConfig persists the given key-value config mapping onto the config store.

func StoreGetAddressFromTimestamp

func StoreGetAddressFromTimestamp(c *cli.Context)

StoreGetAddressFromTimestamp sends a GetAddressFromTimestamp command to the specified store.

func StoreIsExtentSealed

func StoreIsExtentSealed(c *cli.Context)

StoreIsExtentSealed checks if an extent is sealed on the specified store

func StoreListExtents

func StoreListExtents(c *cli.Context)

StoreListExtents sends a list-extents request to the specified store.

func StorePurgeMessages

func StorePurgeMessages(c *cli.Context)

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

func StoreSealExtent

func StoreSealExtent(c *cli.Context)

StoreSealExtent sends a SealExtent command to the specified store.

func UUID2hostAddr

func UUID2hostAddr(c *cli.Context)

UUID2hostAddr returns the address port given a uuid

func UnloadConsumerGroup

func UnloadConsumerGroup(c *cli.Context)

UnloadConsumerGroup unloads the CG on the given outputhost

func UnloadDestination

func UnloadDestination(c *cli.Context)

UnloadDestination unloads the destination on the given inputhost

func UpdateConsumerGroup

func UpdateConsumerGroup(c *cli.Context)

UpdateConsumerGroup updates properties of a consumer group

func UpdateDestination

func UpdateDestination(c *cli.Context)

UpdateDestination updates properties of a destination