Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Config ¶
type Config struct {
BatchSize int // Max number of logs to buffer before sending.
FlushInterval time.Duration // Max time to wait before sending a batch.
SendTimeout time.Duration // timeout for the gRPC send operation, we need to think about this little more.
QueueSize int // The size of the internal log entry queue.
}
Config holds the configuration for the telemetry logger.
type Logger ¶
type Logger interface {
Report(level gen.LogLevel, source string, msg string, err error, fields map[string]string)
Stop()
}
Logger is the interface that collectors will use to report critical errors. It decouples the collectors from the concrete implementation.
type TelemetryLogSender ¶
type TelemetryLogSender interface {
SendTelemetryLogs(ctx context.Context, in *gen.SendTelemetryLogsRequest) (*gen.SendTelemetryLogsResponse, error)
}
MetricsCollectorClient defines the necessary gRPC method for sending logs. Forcefully had to do this as, was not fully convinced to put this in transport layer and cant use the DackerClient/DirectSender interface here for circular dependency
Click to show internal directories.
Click to hide internal directories.