net

Documentation

Index

• type Connection
  • func (c Connection) Close() (err error)
  • func (c Connection) RemoteAddr() string
  • func (c Connection) Send(bs []byte) (n int, err error)
• type NetEasyNetPlugin
  • func NewNetEasyNetPlugin(ctx context.Context, iconfig _interface.IConfig, handler _interface.IEasyNet) *NetEasyNetPlugin
  • func (g NetEasyNetPlugin) Run() error
• type NetServer
  • func NewNetServer(ctx context.Context, config *YamlConfig, handler _interface.IEasyNet) *NetServer
  • func (s *NetServer) Run() error
• type YamlConfig
  • func (n *YamlConfig) GetIp() string
  • func (n *YamlConfig) GetPort() int32
  • func (n *YamlConfig) GetProtocol() string

Types

type Connection

type Connection struct {
	Conn net.Conn
}

func (Connection) Close

func (c Connection) Close() (err error)

func (Connection) RemoteAddr

func (c Connection) RemoteAddr() string

func (Connection) Send

func (c Connection) Send(bs []byte) (n int, err error)

type NetEasyNetPlugin

type NetEasyNetPlugin struct {
	Conn net.Conn

	Ctx context.Context

	Config *YamlConfig

	Server *NetServer

	Handler _interface.IEasyNet
}

func NewNetEasyNetPlugin

func NewNetEasyNetPlugin(ctx context.Context, iconfig _interface.IConfig, handler _interface.IEasyNet) *NetEasyNetPlugin

func (NetEasyNetPlugin) Run

func (g NetEasyNetPlugin) Run() error

type NetServer

type NetServer struct {
	Ctx context.Context

	Network string
	Address string

	InputStreamMap map[string]_interface.IInputStream
	ConnectionMap  map[string]_interface.IConnection
	// contains filtered or unexported fields
}

func NewNetServer

func NewNetServer(ctx context.Context, config *YamlConfig, handler _interface.IEasyNet) *NetServer

func (*NetServer) Run

func (s *NetServer) Run() error

type YamlConfig

type YamlConfig struct {
	Protocol string `json:"protocol" yaml:"protocol"`
	Ip       string `json:"ip" yaml:"ip"`
	Port     int32  `json:"port" yaml:"port"`
}

func (*YamlConfig) GetIp

func (n *YamlConfig) GetIp() string

func (*YamlConfig) GetPort

func (n *YamlConfig) GetPort() int32

func (*YamlConfig) GetProtocol

func (n *YamlConfig) GetProtocol() string