clickhouse

Documentation

Index

• type Client
  • func NewClient(config ClientConfig) (*Client, error)
  • func (c *Client) GetContainerLogs(ctx context.Context, from, to timeseries.Time, containers map[string][]string, ...) ([]*model.LogEntry, error)
  • func (c *Client) GetContainerLogsHistogram(ctx context.Context, from, to timeseries.Time, step timeseries.Duration, ...) (map[string]*timeseries.TimeSeries, error)
  • func (c *Client) GetInboundSpans(ctx context.Context, listens []model.Listen, ignoredContainerIds []string, ...) ([]*model.TraceSpan, error)
  • func (c *Client) GetParentSpans(ctx context.Context, spans []*model.TraceSpan) ([]*model.TraceSpan, error)
  • func (c *Client) GetProfile(ctx context.Context, from, to timeseries.Time, services []string, ...) (*model.FlameGraphNode, error)
  • func (c *Client) GetProfileTypes(ctx context.Context) (map[string][]model.ProfileType, error)
  • func (c *Client) GetServiceLogs(ctx context.Context, from, to timeseries.Time, service string, ...) ([]*model.LogEntry, error)
  • func (c *Client) GetServiceLogsHistogram(ctx context.Context, from, to timeseries.Time, step timeseries.Duration, ...) (map[string]*timeseries.TimeSeries, error)
  • func (c *Client) GetServicesFromLogs(ctx context.Context) (map[string][]string, error)
  • func (c *Client) GetServicesFromTraces(ctx context.Context) ([]string, error)
  • func (c *Client) GetSpansByServiceName(ctx context.Context, name string, ignoredPeerAddrs []string, ...) ([]*model.TraceSpan, error)
  • func (c *Client) GetSpansByTraceId(ctx context.Context, traceId string) ([]*model.TraceSpan, error)
  • func (c *Client) Ping(ctx context.Context) error
• type ClientConfig
  • func NewClientConfig(address, user, password string) ClientConfig

Types

type Client

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

func NewClient

func NewClient(config ClientConfig) (*Client, error)

func (*Client) GetContainerLogs

func (c *Client) GetContainerLogs(ctx context.Context, from, to timeseries.Time, containers map[string][]string, severities []string, hashes []string, search string, limit int) ([]*model.LogEntry, error)

func (*Client) GetContainerLogsHistogram

func (c *Client) GetContainerLogsHistogram(ctx context.Context, from, to timeseries.Time, step timeseries.Duration, containers map[string][]string, severities []string, hashes []string, search string) (map[string]*timeseries.TimeSeries, error)

func (*Client) GetInboundSpans

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

func (*Client) GetParentSpans

func (c *Client) GetParentSpans(ctx context.Context, spans []*model.TraceSpan) ([]*model.TraceSpan, error)

func (*Client) GetProfile

func (c *Client) GetProfile(ctx context.Context, from, to timeseries.Time, services []string, typ model.ProfileType, diff bool) (*model.FlameGraphNode, error)

func (*Client) GetProfileTypes

func (c *Client) GetProfileTypes(ctx context.Context) (map[string][]model.ProfileType, error)

func (*Client) GetServiceLogs

func (c *Client) GetServiceLogs(ctx context.Context, from, to timeseries.Time, service string, severities []string, search string, limit int) ([]*model.LogEntry, error)

func (*Client) GetServiceLogsHistogram

func (c *Client) GetServiceLogsHistogram(ctx context.Context, from, to timeseries.Time, step timeseries.Duration, service string, severities []string, search string) (map[string]*timeseries.TimeSeries, error)

func (*Client) GetServicesFromLogs

func (c *Client) GetServicesFromLogs(ctx context.Context) (map[string][]string, error)

func (*Client) GetServicesFromTraces

func (c *Client) GetServicesFromTraces(ctx context.Context) ([]string, error)

func (*Client) GetSpansByServiceName

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

func (*Client) GetSpansByTraceId

func (c *Client) GetSpansByTraceId(ctx context.Context, traceId string) ([]*model.TraceSpan, error)

func (*Client) Ping

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

type ClientConfig

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

func NewClientConfig

func NewClientConfig(address, user, password string) ClientConfig