network

package
v0.8.4 Latest Latest
Warning

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

 Go to latest Published: Oct 24, 2023 License: AGPL-3.0 Imports: 24 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func GetID 

func GetID(network, address string, seed int, logger zerolog.Logger) string

GetID returns a unique ID (hash) for a network connection.

func IsConnClosed added in v0.1.4 

func IsConnClosed(received int, err *gerr.GatewayDError) bool

IsConnClosed returns true if the connection is closed.

func IsConnTimedOut added in v0.1.4 

func IsConnTimedOut(err *gerr.GatewayDError) bool

IsConnTimedOut returns true if the error is a timeout error.

func LocalAddr added in v0.6.9 

func LocalAddr(conn net.Conn) string

LocalAddr returns the local address of the connection.

func RemoteAddr added in v0.6.9 

func RemoteAddr(conn net.Conn) string

RemoteAddr returns the remote address of the connection.

func Resolve added in v0.0.2 

func Resolve(network, address string, logger zerolog.Logger) (string, *gerr.GatewayDError)

Resolve resolves a network address.

Types

type Action added in v0.8.3 

type Action int
const (
	None Action = iota
	Close
	Shutdown
)

type Client 

type Client struct {
	TCPKeepAlive       bool
	TCPKeepAlivePeriod time.Duration
	ReceiveChunkSize   int
	ReceiveDeadline    time.Duration
	SendDeadline       time.Duration
	ReceiveTimeout     time.Duration
	ID                 string
	Network            string // tcp/udp/unix
	Address            string
	// contains filtered or unexported fields
}

func NewClient 

func NewClient(ctx context.Context, clientConfig *config.Client, logger zerolog.Logger) *Client

NewClient creates a new client.

func (*Client) Close 

func (c *Client) Close()

Close closes the connection to the server.

func (*Client) IsConnected added in v0.1.0 

func (c *Client) IsConnected() bool

IsConnected checks if the client is still connected to the server.

func (*Client) LocalAddr added in v0.6.9 

func (c *Client) LocalAddr() string

LocalAddr returns the local address of the client safely.

func (*Client) Receive 

func (c *Client) Receive() (int, []byte, *gerr.GatewayDError)

Receive receives data from the server.

func (*Client) Reconnect added in v0.8.3 

func (c *Client) Reconnect() error

Reconnect reconnects to the server.

func (*Client) RemoteAddr added in v0.6.9 

func (c *Client) RemoteAddr() string

RemoteAddr returns the remote address of the client safely.

func (*Client) Send 

func (c *Client) Send(data []byte) (int, *gerr.GatewayDError)

Send sends data to the server.

type Engine added in v0.8.3 

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

Engine is the network engine. TODO: Move this to the Server struct.

func NewEngine added in v0.8.3 

func NewEngine(logger zerolog.Logger) Engine

NewEngine creates a new engine.

func (*Engine) CountConnections added in v0.8.3 

func (engine *Engine) CountConnections() int

CountConnections returns the current number of connections.

func (*Engine) Stop added in v0.8.3 

func (engine *Engine) Stop(ctx context.Context) error

Stop stops the engine.

type Field added in v0.2.3 

type Field struct {
	Name  string
	Value []byte
}

type IClient added in v0.2.2 

type IClient interface {
	Send(data []byte) (int, *gerr.GatewayDError)
	Receive() (int, []byte, *gerr.GatewayDError)
	Reconnect() error
	Close()
	IsConnected() bool
	RemoteAddr() string
	LocalAddr() string
}

type IProxy added in v0.2.2 

type IProxy interface {
	Connect(conn net.Conn) *gerr.GatewayDError
	Disconnect(conn net.Conn) *gerr.GatewayDError
	PassThroughToServer(conn net.Conn, stack *Stack) *gerr.GatewayDError
	PassThroughToClient(conn net.Conn, stack *Stack) *gerr.GatewayDError
	IsHealthy(cl *Client) (*Client, *gerr.GatewayDError)
	IsExhausted() bool
	Shutdown()
	AvailableConnections() []string
	BusyConnections() []string
}

type Option added in v0.8.3 

type Option struct {
	EnableTicker bool
}

type Proxy 

type Proxy struct {
	Elastic             bool
	ReuseElasticClients bool
	HealthCheckPeriod   time.Duration

	// ClientConfig is used for elastic proxy and reconnection
	ClientConfig *config.Client
	// contains filtered or unexported fields
}

func NewProxy 

func NewProxy(
	ctx context.Context,
	connPool pool.IPool, pluginRegistry *plugin.Registry,
	elastic, reuseElasticClients bool,
	healthCheckPeriod time.Duration,
	clientConfig *config.Client, logger zerolog.Logger,
	pluginTimeout time.Duration,
) *Proxy

