tests

package

v0.0.0-...-cba18c7 Latest Latest Go to latest Published: May 3, 2024 License: Apache-2.0 Imports: 12 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/DataDog/datadog-agent

Documentation ¶

Overview ¶

Package tests holds tests related files

Index ¶

func NewFakeMonoResolver() tags.Resolver
func NewFakeResolverDifferentImageNames() tags.Resolver
type FakeManualResolver
- func NewFakeManualResolver() *FakeManualResolver
type FakeMonoResolver
type FakeResolver
type TraceEvent
type TracePipe
- func NewTracePipe() (*TracePipe, error)

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func NewFakeMonoResolver ¶

func NewFakeMonoResolver() tags.Resolver

NewFakeMonoResolver returns a new tags resolver

func NewFakeResolverDifferentImageNames ¶

func NewFakeResolverDifferentImageNames() tags.Resolver

NewFakeResolverDifferentImageNames returns a new tags resolver

Types ¶

type FakeManualResolver ¶

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

FakeManualResolver represents a fake manual resolver

func NewFakeManualResolver ¶

func NewFakeManualResolver() *FakeManualResolver

NewFakeManualResolver returns a new tags resolver

func (*FakeManualResolver) GetContainerSelector ¶

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

GetContainerSelector returns the container selector

func (*FakeManualResolver) GetValue ¶

func (fmr *FakeManualResolver) GetValue(id string, tag string) string

GetValue return the tag value for the given id and tag name

func (*FakeManualResolver) Resolve ¶

func (fmr *FakeManualResolver) Resolve(containerID string) []string

Resolve returns the tags for the given id

func (*FakeManualResolver) ResolveWithErr ¶

func (fmr *FakeManualResolver) ResolveWithErr(id string) ([]string, error)

ResolveWithErr returns the tags for the given id

func (*FakeManualResolver) SpecifyNextSelector ¶

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

SpecifyNextSelector specifies the next image name and tag to be resolved

func (*FakeManualResolver) Start ¶

func (fmr *FakeManualResolver) Start(_ context.Context) error

Start the resolver

func (*FakeManualResolver) Stop ¶

func (fmr *FakeManualResolver) Stop() error

Stop the resolver

type FakeMonoResolver ¶

type FakeMonoResolver struct {
}

FakeMonoResolver represents a fake mono resolver

func (*FakeMonoResolver) GetValue ¶

func (fmr *FakeMonoResolver) GetValue(id string, tag string) string

GetValue return the tag value for the given id and tag name

func (*FakeMonoResolver) Resolve ¶

func (fmr *FakeMonoResolver) Resolve(containerID string) []string

Resolve returns the tags for the given id

func (*FakeMonoResolver) ResolveWithErr ¶

func (fmr *FakeMonoResolver) ResolveWithErr(id string) ([]string, error)

ResolveWithErr returns the tags for the given id

func (*FakeMonoResolver) Start ¶

func (fmr *FakeMonoResolver) Start(_ context.Context) error

Start the resolver

func (*FakeMonoResolver) Stop ¶

func (fmr *FakeMonoResolver) Stop() error

Stop the resolver

type FakeResolver ¶

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

FakeResolver represents a fake cache resolver

func (*FakeResolver) GetValue ¶

func (fr *FakeResolver) GetValue(id string, tag string) string

GetValue return the tag value for the given id and tag name

func (*FakeResolver) Resolve ¶

func (fr *FakeResolver) Resolve(containerID string) []string

Resolve returns the tags for the given id

func (*FakeResolver) ResolveWithErr ¶

func (fr *FakeResolver) ResolveWithErr(id string) ([]string, error)

ResolveWithErr returns the tags for the given id

func (*FakeResolver) Start ¶

func (fr *FakeResolver) Start(_ context.Context) error

Start the resolver

func (*FakeResolver) Stop ¶

func (fr *FakeResolver) Stop() error

Stop the resolver

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

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
statsdclient Package statsdclient holds statsdclient related files	Package statsdclient holds statsdclient related files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL