type Callback func(Path,time.Time, []byte,packet.CaptureMeta)

type Pathuint8

const (// FromLocal indicates the packet was logged as it traversed the FromLocal path:// i.e.: A packet from the local system into the TUN.FromLocalPath = 0// FromPeer indicates the packet was logged upon reception from a remote peer.FromPeerPath = 1// SynthesizedToLocal indicates the packet was generated from within tailscaled,// and is being routed to the local machine's network stack.SynthesizedToLocalPath = 2// SynthesizedToPeer indicates the packet was generated from within tailscaled,// and is being routed to a remote Wireguard peer.SynthesizedToPeerPath = 3// PathDisco indicates the packet is information about a disco frame.PathDiscoPath = 254)

Valid Path values.

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

funcNew¶

func New() *Sink

New creates a new capture sink.

func (*Sink)Close¶

func (s *Sink) Close()error

Close shuts down the sink. Future calls to LogPacketare ignored, and any registered output that implementsio.Closer is closed.

func (*Sink)LogPacket¶

func (s *Sink) LogPacket(pathPath, whentime.Time, data []byte, metapacket.CaptureMeta)

LogPacket is called to insert a packet into the capture.

This function does not take ownership of the provided data slice.

func (*Sink)NumOutputs¶

func (s *Sink) NumOutputs()int

NumOutputs returns the number of outputs registered with the sink.

func (*Sink)RegisterOutput¶

func (s *Sink) RegisterOutput(wio.Writer) (unregister func())

RegisterOutput connects an output to this sink, whichwill be written to with a pcap stream as packets are logged.A function is returned which unregisters the output whencalled.

If w implements io.Closer, it will be closed upon erroror when the sink is closed. If w implements http.Flusher,it will be flushed periodically.

func (*Sink)WaitCh¶

func (s *Sink) WaitCh() <-chan struct{}

WaitCh returns a channel which blocks untilthe sink is closed.