hubble

Documentation

Index

• Variables
• func DisableWithHelm(ctx context.Context, k8sClient *k8s.Client, params Parameters) error
• func EnableWithHelm(ctx context.Context, k8sClient *k8s.Client, params Parameters) error
• type K8sHubble
  • func NewK8sHubble(ctx context.Context, client k8sHubbleImplementation, p Parameters) (*K8sHubble, error)
  • func (k *K8sHubble) Disable(ctx context.Context, uninstall bool) error
  • func (k *K8sHubble) Enable(ctx context.Context) error
  • func (k *K8sHubble) Log(format string, a ...interface{})
  • func (k *K8sHubble) NewClusterRole(name string) *rbacv1.ClusterRole
  • func (k *K8sHubble) NewClusterRoleBinding(crbName string) *rbacv1.ClusterRoleBinding
  • func (k *K8sHubble) NewServiceAccount(name string) *corev1.ServiceAccount
  • func (k *K8sHubble) Validate(ctx context.Context) error
• type Parameters
  • func (p *Parameters) Log(format string, a ...interface{})
  • func (p *Parameters) RelayPortForwardCommand(ctx context.Context, client k8sHubbleImplementation) error
  • func (p *Parameters) UIPortForwardCommand() error

Variables

var (
	// FlagsToHelmOpts maps the deprecated install flags to the helm
	// options
	FlagsToHelmOpts = map[string][]string{
		"relay-image":      {"hubble.relay.image.override"},
		"relay-version":    {"hubble.relay.image.tag"},
		"ui-image":         {"hubble.ui.frontend.image.override"},
		"ui-backend-image": {"hubble.ui.backend.image.override"},
		"ui-version":       {"hubble.ui.frontend.image.tag", "hubble.ui.backend.image.tag"},
	}
	// FlagValues maps all FlagsToHelmOpts keys to their values
	FlagValues = map[string]pflag.Value{}
)

Functions

func DisableWithHelm

func DisableWithHelm(ctx context.Context, k8sClient *k8s.Client, params Parameters) error

func EnableWithHelm

func EnableWithHelm(ctx context.Context, k8sClient *k8s.Client, params Parameters) error

Types

type K8sHubble

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

func NewK8sHubble

func NewK8sHubble(ctx context.Context, client k8sHubbleImplementation, p Parameters) (*K8sHubble, error)

func (*K8sHubble) Disable

func (k *K8sHubble) Disable(ctx context.Context, uninstall bool) error

func (*K8sHubble) Enable

func (k *K8sHubble) Enable(ctx context.Context) error

func (*K8sHubble) Log

func (k *K8sHubble) Log(format string, a ...interface{})

func (*K8sHubble) NewClusterRole

func (k *K8sHubble) NewClusterRole(name string) *rbacv1.ClusterRole

func (*K8sHubble) NewClusterRoleBinding

func (k *K8sHubble) NewClusterRoleBinding(crbName string) *rbacv1.ClusterRoleBinding

func (*K8sHubble) NewServiceAccount

func (k *K8sHubble) NewServiceAccount(name string) *corev1.ServiceAccount

func (*K8sHubble) Validate

func (k *K8sHubble) Validate(ctx context.Context) error

type Parameters

type Parameters struct {
	Namespace        string
	Relay            bool
	RelayImage       string
	RelayVersion     string
	RelayServiceType string
	PortForward      int
	CreateCA         bool
	UI               bool
	UIImage          string
	UIBackendImage   string
	UIVersion        string
	UIPortForward    int
	Writer           io.Writer
	Context          string // Only for 'kubectl' pass-through commands
	Wait             bool
	WaitDuration     time.Duration

	// K8sVersion is the Kubernetes version that will be used to generate the
	// kubernetes manifests. If the auto-detection fails, this flag can be used
	// as a workaround.
	K8sVersion string
	// HelmChartDirectory points to the location of a helm chart directory.
	// Useful to test from upstream where a helm release is not available yet.
	HelmChartDirectory string

	// HelmOpts are all the options the user used to pass into the Cilium cli
	// template.
	HelmOpts values.Options

	// HelmGenValuesFile points to the file that will store the generated helm
	// options.
	HelmGenValuesFile string

	// HelmValuesSecretName is the name of the secret where helm values will be
	// stored.
	HelmValuesSecretName string

	// RedactHelmCertKeys does not print helm certificate keys into the terminal.
	RedactHelmCertKeys bool

	// UIOpenBrowser will automatically open browser if true
	UIOpenBrowser bool
}

func (*Parameters) Log

func (p *Parameters) Log(format string, a ...interface{})

func (*Parameters) RelayPortForwardCommand

func (p *Parameters) RelayPortForwardCommand(ctx context.Context, client k8sHubbleImplementation) error

func (*Parameters) UIPortForwardCommand

func (p *Parameters) UIPortForwardCommand() error