transport

Documentation

Index

• Variables
• type Metric
• type MockReporter
  • func NewMockReporter(expectedOnMetricsProcessedCalls int) *MockReporter
  • func (m *MockReporter) OnDebugf(_ string, _ ...any)
  • func (m *MockReporter) WaitAllOnMetricsProcessedCalls()
• type Reporter
• type Server
  • func NewTCPServer(transport Transport, address string) (Server, error)
  • func NewUDPServer(transport Transport, address string) (Server, error)
• type SplitBytes
  • func NewSplitBytes(buf []byte, delim byte) *SplitBytes
  • func (sb *SplitBytes) Chunk() []byte
  • func (sb *SplitBytes) Next() bool
• type Transport
  • func NewTransport(ts string) Transport
  • func (trans Transport) IsPacketTransport() bool
  • func (trans Transport) IsStreamTransport() bool
  • func (trans Transport) String() string

Variables

var (
	ErrUnsupportedTransport       = errors.New("unsupported transport")
	ErrUnsupportedPacketTransport = errors.New("unsupported Packet transport")
	ErrUnsupportedStreamTransport = errors.New("unsupported Stream transport")
)

Types

type Metric

type Metric struct {
	Raw  string
	Addr net.Addr
}

type MockReporter

type MockReporter struct {
	// contains filtered or unexported fields
}

MockReporter provides a Reporter that provides some useful functionalities for tests (eg.: wait for certain number of messages).

func NewMockReporter

func NewMockReporter(expectedOnMetricsProcessedCalls int) *MockReporter

NewMockReporter returns a new instance of a MockReporter.

func (*MockReporter) OnDebugf

func (m *MockReporter) OnDebugf(_ string, _ ...any)

func (*MockReporter) WaitAllOnMetricsProcessedCalls

func (m *MockReporter) WaitAllOnMetricsProcessedCalls()

WaitAllOnMetricsProcessedCalls blocks until the number of expected calls specified at creation of the reporter is completed.

type Reporter

type Reporter interface {
	// OnDebugf allows less structured reporting for debugging scenarios.
	OnDebugf(
		template string,
		args ...any)
}

Reporter is used to report (via zPages, logs, metrics, etc) the events happening when the Server is receiving and processing data.

type Server

type Server interface {
	// ListenAndServe is a blocking call that starts to listen for client messages
	// on the specific transport, and prepares the message to be processed by
	// the Parser and passed to the next consumer.
	ListenAndServe(
		mc consumer.Metrics,
		r Reporter,
		transferChan chan<- Metric,
	) error

	// Close stops any running ListenAndServe, however, it waits for any
	// data already received to be parsed and sent to the next consumer.
	Close() error
}

Server abstracts the type of transport being used and offer an interface to handle serving clients over that transport.

func NewTCPServer

func NewTCPServer(transport Transport, address string) (Server, error)

NewTCPServer creates a transport.Server using TCP as its transport.

func NewUDPServer

func NewUDPServer(transport Transport, address string) (Server, error)

NewUDPServer creates a transport.Server using UDP as its transport.

type SplitBytes

type SplitBytes struct {
	// contains filtered or unexported fields
}

SplitBytes iterates over a byte buffer, returning chunks split by a given delimiter byte. It does not perform any allocations, and does not modify the buffer it is given. It is not safe for use by concurrent goroutines.

sb := NewSplitBytes(buf, '\n')
for sb.Next() {
    fmt.Printf("%q\n", sb.Chunk())
}

The sequence of chunks returned by SplitBytes is equivalent to calling bytes.Split, except without allocating an intermediate slice.

func NewSplitBytes

func NewSplitBytes(buf []byte, delim byte) *SplitBytes

NewSplitBytes initializes a SplitBytes struct with the provided buffer and delimiter.

func (*SplitBytes) Chunk

func (sb *SplitBytes) Chunk() []byte

Chunk returns the current chunk.

func (*SplitBytes) Next

func (sb *SplitBytes) Next() bool

Next advances SplitBytes to the next chunk, returning true if a new chunk actually exists and false otherwise.

type Transport

type Transport string

Transport is a set of constants of the transport supported by this receiver.

const (
	UDP  Transport = "udp"
	UDP4 Transport = "udp4"
	UDP6 Transport = "udp6"
	TCP  Transport = "tcp"
	TCP4 Transport = "tcp4"
	TCP6 Transport = "tcp6"
)

func NewTransport

func NewTransport(ts string) Transport

NewTransport creates a Transport based on the transport string or returns an empty Transport.

func (Transport) IsPacketTransport

func (trans Transport) IsPacketTransport() bool

IsPacketTransport returns true if the transport is packet based.

func (Transport) IsStreamTransport

func (trans Transport) IsStreamTransport() bool

IsStreamTransport returns true if the transport is stream based.

func (Transport) String

func (trans Transport) String() string

String casts the transport to a String if the Transport is supported. Return an empty Transport overwise.