Documentation ¶
Index ¶
- func Clients(config *rest.Config) (dynamic.Interface, kubernetes.Interface, error)
- func ConfigureTestFramework(args []string) error
- func ForBroker(submariner *v1alpha1.Submariner, serviceDisc *v1alpha1.ServiceDiscovery) (*rest.Config, string, error)
- type Producer
- func (rcp *Producer) AddInClusterConfigFlag(cmd *cobra.Command)
- func (rcp *Producer) AddKubeConfigFlag(cmd *cobra.Command)
- func (rcp *Producer) AddKubeContextFlag(cmd *cobra.Command)
- func (rcp *Producer) AddKubeContextMultiFlag(cmd *cobra.Command, usage string)
- func (rcp *Producer) CheckVersionMismatch(cmd *cobra.Command, args []string) error
- func (rcp *Producer) ClientConfig() clientcmd.ClientConfig
- func (rcp *Producer) ClusterNameFromContext() (*string, error)
- func (rcp *Producer) CountRequestedClusters() int
- func (rcp *Producer) ForCluster() (RestConfig, error)
- func (rcp *Producer) ForClusters() ([]RestConfig, error)
- func (rcp *Producer) GetClusterID() (string, error)
- func (rcp *Producer) MustGetForClusters() []RestConfig
- func (rcp *Producer) PopulateTestFramework()
- type RestConfig
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ConfigureTestFramework ¶
func ForBroker ¶
func ForBroker(submariner *v1alpha1.Submariner, serviceDisc *v1alpha1.ServiceDiscovery) (*rest.Config, string, error)
Types ¶
type Producer ¶
type Producer struct {
// contains filtered or unexported fields
}
func NewProducer ¶
func NewProducer() Producer
func NewProducerFrom ¶
func (*Producer) AddInClusterConfigFlag ¶
AddInClusterConfigFlag adds a flag enabling in-cluster configurations for processes running in pods.
func (*Producer) AddKubeConfigFlag ¶
func (*Producer) AddKubeContextFlag ¶
AddKubeContextFlag adds a "kubeconfig" flag and a single "kubecontext" flag that can be used once and only once.
func (*Producer) AddKubeContextMultiFlag ¶
AddKubeContextMultiFlag adds a "kubeconfig" flag and a "kubecontext" flag that can be specified multiple times (or comma separated).
func (*Producer) CheckVersionMismatch ¶
func (*Producer) ClientConfig ¶
func (rcp *Producer) ClientConfig() clientcmd.ClientConfig
ClientConfig returns a clientcmd.ClientConfig to use when communicating with K8s.
func (*Producer) ClusterNameFromContext ¶
func (*Producer) CountRequestedClusters ¶
func (*Producer) ForCluster ¶
func (rcp *Producer) ForCluster() (RestConfig, error)
func (*Producer) ForClusters ¶
func (rcp *Producer) ForClusters() ([]RestConfig, error)
func (*Producer) GetClusterID ¶
func (*Producer) MustGetForClusters ¶
func (rcp *Producer) MustGetForClusters() []RestConfig
func (*Producer) PopulateTestFramework ¶
func (rcp *Producer) PopulateTestFramework()
type RestConfig ¶
Click to show internal directories.
Click to hide internal directories.