install

func AgentContainer ¶

func AgentContainer(
	name string,
	imageName string,
	appContainer *corev1.Container,
	port corev1.ContainerPort,
	appPort int,
	managerNamespace string,
	setGID bool,
) corev1.Container

AgentContainer will return a configured traffic agent

func AgentVolume ¶

func AgentVolume() corev1.Volume

func FindMatchingPort ¶

func FindMatchingPort(cns []corev1.Container, portNameOrNumber string, svc *kates.Service) (
	sPort *kates.ServicePort,
	cn *kates.Container,
	cPortIndex int,
	err error,
)

FindMatchingPort finds the matching container associated with portNameOrNumber in the given service.

func FindMatchingService ¶

func FindMatchingService(c context.Context, client *kates.Client, portNameOrNumber, svcName, namespace string, labels map[string]string) (*kates.Service, error)

func FindMatchingServices ¶

func FindMatchingServices(c context.Context, client *kates.Client, portNameOrNumber, svcName, namespace string, labels map[string]string) ([]*kates.Service, error)

func GenerateKeys ¶

func GenerateKeys(mgrNamespace string) (crtPem, keyPem, caPem []byte, err error)

GenerateKeys creates the crt.pem, key.pem, and ca.pem needed when setting up the mutator webhook for agent auto injection

func GetPodTemplateFromObject ¶

func GetPodTemplateFromObject(obj kates.Object) (*kates.PodTemplateSpec, error)

func GetPort ¶

func GetPort(cn *corev1.Container, portName string) (*corev1.ContainerPort, error)

GetPort finds a port with the given name and returns it.

func HiddenPortName ¶

func HiddenPortName(name string, ordinal int) string

HiddenPortName prefixes the given name with "tm-" and truncates it to 15 characters. If the ordinal is greater than zero, the last two digits are reserved for the hexadecimal representation of that ordinal.

func InitContainer ¶ added in v2.4.4

func InitContainer(imageName string, port corev1.ContainerPort, appPort int) corev1.Container

InitContainer will return a configured init container for an agent.

func IsAlreadyUndone ¶ added in v2.4.0

func IsAlreadyUndone(err error) bool

IsAlreadyUndone returns whether the given error -- possibly a multierror -- indicates that all actions have been undone.

func NewAlreadyUndone ¶ added in v2.4.0

func NewAlreadyUndone(err error, msg string) error

func ObjErrorf ¶

func ObjErrorf(obj kates.Object, format string, args ...interface{}) error

func ToPEM ¶

func ToPEM(file, keyType string, data []byte) ([]byte, error)

ToPEM returns the PEM encoding of data