Versions in this module Expand all Collapse all v1 v1.1.0 Jun 30, 2020 v1.0.0 Oct 25, 2019 Changes in this version + const BrokerLabelKey + const BrokerLabelValue + const NamespacedBrokerName + type ClusterFacade struct + func NewClusterBrokersFacade(client client.Client, workingNamespace, serviceName, clusterBrokerName string, ...) *ClusterFacade + func (f *ClusterFacade) Create() error + func (f *ClusterFacade) Delete() error + func (f *ClusterFacade) Exist() (bool, error) + func (f *ClusterFacade) SetNamespace(namespace string) + type ClusterSyncer struct + func NewClusterBrokerSyncer(cli client.Client, clusterBrokerName string, log logrus.FieldLogger) *ClusterSyncer + func (r *ClusterSyncer) SetNamespace(namespace string) + func (r *ClusterSyncer) Sync() error + type Facade struct + func NewBrokersFacade(cli client.Client, systemNamespace, serviceName string, log logrus.FieldLogger) *Facade + func (f *Facade) Create() error + func (f *Facade) Delete() error + func (f *Facade) Exist() (bool, error) + func (f *Facade) SetNamespace(namespace string) + type Syncer struct + func NewBrokerSyncer(cli client.Client, log logrus.FieldLogger) *Syncer + func (r *Syncer) SetNamespace(namespace string) + func (r *Syncer) Sync() error