tests

Documentation

Overview

Package tests holds tests related files

Package tests holds tests related files

Index

• func NewFakeMonoTagger() tags.Tagger
• func NewFakeTaggerDifferentImageNames() tags.Tagger
• type FakeManualTagger
  • func NewFakeManualTagger() *FakeManualTagger
  • func (fmr *FakeManualTagger) GetContainerSelector(containerID string) *cgroupModel.WorkloadSelector
  • func (fmr *FakeManualTagger) GlobalTags(_ types.TagCardinality) ([]string, error)
  • func (fmr *FakeManualTagger) SpecifyNextSelector(selector *cgroupModel.WorkloadSelector)
  • func (fmr *FakeManualTagger) Tag(entity types.EntityID, _ types.TagCardinality) ([]string, error)
• type FakeMonoTagger
  • func (fmr *FakeMonoTagger) GlobalTags(_ types.TagCardinality) ([]string, error)
  • func (fmr *FakeMonoTagger) Tag(entity types.EntityID, _ types.TagCardinality) ([]string, error)
• type FakeTagger
  • func (fr *FakeTagger) GlobalTags(_ types.TagCardinality) ([]string, error)
  • func (fr *FakeTagger) Tag(entity types.EntityID, _ types.TagCardinality) ([]string, error)
• type TraceEvent
• type TracePipe
  • func NewTracePipe() (*TracePipe, error)
  • func (t *TracePipe) Channel() (<-chan *TraceEvent, <-chan error)
  • func (t *TracePipe) Close() error
  • func (t *TracePipe) ReadLine() (*TraceEvent, error)

Functions

func NewFakeMonoTagger

func NewFakeMonoTagger() tags.Tagger

NewFakeMonoTagger returns a new tags tagger

func NewFakeTaggerDifferentImageNames

func NewFakeTaggerDifferentImageNames() tags.Tagger

NewFakeTaggerDifferentImageNames returns a new tagger

Types

type FakeManualTagger

type FakeManualTagger struct {
	sync.Mutex
	// contains filtered or unexported fields
}

FakeManualTagger represents a fake manual tagger

func NewFakeManualTagger

func NewFakeManualTagger() *FakeManualTagger

NewFakeManualTagger returns a new tagger

func (*FakeManualTagger) GetContainerSelector

func (fmr *FakeManualTagger) GetContainerSelector(containerID string) *cgroupModel.WorkloadSelector

GetContainerSelector returns the container selector

func (*FakeManualTagger) GlobalTags

func (fmr *FakeManualTagger) GlobalTags(_ types.TagCardinality) ([]string, error)

GlobalTags returns the global tags

func (*FakeManualTagger) SpecifyNextSelector

func (fmr *FakeManualTagger) SpecifyNextSelector(selector *cgroupModel.WorkloadSelector)

SpecifyNextSelector specifies the next image name and tag to be resolved

func (*FakeManualTagger) Tag

func (fmr *FakeManualTagger) Tag(entity types.EntityID, _ types.TagCardinality) ([]string, error)

Tag returns the tags for the given id

type FakeMonoTagger

type FakeMonoTagger struct{}

FakeMonoTagger represents a fake mono tagger

func (*FakeMonoTagger) GlobalTags

func (fmr *FakeMonoTagger) GlobalTags(_ types.TagCardinality) ([]string, error)

GlobalTags returns the global tags

func (*FakeMonoTagger) Tag

func (fmr *FakeMonoTagger) Tag(entity types.EntityID, _ types.TagCardinality) ([]string, error)

Tag returns the tags for the given id

type FakeTagger

type FakeTagger struct {
	sync.Mutex
	// contains filtered or unexported fields
}

FakeTagger represents a fake tagger

func (*FakeTagger) GlobalTags

func (fr *FakeTagger) GlobalTags(_ types.TagCardinality) ([]string, error)

GlobalTags returns the global tags

func (*FakeTagger) Tag

func (fr *FakeTagger) Tag(entity types.EntityID, _ types.TagCardinality) ([]string, error)

Tag returns the tags for the given id

type TraceEvent

type TraceEvent struct {
	Raw       string
	Task      string
	PID       string
	CPU       string
	Flags     string
	Timestamp string
	Function  string
	Message   string
}

TraceEvent contains the raw event as well as the contents of every field as string, as defined under "Output format" in https://www.kernel.org/doc/Documentation/trace/ftrace.txt

type TracePipe

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

TracePipe to read from /sys/kernel/[debug/]tracing/trace_pipe Note that data can be read only once, i.e. if you have more than one tracer / channel, only one will receive an event: "Once data is read from this file, it is consumed, and will not be read again with a sequential read." https://www.kernel.org/doc/Documentation/trace/ftrace.txt

func NewTracePipe

func NewTracePipe() (*TracePipe, error)

NewTracePipe instantiates a new trace pipe

func (*TracePipe) Channel

func (t *TracePipe) Channel() (<-chan *TraceEvent, <-chan error)

Channel returns a channel of events and an other for errors

func (*TracePipe) Close

func (t *TracePipe) Close() error

Close the trace pipe

func (*TracePipe) ReadLine

func (t *TracePipe) ReadLine() (*TraceEvent, error)

ReadLine reads a line