Versions in this module Expand all Collapse all v0 v0.0.5 Mar 24, 2021 Changes in this version + const BookkeeperSts + const BrokerDeployment + const BrokerSts + const DefaultPulsarNamespace + const FunctionWorkerDeployment + const ProxyDeployment + const ZookeeperSts + func GetObjectMetaData(obj interface{}) meta_v1.ObjectMeta + type Client struct + Bookkeeper StatefulSet + Broker Deployment + BrokerSts StatefulSet + Clientset *kubernetes.Clientset + ClusterName string + DefaultNamespace string + FunctionWorker StatefulSet + Metrics *metrics.Clientset + Proxy Deployment + Status ClusterStatusCode + Zookeeper StatefulSet + func GetK8sClient(pulsarNamespace string) (*Client, error) + func (c *Client) EvalHealth() (string, ClusterStatus) + func (c *Client) GetNodeResource() + func (c *Client) UpdateReplicas(namespace string) error + func (c *Client) WatchPodResource(namespace, component string) error + func (c *Client) WatchPods(namespace string) error + type ClusterStatus struct + BookkeeperOfflineInstances int + BrokerOfflineInstances int + BrokerStsOfflineInstances int + ProxyOfflineInstances int + Status ClusterStatusCode + ZookeeperOfflineInstances int + type ClusterStatusCode int + const OK + const PartialReady + const TotalDown + type Deployment struct + Instances int32 + Name string + Replicas int32 + type StatefulSet struct + Instances int32 + Name string + Replicas int32
Go to main page