acceptor

package
v2.11.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 26, 2024 License: MIT Imports: 14 Imported by: 30

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Acceptor 

type Acceptor interface {
	ListenAndServe()
	Stop()
	GetAddr() string
	GetConnChan() chan PlayerConn
	EnableProxyProtocol()
	IsRunning() bool
	GetConfiguredAddress() string
}

Acceptor type interface

type Conn added in v2.10.1 

type Conn struct {
	net.Conn
	// contains filtered or unexported fields
}

Conn is used to wrap and underlying connection which may be speaking the Proxy Protocol. If it is, the RemoteAddr() will return the address of the client instead of the proxy address.

func (*Conn) LocalAddr added in v2.10.1 

func (p *Conn) LocalAddr() net.Addr

func (*Conn) RemoteAddr added in v2.10.1 

func (p *Conn) RemoteAddr() net.Addr

RemoteAddr returns the address of the client if the proxy protocol is being used, otherwise just returns the address of the socket peer. If there is an error parsing the header, the address of the client is not returned, and the socket is closed. Once implication of this is that the call could block if the client is slow. Using a Deadline is recommended if this is called before Read()

type PlayerConn 

type PlayerConn interface {
	GetNextMessage() (b []byte, err error)
	RemoteAddr() net.Addr
	net.Conn
}

PlayerConn iface

type ProxyProtocolListener added in v2.10.1 

type ProxyProtocolListener struct {
	net.Listener
	// contains filtered or unexported fields
}

Listener is used to wrap an underlying listener, whose connections may be using the HAProxy Proxy Protocol. If the connection is using the protocol, the RemoteAddr() will return the correct client address.

func (*ProxyProtocolListener) Accept added in v2.10.1 

func (p *ProxyProtocolListener) Accept() (net.Conn, error)

Accept waits for and returns the next connection to the listener.

type TCPAcceptor 

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

TCPAcceptor struct

func NewTCPAcceptor 

func NewTCPAcceptor(addr string, certs ...string) *TCPAcceptor

NewTCPAcceptor creates a new instance of tcp acceptor

func NewTLSAcceptor added in v2.4.0 

func NewTLSAcceptor(addr string, certs ...tls.Certificate) *TCPAcceptor

func (*TCPAcceptor) EnableProxyProtocol added in v2.3.0 

func (a *TCPAcceptor) EnableProxyProtocol()

func (*TCPAcceptor) GetAddr 

func (a *TCPAcceptor) GetAddr() string

GetAddr returns the addr the acceptor will listen on

func (*TCPAcceptor) GetConfiguredAddress added in v2.7.2 

func (a *TCPAcceptor) GetConfiguredAddress() string

func (*TCPAcceptor) GetConnChan 

func (a *TCPAcceptor) GetConnChan() chan PlayerConn

GetConnChan gets a connection channel

func (*TCPAcceptor) IsRunning added in v2.7.2 

func (a *TCPAcceptor) IsRunning() bool

func (*TCPAcceptor) ListenAndServe 

func (a *TCPAcceptor) ListenAndServe()

ListenAndServe using tcp acceptor

func (*TCPAcceptor) ListenAndServeTLS 

func (a *TCPAcceptor) ListenAndServeTLS(cert, key string)

ListenAndServeTLS listens using tls

func (*TCPAcceptor) Stop 

func (a *TCPAcceptor) Stop()

Stop stops the acceptor

type WSAcceptor 

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

WSAcceptor struct

func NewWSAcceptor 

func NewWSAcceptor(addr string, certs ...string) *WSAcceptor

NewWSAcceptor returns a new instance of WSAcceptor

func (*WSAcceptor) EnableProxyProtocol added in v2.3.0 

func (w *WSAcceptor) EnableProxyProtocol()

PROXY protocol support not implemented for WS acceptor

func (*WSAcceptor) GetAddr 

func (w *WSAcceptor) GetAddr() string

GetAddr returns the addr the acceptor will listen on

func (*WSAcceptor) GetConfiguredAddress added in v2.7.2 

func (w *WSAcceptor) GetConfiguredAddress() string

func (*WSAcceptor) GetConnChan 

func (w *WSAcceptor) GetConnChan() chan PlayerConn

GetConnChan gets a connection channel

func (*WSAcceptor) IsRunning added in v2.7.2 

func (w *WSAcceptor) IsRunning() bool

func (*WSAcceptor) ListenAndServe 

func (w *WSAcceptor) ListenAndServe()

ListenAndServe listens and serve in the specified addr

func (*WSAcceptor) ListenAndServeTLS 

func (w *WSAcceptor) ListenAndServeTLS(cert, key string)

ListenAndServeTLS listens and serve in the specified addr using tls

func (*WSAcceptor) Stop 

func (w *WSAcceptor) Stop()

Stop stops the acceptor

type WSConn 

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

WSConn is an adapter to t.Conn, which implements all t.Conn interface base on *websocket.Conn

func NewWSConn 

func NewWSConn(conn *websocket.Conn) (*WSConn, error)

NewWSConn return an initialized *WSConn

func (*WSConn) Close 

func (c *WSConn) Close() error

Close closes the connection. Any blocked Read or Write operations will be unblocked and return errors.

func (*WSConn) GetNextMessage 

func (c *WSConn) GetNextMessage() (b []byte, err error)

GetNextMessage reads the next message available in the stream

func (*WSConn) LocalAddr 

func (c *WSConn) LocalAddr() net.Addr

LocalAddr returns the local network address.

func (*WSConn) Read 

func (c *WSConn) Read(b []byte) (int, error)

Read reads data from the connection. Read can be made to time out and return an Error with Timeout() == true after a fixed time limit; see SetDeadline and SetReadDeadline.

func (*WSConn) RemoteAddr 

func (c *WSConn) RemoteAddr() net.Addr

RemoteAddr returns the remote network address.

func (*WSConn) SetDeadline 

func (c *WSConn) SetDeadline(t time.Time) error

SetDeadline sets the read and write deadlines associated with the connection. It is equivalent to calling both SetReadDeadline and SetWriteDeadline.

A deadline is an absolute time after which I/O operations fail with a timeout (see type Error) instead of blocking. The deadline applies to all future and pending I/O, not just the immediately following call to Read or Write. After a deadline has been exceeded, the connection can be refreshed by setting a deadline in the future.

An idle timeout can be implemented by repeatedly extending the deadline after successful Read or Write calls.

A zero value for t means I/O operations will not time out.

func (*WSConn) SetReadDeadline 

func (c *WSConn) SetReadDeadline(t time.Time) error

SetReadDeadline sets the deadline for future Read calls and any currently-blocked Read call. A zero value for t means Read will not time out.

func (*WSConn) SetWriteDeadline 

func (c *WSConn) SetWriteDeadline(t time.Time) error

SetWriteDeadline sets the deadline for future Write calls and any currently-blocked Write call. Even if write times out, it may return n > 0, indicating that some of the data was successfully written. A zero value for t means Write will not time out.

func (*WSConn) Write 

func (c *WSConn) Write(b []byte) (int, error)

Write writes data to the connection. Write can be made to time out and return an Error with Timeout() == true after a fixed time limit; see SetDeadline and SetWriteDeadline.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.