plugin

Documentation

Index

• Constants
• func IPtoByte(ipStr string) []byte
• func IsPseudo(key string) bool
• func IsValidDir(dirPath string) error
• func SendRST(srcMac, dstMac net.HardwareAddr, srcIp, dstIp net.IP, ...) error
• func SendSYN(srcIp, dstIp net.IP, srcPort, dstPort layers.TCPPort, seq uint32) error
• type DescSrcWrapper
  • func NewDescSrcWrapper(descSource grpcurl.DescriptorSource) *DescSrcWrapper
  • func (s *DescSrcWrapper) AllExtensionsForType(typeName string) ([]*desc.FieldDescriptor, error)
  • func (s *DescSrcWrapper) FindSymbol(fullyQualifiedName string) (desc.Descriptor, error)
  • func (s *DescSrcWrapper) ListServices() ([]string, error)
• type DeviceListener
  • func NewDeviceListener(device string, port int, rawInput *RAWInput) *DeviceListener
  • func (l *DeviceListener) Close()
  • func (l *DeviceListener) String() string
• type FileDirInput
  • func NewFileDirInput(codec string, path string, readDepth int, speed float64) *FileDirInput
  • func (in *FileDirInput) Close() error
  • func (in *FileDirInput) Read() (msg *protocol.Message, err error)
• type FileDirOutput
  • func NewFileDirOutput(codec string, path string, cf *FileDirOutputConfig) *FileDirOutput
  • func (o *FileDirOutput) Close() error
  • func (o *FileDirOutput) Write(msg *protocol.Message) (err error)
• type FileDirOutputConfig
• type GRPCOutput
  • func NewGRPCOutput(addr string, workerNum int) *GRPCOutput
  • func (o *GRPCOutput) Close() error
  • func (o *GRPCOutput) Write(msg *protocol.Message) (err error)
• type GrpcWorker
  • func NewGrpcWorker(addr string, msgChannel chan *protocol.Message, ...) *GrpcWorker
  • func (w *GrpcWorker) Call(msg *protocol.Message) (err error)
• type RAWInput
  • func NewRAWInput(address string) (*RAWInput, error)
  • func (i *RAWInput) Close() error
  • func (i *RAWInput) Listen()
  • func (i *RAWInput) Read() (*protocol.Message, error)
• type ReinforcedReader
  • func NewReinforcedReader(filepaths []string, codec protocol.Codec) *ReinforcedReader
  • func (r *ReinforcedReader) Close() error
  • func (r *ReinforcedReader) NextFile() error
  • func (r *ReinforcedReader) ReadMessage() (*protocol.Message, error)
• type RocketMQInput
  • func NewRocketMQInput(nameServers []string, topic, groupName string, accessKey, secretKey string) (*RocketMQInput, error)
  • func (in *RocketMQInput) Close() error
  • func (in *RocketMQInput) Read() (*protocol.Message, error)
• type RocketMQOutput
  • func NewRocketMQOutput(nameServers []string, topic, accessKey, secretKey string) (*RocketMQOutput, error)
  • func (o *RocketMQOutput) Close() error
  • func (o *RocketMQOutput) Write(msg *protocol.Message) (err error)
• type StdOutput
  • func NewStdOutput(codec string) *StdOutput
  • func (o *StdOutput) Close() error
  • func (o *StdOutput) Write(msg *protocol.Message) (err error)

Constants

const (
	RSTNum = 3
)

Functions

func IPtoByte

func IPtoByte(ipStr string) []byte

func IsPseudo

func IsPseudo(key string) bool

func IsValidDir

func IsValidDir(dirPath string) error

func SendRST

func SendRST(srcMac, dstMac net.HardwareAddr, srcIp, dstIp net.IP, srcPort, dstPort layers.TCPPort,
	seq uint32, handle *pcap.Handle) error

func SendSYN

func SendSYN(srcIp, dstIp net.IP, srcPort, dstPort layers.TCPPort, seq uint32) error

Types

type DescSrcWrapper

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

func NewDescSrcWrapper

func NewDescSrcWrapper(descSource grpcurl.DescriptorSource) *DescSrcWrapper

func (*DescSrcWrapper) AllExtensionsForType

func (s *DescSrcWrapper) AllExtensionsForType(typeName string) ([]*desc.FieldDescriptor, error)

func (*DescSrcWrapper) FindSymbol

