backend

Documentation

Index

• func ConnectBrokers(kubeConfigPath string, namespace string) error
• func ConnectGateway(kubeConfigPath string, namespace string) error
• func ConnectToZeebeCluster(k8Client internal.K8Client) (zbc.Client, func(), error)
• func DisconnectBroker(kubeConfigPath string, namespace string, ...) error
• func DisconnectGateway(kubeConfigPath string, namespace string, ...) error
• type Broker
• type DisconnectBrokerCfg
• type DisconnectGatewayCfg

Functions

func ConnectBrokers

func ConnectBrokers(kubeConfigPath string, namespace string) error

func ConnectGateway

func ConnectGateway(kubeConfigPath string, namespace string) error

func ConnectToZeebeCluster

func ConnectToZeebeCluster(k8Client internal.K8Client) (zbc.Client, func(), error)

func DisconnectBroker

func DisconnectBroker(kubeConfigPath string, namespace string, disconnectBrokerCfg DisconnectBrokerCfg) error

func DisconnectGateway

func DisconnectGateway(kubeConfigPath string, namespace string, disconnectGatewayCfg DisconnectGatewayCfg) error

Types

type Broker

type Broker struct {
	NodeId      int
	PartitionId int
	Role        string
}

type DisconnectBrokerCfg

type DisconnectBrokerCfg struct {
	Broker1Cfg   Broker
	Broker2Cfg   Broker
	OneDirection bool
}

type DisconnectGatewayCfg

type DisconnectGatewayCfg struct {
	DisconnectToAll bool
	OneDirection    bool
	BrokerCfg       Broker
}