Documentation ¶
Index ¶
- func NewClientWorker(parentLogger logger.Logger, args base.ChunkConsumerArgs, ...) base.ChunkConsumer
- func NewEventSerializer(parentLogger logger.Logger, schema base.LogSchema, config SerializationConfig, ...) base.LogSerializer
- type Config
- func (cfg *Config) DecodeChunkToJSON(chunk base.LogChunk, separator []byte, indented bool, writer io.Writer) (base.LogChunkInfo, error)
- func (cfg *Config) MatchChunkID(chunkID string) bool
- func (cfg *Config) NewChunkMaker(parentLogger logger.Logger, tag string) base.LogChunkMaker
- func (cfg *Config) NewForwarder(parentLogger logger.Logger, args base.ChunkConsumerArgs, ...) base.ChunkConsumer
- func (cfg *Config) NewSerializer(parentLogger logger.Logger, schema base.LogSchema, tag string) base.LogSerializer
- func (cfg *Config) VerifyConfig(schema base.LogSchema) error
- type SerializationConfig
- type UpstreamConfig
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewClientWorker ¶
func NewClientWorker(parentLogger logger.Logger, args base.ChunkConsumerArgs, metricCreator promreg.MetricCreator, cfg UpstreamConfig) base.ChunkConsumer
func NewEventSerializer ¶
func NewEventSerializer(parentLogger logger.Logger, schema base.LogSchema, config SerializationConfig, ddtags string) base.LogSerializer
Types ¶
type Config ¶
type Config struct { bconfig.Header `yaml:",inline"` Serialization SerializationConfig `yaml:"serialization"` Upstream UpstreamConfig `yaml:"upstream"` }
func (*Config) DecodeChunkToJSON ¶
func (*Config) MatchChunkID ¶
func (*Config) NewChunkMaker ¶
func (*Config) NewForwarder ¶
func (cfg *Config) NewForwarder(parentLogger logger.Logger, args base.ChunkConsumerArgs, metricCreator promreg.MetricCreator) base.ChunkConsumer
func (*Config) NewSerializer ¶
type SerializationConfig ¶
type SerializationConfig struct {
HiddenFields []string `yaml:"hiddenFields"`
}
type UpstreamConfig ¶
Click to show internal directories.
Click to hide internal directories.