pcap

Documentation

Index

• type Transport
  • func NewTransport(_options ...options.WithOption) *Transport
  • func (m *Transport) Close() error
  • func (m *Transport) CreateTransportInstance(transportUrl url.URL, options map[string][]string, ...) (transports.TransportInstance, error)
  • func (m *Transport) GetTransportCode() string
  • func (m *Transport) GetTransportName() string
  • func (m *Transport) String() string
• type TransportInstance
  • func NewPcapTransportInstance(transportFile string, transportType TransportType, portRange string, ...) *TransportInstance
  • func (m *TransportInstance) Close() error
  • func (m *TransportInstance) Connect() error
  • func (m *TransportInstance) GetReader() transports.ExtendedReader
  • func (m *TransportInstance) IsConnected() bool
  • func (m *TransportInstance) String() string
  • func (m *TransportInstance) Write(_ []byte) error
• type TransportType

Types

type Transport

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

func NewTransport

func NewTransport(_options ...options.WithOption) *Transport

func (*Transport) Close

func (m *Transport) Close() error

func (*Transport) CreateTransportInstance

func (m *Transport) CreateTransportInstance(transportUrl url.URL, options map[string][]string, _options ...options.WithOption) (transports.TransportInstance, error)

func (*Transport) GetTransportCode

func (m *Transport) GetTransportCode() string

func (*Transport) GetTransportName

func (m *Transport) GetTransportName() string

func (*Transport) String

func (m *Transport) String() string

type TransportInstance

type TransportInstance struct {
	transportUtils.DefaultBufferedTransportInstance
	// contains filtered or unexported fields
}

func NewPcapTransportInstance

func NewPcapTransportInstance(transportFile string, transportType TransportType, portRange string, speedFactor float32, transport *Transport, _options ...options.WithOption) *TransportInstance

func (*TransportInstance) Close

func (m *TransportInstance) Close() error

func (*TransportInstance) Connect

func (m *TransportInstance) Connect() error

func (*TransportInstance) GetReader

func (m *TransportInstance) GetReader() transports.ExtendedReader

func (*TransportInstance) IsConnected

func (m *TransportInstance) IsConnected() bool

func (*TransportInstance) String

func (m *TransportInstance) String() string

func (*TransportInstance) Write

func (m *TransportInstance) Write(_ []byte) error

type TransportType

type TransportType string

const (
	UDP  TransportType = "udp"
	TCP  TransportType = "tcp"
	PCAP TransportType = "pcap"
)