meta

Documentation

Index

• func CreateTCPConnection(options TCPConnectionOptions) (gen.MetaBehavior, error)
• func CreateTCPServer(options TCPServerOptions) (gen.MetaBehavior, error)
• func CreateUDPServer(options UDPServerOptions) (gen.MetaBehavior, error)
• func CreateWebServer(options WebServerOptions) (gen.MetaBehavior, error)
• type MessageTCP
• type MessageTCPConnect
• type MessageTCPDisconnect
• type MessageUDP
• type MessageWebRequest
• type TCPConnectionOptions
• type TCPServerOptions
• type UDPServerOptions
• type WebHandler
  • func CreateWebHandler(options WebHandlerOptions) WebHandler
• type WebHandlerOptions
• type WebServerOptions

Functions

func CreateTCPConnection

func CreateTCPConnection(options TCPConnectionOptions) (gen.MetaBehavior, error)

func CreateTCPServer

func CreateTCPServer(options TCPServerOptions) (gen.MetaBehavior, error)

func CreateUDPServer

func CreateUDPServer(options UDPServerOptions) (gen.MetaBehavior, error)

func CreateWebServer

func CreateWebServer(options WebServerOptions) (gen.MetaBehavior, error)

Types

type MessageTCP

type MessageTCP struct {
	ID   gen.Alias
	Data []byte
}

type MessageTCPConnect

type MessageTCPConnect struct {
	ID         gen.Alias
	RemoteAddr net.Addr
	LocalAddr  net.Addr
}

type MessageTCPDisconnect

type MessageTCPDisconnect struct {
	ID gen.Alias
}

type MessageUDP

type MessageUDP struct {
	ID   gen.Alias
	Addr net.Addr
	Data []byte
}

type MessageWebRequest

type MessageWebRequest struct {
	Response http.ResponseWriter
	Request  *http.Request
	Done     func()
}

type TCPConnectionOptions

type TCPConnectionOptions struct {
	Host               string
	Port               uint16
	Process            gen.Atom
	CertManager        gen.CertManager
	BufferSize         int
	BufferPool         *sync.Pool
	KeepAlivePeriod    time.Duration
	InsecureSkipVerify bool
}

type TCPServerOptions

type TCPServerOptions struct {
	Host               string
	Port               uint16
	ProcessPool        []gen.Atom
	CertManager        gen.CertManager
	BufferSize         int
	BufferPool         *sync.Pool
	KeepAlivePeriod    time.Duration
	InsecureSkipVerify bool
}

type UDPServerOptions

type UDPServerOptions struct {
	Host       string
	Port       uint16
	Process    gen.Atom
	BufferSize int
	BufferPool *sync.Pool
}

type WebHandler

type WebHandler interface {
	http.Handler
	gen.MetaBehavior
}

func CreateWebHandler

func CreateWebHandler(options WebHandlerOptions) WebHandler

type WebHandlerOptions

type WebHandlerOptions struct {
	Worker         gen.Atom
	RequestTimeout time.Duration
}

type WebServerOptions

type WebServerOptions struct {
	Host        string
	Port        uint16
	CertManager gen.CertManager
	Handler     http.Handler
}