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 *zap.SugaredLogger, opts ...OTLPShipperOption, ) Shipper
Click to show internal directories.
Click to hide internal directories.