goprofile

package
v1.8.8 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 27, 2024 License: Apache-2.0 Imports: 26 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Address

type Address struct {
	Host           string
	Port           int32
	InstanceLabels map[string]string
}

type GoProfile

type GoProfile struct {
	Mode            Mode
	Interval        int32 // unit second
	Timeout         int32 // unit second
	BodyLimitSize   int32 // unit KB
	EnabledProfiles []string
	Labels          map[string]string
	Config          map[string]interface{}
	// contains filtered or unexported fields
}

func (*GoProfile) Description

func (g *GoProfile) Description() string

func (*GoProfile) Init

func (g *GoProfile) Init(context pipeline.Context) (int, error)

func (*GoProfile) Start

func (g *GoProfile) Start(collector pipeline.Collector) error

func (*GoProfile) Stop

func (g *GoProfile) Stop() error

type Ingestion

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

func (*Ingestion) Ingest

func (i *Ingestion) Ingest(ctx context.Context, input *ingestion.IngestInput) error

type KubernetesConfig

type KubernetesConfig struct {
	IncludeEnv            map[string]string
	ExcludeEnv            map[string]string
	IncludeContainerLabel map[string]string
	ExcludeContainerLabel map[string]string
	IncludeK8sLabel       map[string]string
	ExcludeK8sLabel       map[string]string
	ExternalEnvTag        map[string]string
	ExternalK8sLabelTag   map[string]string
	K8sNamespaceRegex     string
	K8sPodRegex           string
	K8sContainerRegex     string
	// contains filtered or unexported fields
}

func (*KubernetesConfig) InitDiscoverer

func (k *KubernetesConfig) InitDiscoverer()

func (*KubernetesConfig) Name

func (k *KubernetesConfig) Name() string

func (*KubernetesConfig) NewDiscoverer

func (*KubernetesConfig) Run

func (k *KubernetesConfig) Run(ctx context.Context, up chan<- []*targetgroup.Group)

type Manager

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

func NewManager

func NewManager(collector pipeline.Collector) *Manager

func (*Manager) Start

func (m *Manager) Start(p *GoProfile) error

func (*Manager) Stop

func (m *Manager) Stop()

type Mode

type Mode string
const (
	HostMode       Mode = "host"
	KubernetesMode Mode = "kubernetes"
)

type Register

type Register struct {
}

func (*Register) MustRegister

func (r *Register) MustRegister(collector ...prometheus.Collector)

func (*Register) Register

func (r *Register) Register(collector prometheus.Collector) error

func (*Register) Unregister

func (r *Register) Unregister(collector prometheus.Collector) bool

type StaticConfig

type StaticConfig struct {
	Addresses []Address
	// contains filtered or unexported fields
}

func (*StaticConfig) Name

func (k *StaticConfig) Name() string

func (*StaticConfig) NewDiscoverer

func (k *StaticConfig) NewDiscoverer(options discovery.DiscovererOptions) (discovery.Discoverer, error)

Jump to

Keyboard shortcuts

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