debug

Documentation

Index

• Constants
• func AfterEach(ctx context.Context)
• func BeforeEach(ctx context.Context, config *rest.Config, kubeClient client.Client)
• func PrintTestTimes(times map[string][]TimeInterval) map[string][][]string
• func WriteTimestamps(outputDir string, timestamps *TimeIntervalCollector) error
• type EventClient
  • func NewEventClient(kubeClient client.Client) *EventClient
  • func (c *EventClient) DumpEvents(ctx context.Context) error
• type Monitor
  • func New(ctx context.Context, config *rest.Config, kubeClient client.Client) *Monitor
  • func (m *Monitor) MustStart()
  • func (m *Monitor) Stop()
• type NodeClaimController
  • func NewNodeClaimController(kubeClient client.Client) *NodeClaimController
  • func (c *NodeClaimController) GetInfo(nc *v1.NodeClaim) string
  • func (c *NodeClaimController) Reconcile(ctx context.Context, req reconcile.Request) (reconcile.Result, error)
  • func (c *NodeClaimController) Register(_ context.Context, m manager.Manager) error
• type NodeController
  • func NewNodeController(kubeClient client.Client) *NodeController
  • func (c *NodeController) GetInfo(ctx context.Context, n *corev1.Node) string
  • func (c *NodeController) Reconcile(ctx context.Context, req reconcile.Request) (reconcile.Result, error)
  • func (c *NodeController) Register(ctx context.Context, m manager.Manager) error
• type PodController
  • func NewPodController(kubeClient client.Client) *PodController
  • func (c *PodController) GetInfo(p *v1.Pod) string
  • func (c *PodController) Reconcile(ctx context.Context, req reconcile.Request) (reconcile.Result, error)
  • func (c *PodController) Register(_ context.Context, m manager.Manager) error
• type TimeInterval
  • func (t TimeInterval) String() []string
• type TimeIntervalCollector
  • func NewTimestampCollector() *TimeIntervalCollector
  • func (t *TimeIntervalCollector) End(stage string)
  • func (t *TimeIntervalCollector) Finalize()
  • func (t *TimeIntervalCollector) Record(name string)
  • func (t *TimeIntervalCollector) Reset()
  • func (t *TimeIntervalCollector) Start(stage string) time.Time

Constants

const (
	StageE2E        = "E2E"
	StageBeforeEach = "BeforeEach"
	StageAfterEach  = "AfterEach"
)

const (
	NoWatch  = "NoWatch"
	NoEvents = "NoEvents"
)

Functions

func AfterEach

func AfterEach(ctx context.Context)

func BeforeEach

func BeforeEach(ctx context.Context, config *rest.Config, kubeClient client.Client)

func PrintTestTimes

func PrintTestTimes(times map[string][]TimeInterval) map[string][][]string

PrintTestTimes returns a list of tables. Each table has a list of Timestamps, where each timestamp is a list of strings.

func WriteTimestamps

func WriteTimestamps(outputDir string, timestamps *TimeIntervalCollector) error

WriteTimestamps will create a temp directory and a .csv file for each suite test If the OUTPUT_DIR environment variable is set, we'll print the csvs to that directory.

Types

type EventClient

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

func NewEventClient

func NewEventClient(kubeClient client.Client) *EventClient

func (*EventClient) DumpEvents

func (c *EventClient) DumpEvents(ctx context.Context) error

type Monitor

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

func New

func New(ctx context.Context, config *rest.Config, kubeClient client.Client) *Monitor

func (*Monitor) MustStart

func (m *Monitor) MustStart()

MustStart starts the debug monitor

func (*Monitor) Stop

func (m *Monitor) Stop()

Stop stops the monitor

type NodeClaimController

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

func NewNodeClaimController

func NewNodeClaimController(kubeClient client.Client) *NodeClaimController

func (*NodeClaimController) GetInfo

func (c *NodeClaimController) GetInfo(nc *v1.NodeClaim) string

func (*NodeClaimController) Reconcile

func (c *NodeClaimController) Reconcile(ctx context.Context, req reconcile.Request) (reconcile.Result, error)

func (*NodeClaimController) Register

func (c *NodeClaimController) Register(_ context.Context, m manager.Manager) error

type NodeController

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

func NewNodeController

func NewNodeController(kubeClient client.Client) *NodeController

func (*NodeController) GetInfo

func (c *NodeController) GetInfo(ctx context.Context, n *corev1.Node) string

func (*NodeController) Reconcile

func (c *NodeController) Reconcile(ctx context.Context, req reconcile.Request) (reconcile.Result, error)

func (*NodeController) Register

func (c *NodeController) Register(ctx context.Context, m manager.Manager) error

type PodController

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

func NewPodController

func NewPodController(kubeClient client.Client) *PodController

func (*PodController) GetInfo

func (c *PodController) GetInfo(p *v1.Pod) string

func (*PodController) Reconcile

func (c *PodController) Reconcile(ctx context.Context, req reconcile.Request) (reconcile.Result, error)

func (*PodController) Register

func (c *PodController) Register(_ context.Context, m manager.Manager) error

type TimeInterval

type TimeInterval struct {
	Start time.Time
	End   time.Time
	Stage string
}

func (TimeInterval) String

func (t TimeInterval) String() []string

type TimeIntervalCollector

type TimeIntervalCollector struct {

	// used for ordering on Collect
	Stages []string
	// contains filtered or unexported fields
}

func NewTimestampCollector

func NewTimestampCollector() *TimeIntervalCollector

func (*TimeIntervalCollector) End

func (t *TimeIntervalCollector) End(stage string)

End will mark the interval's end time. If there is no End associated with a Start, the interval's inferred End is at the start of the AfterEach.

func (*TimeIntervalCollector) Finalize

func (t *TimeIntervalCollector) Finalize()

Finalize will automatically add End time entries for Start entries without a corresponding set End. This is useful for when the test fails, since deferring time recording is tough to do.

func (*TimeIntervalCollector) Record

func (t *TimeIntervalCollector) Record(name string)

Record adds the current starts/ends/stages as a list of time intervals, and adds it to the existingTimestamps, then resets the starts/ends/stages.

func (*TimeIntervalCollector) Reset

func (t *TimeIntervalCollector) Reset()

func (*TimeIntervalCollector) Start

func (t *TimeIntervalCollector) Start(stage string) time.Time

Start will add a timestamp with the given stage and add it to the list If there is no End associated with a Start, the interval's inferred End is at the start of the AfterEach.