plugin

Sep 25, 2024

Changes in this version

+ type DescSrcWrapper struct

+ 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 GrpcWorker struct

+ func NewGrpcWorker(addr string, msgChannel chan *protocol.Message, ...) *GrpcWorker

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

Sep 16, 2024

Changes in this version

+ const RSTNum

+ func SendRST(srcMac, dstMac net.HardwareAddr, srcIp, dstIp net.IP, ...) error

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

Jul 29, 2024

Changes in this version

+ type RocketMQInput struct

+ 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 struct

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

+ func (o *RocketMQOutput) Close() error

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

Oct 17, 2022

Changes in this version

+ const ACK

+ const FIN

+ const PSH

+ const RST

+ const SYN

+ const URG

+ func CheckSum(data []byte) uint16

+ func IPtoByte(ipStr string) [4]byte

+ func IsPseudo(key string) bool

+ func IsValidDir(dirPath string) error

+ type DeviceListener struct

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

+ func (l *DeviceListener) Close()

+ func (l *DeviceListener) String() string

+ type FileDirInput struct

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

+ func (in *FileDirInput) Close() error

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

+ type FileDirOutput struct

+ 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 struct

+ MaxAge int

+ MaxBackups int

+ MaxSize int

+ type GRPCOutput struct

+ func NewGRPCOutput(addr string) *GRPCOutput

+ func (o *GRPCOutput) Close() error

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

+ type OutputKafkaConfig struct

+ Host string

+ SASLConfig SASLKafkaConfig

+ Topic string

+ UseJSON bool

+ type PsdHeader struct

+ DstAddr uint32

+ ProtoType uint8

+ SrcAddr uint32

+ TcpLength uint16

+ Zero uint8

+ type RAWInput struct

+ Processor *http2.Processor

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

+ func (i *RAWInput) Close() error

+ func (i *RAWInput) Listen()

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

+ type ReinforcedReader struct

+ EOF bool

+ 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 SASLKafkaConfig struct

+ Mechanism string

+ Password string

+ UseSASL bool

+ Username string

+ type StdOutput struct

+ func NewStdOutput(codec string) *StdOutput

+ func (o *StdOutput) Close() error

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

+ type TCPHeader struct

+ AckNum uint32

+ Checksum uint16

+ DstPort uint16

+ Flag uint8

+ Offset uint8

+ SeqNum uint32

+ SrcPort uint16

+ UrgentPtr uint16

+ Window uint16