framework

Documentation

Index

• Variables
• func Flags(fs *flag.FlagSet)
• type Agent
  • func (a *Agent) Get(m *btesting.Matcher, backend *proxyv1alpha2.Backend, body io.Reader) bool
  • func (a *Agent) GetDashboard(m *btesting.Matcher) bool
• type ConfigStruct
• type EtcdCluster
  • func (c *EtcdCluster) Client(m *btesting.Matcher) *e2eutil.EtcdClient
  • func (c *EtcdCluster) Destroy(client *client.Set)
  • func (c *EtcdCluster) EqualVersion(m *btesting.Matcher, version string)
  • func (c *EtcdCluster) HaveEmptyDir(m *btesting.Matcher)
  • func (c *EtcdCluster) HavePVC(m *btesting.Matcher)
  • func (c *EtcdCluster) NumOfPods(m *btesting.Matcher, length int)
  • func (c *EtcdCluster) Ready(m *btesting.Matcher)
  • func (c *EtcdCluster) Reload()
  • func (c *EtcdCluster) Update(m *btesting.Matcher, client *client.Set, traits ...k8sfactory.Trait)
  • func (c *EtcdCluster) WaitBecome(m *btesting.Matcher, client *client.Set, status etcdv1alpha2.EtcdClusterPhase)
• type EtcdClusters
  • func (e *EtcdClusters) EtcdCluster(name string) *EtcdCluster
  • func (e *EtcdClusters) Reload(name string) error
  • func (e *EtcdClusters) Setup(m *btesting.Matcher, traits ...k8sfactory.Trait) bool
• type Framework
  • func New(t *testing.T, conf *rest.Config) *Framework
  • func (f *Framework) Client() *client.Set
  • func (f *Framework) CoreClient() *kubernetes.Clientset
  • func (f *Framework) Execute()
• type Proxy
  • func (p *Proxy) Agent(clientCert bool) *Agent
  • func (p *Proxy) Setup(m *btesting.Matcher, testUserId string) bool

Variables

var Config = &ConfigStruct{}

var EtcdClusterBase = etcd.Factory(nil,
	k8sfactory.Namespace(metav1.NamespaceDefault),
	etcd.Version("v3.4.3"),
	etcd.HighAvailability,
)

var ProxyBase = proxy.Factory(&proxyv1alpha2.Proxy{
	Spec: proxyv1alpha2.ProxySpec{
		Development: true,
		Domain:      "e2e.f110.dev",
		Replicas:    3,
		CertificateAuthority: &proxyv1alpha2.CertificateAuthoritySpec{
			Local: &proxyv1alpha2.LocalCertificateAuthoritySpec{
				Name: "e2e",
			},
		},
		BackendSelector: &proxyv1alpha2.LabelSelector{
			LabelSelector: metav1.LabelSelector{
				MatchLabels: map[string]string{"instance": "e2e"},
			},
		},
		RoleSelector: &proxyv1alpha2.LabelSelector{
			LabelSelector: metav1.LabelSelector{
				MatchLabels: map[string]string{"instance": "e2e"},
			},
		},
		IdentityProvider: proxyv1alpha2.IdentityProviderSpec{
			Provider: "google",
			ClientId: "e2e",
		},
		IssuerRef: certmanagermetav1.ObjectReference{
			Kind: "ClusterIssuer",
			Name: "self-signed",
		},
	},
}, k8sfactory.Name("e2e"), k8sfactory.Namespace(metav1.NamespaceDefault), proxy.EtcdDataStore, proxy.CookieSession)

Functions

func Flags

func Flags(fs *flag.FlagSet)

Types

type Agent

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

func (*Agent) Get

func (a *Agent) Get(m *btesting.Matcher, backend *proxyv1alpha2.Backend, body io.Reader) bool

func (*Agent) GetDashboard

func (a *Agent) GetDashboard(m *btesting.Matcher) bool

type ConfigStruct

type ConfigStruct struct {
	RandomSeed         int64
	ProxyVersion       string
	CRDDir             string
	ClusterVersion     string
	Verbose            bool
	KindFile           string
	OperatorImageFile  string
	ProxyImageFile     string
	RPCImageFile       string
	DashboardImageFile string
	SidecarImageFile   string
	BuildVersion       string
	AllInOneManifest   string
	Step               bool
	Retain             bool
}

type EtcdCluster

type EtcdCluster struct {
	*etcdv1alpha2.EtcdCluster
	// contains filtered or unexported fields
}

func (*EtcdCluster) Client

func (c *EtcdCluster) Client(m *btesting.Matcher) *e2eutil.EtcdClient

func (*EtcdCluster) Destroy

func (c *EtcdCluster) Destroy(client *client.Set)

func (*EtcdCluster) EqualVersion

func (c *EtcdCluster) EqualVersion(m *btesting.Matcher, version string)

func (*EtcdCluster) HaveEmptyDir

func (c *EtcdCluster) HaveEmptyDir(m *btesting.Matcher)

func (*EtcdCluster) HavePVC

func (c *EtcdCluster) HavePVC(m *btesting.Matcher)

func (*EtcdCluster) NumOfPods

func (c *EtcdCluster) NumOfPods(m *btesting.Matcher, length int)

func (*EtcdCluster) Ready

func (c *EtcdCluster) Ready(m *btesting.Matcher)

func (*EtcdCluster) Reload

func (c *EtcdCluster) Reload()

func (*EtcdCluster) Update

func (c *EtcdCluster) Update(m *btesting.Matcher, client *client.Set, traits ...k8sfactory.Trait)

func (*EtcdCluster) WaitBecome

func (c *EtcdCluster) WaitBecome(m *btesting.Matcher, client *client.Set, status etcdv1alpha2.EtcdClusterPhase)

type EtcdClusters

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

func (*EtcdClusters) EtcdCluster

func (e *EtcdClusters) EtcdCluster(name string) *EtcdCluster

func (*EtcdClusters) Reload

func (e *EtcdClusters) Reload(name string) error

func (*EtcdClusters) Setup

func (e *EtcdClusters) Setup(m *btesting.Matcher, traits ...k8sfactory.Trait) bool

type Framework

type Framework struct {
	*btesting.BehaviorDriven

	Proxy        *Proxy
	EtcdClusters *EtcdClusters
	// contains filtered or unexported fields
}

func New

func New(t *testing.T, conf *rest.Config) *Framework

func (*Framework) Client

func (f *Framework) Client() *client.Set

func (*Framework) CoreClient

func (f *Framework) CoreClient() *kubernetes.Clientset

func (*Framework) Execute

func (f *Framework) Execute()

type Proxy

type Proxy struct {
	Backend *proxyv1alpha2.Backend
	// contains filtered or unexported fields
}

func (*Proxy) Agent

func (p *Proxy) Agent(clientCert bool) *Agent

func (*Proxy) Setup

func (p *Proxy) Setup(m *btesting.Matcher, testUserId string) bool