broker

Documentation

Index

• Constants
• func CreateNewBrokerAdminSA(ctx context.Context, kubeClient kubernetes.Interface, inNamespace string) (err error)
• func CreateNewBrokerRoleBinding(ctx context.Context, kubeClient kubernetes.Interface, ...) (brokerRoleBinding *rbacv1.RoleBinding, err error)
• func CreateNewBrokerSA(ctx context.Context, kubeClient kubernetes.Interface, ...) (err error)
• func CreateOrUpdateBrokerAdminRole(ctx context.Context, clientset kubernetes.Interface, inNamespace string) (created bool, err error)
• func CreateOrUpdateBrokerAdminRoleBinding(ctx context.Context, kubeClient kubernetes.Interface, inNamespace string) (created bool, err error)
• func CreateOrUpdateClusterBrokerRole(ctx context.Context, kubeClient kubernetes.Interface, inNamespace string) (bool, error)
• func CreateSAForCluster(ctx context.Context, kubeClient kubernetes.Interface, ...) (*v1.Secret, error)
• func Ensure(ctx context.Context, crdUpdater crd.Updater, kubeClient kubernetes.Interface, ...) error
• func GenerateRandomPSK() ([]byte, error)
• func NewBrokerRoleBinding(serviceAccount, role, namespace string) *rbacv1.RoleBinding
• func NewBrokerSA(submarinerBrokerSA string) *v1.ServiceAccount
• func RecoverData(submCluster *cluster.Info, broker *v1alpha1.Broker, brokerNamespace string, ...) error
• func WaitForClientToken(ctx context.Context, kubeClient kubernetes.Interface, ...) (*v1.Secret, error)
• func WriteInfoToFile(restConfig *rest.Config, brokerNamespace string, ipsecPSK []byte, ...) error
• type Info
  • func ReadInfoFromFile(filename string) (*Info, error)
  • func (d *Info) GetBrokerAdministratorConfig(ctx context.Context, insecure bool) (*rest.Config, error)
  • func (d *Info) GetComponents() sets.Set[string]
  • func (d *Info) IsConnectivityEnabled() bool
  • func (d *Info) IsServiceDiscoveryEnabled() bool

Constants

const InfoFileName = "broker-info.subm"

Functions

func CreateNewBrokerAdminSA

func CreateNewBrokerAdminSA(ctx context.Context, kubeClient kubernetes.Interface, inNamespace string) (err error)

func CreateNewBrokerRoleBinding

func CreateNewBrokerRoleBinding(ctx context.Context, kubeClient kubernetes.Interface, serviceAccount, roleName, inNamespace string) (
	brokerRoleBinding *rbacv1.RoleBinding, err error,
)

func CreateNewBrokerSA

func CreateNewBrokerSA(ctx context.Context, kubeClient kubernetes.Interface, submarinerBrokerSA, inNamespace string) (err error)

func CreateOrUpdateBrokerAdminRole

func CreateOrUpdateBrokerAdminRole(ctx context.Context, clientset kubernetes.Interface, inNamespace string) (created bool, err error)

func CreateOrUpdateBrokerAdminRoleBinding

func CreateOrUpdateBrokerAdminRoleBinding(ctx context.Context, kubeClient kubernetes.Interface, inNamespace string) (
	created bool, err error,
)

func CreateOrUpdateClusterBrokerRole

func CreateOrUpdateClusterBrokerRole(ctx context.Context, kubeClient kubernetes.Interface, inNamespace string) (bool, error)

func CreateSAForCluster

func CreateSAForCluster(ctx context.Context, kubeClient kubernetes.Interface, clusterID, inNamespace string) (*v1.Secret, error)

CreateSAForCluster creates a new SA for each new cluster joined and binds it to the submariner cluster role.

func Ensure

func Ensure(ctx context.Context, crdUpdater crd.Updater, kubeClient kubernetes.Interface, componentArr []string, createCRDs bool,
	brokerNS string,
) error

func GenerateRandomPSK

func GenerateRandomPSK() ([]byte, error)

GenerateRandomPSK returns a securely generated array suitable for use as a PSK.

func NewBrokerRoleBinding

func NewBrokerRoleBinding(serviceAccount, role, namespace string) *rbacv1.RoleBinding

Create a role for to bind the cluster admin (subctl) SA.

func NewBrokerSA

func NewBrokerSA(submarinerBrokerSA string) *v1.ServiceAccount

func RecoverData

func RecoverData(submCluster *cluster.Info, broker *v1alpha1.Broker, brokerNamespace string,
	brokerRestConfig *rest.Config, status reporter.Interface,
) error

func WaitForClientToken

func WaitForClientToken(ctx context.Context, kubeClient kubernetes.Interface, submarinerBrokerSA, inNamespace string) (*v1.Secret, error)

func WriteInfoToFile

func WriteInfoToFile(restConfig *rest.Config, brokerNamespace string, ipsecPSK []byte, components sets.Set[string],
	customDomains []string, status reporter.Interface,
) error

Types

type Info

type Info struct {
	BrokerURL        string         `json:"brokerURL"`
	ClientToken      *corev1.Secret `omitempty,json:"clientToken"`
	IPSecPSK         *corev1.Secret `omitempty,json:"ipsecPSK"`
	ServiceDiscovery bool           `omitempty,json:"serviceDiscovery"`
	Components       []string       `json:",omitempty"`
	CustomDomains    *[]string      `omitempty,json:"customDomains"`
}

func ReadInfoFromFile

func ReadInfoFromFile(filename string) (*Info, error)

func (*Info) GetBrokerAdministratorConfig

func (d *Info) GetBrokerAdministratorConfig(ctx context.Context, insecure bool) (*rest.Config, error)

func (*Info) GetComponents

func (d *Info) GetComponents() sets.Set[string]

func (*Info) IsConnectivityEnabled

func (d *Info) IsConnectivityEnabled() bool

func (*Info) IsServiceDiscoveryEnabled

func (d *Info) IsServiceDiscoveryEnabled() bool