e2eutil

Documentation

Index

• func CACertPool(coreClient kubernetes.Interface, proxy *proxyv1.Proxy) (*x509.CertPool, error)
• func CreateCluster(id string) (string, error)
• func CreateJwtToken(coreClient kubernetes.Interface, proxy *proxyv1.Proxy, id string) (string, error)
• func DeleteCluster(id string) error
• func DeployTestService(coreClient kubernetes.Interface, client clientset.Interface, ...) (*proxyv1.Backend, *proxyv1.Role, error)
• func EnsureCRD(config *rest.Config, crd []*apiextensionsv1.CustomResourceDefinition, ...) error
• func EnsureCertManager(cfg *rest.Config) error
• func EnsureExistingTestUser(rpcClient *RPCClient, id, role string) error
• func MakeId() string
• func NewRPCClient(proxy *proxyv1.Proxy, port uint16, caPool *x509.CertPool, token string) (*rpcclient.ClientWithUserToken, error)
• func PortForward(ctx context.Context, cfg *rest.Config, coreClient kubernetes.Interface, ...) (*portforward.PortForwarder, error)
• func ProxyCertPool(coreClient kubernetes.Interface, proxy *proxyv1.Proxy) (*x509.CertPool, error)
• func ReadCRDFiles(dir string) ([]*apiextensionsv1.CustomResourceDefinition, error)
• func SetupClientCert(rpcClient *RPCClient, id string) (*tls.Certificate, error)
• func StartCertManager(cfg *rest.Config, manifest string) error
• func WaitForReady(ctx context.Context, client *kubernetes.Clientset) error
• func WaitForReadyOfProxy(client clientset.Interface, p *proxyv1.Proxy, timeout time.Duration) error
• func WaitForStatusOfEtcdClusterBecome(client clientset.Interface, ec *etcdv1alpha1.EtcdCluster, ...) error
• func WaitForStatusOfProxyBecome(client clientset.Interface, p *proxyv1.Proxy, phase proxyv1.ProxyPhase, ...) error
• type RPCClient
  • func DialRPCServer(cfg *rest.Config, coreClient kubernetes.Interface, proxy *proxyv1.Proxy, ...) (*RPCClient, error)

Functions

func CACertPool

func CACertPool(coreClient kubernetes.Interface, proxy *proxyv1.Proxy) (*x509.CertPool, error)

func CreateCluster

func CreateCluster(id string) (string, error)

func CreateJwtToken

func CreateJwtToken(coreClient kubernetes.Interface, proxy *proxyv1.Proxy, id string) (string, error)

func DeleteCluster

func DeleteCluster(id string) error

func DeployTestService

func DeployTestService(coreClient kubernetes.Interface, client clientset.Interface, proxy *proxyv1.Proxy) (*proxyv1.Backend, *proxyv1.Role, error)

func EnsureCRD

func EnsureCRD(config *rest.Config, crd []*apiextensionsv1.CustomResourceDefinition, timeout time.Duration) error

func EnsureCertManager

func EnsureCertManager(cfg *rest.Config) error

func EnsureExistingTestUser

func EnsureExistingTestUser(rpcClient *RPCClient, id, role string) error

func MakeId

func MakeId() string

func NewRPCClient

func NewRPCClient(proxy *proxyv1.Proxy, port uint16, caPool *x509.CertPool, token string) (*rpcclient.ClientWithUserToken, error)

func PortForward

func PortForward(ctx context.Context, cfg *rest.Config, coreClient kubernetes.Interface, svc *corev1.Service, portName string) (*portforward.PortForwarder, error)

func ProxyCertPool

func ProxyCertPool(coreClient kubernetes.Interface, proxy *proxyv1.Proxy) (*x509.CertPool, error)

func ReadCRDFiles

func ReadCRDFiles(dir string) ([]*apiextensionsv1.CustomResourceDefinition, error)

func SetupClientCert

func SetupClientCert(rpcClient *RPCClient, id string) (*tls.Certificate, error)

func StartCertManager

func StartCertManager(cfg *rest.Config, manifest string) error

func WaitForReady

func WaitForReady(ctx context.Context, client *kubernetes.Clientset) error

func WaitForReadyOfProxy

func WaitForReadyOfProxy(client clientset.Interface, p *proxyv1.Proxy, timeout time.Duration) error

func WaitForStatusOfEtcdClusterBecome

func WaitForStatusOfEtcdClusterBecome(client clientset.Interface, ec *etcdv1alpha1.EtcdCluster, phase etcdv1alpha1.EtcdClusterPhase, timeout time.Duration) error

func WaitForStatusOfProxyBecome

func WaitForStatusOfProxyBecome(client clientset.Interface, p *proxyv1.Proxy, phase proxyv1.ProxyPhase, timeout time.Duration) error

Types

type RPCClient

type RPCClient struct {
	*rpcclient.ClientWithUserToken
	// contains filtered or unexported fields
}

func DialRPCServer

func DialRPCServer(cfg *rest.Config, coreClient kubernetes.Interface, proxy *proxyv1.Proxy, id string) (*RPCClient, error)