e2eutil

Documentation

Index

• func CACertPool(coreClient kubernetes.Interface, proxy *proxyv1alpha2.Proxy) (*x509.CertPool, error)
• func CreateJwtToken(coreClient kubernetes.Interface, proxy *proxyv1alpha2.Proxy, id string) (string, error)
• func DeployDisableAuthnTestService(coreClient kubernetes.Interface, client clientset.Interface, ...) (*proxyv1alpha2.Backend, error)
• func DeployTestService(coreClient kubernetes.Interface, client clientset.Interface, ...) (*proxyv1alpha2.Backend, error)
• func EnsureExistingTestUser(rpcClient *RPCClient, id, role string) error
• func MakeId() string
• func NewRPCClient(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 *proxyv1alpha2.Proxy) (*x509.CertPool, error)
• func SetupClientCert(rpcClient *RPCClient, id string) (*tls.Certificate, error)
• func WaitForReadyOfProxy(client clientset.Interface, p *proxyv1alpha2.Proxy, timeout time.Duration) error
• func WaitForStatusOfEtcdClusterBecome(client clientset.Interface, ec *etcdv1alpha2.EtcdCluster, ...) error
• func WaitForStatusOfProxyBecome(client clientset.Interface, p *proxyv1alpha2.Proxy, ...) error
• type EtcdClient
  • func NewEtcdClient(coreClient kubernetes.Interface, cfg *rest.Config, ...) (*EtcdClient, error)
  • func (e *EtcdClient) Close() error
• type RPCClient
  • func DialRPCServer(cfg *rest.Config, coreClient kubernetes.Interface, proxy *proxyv1alpha2.Proxy, ...) (*RPCClient, error)

Functions

func CACertPool

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

func CreateJwtToken

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

func DeployDisableAuthnTestService

func DeployDisableAuthnTestService(coreClient kubernetes.Interface, client clientset.Interface, proxy *proxyv1alpha2.Proxy, name string) (*proxyv1alpha2.Backend, error)

func DeployTestService

func DeployTestService(coreClient kubernetes.Interface, client clientset.Interface, proxy *proxyv1alpha2.Proxy, name string) (*proxyv1alpha2.Backend, error)

func EnsureExistingTestUser

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

func MakeId

func MakeId() string

func NewRPCClient

func NewRPCClient(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 *proxyv1alpha2.Proxy) (*x509.CertPool, error)

func SetupClientCert

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

func WaitForReadyOfProxy

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

func WaitForStatusOfEtcdClusterBecome

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

func WaitForStatusOfProxyBecome

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

Types

type EtcdClient

type EtcdClient struct {
	*clientv3.Client
	*portforward.PortForwarder
}

func NewEtcdClient

func NewEtcdClient(coreClient kubernetes.Interface, cfg *rest.Config, ec *etcdv1alpha2.EtcdCluster) (*EtcdClient, error)

func (*EtcdClient) Close

func (e *EtcdClient) Close() error

type RPCClient

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

func DialRPCServer

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