Documentation
¶
Index ¶
- Constants
- type Kubernetes
- type Option
- func WithBaseOperatorAPI(t *testing.T, td spiffeid.TrustDomain, ns string, sentryPort int) Option
- func WithClusterDaprComponentList(t *testing.T, comps *compapi.ComponentList) Option
- func WithClusterDaprComponentListFromStore(t *testing.T, store *store.Store) Option
- func WithClusterDaprConfigurationList(t *testing.T, configs *configapi.ConfigurationList) Option
- func WithClusterDaprHTTPEndpointList(t *testing.T, endpoints *httpendapi.HTTPEndpointList) Option
- func WithClusterDaprResiliencyList(t *testing.T, res *resapi.ResiliencyList) Option
- func WithClusterDaprSubscriptionList(t *testing.T, subs *subv1api.SubscriptionList) Option
- func WithClusterDaprSubscriptionListFromStore(t *testing.T, store *store.Store) Option
- func WithClusterDaprSubscriptionListV2(t *testing.T, subs *subv2api.SubscriptionList) Option
- func WithClusterDaprSubscriptionV2ListFromStore(t *testing.T, store *store.Store) Option
- func WithClusterDeploymentList(t *testing.T, deploys *appsv1.DeploymentList) Option
- func WithClusterNamespaceList(t *testing.T, namespaces *corev1.NamespaceList) Option
- func WithClusterNamespaceListFromStore(t *testing.T, store *store.Store) Option
- func WithClusterPodList(t *testing.T, pods *corev1.PodList) Option
- func WithClusterServiceAccountList(t *testing.T, services *corev1.ServiceAccountList) Option
- func WithClusterServiceList(t *testing.T, services *corev1.ServiceList) Option
- func WithClusterStatefulSetList(t *testing.T, ss *appsv1.StatefulSetList) Option
- func WithConfigMapGet(t *testing.T, configmap *corev1.ConfigMap) Option
- func WithDaprConfigurationGet(t *testing.T, config *configapi.Configuration) Option
- func WithDaprResiliencyGet(t *testing.T, ns, name string, res *resapi.Resiliency) Option
- func WithPath(path string, handler http.HandlerFunc) Option
- func WithSecretGet(t *testing.T, secret *corev1.Secret) Option
- func WithSecretList(t *testing.T, secrets *corev1.SecretList) Option
- func WithStatefulSetGet(t *testing.T, statefulset *appsv1.StatefulSet) Option
Constants ¶
View Source
const (
EnvVarCRDDirectory = "DAPR_INTEGRATION_CRD_DIRECTORY"
)
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Kubernetes ¶
type Kubernetes struct {
// contains filtered or unexported fields
}
Kubernetes is a mock Kubernetes API server process.
func (*Kubernetes) Cleanup ¶
func (k *Kubernetes) Cleanup(t *testing.T)
func (*Kubernetes) Informer ¶ added in v1.13.0
func (k *Kubernetes) Informer() *informer.Informer
func (*Kubernetes) KubeconfigPath ¶ added in v1.13.0
func (k *Kubernetes) KubeconfigPath(t *testing.T) string
func (*Kubernetes) Port ¶
func (k *Kubernetes) Port() int
type Option ¶
type Option func(*options)
Option is a function that configures the mock Kubernetes process.
func WithBaseOperatorAPI ¶ added in v1.13.0
func WithClusterDaprComponentList ¶ added in v1.13.0
func WithClusterDaprComponentList(t *testing.T, comps *compapi.ComponentList) Option
func WithClusterDaprComponentListFromStore ¶ added in v1.13.0
func WithClusterDaprConfigurationList ¶ added in v1.13.0
func WithClusterDaprConfigurationList(t *testing.T, configs *configapi.ConfigurationList) Option
func WithClusterDaprHTTPEndpointList ¶ added in v1.13.0
func WithClusterDaprHTTPEndpointList(t *testing.T, endpoints *httpendapi.HTTPEndpointList) Option
func WithClusterDaprResiliencyList ¶ added in v1.13.0
func WithClusterDaprResiliencyList(t *testing.T, res *resapi.ResiliencyList) Option
func WithClusterDaprSubscriptionList ¶ added in v1.13.0
func WithClusterDaprSubscriptionList(t *testing.T, subs *subv1api.SubscriptionList) Option
func WithClusterDaprSubscriptionListFromStore ¶ added in v1.14.0
func WithClusterDaprSubscriptionListV2 ¶ added in v1.14.0
func WithClusterDaprSubscriptionListV2(t *testing.T, subs *subv2api.SubscriptionList) Option
func WithClusterDaprSubscriptionV2ListFromStore ¶ added in v1.14.0
func WithClusterDeploymentList ¶ added in v1.13.0
func WithClusterDeploymentList(t *testing.T, deploys *appsv1.DeploymentList) Option
func WithClusterNamespaceList ¶ added in v1.15.0
func WithClusterNamespaceList(t *testing.T, namespaces *corev1.NamespaceList) Option
func WithClusterNamespaceListFromStore ¶ added in v1.15.0
func WithClusterPodList ¶ added in v1.13.0
func WithClusterServiceAccountList ¶ added in v1.14.0
func WithClusterServiceAccountList(t *testing.T, services *corev1.ServiceAccountList) Option
func WithClusterServiceList ¶ added in v1.13.0
func WithClusterServiceList(t *testing.T, services *corev1.ServiceList) Option
func WithClusterStatefulSetList ¶ added in v1.13.0
func WithClusterStatefulSetList(t *testing.T, ss *appsv1.StatefulSetList) Option
func WithDaprConfigurationGet ¶
func WithDaprConfigurationGet(t *testing.T, config *configapi.Configuration) Option
func WithDaprResiliencyGet ¶ added in v1.13.0
func WithSecretList ¶ added in v1.13.6
func WithSecretList(t *testing.T, secrets *corev1.SecretList) Option
func WithStatefulSetGet ¶ added in v1.14.0
func WithStatefulSetGet(t *testing.T, statefulset *appsv1.StatefulSet) Option
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.