func (s *DescSrcWrapper) FindSymbol(fullyQualifiedName string) (desc.Descriptor, error)

func (*DescSrcWrapper) ListServices

func (s *DescSrcWrapper) ListServices() ([]string, error)

type DeviceListener

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

func NewDeviceListener

func NewDeviceListener(device string, port int, rawInput *RAWInput) *DeviceListener

func (*DeviceListener) Close

func (l *DeviceListener) Close()

func (*DeviceListener) String

func (l *DeviceListener) String() string

type FileDirInput

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

func NewFileDirInput

func NewFileDirInput(codec string, path string, readDepth int, speed float64) *FileDirInput

func (*FileDirInput) Close

func (in *FileDirInput) Close() error

func (*FileDirInput) Read

func (in *FileDirInput) Read() (msg *protocol.Message, err error)

type FileDirOutput

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

func NewFileDirOutput

func NewFileDirOutput(codec string, path string, cf *FileDirOutputConfig) *FileDirOutput

func (*FileDirOutput) Close

func (o *FileDirOutput) Close() error

func (*FileDirOutput) Write

func (o *FileDirOutput) Write(msg *protocol.Message) (err error)

type FileDirOutputConfig

type FileDirOutputConfig struct {
	// MaxSize is the maximum size in megabytes of the log file before it gets rotated.
	MaxSize int `json:"maxSize"`
	// MaxBackups is the maximum number of old log files to retain.
	MaxBackups int `json:"maxBackups"`
	// MaxAge is the maximum number of days to retain old log files based on the
	// timestamp encoded in their filename.
	MaxAge int `json:"maxAge"`
}

type GRPCOutput

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

func NewGRPCOutput

func NewGRPCOutput(addr string, workerNum int) *GRPCOutput

func (*GRPCOutput) Close

func (o *GRPCOutput) Close() error

func (*GRPCOutput) Write

func (o *GRPCOutput) Write(msg *protocol.Message) (err error)

type GrpcWorker

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

func NewGrpcWorker

func NewGrpcWorker(addr string, msgChannel chan *protocol.Message, descSource grpcurl.DescriptorSource) *GrpcWorker

func (*GrpcWorker) Call

func (w *GrpcWorker) Call(msg *protocol.Message) (err error)

type RAWInput

type RAWInput struct {
	Processor *http2.Processor
	// contains filtered or unexported fields
}

RAWInput used for intercepting traffic for given address

func NewRAWInput

func NewRAWInput(address string) (*RAWInput, error)

NewRAWInput constructor for RAWInput. Accepts raw input config as arguments.

func (*RAWInput) Close

func (i *RAWInput) Close() error

Close closes the input raw listener

func (*RAWInput) Listen

func (i *RAWInput) Listen()

func (*RAWInput) Read

func (i *RAWInput) Read() (*protocol.Message, error)

PluginRead reads meassage from this plugin

type ReinforcedReader

type ReinforcedReader struct {
	sync.Mutex

	EOF bool
	// contains filtered or unexported fields
}

func NewReinforcedReader

func NewReinforcedReader(filepaths []string, codec protocol.Codec) *ReinforcedReader

func (*ReinforcedReader) Close

func (r *ReinforcedReader) Close() error

func (*ReinforcedReader) NextFile

func (r *ReinforcedReader) NextFile() error

func (*ReinforcedReader) ReadMessage

func (r *ReinforcedReader) ReadMessage() (*protocol.Message, error)

type RocketMQInput

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

func NewRocketMQInput

func NewRocketMQInput(nameServers []string, topic, groupName string, accessKey, secretKey string) (*RocketMQInput, error)

func (*RocketMQInput) Close

func (in *RocketMQInput) Close() error

func (*RocketMQInput) Read

func (in *RocketMQInput) Read() (*protocol.Message, error)

type RocketMQOutput

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

func NewRocketMQOutput

func NewRocketMQOutput(nameServers []string, topic, accessKey, secretKey string) (*RocketMQOutput, error)

func (*RocketMQOutput) Close

func (o *RocketMQOutput) Close() error

func (*RocketMQOutput) Write

func (o *RocketMQOutput) Write(msg *protocol.Message) (err error)

type StdOutput

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

func NewStdOutput

func NewStdOutput(codec string) *StdOutput

func (*StdOutput) Close

func (o *StdOutput) Close() error

func (*StdOutput) Write

func (o *StdOutput) Write(msg *protocol.Message) (err error)