tracing

Documentation

Index

• Constants
• type ClickhouseClient
  • func NewClickhouseClient(config ClickhouseClientConfig) (*ClickhouseClient, error)
  • func (c *ClickhouseClient) GetInboundSpans(ctx context.Context, listens []model.Listen, ignoredContainerIds []string, ...) ([]*Span, error)
  • func (c *ClickhouseClient) GetParentSpans(ctx context.Context, spans []*Span) ([]*Span, error)
  • func (c *ClickhouseClient) GetServiceNames(ctx context.Context) ([]string, error)
  • func (c *ClickhouseClient) GetSpansByServiceName(ctx context.Context, name string, ignoredPeerAddrs []string, ...) ([]*Span, error)
  • func (c *ClickhouseClient) GetSpansByTraceId(ctx context.Context, traceId string) ([]*Span, error)
  • func (c *ClickhouseClient) Ping(ctx context.Context) error
• type ClickhouseClientConfig
  • func NewClickhouseClientConfig(address, user, password string) ClickhouseClientConfig
• type Event
• type Span
• type Type

Constants

const (
	TypeOtel     = "otel"
	TypeOtelEbpf = "otel_ebpf"
)

Types

type ClickhouseClient

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

func NewClickhouseClient

func NewClickhouseClient(config ClickhouseClientConfig) (*ClickhouseClient, error)

func (*ClickhouseClient) GetInboundSpans

func (c *ClickhouseClient) GetInboundSpans(ctx context.Context, listens []model.Listen, ignoredContainerIds []string, tsFrom, tsTo timeseries.Time, durFrom, durTo time.Duration, errors bool, limit int) ([]*Span, error)

func (*ClickhouseClient) GetParentSpans

func (c *ClickhouseClient) GetParentSpans(ctx context.Context, spans []*Span) ([]*Span, error)

func (*ClickhouseClient) GetServiceNames

func (c *ClickhouseClient) GetServiceNames(ctx context.Context) ([]string, error)

func (*ClickhouseClient) GetSpansByServiceName

func (c *ClickhouseClient) GetSpansByServiceName(ctx context.Context, name string, ignoredPeerAddrs []string, tsFrom, tsTo timeseries.Time, durFrom, durTo time.Duration, errors bool, limit int) ([]*Span, error)

func (*ClickhouseClient) GetSpansByTraceId

func (c *ClickhouseClient) GetSpansByTraceId(ctx context.Context, traceId string) ([]*Span, error)

func (*ClickhouseClient) Ping

func (c *ClickhouseClient) Ping(ctx context.Context) error

type ClickhouseClientConfig

type ClickhouseClientConfig struct {
	Protocol      string
	Address       string
	TlsEnable     bool
	TlsSkipVerify bool
	User          string
	Password      string
	Database      string
	TracesTable   string
	DialContext   func(ctx context.Context, addr string) (net.Conn, error)
}

func NewClickhouseClientConfig

func NewClickhouseClientConfig(address, user, password string) ClickhouseClientConfig

type Event

type Event struct {
	Timestamp  time.Time
	Name       string
	Attributes map[string]string
}

type Span

type Span struct {
	Timestamp     time.Time
	Name          string
	TraceId       string
	SpanId        string
	ParentSpanId  string
	ServiceName   string
	Duration      time.Duration
	StatusCode    string
	StatusMessage string
	Attributes    map[string]string
	Events        []Event
}

type Type

type Type string