kubernetes

Documentation

Index

• Constants
• type Kubernetes
  • func New(t *testing.T, fopts ...Option) *Kubernetes
  • func (k *Kubernetes) Cleanup(t *testing.T)
  • func (k *Kubernetes) Informer() *informer.Informer
  • func (k *Kubernetes) KubeconfigPath(t *testing.T) string
  • func (k *Kubernetes) Port() int
  • func (k *Kubernetes) Run(t *testing.T, ctx context.Context)
• 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 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

const (
	EnvVarCRDDirectory = "DAPR_INTEGRATION_CRD_DIRECTORY"
)

Types

type Kubernetes

type Kubernetes struct {
	// contains filtered or unexported fields
}

Kubernetes is a mock Kubernetes API server process.

func New

func New(t *testing.T, fopts ...Option) *Kubernetes

func (*Kubernetes) Cleanup

func (k *Kubernetes) Cleanup(t *testing.T)

func (*Kubernetes) Informer

func (k *Kubernetes) Informer() *informer.Informer

func (*Kubernetes) KubeconfigPath

func (k *Kubernetes) KubeconfigPath(t *testing.T) string

func (*Kubernetes) Port

func (k *Kubernetes) Port() int

func (*Kubernetes) Run

func (k *Kubernetes) Run(t *testing.T, ctx context.Context)

type Option

type Option func(*options)

Option is a function that configures the mock Kubernetes process.

func WithBaseOperatorAPI

func WithBaseOperatorAPI(t *testing.T, td spiffeid.TrustDomain, ns string, sentryPort int) Option

func WithClusterDaprComponentList

func WithClusterDaprComponentList(t *testing.T, comps *compapi.ComponentList) Option

func WithClusterDaprComponentListFromStore

func WithClusterDaprComponentListFromStore(t *testing.T, store *store.Store) Option

func WithClusterDaprConfigurationList

func WithClusterDaprConfigurationList(t *testing.T, configs *configapi.ConfigurationList) Option

func WithClusterDaprHTTPEndpointList

func WithClusterDaprHTTPEndpointList(t *testing.T, endpoints *httpendapi.HTTPEndpointList) Option

func WithClusterDaprResiliencyList

func WithClusterDaprResiliencyList(t *testing.T, res *resapi.ResiliencyList) Option

func WithClusterDaprSubscriptionList

func WithClusterDaprSubscriptionList(t *testing.T, subs *subv1api.SubscriptionList) Option

func WithClusterDaprSubscriptionListFromStore

func WithClusterDaprSubscriptionListFromStore(t *testing.T, store *store.Store) Option

func WithClusterDaprSubscriptionListV2

func WithClusterDaprSubscriptionListV2(t *testing.T, subs *subv2api.SubscriptionList) Option

func WithClusterDaprSubscriptionV2ListFromStore

func WithClusterDaprSubscriptionV2ListFromStore(t *testing.T, store *store.Store) Option

func WithClusterDeploymentList

func WithClusterDeploymentList(t *testing.T, deploys *appsv1.DeploymentList) Option

func WithClusterPodList

func WithClusterPodList(t *testing.T, pods *corev1.PodList) Option

func WithClusterServiceAccountList

func WithClusterServiceAccountList(t *testing.T, services *corev1.ServiceAccountList) Option

func WithClusterServiceList

func WithClusterServiceList(t *testing.T, services *corev1.ServiceList) Option

func WithClusterStatefulSetList

func WithClusterStatefulSetList(t *testing.T, ss *appsv1.StatefulSetList) Option

func WithConfigMapGet

func WithConfigMapGet(t *testing.T, configmap *corev1.ConfigMap) Option

func WithDaprConfigurationGet

func WithDaprConfigurationGet(t *testing.T, config *configapi.Configuration) Option

func WithDaprResiliencyGet

func WithDaprResiliencyGet(t *testing.T, ns, name string, res *resapi.Resiliency) Option

func WithPath

func WithPath(path string, handler http.HandlerFunc) Option

func WithSecretGet

func WithSecretGet(t *testing.T, secret *corev1.Secret) Option

func WithSecretList

func WithSecretList(t *testing.T, secrets *corev1.SecretList) Option

func WithStatefulSetGet

func WithStatefulSetGet(t *testing.T, statefulset *appsv1.StatefulSet) Option