pulsar

Documentation

Index

• func DeployBookie(bookie map[string]interface{}, version, zkAddrList, logKey, magicKey string, ...) bool
• func DeployPulsar(pulsar map[string]interface{}, ...) bool
• func DeployPulsarManager(pulsarManager map[string]interface{}, ...) bool
• func DeployPulsarPrometheus(prometheus map[string]interface{}, ...) bool
• func GetPulsarBookieListForPrometheus(bookieArr []map[string]interface{}) string
• func GetPulsarBrokerList(pulsarArr []map[string]interface{}, instID string) string
• func GetPulsarBrokerListForPrometheus(pulsarArr []map[string]interface{}) string
• func GetPulsarZKListForPrometheus(zkArr []map[string]interface{}) string
• func UndeployBookie(bookie map[string]interface{}, version, logKey, magicKey string, ...) bool
• func UndeployPulsar(pulsar map[string]interface{}, ...) bool
• func UndeployPulsarManager(pulsarManager map[string]interface{}, version, logKey, magicKey string, ...) bool

Functions

func DeployBookie

func DeployBookie(bookie map[string]interface{}, version, zkAddrList, logKey, magicKey string, initMeta bool,
	paasResult *result.ResultBean) bool

func DeployPulsar

func DeployPulsar(pulsar map[string]interface{}, pulsarClusterName, brokerAddrList, version, zkAddrList, logKey, magicKey string,
	initMeta bool, paasResult *result.ResultBean) bool

func DeployPulsarManager

func DeployPulsarManager(pulsarManager map[string]interface{}, bookies, version, logKey, magicKey string,
	paasResult *result.ResultBean) bool

func DeployPulsarPrometheus

func DeployPulsarPrometheus(prometheus map[string]interface{}, pulsarClusterName, brokers, bookies, zks, version, logKey, magicKey string,
	paasResult *result.ResultBean) bool

func GetPulsarBookieListForPrometheus

func GetPulsarBookieListForPrometheus(bookieArr []map[string]interface{}) string

func GetPulsarBrokerList

func GetPulsarBrokerList(pulsarArr []map[string]interface{}, instID string) string

func GetPulsarBrokerListForPrometheus

func GetPulsarBrokerListForPrometheus(pulsarArr []map[string]interface{}) string

func GetPulsarZKListForPrometheus

func GetPulsarZKListForPrometheus(zkArr []map[string]interface{}) string

func UndeployBookie

func UndeployBookie(bookie map[string]interface{}, version, logKey, magicKey string,
	paasResult *result.ResultBean) bool

func UndeployPulsar

func UndeployPulsar(pulsar map[string]interface{}, pulsarClusterName, brokerAddrList, version, logKey, magicKey string,
	paasResult *result.ResultBean) bool

func UndeployPulsarManager

func UndeployPulsarManager(pulsarManager map[string]interface{}, version, logKey, magicKey string,
	paasResult *result.ResultBean) bool