Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type OTLPShipperOption ¶
type OTLPShipperOption func(*otlpShipperOptions)
func WithBatchSize ¶
func WithBatchSize(batchSize int) OTLPShipperOption
func WithComponent ¶
func WithComponent(component string) OTLPShipperOption
func WithLogType ¶
func WithLogType(logType string) OTLPShipperOption
func WithWorkers ¶
func WithWorkers(workers int) OTLPShipperOption
type Shipper ¶
type Shipper interface {
// Publish will publish each token in a scanner to a destination
// any batch processing should be handled by the shipper
Publish(context.Context, *bufio.Scanner) error
}
Shipper is a convenient interface for publishing data to a destination
func NewOTLPShipper ¶
func NewOTLPShipper( cc grpc.ClientConnInterface, parser dateparser.DateParser, lg *slog.Logger, opts ...OTLPShipperOption, ) Shipper
Source Files
Click to show internal directories.
Click to hide internal directories.