Versions in this module Expand all Collapse all v1 v1.0.2 Mar 22, 2024 v1.0.1 Nov 9, 2023 Changes in this version + const DefaultCollectorHost + const DefaultCollectorPort + const DefaultGRPCServiceConfig + const DefaultNumWorkers + const MaxExportBatchSize + var Concurrency int = 1 + var QueueSize int = 2048 + type Exporter struct + func NewExporter(opts ...ExporterOption) (*Exporter, error) + func NewUnstartedExporter(opts ...ExporterOption) *Exporter + func (e *Exporter) ExportLogs(parent context.Context, logs []*logsproto.ResourceLogs) error + func (e *Exporter) Shutdown(ctx context.Context) error + func (e *Exporter) Start() error + type ExporterOption func(*config) + func WithAddress(addr string) ExporterOption + func WithCompressor(compressor string) ExporterOption + func WithConcurrency(concurrency int) ExporterOption + func WithGRPCDialOption(opts ...grpc.DialOption) ExporterOption + func WithGRPCServiceConfig(serviceConfig string) ExporterOption + func WithHeaders(headers map[string]string) ExporterOption + func WithInsecure() ExporterOption + func WithReconnectionPeriod(rp time.Duration) ExporterOption + func WithTLSCredentials(creds credentials.TransportCredentials) ExporterOption + func WithTenantID(tenantID string) ExporterOption + func WorkerCount(n uint) ExporterOption
Go to main page