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)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func DeleteServiceConfig ¶
DeleteServiceConfig deletes the service config items matching the given criteria
func GetCgState ¶ added in v1.26.0
GetCgState gets the cg state on the given outputhost
func GetDestinationState ¶ added in v1.26.0
GetDestinationState gets the destination state on the given inputhost
func GetServiceConfig ¶
GetServiceConfig prints the config items matching the given input criteria.
func HostAddr2uuid ¶
HostAddr2uuid returns the uuid based on a host port information
func ListAllCgs ¶ added in v1.26.0
ListAllCgs unloads the CG on the given outputhost
func ListAllDestinations ¶
ListAllDestinations lists all the destinations, user can choose deleted status too
func ListAllLoadedDestinations ¶ added in v1.26.0
ListAllLoadedDestinations unloads the destination on the given inputhost
func ListConsumerGroupExtents ¶
ListConsumerGroupExtents lists all the consumer group extents
func ListEntityOps ¶
ListEntityOps lists all CRUD ops related with the destination
func ListExtents ¶
ListExtents lists all the extents of a destination
func ReadCgQueue ¶
ReadCgQueue shows the detailed information of a cg
func ReadDestQueue ¶
ReadDestQueue shows the detailed information of destination queue
func ReadExtent ¶
ReadExtent shows the detailed information of an extent
func ReadStoreHost ¶
ReadStoreHost reads the store host metadata from metastore
func SealConsistencyCheck ¶ added in v1.26.0
SealConsistencyCheck iterates through every sealed extent for every destination and checks to see if the corresponding replicas have been sealed.
func SetServiceConfig ¶
SetServiceConfig persists the given key-value config mapping onto the config store.
func StoreGetAddressFromTimestamp ¶ added in v1.26.0
StoreGetAddressFromTimestamp sends a GetAddressFromTimestamp command to the specified store.
func StoreIsExtentSealed ¶ added in v1.26.0
StoreIsExtentSealed checks if an extent is sealed on the specified store
func StoreListExtents ¶ added in v1.26.0
StoreListExtents sends a list-extents request to the specified store.
func StorePurgeMessages ¶ added in v1.26.0
StorePurgeMessages sends a purge command for an extent to the specified store.
func StoreSealExtent ¶ added in v1.26.0
StoreSealExtent sends a SealExtent command to the specified store.
func UUID2hostAddr ¶
UUID2hostAddr returns the address port given a uuid
func UnloadConsumerGroup ¶
UnloadConsumerGroup unloads the CG on the given outputhost
func UnloadDestination ¶ added in v1.26.0
UnloadDestination unloads the destination on the given inputhost
Types ¶
This section is empty.
Source Files