cluster

Documentation

Overview

Package cluster is used to configure a kubernetes cluster for testing.

Index

• type Cluster
  • func New(workingDir string) *Cluster
  • func (cluster *Cluster) GetNodePortAddr(ctx context.Context, namespace, svcName string) (hostport string, err error)
  • func (cluster *Cluster) NewHTTPClient() *http.Client
  • func (cluster *Cluster) NewHTTPClientWithTransport(transport http.RoundTripper) *http.Client
  • func (cluster *Cluster) Setup(ctx context.Context) error
• type TLSCerts
• type TLSCertsBundle

Types

type Cluster

type Cluster struct {
	Transport *http.Transport
	// contains filtered or unexported fields
}

A Cluster is used to configure a kubernetes cluster.

func New

func New(workingDir string) *Cluster

New creates a new Cluster.

func (*Cluster) GetNodePortAddr

func (cluster *Cluster) GetNodePortAddr(ctx context.Context, namespace, svcName string) (hostport string, err error)

GetNodePortAddr returns the node:port address for a NodePort kubernetes service.

func (*Cluster) NewHTTPClient

func (cluster *Cluster) NewHTTPClient() *http.Client

NewHTTPClient calls NewHTTPClientWithTransport with the default cluster transport.

func (*Cluster) NewHTTPClientWithTransport

func (cluster *Cluster) NewHTTPClientWithTransport(transport http.RoundTripper) *http.Client

NewHTTPClientWithTransport creates a new *http.Client, with a cookie jar, and a LocalRoundTripper which routes traffic to the nginx ingress controller.

func (*Cluster) Setup

func (cluster *Cluster) Setup(ctx context.Context) error

Setup configures the test cluster so that it is ready for the integration tests.

type TLSCerts

type TLSCerts struct {
	CA     []byte
	Cert   []byte
	Key    []byte
	Client struct {
		Cert []byte
		Key  []byte
	}
}

TLSCerts holds the certificate authority, certificate and certificate key for a TLS connection.

type TLSCertsBundle

type TLSCertsBundle struct {
	Trusted      TLSCerts
	WronglyNamed TLSCerts
	Untrusted    TLSCerts
}

TLSCertsBundle holds various TLSCerts.