broker

Documentation

Index

• Constants
• func CreateNewBrokerAdminRole(clientset *kubernetes.Clientset) (brokerAdminRole *rbac.Role, err error)
• func CreateNewBrokerNamespace(clientset *kubernetes.Clientset) (brokernamespace *v1.Namespace, err error)
• func CreateNewBrokerRoleBinding(clientset *kubernetes.Clientset, serviceAccount, role string) (brokerRoleBinding *rbac.RoleBinding, err error)
• func CreateNewBrokerSA(clientset *kubernetes.Clientset, submarinerBrokerSA string) (brokerSA *v1.ServiceAccount, err error)
• func CreateNewClusterBrokerRole(clientset *kubernetes.Clientset) (brokerrole *rbac.Role, err error)
• func CreateSAForCluster(clientset *kubernetes.Clientset, clusterID string) (*v1.Secret, error)
• func Ensure(config *rest.Config) error
• func GetClientTokenSecret(clientSet clientset.Interface, brokerNamespace string, ...) (*v1.Secret, error)
• func NewBrokerAdminRole() *rbacv1.Role
• func NewBrokerClusterRole() *rbacv1.Role
• func NewBrokerNamespace() *v1.Namespace
• func NewBrokerRoleBinding(serviceAccount, role string) *rbacv1.RoleBinding
• func NewBrokerSA(submarinerBrokerSA string) *v1.ServiceAccount
• func TestBrokerSetup(t *testing.T)
• func WaitForClientToken(clientset *kubernetes.Clientset, submarinerBrokerSA string) (secret *v1.Secret, err error)

Constants

const (
	SubmarinerBrokerAdminSA = "submariner-k8s-broker-admin"
)

const (
	SubmarinerBrokerNamespace = "submariner-k8s-broker"
)

Functions

func CreateNewBrokerAdminRole

func CreateNewBrokerAdminRole(clientset *kubernetes.Clientset) (brokerAdminRole *rbac.Role, err error)

func CreateNewBrokerNamespace

func CreateNewBrokerNamespace(clientset *kubernetes.Clientset) (brokernamespace *v1.Namespace, err error)

func CreateNewBrokerRoleBinding

func CreateNewBrokerRoleBinding(clientset *kubernetes.Clientset, serviceAccount, role string) (brokerRoleBinding *rbac.RoleBinding, err error)

func CreateNewBrokerSA

func CreateNewBrokerSA(clientset *kubernetes.Clientset, submarinerBrokerSA string) (brokerSA *v1.ServiceAccount, err error)

func CreateNewClusterBrokerRole

func CreateNewClusterBrokerRole(clientset *kubernetes.Clientset) (brokerrole *rbac.Role, err error)

func CreateSAForCluster

func CreateSAForCluster(clientset *kubernetes.Clientset, clusterID string) (*v1.Secret, error)

CreateSAForCluster creates a new SA, and binds it to the submariner cluster role

func Ensure

func Ensure(config *rest.Config) error

func GetClientTokenSecret

func GetClientTokenSecret(clientSet clientset.Interface, brokerNamespace string, submarinerBrokerSA string) (*v1.Secret, error)

func NewBrokerAdminRole

func NewBrokerAdminRole() *rbacv1.Role

Create a role to bind to Broker SA

func NewBrokerClusterRole

func NewBrokerClusterRole() *rbacv1.Role

Create a role for each Cluster SAs to bind to

func NewBrokerNamespace

func NewBrokerNamespace() *v1.Namespace

func NewBrokerRoleBinding

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

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

func NewBrokerSA

func NewBrokerSA(submarinerBrokerSA string) *v1.ServiceAccount

func TestBrokerSetup

func TestBrokerSetup(t *testing.T)

func WaitForClientToken

func WaitForClientToken(clientset *kubernetes.Clientset, submarinerBrokerSA string) (secret *v1.Secret, err error)