guds

Documentation

Index

• Constants
• Variables
• func BytesToInt(b []byte) int
• func IntToBytes(n int) []byte
• func MergeBytes(b1 []byte, b2 ...[]byte) []byte
• type Action
• type Callback
  • func (c *Callback) Catch(callback func(err error)) *Callback
  • func (c *Callback) Close()
  • func (c *Callback) Then(callback func(b interface{})) *Callback
• type Client
  • func DefaultClient() *Client
  • func NewClient(address string, connectTimeout time.Duration) (*Client, error)
  • func (c *Client) Send(api string, context interface{}) *Callback
  • func (c *Client) Start()
  • func (c *Client) Wait()
• type Conn
• type Data
• type Message
  • func NewMessage(api string, data interface{}) *Message
  • func (m *Message) Async() bool
  • func (m *Message) BodyBytes() []byte
  • func (m *Message) BodyLength() int
  • func (m *Message) BodyStringify() string
  • func (m *Message) Bytes() []byte
  • func (m *Message) GJson() gjson.Result
  • func (m *Message) Length() int
  • func (m *Message) Parse(b []byte) error
  • func (m *Message) Stringify() string
  • func (m *Message) ToData() Data
• type Reply
• type Router
  • func (h *Router) Get(api string) func(msg Data, c chan Reply)
  • func (h *Router) Register(api string, callback func(msg Data, c chan Reply))
  • func (h *Router) Remove(api string)
  • func (h *Router) RemoveAll()
• type Server
  • func DefaultServer() *Server
  • func NewServer(addr string, multicore bool, poolSize int, timeout time.Duration) *Server
  • func (u *Server) OnClosed(c gnet.Conn, err error) (action gnet.Action)
  • func (u *Server) OnInitComplete(srv gnet.Server) (action gnet.Action)
  • func (u *Server) OnOpened(c gnet.Conn) (out []byte, action gnet.Action)
  • func (u *Server) React(frame []byte, c gnet.Conn, out chan gnet.Out)
  • func (u *Server) RecordLog()
  • func (u *Server) Router() *Router
  • func (u *Server) Run()

Constants

const (
	DefaultAntsPoolSize = 1 << 18

	ExpiryDuration = 10 * time.Second

	Nonblocking = true
)

Variables

var (
	ErrTimeout = errors.New("request timeout! ")
)

Functions

func BytesToInt

func BytesToInt(b []byte) int

大端序字节转 int

func IntToBytes

func IntToBytes(n int) []byte

int 转大端序字节

func MergeBytes

func MergeBytes(b1 []byte, b2 ...[]byte) []byte

Types

type Action

type Action gnet.Action

const (
	None     Action = iota
	Close           // 连接关闭
	ShutDown        // 服务关闭
	Continue        // 消息继续
	Done            // 消息结束
)

type Callback

type Callback struct {
	Err  error
	Done bool
	Body chan interface{}
}

func (*Callback) Catch

func (c *Callback) Catch(callback func(err error)) *Callback

func (*Callback) Close

func (c *Callback) Close()

func (*Callback) Then

func (c *Callback) Then(callback func(b interface{})) *Callback

type Client

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

func DefaultClient

func DefaultClient() *Client

func NewClient

func NewClient(address string, connectTimeout time.Duration) (*Client, error)

func (*Client) Send

func (c *Client) Send(api string, context interface{}) *Callback

func (*Client) Start

func (c *Client) Start()

func (*Client) Wait

func (c *Client) Wait()

type Conn

type Conn gnet.Conn

type Data

type Data struct {
	gjson.Result
}

type Message

type Message struct {
	Api  string      `json:"api"`
	Body interface{} `json:"body,omitempty"`
	// contains filtered or unexported fields
}

func NewMessage

func NewMessage(api string, data interface{}) *Message

func (*Message) Async

func (m *Message) Async() bool

func (*Message) BodyBytes

func (m *Message) BodyBytes() []byte

func (*Message) BodyLength

func (m *Message) BodyLength() int

func (*Message) BodyStringify

func (m *Message) BodyStringify() string

func (*Message) Bytes

func (m *Message) Bytes() []byte

func (*Message) GJson

func (m *Message) GJson() gjson.Result

func (*Message) Length

func (m *Message) Length() int

func (*Message) Parse

func (m *Message) Parse(b []byte) error

func (*Message) Stringify

func (m *Message) Stringify() string

func (*Message) ToData

func (m *Message) ToData() Data

type Reply

type Reply struct {
	Async  bool
	Status Action
	Body   interface{}
}

type Router

type Router struct {
	sync.RWMutex
	Callbacks map[string]func(msg Data, c chan Reply)
}

func (*Router) Get

func (h *Router) Get(api string) func(msg Data, c chan Reply)

func (*Router) Register

func (h *Router) Register(api string, callback func(msg Data, c chan Reply))

func (*Router) Remove

func (h *Router) Remove(api string)

func (*Router) RemoveAll

func (h *Router) RemoveAll()

type Server

type Server struct {
	*gnet.EventServer
	// contains filtered or unexported fields
}

func DefaultServer

func DefaultServer() *Server

func NewServer

func NewServer(addr string, multicore bool, poolSize int, timeout time.Duration) *Server

func (*Server) OnClosed

func (u *Server) OnClosed(c gnet.Conn, err error) (action gnet.Action)

func (*Server) OnInitComplete

func (u *Server) OnInitComplete(srv gnet.Server) (action gnet.Action)

func (*Server) OnOpened

func (u *Server) OnOpened(c gnet.Conn) (out []byte, action gnet.Action)

func (*Server) React

func (u *Server) React(frame []byte, c gnet.Conn, out chan gnet.Out)

func (*Server) RecordLog

func (u *Server) RecordLog()

记录日志

func (*Server) Router

func (u *Server) Router() *Router

func (*Server) Run

func (u *Server) Run()