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 GetServiceConfig(c *cli.Context)
• func HostAddr2uuid(c *cli.Context)
• func ListAllDestinations(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 SetServiceConfig(c *cli.Context)
• func UUID2hostAddr(c *cli.Context)
• func UnloadConsumerGroup(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 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 ListAllDestinations

func ListAllDestinations(c *cli.Context)

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

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 SetServiceConfig

func SetServiceConfig(c *cli.Context)

SetServiceConfig persists the given key-value config mapping onto the config 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 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