huaweiapm

README

huawei-apm

a Go lib to send kpi and tracing message to huawei cloud apm

Documentation

Index

• Constants
• Variables
• func BuildTDiscoveryInfo(opts Options) (*apm.TDiscoveryInfo, error)
• func GetDiscoveryInfo() *apm.TDiscoveryInfo
• func GetLocalIP() string
• func NewAppID(project, appName string) string
• func NewRawAppID(project, appName string) string
• func NewRawResourceID(ports []string, podID string) string
• func NewResourceID(ports []string, podID string) string
• func Start(opts Options) error
• type Options
• type TracingReporter
  • func NewTracingReporter(batchInterval string, batchSize int) *TracingReporter
  • func (tr *TracingReporter) StartReportSpans()
  • func (tr *TracingReporter) WriteSpan(span *zipkincore.Span)

Constants

const (
	DefaultDiscoveryInterval    = "290s"
	DefaultTracingBatchInterval = "1m"
	DefaultTracingBatchSize     = 1000
)

const (
	AgentVersion = "2.1.0"
)

Variables

var StartInventory = make(chan bool)

var StartKPI = make(chan bool)

var StartTracing = make(chan bool)

var StopInventory = make(chan bool)

var StopKPI = make(chan bool)

var StopTracing = make(chan bool)

Switchers

Functions

func BuildTDiscoveryInfo

func BuildTDiscoveryInfo(opts Options) (*apm.TDiscoveryInfo, error)

BuildTDiscoveryInfo create a APM instance info if you report this info to cloud, APM can discovery your process should report it every 5 mins

func GetDiscoveryInfo

func GetDiscoveryInfo() *apm.TDiscoveryInfo

func GetLocalIP

func GetLocalIP() string

GetLocalIP 获得本机IP

func NewAppID

func NewAppID(project, appName string) string

func NewRawAppID

func NewRawAppID(project, appName string) string

func NewRawResourceID

func NewRawResourceID(ports []string, podID string) string

func NewResourceID

func NewResourceID(ports []string, podID string) string

NewResourceID generate unique md5 ID for a process

func Start

func Start(opts Options) error

Types

type Options

type Options struct {

	//Inventory options
	Ports           []string
	Hostname        string
	IP              string
	Project         string
	App             string
	ServiceType     string `validate:"min=1"`
	ServiceName     string `validate:"min=1"`
	MonitoringGroup string `validate:"min=1"`
}

type TracingReporter

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

func NewTracingReporter

func NewTracingReporter(batchInterval string, batchSize int) *TracingReporter

func (*TracingReporter) StartReportSpans

func (tr *TracingReporter) StartReportSpans()

func (*TracingReporter) WriteSpan

func (tr *TracingReporter) WriteSpan(span *zipkincore.Span)