internal

package

v0.0.0-...-3d0ed7e Latest Latest Go to latest Published: Sep 12, 2023 License: Apache-2.0 Imports: 16 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

This section is empty.

This section is empty.

func HandlersDocs(serverType string, services map[string]*component.Service, getPtrNames bool) (map[string]interface{}, error)

HandlersDocs returns a map from route to input and output

type Route struct {
	SvType  string
	Service string
	Method  string
}

Route struct

func NewRoute(server, service, method string) *Route

NewRoute creates a new route

func (r *Route) Short() string

Short transforms the route into a string without the server type

func (r *Route) String() string

String transforms the route into a string

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

func NewTcpLink(conn net.Conn) *TcpLink

func (my *TcpLink) Close() error

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

func (my *TcpLink) GoLoop(heartbeatInterval time.Duration, onReadHandler road.OnReadHandler)

func (my *TcpLink) RemoteAddr() net.Addr

RemoteAddr returns the remote address.

func (my *TcpLink) Write(data []byte) (int, error)

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

func NewWsLink(conn net.Conn) *WsLink

func (my *WsLink) Close() error

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

func (my *WsLink) GoLoop(heartbeatInterval time.Duration, onReadHandler road.OnReadHandler)

func (my *WsLink) RemoteAddr() net.Addr

RemoteAddr returns the remote address.

func (my *WsLink) Write(data []byte) (int, error)