rpc

README

rpc.go

Documentation

Index

• Constants
• Variables
• type AcceptClient
• type Client
  • func NewClient() (*Client, error)
  • func (c *Client) Close()
  • func (c *Client) DialAndServe(address string, password []byte, salt []byte) error
  • func (c *Client) NextRequestId(cb func(*Message)) uint32
  • func (c *Client) OnReply(msg *Message)
  • func (c *Client) Reconnect(second time.Duration)
  • func (c *Client) Send(tag uint32, data []byte, cb func(*Message)) (err error)
• type Message
  • func (m *Message) Reply(tag uint32, payload []byte)
• type MessageType
• type Server
  • func NewServer() (*Server, error)
  • func (s *Server) NextRequestId(cb func(*Message)) uint32
  • func (s *Server) Send(id uint64, tag uint32, data []byte, cb func(*Message)) (n int, err error)
  • func (s *Server) Serve(address string, password []byte, salt []byte) error

Constants

const (
	MessageTypeKeep  = MessageType(1)
	MessageTypeData  = MessageType(2)
	MessageTypeReply = MessageType(3)
)

Variables

var (
	ErrorMessageFormatInvalid = errors.New("message format invalid")
	ErrorConnectIdInvalid     = errors.New("connect id invalid")
	ErrorConnectionInvalid    = errors.New("connection invalid")
)

Types

type AcceptClient

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

type Client

type Client struct {
	ReadTimeout  time.Duration
	WriteTimeout time.Duration

	OnConnected func()
	OnClose     func()
	OnData      func(message *Message)
	// contains filtered or unexported fields
}

func NewClient

func NewClient() (*Client, error)

func (*Client) Close

func (c *Client) Close()

func (*Client) DialAndServe

func (c *Client) DialAndServe(address string, password []byte, salt []byte) error

func (*Client) NextRequestId

func (c *Client) NextRequestId(cb func(*Message)) uint32

func (*Client) OnReply

func (c *Client) OnReply(msg *Message)

func (*Client) Reconnect

func (c *Client) Reconnect(second time.Duration)

func (*Client) Send

func (c *Client) Send(tag uint32, data []byte, cb func(*Message)) (err error)

type Message

type Message struct {
	Type    MessageType
	Payload []byte
	Tag     uint32
	// contains filtered or unexported fields
}

func (*Message) Reply

func (m *Message) Reply(tag uint32, payload []byte)

type MessageType

type MessageType uint8

type Server

type Server struct {
	ReadTimeout  time.Duration
	WriteTimeout time.Duration

	OnNew   func(id uint64)
	OnData  func(id uint64, message *Message)
	OnClose func(id uint64)
	// contains filtered or unexported fields
}

func NewServer

func NewServer() (*Server, error)

创建服务器

func (*Server) NextRequestId

func (s *Server) NextRequestId(cb func(*Message)) uint32

func (*Server) Send

func (s *Server) Send(id uint64, tag uint32, data []byte, cb func(*Message)) (n int, err error)

func (*Server) Serve

func (s *Server) Serve(address string, password []byte, salt []byte) error