admin

Documentation

Index

• 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 ListEntityOps(c *cli.Context)
• func ListExtents(c *cli.Context)
• func ListHosts(c *cli.Context)
• func ReadCgAckID(c *cli.Context)
• func ReadCgQueue(c *cli.Context)
• func ReadDestQueue(c *cli.Context)
• func ReadExtent(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)

Functions

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

func ReadCgAckID(c *cli.Context)

ReadCgAckID parses cg ack id

func ReadCgQueue

func ReadCgQueue(c *cli.Context)

ReadCgQueue shows the detailed information of a cg

func ReadDestQueue

func ReadDestQueue(c *cli.Context)

ReadDestQueue shows the detailed information of destination queue

func ReadExtent

func ReadExtent(c *cli.Context)

ReadExtent shows the detailed information of an extent

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