Documentation
¶
Index ¶
- func ConfigureTestFramework(args []string) error
- func ForBroker(submariner *v1alpha1.Submariner, serviceDisc *v1alpha1.ServiceDiscovery) (*rest.Config, string, error)
- type PerContextFn
- type Producer
- func (rcp *Producer) AddInClusterConfigFlag(cmd *cobra.Command)
- func (rcp *Producer) AddKubeConfigFlag(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) CountRequestedClusters() int
- func (rcp *Producer) ForCluster() (RestConfig, error)
- func (rcp *Producer) MustGetForClusters() []RestConfig
- func (rcp *Producer) PopulateTestFramework()
- func (rcp *Producer) RunOnSelectedContext(function PerContextFn, status reporter.Interface) error
- func (rcp *Producer) SetupFlags(flags *pflag.FlagSet)
- func (rcp *Producer) WithDefaultNamespace(defaultNamespace string) *Producer
- func (rcp *Producer) WithNamespace() *Producer
- 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 PerContextFn ¶ added in v0.14.0
type Producer ¶
type Producer struct {
// contains filtered or unexported fields
}
func NewProducer ¶
func NewProducer() *Producer
NewProducer initialises a blank producer which needs to be set up with flags (see SetupFlags).
func NewProducerFrom ¶
NewProducerFrom initialises a producer using the given kubeconfig file and context. The context may be empty, in which case the default context will be used.
func (*Producer) AddInClusterConfigFlag ¶
AddInClusterConfigFlag adds a flag enabling in-cluster configurations for processes running in pods.
func (*Producer) AddKubeConfigFlag ¶
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) CountRequestedClusters ¶
func (*Producer) ForCluster ¶
func (rcp *Producer) ForCluster() (RestConfig, error)
func (*Producer) MustGetForClusters ¶
func (rcp *Producer) MustGetForClusters() []RestConfig
func (*Producer) PopulateTestFramework ¶
func (rcp *Producer) PopulateTestFramework()
func (*Producer) RunOnSelectedContext ¶ added in v0.14.0
func (rcp *Producer) RunOnSelectedContext(function PerContextFn, status reporter.Interface) error
RunOnSelectedContext runs the given function on the selected context.
func (*Producer) SetupFlags ¶ added in v0.14.0
SetupFlags configures the given flags to control the producer settings.
func (*Producer) WithDefaultNamespace ¶ added in v0.14.0
WithDefaultNamespace configures the producer to set up a namespace flag, with the given default value. The chosen namespace will be passed to the PerContextFn used to process the context.
func (*Producer) WithNamespace ¶ added in v0.14.0
WithNamespace configures the producer to set up a namespace flag. The chosen namespace will be passed to the PerContextFn used to process the context.