zipkin

package

v1.6.0 Latest Latest Go to latest Published: Aug 17, 2023 License: Apache-2.0 Imports: 24 Imported by: 3

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/mosn/mosn

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
Variables
func HttpReporterBuilder(cfg ZipkinTraceConfig) (reporter.Reporter, error)
func KafkaReporterBuilder(cfg ZipkinTraceConfig) (reporter.Reporter, error)
func NewHttpTracer(config map[string]interface{}) (api.Tracer, error)
func NewZipkinDriverImpl() *zipkinDriver
func ParseHostPort(hostPort string) (string, uint16, error)
type HttpReportConfig
type KafkaReportConfig
type ReporterBuilder
- func GetReportBuilder(typ string) (ReporterBuilder, bool)
type SpanTag
- func (s SpanTag) String() string
type ZipkinTraceConfig
- func (z *ZipkinTraceConfig) ValidateZipkinConfig() (bool, error)

Constants ¶

View Source

const (
	ZipkinKafkaReport string = "kafka"
	ZipkinHttpReport  string = "http"
)

View Source

const (
	NoopSpanTraceID  = "-1"
	NoopSpanID       = "0"
	NoopSpanParentID = "-1"
)

View Source

const (
	DriverName = "Zipkin"
)

Variables ¶

View Source

var NoopSpan = noopSpan{}

Functions ¶

func HttpReporterBuilder ¶

func HttpReporterBuilder(cfg ZipkinTraceConfig) (reporter.Reporter, error)

func KafkaReporterBuilder ¶

func KafkaReporterBuilder(cfg ZipkinTraceConfig) (reporter.Reporter, error)

func NewHttpTracer ¶

func NewHttpTracer(config map[string]interface{}) (api.Tracer, error)

func NewZipkinDriverImpl ¶

func NewZipkinDriverImpl() *zipkinDriver

func ParseHostPort ¶

func ParseHostPort(hostPort string) (string, uint16, error)

ParseHostPort parse ip, port from string host

Types ¶

type HttpReportConfig ¶

type HttpReportConfig struct {
	Timeout       int `json:"timeout"`
	BatchSize     int `json:"batch_size"`
	BatchInterval int `json:"batch_interval"`
}

type KafkaReportConfig ¶

type KafkaReportConfig struct {
	Topic string `json:"topic"`
}

type ReporterBuilder ¶

type ReporterBuilder func(ZipkinTraceConfig) (reporter.Reporter, error)

func GetReportBuilder ¶

func GetReportBuilder(typ string) (ReporterBuilder, bool)

type SpanTag ¶

type SpanTag uint64

const (
	ServiceName SpanTag = iota
	MethodName
	PROTOCOL
	ResultStatus
	RequestSize
	ResponseSize
	DownsteamHostAddress
	UpstreamHostAddress
	CallerAppName //caller
	CalleeAppName //remote app
)

func (SpanTag) String ¶

func (s SpanTag) String() string

type ZipkinTraceConfig ¶

type ZipkinTraceConfig struct {
	ServiceName string             `json:"service_name"`
	Reporter    string             `json:"reporter"`
	SampleRate  float64            `json:"sample_rate"`
	Addresses   []string           `json:"addresses"`
	HttpConfig  *HttpReportConfig  `json:"http"`
	KafkaConfig *KafkaReportConfig `json:"kafka"`
}

func (*ZipkinTraceConfig) ValidateZipkinConfig ¶

func (z *ZipkinTraceConfig) ValidateZipkinConfig() (bool, error)

Source Files ¶

View all Source files

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