NewProxy creates a new proxy.

func (*Proxy) AvailableConnections added in v0.5.0 

func (pr *Proxy) AvailableConnections() []string

AvailableConnections returns a list of available connections.

func (*Proxy) BusyConnections added in v0.5.0 

func (pr *Proxy) BusyConnections() []string

BusyConnections returns a list of busy connections.

func (*Proxy) Connect 

func (pr *Proxy) Connect(conn net.Conn) *gerr.GatewayDError

Connect maps a server connection from the available connection pool to a incoming connection. It returns an error if the pool is exhausted. If the pool is elastic, it creates a new client and maps it to the incoming connection.

func (*Proxy) Disconnect 

func (pr *Proxy) Disconnect(conn net.Conn) *gerr.GatewayDError

Disconnect removes the client from the busy connection pool and tries to recycle the server connection.

func (*Proxy) IsExhausted added in v0.1.0 

func (pr *Proxy) IsExhausted() bool

IsExhausted checks if the available connection pool is exhausted.

func (*Proxy) IsHealthy added in v0.8.3 

func (pr *Proxy) IsHealthy(client *Client) (*Client, *gerr.GatewayDError)

IsHealthy checks if the pool is exhausted or the client is disconnected.

func (*Proxy) PassThroughToClient added in v0.8.3 

func (pr *Proxy) PassThroughToClient(conn net.Conn, stack *Stack) *gerr.GatewayDError

PassThroughToClient sends the data from the server to the client.

func (*Proxy) PassThroughToServer added in v0.8.3 

func (pr *Proxy) PassThroughToServer(conn net.Conn, stack *Stack) *gerr.GatewayDError

PassThroughToServer sends the data from the client to the server.

func (*Proxy) Shutdown 

func (pr *Proxy) Shutdown()

Shutdown closes all connections and clears the connection pools.

type Request added in v0.8.3 

type Request struct {
	Data []byte
}

type Server 

type Server struct {
	Network      string // tcp/udp/unix
	Address      string
	Options      Option
	Status       config.Status
	TickInterval time.Duration
	// contains filtered or unexported fields
}

func NewServer added in v0.0.2 

func NewServer(
	ctx context.Context,
	network, address string,
	tickInterval time.Duration,
	options Option,
	proxy IProxy,
	logger zerolog.Logger,
	pluginRegistry *plugin.Registry,
	pluginTimeout time.Duration,
) *Server

NewServer creates a new server.

func (*Server) IsRunning added in v0.0.2 

func (s *Server) IsRunning() bool

IsRunning returns true if the server is running.

func (*Server) OnBoot 

func (s *Server) OnBoot(engine Engine) Action

OnBoot is called when the server is booted. It calls the OnBooting and OnBooted hooks. It also sets the status to running, which is used to determine if the server should be running or shutdown.

func (*Server) OnClose 

func (s *Server) OnClose(conn net.Conn, err error) Action

OnClose is called when a connection is closed. It calls the OnClosing and OnClosed hooks. It also recycles the connection back to the available connection pool, unless the pool is elastic and reuse is disabled.

func (*Server) OnOpen 

func (s *Server) OnOpen(conn net.Conn) ([]byte, Action)

OnOpen is called when a new connection is opened. It calls the OnOpening and OnOpened hooks. It also checks if the server is at the soft or hard limit and closes the connection if it is.

func (*Server) OnShutdown 

func (s *Server) OnShutdown()

OnShutdown is called when the server is shutting down. It calls the OnShutdown hooks.

func (*Server) OnTick 

func (s *Server) OnTick() (time.Duration, Action)

OnTick is called every TickInterval. It calls the OnTick hooks.

func (*Server) OnTraffic 

func (s *Server) OnTraffic(conn net.Conn, stopConnection chan struct{}) Action

OnTraffic is called when data is received from the client. It calls the OnTraffic hooks. It then passes the traffic to the proxied connection.

func (*Server) Run 

func (s *Server) Run() *gerr.GatewayDError

Run starts the server and blocks until the server is stopped. It calls the OnRun hooks.

func (*Server) Shutdown 

func (s *Server) Shutdown()

Shutdown stops the server.

type Stack added in v0.8.3 

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

func NewStack added in v0.8.3 

func NewStack() *Stack

func (*Stack) Clear added in v0.8.3 

func (s *Stack) Clear()

func (*Stack) GetLastRequest added in v0.8.3 

func (s *Stack) GetLastRequest() *Request

func (*Stack) PopLastRequest added in v0.8.3 

func (s *Stack) PopLastRequest() *Request

func (*Stack) Push added in v0.8.3 

func (s *Stack) Push(req *Request)

func (*Stack) UpdateLastRequest added in v0.8.3 

func (s *Stack) UpdateLastRequest(req *Request)

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.