store

Documentation

Index

• Constants
• Variables
• func NewLogger(pc *PluginConfig) hclog.Logger
• func NewStore(pc *PluginConfig, kc *KustoConfig, logger hclog.Logger) (shared.StoragePlugin, error)
• func TransformSpanToStringArray(span *model.Span) ([]string, error)
• type KustoConfig
  • func ParseKustoConfig(path string) (*KustoConfig, error)
• type PluginConfig
  • func NewDefaultPluginConfig() *PluginConfig
  • func ParseConfig(path string) (*PluginConfig, error)
• type PluginTracer
  • func NewPluginTracer(pc *PluginConfig) (*PluginTracer, error)
  • func (pt *PluginTracer) Close() error
  • func (pt *PluginTracer) EnableGlobalTracer()
  • func (pt *PluginTracer) Tracer() opentracing.Tracer

Constants

const (
	ServiceName = "jaeger-kusto"
)

const (
	//TagDotReplacementCharacter state which character should replace the dot in dynamic column
	TagDotReplacementCharacter = "_"
)

Variables

var (
	// ErrServiceNameNotSet occurs when attempting to query with an empty service name
	ErrServiceNameNotSet = errors.New("service Name must be set")

	// ErrStartTimeMinGreaterThanMax occurs when start time min is above start time max
	ErrStartTimeMinGreaterThanMax = errors.New("start Time Minimum is above Maximum")

	// ErrDurationMinGreaterThanMax occurs when duration min is above duration max
	ErrDurationMinGreaterThanMax = errors.New("duration Minimum is above Maximum")

	// ErrMalformedRequestObject occurs when a request object is nil
	ErrMalformedRequestObject = errors.New("malformed request object")

	// ErrStartAndEndTimeNotSet occurs when start time and end time are not set
	ErrStartAndEndTimeNotSet = errors.New("start and End Time must be set")
)

taken from https://github.com/logzio/jaeger-logzio/blob/master/store/store.go

Functions

func NewLogger

func NewLogger(pc *PluginConfig) hclog.Logger

NewLogger returns configured logger from global options

func NewStore

func NewStore(pc *PluginConfig, kc *KustoConfig, logger hclog.Logger) (shared.StoragePlugin, error)

NewStore creates new Kusto store for Jaeger span storage

func TransformSpanToStringArray

func TransformSpanToStringArray(span *model.Span) ([]string, error)

TransformSpanToStringArray converts span to string ready for Kusto ingestion

Types

type KustoConfig

type KustoConfig struct {
	ClientID     string `json:"clientId"`
	ClientSecret string `json:"clientSecret"`
	TenantID     string `json:"tenantId"`
	Endpoint     string `json:"endpoint"`
	Database     string `json:"database"`
}

KustoConfig contains AzureAD service principal and Kusto cluster configs

func ParseKustoConfig

func ParseKustoConfig(path string) (*KustoConfig, error)

ParseKustoConfig reads file at path and returns instance of KustoConfig or error

type PluginConfig

type PluginConfig struct {
	KustoConfigPath           string  `json:"kustoConfigPath"`
	LogLevel                  string  `json:"logLevel"`
	LogJson                   bool    `json:"logJson"`
	ProfilingEnabled          bool    `json:"profilingEnabled"`
	ProfilingPort             int     `json:"profilingPort"`
	TracingSamplerPercentage  float64 `json:"tracingSamplerPercentage"`
	TracingRPCMetrics         bool    `json:"tracingRPCMetrics"`
	WriterSpanBufferSize      int     `json:"writerSpanBufferSize"`
	WriterBatchMaxBytes       int     `json:"writerBatchMaxBytes"`
	WriterBatchTimeoutSeconds int     `json:"writerBatchTimeoutSeconds"`
}

PluginConfig contains global options

func NewDefaultPluginConfig

func NewDefaultPluginConfig() *PluginConfig

NewDefaultPluginConfig returns default configuration options

func ParseConfig

func ParseConfig(path string) (*PluginConfig, error)

ParseConfig reads file at path and returns instance of PluginConfig or error

type PluginTracer

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

func NewPluginTracer

func NewPluginTracer(pc *PluginConfig) (*PluginTracer, error)

func (*PluginTracer) Close

func (pt *PluginTracer) Close() error

func (*PluginTracer) EnableGlobalTracer

func (pt *PluginTracer) EnableGlobalTracer()

func (*PluginTracer) Tracer

func (pt *PluginTracer) Tracer() opentracing.Tracer