common

Documentation

Index

• func NewZapToBadgerAdapter(logger *zap.Logger) *zapToBadgerAdapter
• func NewZapToGoKitAdapter(logger *zap.Logger) *zapToGoKitAdapter
• func RequestObjectName(agentID, requstID string) string
• func ResponseObjectName(agentID, requstID string) string
• func ServeMetrics(logger *zap.Logger)
• type CommonConfig
• type CommonConfigV2
  • func CreateConfig(configPath string) (CommonConfigV2, error)
• type Networking
• type Profiling
• type Split
• type StorageRelay
• type Telemetry

Functions

func NewZapToBadgerAdapter

func NewZapToBadgerAdapter(logger *zap.Logger) *zapToBadgerAdapter

func NewZapToGoKitAdapter

func NewZapToGoKitAdapter(logger *zap.Logger) *zapToGoKitAdapter

func RequestObjectName

func RequestObjectName(agentID, requstID string) string

func ResponseObjectName

func ResponseObjectName(agentID, requstID string) string

func ServeMetrics

func ServeMetrics(logger *zap.Logger)

Types

type CommonConfig

type CommonConfig struct {
	MQTTBroker string
	Username   string
	Password   string
	Logger     *zap.Logger
	CAFile     string
	Cert       string
	Key        string
	Protocol   string
}

type CommonConfigV2

type CommonConfigV2 struct {
	Profiling    Profiling    `mapstructure:"profiling"`
	Networking   Networking   `mapstructure:"networking"`
	StorageRelay StorageRelay `mapstructure:"storage_relay"`
	Split        Split        `mapstructure:"split"`
	Telemetry    Telemetry    `mapstructure:"telemetry"`
}

func CreateConfig

func CreateConfig(configPath string) (CommonConfigV2, error)

type Networking

type Networking struct {
	Format          string `mapstructure:"format" validate:"omitempty,oneof=json protobuf"`
	Compress        string `mapstructure:"compress" validate:"omitempty,oneof=none zstd"`
	LargeDataPolicy string `mapstructure:"large_data_policy" validate:"omitempty,oneof=none storage_relay split"`
}

type Profiling

type Profiling struct {
	Registry      string `mapstructure:"registry" validate:"omitempty,oneof=cloudprofiler pyroscope"`
	ServerAddress string `mapstructure:"server_address"`
}

type Split

type Split struct {
	ChunkBytes int `mapstructure:"chunk_bytes"`
}

type StorageRelay

type StorageRelay struct {
	ThresholdBytes int    `mapstructure:"threshold_bytes"`
	ObjstoreFile   string `mapstructure:"objstore_file"`
	Deletion       bool   `mapstructure:"deletion"`
}

type Telemetry

type Telemetry struct {
	Enabled bool `mapstructure:"enabled"`
}