socket

Documentation

Index

• type Listener
  • func (l *Listener) AsyncAccept(acceptCallback func(*TCP))
  • func (l *Listener) IsStopped() bool
  • func (l *Listener) Listen(port uint) error
  • func (l *Listener) StopAccept()
• type RPC
  • func (r *RPC) Call(funcName, body string) []byte
  • func (r *RPC) Connect(addr string, port uint, whenDisconnect func()) bool
  • func (r *RPC) Connected() bool
  • func (r *RPC) Init()
• type RPCClient
  • func (r *RPCClient) Send(str string)
• type RPCServer
  • func (r *RPCServer) RunServer(port uint16) error
  • func (r *RPCServer) SetEventFunctor(functor func(*RPCClient, string, []string))
  • func (r *RPCServer) StopServer()
  • func (r *RPCServer) UseXlog()
• type TCP
  • func (t *TCP) Close()
  • func (t *TCP) Connect(address string, port uint) bool
  • func (t *TCP) ConnectionHandler(f func(), d func())
  • func (t *TCP) DelayClose()
  • func (t *TCP) GetLocalAddr() string
  • func (t *TCP) GetRemoteAddr() string
  • func (t *TCP) IsConnected() bool
  • func (t *TCP) Peek(size int) ([]byte, error)
  • func (t *TCP) Read(buffer []byte, size int) error
  • func (t *TCP) Send(buf []byte)

Types

type Listener

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

Listener is for server

func (*Listener) AsyncAccept

func (l *Listener) AsyncAccept(acceptCallback func(*TCP))

AsyncAccept is accept on background

func (*Listener) IsStopped

func (l *Listener) IsStopped() bool

IsStopped Listener가 종료된 상태인지 여부

func (*Listener) Listen

func (l *Listener) Listen(port uint) error

Listen is for server

func (*Listener) StopAccept

func (l *Listener) StopAccept()

StopAccept will be stopped service

type RPC

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

RPC is using tcp

func (*RPC) Call

func (r *RPC) Call(funcName, body string) []byte

func (*RPC) Connect

func (r *RPC) Connect(addr string, port uint, whenDisconnect func()) bool

func (*RPC) Connected

func (r *RPC) Connected() bool

func (*RPC) Init

func (r *RPC) Init()

type RPCClient

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

func (*RPCClient) Send

func (r *RPCClient) Send(str string)

type RPCServer

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

func (*RPCServer) RunServer

func (r *RPCServer) RunServer(port uint16) error

func (*RPCServer) SetEventFunctor

func (r *RPCServer) SetEventFunctor(functor func(*RPCClient, string, []string))

func (*RPCServer) StopServer

func (r *RPCServer) StopServer()

func (*RPCServer) UseXlog

func (r *RPCServer) UseXlog()

type TCP

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

TCP is

func (*TCP) Close

func (t *TCP) Close()

Close 바로 끊김 ㅋ

func (*TCP) Connect

func (t *TCP) Connect(address string, port uint) bool

Connect is

func (*TCP) ConnectionHandler

func (t *TCP) ConnectionHandler(f func(), d func())

ConnectionHandler is

func (*TCP) DelayClose

func (t *TCP) DelayClose()

DelayClose 곧 끊김 ㅋ

func (*TCP) GetLocalAddr

func (t *TCP) GetLocalAddr() string

GetLocalAddr 로컬 주소

func (*TCP) GetRemoteAddr

func (t *TCP) GetRemoteAddr() string

GetRemoteAddr 접속중인 peer 의 원격지 주소

func (*TCP) IsConnected

func (t *TCP) IsConnected() bool

IsConnected is connected or not

func (*TCP) Peek

func (t *TCP) Peek(size int) ([]byte, error)

func (*TCP) Read

func (t *TCP) Read(buffer []byte, size int) error

func (*TCP) Send

func (t *TCP) Send(buf []byte)

Send is