meta

Documentation

Index

• func CreatePort(options PortOptions) (gen.MetaBehavior, error)
• 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 ChunkOptions
  • func (co ChunkOptions) IsValid() error
• type MessagePortData
• type MessagePortError
• type MessagePortStart
• type MessagePortTerminate
• type MessagePortText
• type MessageTCP
• type MessageTCPConnect
• type MessageTCPDisconnect
• type MessageUDP
• type MessageWebRequest
• type PortBinaryOptions
• type PortOptions
• type TCPAdvancedOptions
• type TCPConnectionOptions
• type TCPServerOptions
• type UDPServerOptions
• type WebHandler
  • func CreateWebHandler(options WebHandlerOptions) WebHandler
• type WebHandlerOptions
• type WebServerOptions

Functions

func CreatePort

func CreatePort(options PortOptions) (gen.MetaBehavior, error)

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 ChunkOptions

type ChunkOptions struct {
	Enable                     bool
	FixedLength                int
	HeaderSize                 int
	HeaderLengthPosition       int // within the header
	HeaderLengthSize           int // 1, 2 or 4
	HeaderLengthIncludesHeader bool
	MaxLength                  int
}

func (ChunkOptions) IsValid

func (co ChunkOptions) IsValid() error

type MessagePortData

type MessagePortData struct {
	ID   gen.Alias
	Tag  string
	Data []byte
}

type MessagePortError

type MessagePortError struct {
	ID    gen.Alias
	Tag   string
	Error error
}

type MessagePortStart

type MessagePortStart struct {
	ID  gen.Alias
	Tag string
}

type MessagePortTerminate

type MessagePortTerminate struct {
	ID  gen.Alias
	Tag string
}

type MessagePortText

type MessagePortText struct {
	ID   gen.Alias
	Tag  string
	Text string
}

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 PortBinaryOptions

type PortBinaryOptions struct {
	Enable                     bool
	ReadBufferSize             int
	ReadBufferPool             *sync.Pool
	ReadChunk                  ChunkOptions
	WriteBufferKeepAlive       []byte
	WriteBufferKeepAlivePeriod time.Duration
}

type PortOptions

type PortOptions struct {
	Cmd             string
	Args            []string
	Env             map[gen.Env]string
	EnableEnvMeta   bool
	EnableEnvOS     bool
	Tag             string
	Process         gen.Atom
	SplitFuncStdout bufio.SplitFunc
	SplitFuncStderr bufio.SplitFunc
	Binary          PortBinaryOptions
}

type TCPAdvancedOptions

type TCPAdvancedOptions struct {
	KeepAlivePeriod time.Duration
}

type TCPConnectionOptions

type TCPConnectionOptions struct {
	Host               string
	Port               uint16
	Process            gen.Atom
	CertManager        gen.CertManager
	InsecureSkipVerify bool

	ReadBufferSize             int
	ReadBufferPool             *sync.Pool
	ReadChunk                  ChunkOptions
	WriteBufferKeepAlive       []byte
	WriteBufferKeepAlivePeriod time.Duration

	Advanced TCPAdvancedOptions
}

type TCPServerOptions

type TCPServerOptions struct {
	Host               string
	Port               uint16
	ProcessPool        []gen.Atom
	CertManager        gen.CertManager
	InsecureSkipVerify bool

	ReadBufferSize             int
	ReadBufferPool             *sync.Pool
	ReadChunk                  ChunkOptions
	WriteBufferKeepAlive       []byte
	WriteBufferKeepAlivePeriod time.Duration

	Advanced TCPAdvancedOptions
}

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
}