bloodlabnet

Aug 12, 2022

Changes in this version

+ const TESTSTRING

+ func CreateSFTPServer(workdir string) sftpserver

Aug 12, 2022

Changes in this version

type ConnectionInstance

+ func CreateSFTPClient(ftptype FTPType, host string, port int, hostpath, filemask string, ...) (ConnectionInstance, error)

type ErrorType

+ const ErrorConfiguration

+ const ErrorLogin

+ type LINEBREAK int

+ const LINEBREAK_CR

+ const LINEBREAK_CRLF

+ const LINEBREAK_LF

Aug 11, 2022

Changes in this version

+ func DefaultFTPConfig() *ftpConfiguration

+ type AuthenticationMethod int

+ const PASSWORD

+ const PUBKEY

type ConnectionInstance

+ func CreateFTP(ftptype FTPType, host string, port int, hostpath, filemask string, ...) (ConnectionInstance, error)

+ type FTPConfiguration interface

+ HostKey func(hostkey string)

+ PollInterval func(pollInterval time.Duration)

+ PubKey func(user, pubkey string)

+ UserPass func(user, pass string)

+ type FTPType int

+ const FTP

+ const SFTP

Jul 25, 2022

Changes in this version

+ var DefaultTCPClientSettings = TCPClientConfiguration

+ type TCPClientConfiguration struct

+ Deadline time.Duration

+ FlushBufferTimoutMs int

+ PollInterval time.Duration

+ SessionAfterFirstByte bool

+ SessionInitationTimeout time.Duration

+ SourceIP string

+ Timeout time.Duration

+ func (s TCPClientConfiguration) SetSourceIP(sourceIP string) TCPClientConfiguration

Jul 8, 2022

Changes in this version

+ type BufferedConn struct

+ func (b BufferedConn) FirstByteOrError(howLong time.Duration) error

+ func (b BufferedConn) Peek(n int) ([]byte, error)

+ func (b BufferedConn) Read(p []byte) (int, error)

+ type ConnectionType int

+ type TCPServerConfiguration struct

+ Deadline time.Duration

+ FlushBufferTimoutMs int

+ PollInterval time.Duration

+ SessionAfterFirstByte bool

+ SessionInitationTimeout time.Duration

+ Timeout time.Duration

Jul 7, 2022

Changes in this version

+ type SecureConnectionOptions struct

+ PublicKey string

Jul 7, 2022

Changes in this version

type ProxyType

+ const HAProxySendProxyV2

Jul 6, 2022

Changes in this version

+ var DefaultFTPClientTimings = TimingConfiguration

+ var DefaultTCPServerSettings = TimingConfiguration

type ConnectionInstance

+ FindSessionsByIp func(ip string) []Session

type ReadFilePolicy

+ const DeleteWhenRead

+ const ReadAndLeaveFile

+ const RenameWhenRead

type TimingConfiguration

+ PollInterval time.Duration

Jun 27, 2022

Changes in this version

+ var DefaultTCPServerTimings = TimingConfiguration

+ type ConnectionAndSessionInstance interface

+ Connect func() error

+ func CreateNewTCPClient(hostname string, port int, protocolReceiveve HighLevelProtocol, ...) ConnectionAndSessionInstance

+ type ConnectionInstance interface

+ Receive func() ([]byte, error)

+ Run func(handler Handler)

+ Send func(data []byte) (int, error)

+ Stop func()

+ func CreateNewFTPClient(hostname string, port int, path, fileMask, user, password, pubKey string, ...) ConnectionInstance

+ func CreateNewTCPServerInstance(listeningPort int, protocolReceiveve HighLevelProtocol, ...) ConnectionInstance

+ type ErrorType int

+ const ErrorAccept

+ const ErrorConnect

+ const ErrorConnectionLimit

+ const ErrorCreateSession

+ const ErrorDisconnect

+ const ErrorInternal

+ const ErrorMaxConnections

+ const ErrorReceive

+ const ErrorSend

+ type FileNameGeneration int

+ const Default

+ const TimeStamp

+ type Handler interface

+ Connected func(session Session)

+ DataReceived func(session Session, fileData []byte, receiveTimestamp time.Time)

+ Disconnected func(session Session)

+ Error func(session Session, typeOfError ErrorType, err error)

+ type HighLevelProtocol int

+ const PROTOCLOL_LIS1A1

+ const PROTOCOL_RAW

+ const PROTOCOL_STXETX

+ type ProxyType int

+ const HaProxySendProxyV2

+ const NoLoadBalancer

+ type ReadFilePolicy int

+ const Delete

+ const Nothing

+ const Rename

+ type Session interface

+ Close func() error

+ IsAlive func() bool

+ Receive func() ([]byte, error)

+ RemoteAddress func() (string, error)

+ Send func(msg []byte) (int, error)

+ WaitTermination func() error

+ type TimingConfiguration struct

+ Deadline time.Duration

+ FlushBufferTimoutMs int

+ Timeout time.Duration