Documentation ¶
Index ¶
- Constants
- func CatalogSource(t Test, name string, namespace string) func(g gomega.Gomega) (*olmV1Alpha1.CatalogSource, error)
- func ConditionReason[T conditions.GenericConditionType](conditionType T) func(any) string
- func ConditionStatus[T conditions.GenericConditionType](conditionType T) func(any) corev1.ConditionStatus
- func ControlPlane(t Test, dapr *daprApi.DaprControlPlane) func(g gomega.Gomega) (*daprApi.DaprControlPlane, error)
- func Deployment(t Test, name string, namespace string) func(g gomega.Gomega) (*appsv1.Deployment, error)
- func ExtractCatalogState() func(*olmV1Alpha1.CatalogSource) string
- func ExtractFirstLoadBalancerIngressHostname() func(*netv1.Ingress) string
- func ExtractSubscriptionInstallPlan() func(*olmV1Alpha1.Subscription) string
- func Ingress(t Test, name string, namespace string) func(g gomega.Gomega) (*netv1.Ingress, error)
- func Pod(t Test, name string, namespace string) func(g gomega.Gomega) (*corev1.Pod, error)
- func Service(t Test, name string, namespace string) func(g gomega.Gomega) (*corev1.Service, error)
- func Subscription(t Test, name string, namespace string) func(g gomega.Gomega) (*olmV1Alpha1.Subscription, error)
- type Client
- type Option
- type T
- func (t *T) Client() *Client
- func (t *T) Ctx() context.Context
- func (t *T) Forward(service string, namespace string, remotePort int) (*forwarder.Result, [][]portforward.ForwardedPort, error)
- func (t *T) GET(url string) func(g gomega.Gomega) (*http.Response, error)
- func (t *T) HTTPClient() *http.Client
- func (t *T) InstallChart(chart string, options ...helm.InstallOption)
- func (t *T) NewDaprControlPlane(spec *daprAc.DaprControlPlaneSpecApplyConfiguration) *v1alpha1.DaprControlPlane
- func (t *T) NewNamespacedNameDaprControlPlane(nn types.NamespacedName, spec *daprAc.DaprControlPlaneSpecApplyConfiguration) *v1alpha1.DaprControlPlane
- func (t *T) NewTestNamespace(options ...Option[*corev1.Namespace]) *corev1.Namespace
- func (t *T) POST(url string, contentType string, content []byte) func(g gomega.Gomega) (*http.Response, error)
- func (t *T) SetUpIngress(namespace string, path netv1.HTTPIngressPath) *netv1.Ingress
- func (t *T) T() *testing.T
- type Test
Constants ¶
Variables ¶
This section is empty.
Functions ¶
func CatalogSource ¶
func CatalogSource(t Test, name string, namespace string) func(g gomega.Gomega) (*olmV1Alpha1.CatalogSource, error)
func ConditionReason ¶
func ConditionReason[T conditions.GenericConditionType](conditionType T) func(any) string
func ConditionStatus ¶
func ConditionStatus[T conditions.GenericConditionType](conditionType T) func(any) corev1.ConditionStatus
func ControlPlane ¶
func ControlPlane(t Test, dapr *daprApi.DaprControlPlane) func(g gomega.Gomega) (*daprApi.DaprControlPlane, error)
func Deployment ¶
func ExtractCatalogState ¶
func ExtractCatalogState() func(*olmV1Alpha1.CatalogSource) string
func ExtractSubscriptionInstallPlan ¶
func ExtractSubscriptionInstallPlan() func(*olmV1Alpha1.Subscription) string
func Subscription ¶
func Subscription(t Test, name string, namespace string) func(g gomega.Gomega) (*olmV1Alpha1.Subscription, error)
Types ¶
type Client ¶
type Client struct { kubernetes.Interface Dapr daprClient.Interface Discovery discovery.DiscoveryInterface OLM olmAC.Interface Helm *helm.Helm // contains filtered or unexported fields }
type T ¶
func (*T) Forward ¶
func (t *T) Forward(service string, namespace string, remotePort int) (*forwarder.Result, [][]portforward.ForwardedPort, error)
func (*T) HTTPClient ¶ added in v0.0.4
func (*T) InstallChart ¶
func (t *T) InstallChart( chart string, options ...helm.InstallOption, )
func (*T) NewDaprControlPlane ¶
func (t *T) NewDaprControlPlane( spec *daprAc.DaprControlPlaneSpecApplyConfiguration, ) *v1alpha1.DaprControlPlane
func (*T) NewNamespacedNameDaprControlPlane ¶
func (t *T) NewNamespacedNameDaprControlPlane( nn types.NamespacedName, spec *daprAc.DaprControlPlaneSpecApplyConfiguration, ) *v1alpha1.DaprControlPlane
func (*T) NewTestNamespace ¶
func (*T) SetUpIngress ¶
type Test ¶
type Test interface { T() *testing.T Ctx() context.Context Client() *Client HTTPClient() *http.Client NewTestNamespace(...Option[*corev1.Namespace]) *corev1.Namespace NewDaprControlPlane(*daprAc.DaprControlPlaneSpecApplyConfiguration) *v1alpha1.DaprControlPlane NewNamespacedNameDaprControlPlane(types.NamespacedName, *daprAc.DaprControlPlaneSpecApplyConfiguration) *v1alpha1.DaprControlPlane InstallChart(string, ...helm.InstallOption) SetUpIngress(string, netv1.HTTPIngressPath) *netv1.Ingress Forward(string, string, int) (*forwarder.Result, [][]portforward.ForwardedPort, error) GET(string) func(g gomega.Gomega) (*http.Response, error) POST(string, string, []byte) func(g gomega.Gomega) (*http.Response, error) gomega.Gomega }
Source Files ¶
Click to show internal directories.
Click to hide internal directories.