udppoller

Documentation

Index

• Constants
• type Config
• type Poller
  • func New(cfg *Config, set receiver.Settings) (Poller, error)
• type RawSegment

Constants

const (
	// Transport is the network transport protocol used
	// by the poller
	Transport = "udp"
)

Types

type Config

type Config struct {
	Transport          string
	Endpoint           string
	NumOfPollerToStart int
}

Config represents the configurations needed to start the UDP poller

type Poller

type Poller interface {
	SegmentsChan() <-chan RawSegment
	Start(receiverLongTermCtx context.Context)
	Close() error
}

Poller represents one or more goroutines that are polling from a UDP socket

func New

func New(cfg *Config, set receiver.Settings) (Poller, error)

New creates a new UDP poller

type RawSegment

type RawSegment struct {
	// Payload is the raw bytes that represent one X-Ray segment.
	Payload []byte
	// Ctx is the short-lived context created per raw segment received
	Ctx context.Context
}

RawSegment represents a raw X-Ray segment document.