internal

Documentation

Index

• func LoggerFromContext(ctx context.Context) *zap.Logger
• func LoggerWithContext(ctx context.Context, logger *zap.Logger) context.Context
• type Config
  • func (c *Config) Init(command *cobra.Command) error
• type InfluxdbStorage
  • func NewInfluxdbStorage(ctx context.Context, config *Config) (*InfluxdbStorage, error)
  • func (is *InfluxdbStorage) ArchiveSpanReader() spanstore.Reader
  • func (is *InfluxdbStorage) ArchiveSpanWriter() spanstore.Writer
  • func (is *InfluxdbStorage) Close() error
  • func (is *InfluxdbStorage) DependencyReader() dependencystore.Reader
  • func (is *InfluxdbStorage) SpanReader() spanstore.Reader
  • func (is *InfluxdbStorage) SpanWriter() spanstore.Writer

Functions

func LoggerFromContext

func LoggerFromContext(ctx context.Context) *zap.Logger

func LoggerWithContext

func LoggerWithContext(ctx context.Context, logger *zap.Logger) context.Context

Types

type Config

type Config struct {
	LogLevel              string
	ListenAddr            string
	InfluxdbAddr          string
	InfluxdbTLSDisable    bool
	InfluxdbTimeout       time.Duration
	InfluxdbBucket        string
	InfluxdbBucketArchive string
	InfluxdbToken         string
	InfluxdbQueryMetadata map[string]string
}

func (*Config) Init

func (c *Config) Init(command *cobra.Command) error

type InfluxdbStorage

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

func NewInfluxdbStorage

func NewInfluxdbStorage(ctx context.Context, config *Config) (*InfluxdbStorage, error)

func (*InfluxdbStorage) ArchiveSpanReader

func (is *InfluxdbStorage) ArchiveSpanReader() spanstore.Reader

func (*InfluxdbStorage) ArchiveSpanWriter

func (is *InfluxdbStorage) ArchiveSpanWriter() spanstore.Writer

func (*InfluxdbStorage) Close

func (is *InfluxdbStorage) Close() error

func (*InfluxdbStorage) DependencyReader

func (is *InfluxdbStorage) DependencyReader() dependencystore.Reader

func (*InfluxdbStorage) SpanReader

func (is *InfluxdbStorage) SpanReader() spanstore.Reader

func (*InfluxdbStorage) SpanWriter

func (is *InfluxdbStorage) SpanWriter() spanstore.Writer