goprofile

Documentation

Index

• type Address
• type GoProfile
  • func (g *GoProfile) Description() string
  • func (g *GoProfile) Init(context pipeline.Context) (int, error)
  • func (g *GoProfile) Start(collector pipeline.Collector) error
  • func (g *GoProfile) Stop() error
• type Ingestion
  • func (i *Ingestion) Ingest(ctx context.Context, input *ingestion.IngestInput) error
• type KubernetesConfig
  • func (k *KubernetesConfig) InitDiscoverer()
  • func (k *KubernetesConfig) Name() string
  • func (k *KubernetesConfig) NewDiscoverer(options discovery.DiscovererOptions) (discovery.Discoverer, error)
  • func (k *KubernetesConfig) Run(ctx context.Context, up chan<- []*targetgroup.Group)
• type Manager
  • func NewManager(collector pipeline.Collector) *Manager
  • func (m *Manager) Start(p *GoProfile) error
  • func (m *Manager) Stop()
• type Mode
• type Register
  • func (r *Register) MustRegister(collector ...prometheus.Collector)
  • func (r *Register) Register(collector prometheus.Collector) error
  • func (r *Register) Unregister(collector prometheus.Collector) bool
• type StaticConfig
  • func (k *StaticConfig) Name() string
  • func (k *StaticConfig) NewDiscoverer(options discovery.DiscovererOptions) (discovery.Discoverer, error)

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 (k *KubernetesConfig) NewDiscoverer(options discovery.DiscovererOptions) (discovery.Discoverer, error)

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)