port

Documentation

Index

• Constants
• type PortPlugin
  • func NewPortPlugin(id string, targetHost string, portNumber int, flowLimit int) *PortPlugin
  • func (p *PortPlugin) Execute(dataChannel channel.ISessionChannel, cancelFlag util.CancelFlag) (errorCode string, pluginErr error)
  • func (p *PortPlugin) InputStreamMessageHandler(streamDataMessage message.Message) error
  • func (p *PortPlugin) Stop()

Constants

const (
	Ok               = "Ok"
	Open_port_failed = "Open_port_failed"
	Read_port_failed = "Read_port_failed"
	IO_socket_error  = "IO_port_failed"
	Unknown_error    = "Unknown_error"
)

Types

type PortPlugin

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

func NewPortPlugin

func NewPortPlugin(id string, targetHost string, portNumber int, flowLimit int) *PortPlugin

func (*PortPlugin) Execute

func (p *PortPlugin) Execute(dataChannel channel.ISessionChannel, cancelFlag util.CancelFlag) (errorCode string, pluginErr error)

func (*PortPlugin) InputStreamMessageHandler

func (p *PortPlugin) InputStreamMessageHandler(streamDataMessage message.Message) error

func (*PortPlugin) Stop

func (p *PortPlugin) Stop()