tcp

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 NewTcpTransportInstance(remoteAddress *net.TCPAddr, connectTimeout uint32, transport *Transport, ...) *TransportInstance
  • func (m *TransportInstance) Close() error
  • func (m *TransportInstance) Connect() error
  • func (m *TransportInstance) ConnectWithContext(ctx context.Context) error
  • func (m *TransportInstance) GetReader() transports.ExtendedReader
  • func (m *TransportInstance) IsConnected() bool
  • func (m *TransportInstance) String() string
  • func (m *TransportInstance) Write(data []byte) error

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

	RemoteAddress  *net.TCPAddr
	LocalAddress   *net.TCPAddr
	ConnectTimeout uint32
	// contains filtered or unexported fields
}

func NewTcpTransportInstance

func NewTcpTransportInstance(remoteAddress *net.TCPAddr, connectTimeout uint32, transport *Transport, _options ...options.WithOption) *TransportInstance

func (*TransportInstance) Close

func (m *TransportInstance) Close() error

func (*TransportInstance) Connect

func (m *TransportInstance) Connect() error

func (*TransportInstance) ConnectWithContext

func (m *TransportInstance) ConnectWithContext(ctx context.Context) 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(data []byte) error