rpc

Documentation

Index

• Constants
• type ApiProcessor
• type Connection
  • func GetConnection(c *net.TCPConn) *Connection
  • func NewConnection(addr string) *Connection
  • func (conn *Connection) Close() error
  • func (conn *Connection) Connect() (err error)
  • func (conn *Connection) Send(packet *Packet) (*Packet, error)
  • func (conn *Connection) String() string
• type Node
  • func NewNode(name, addr string, processor ApiProcessor) (*Node, error)
  • func (node *Node) Close() error
  • func (node *Node) Run() (err error)
• type Packet
  • func (p *Packet) String() string
• type Params
  • func NewParams() Params
  • func (p Params) String() string

Constants

const (
	PT_REQUEST  = true
	PT_RESPONSE = false
)

Types

type ApiProcessor

type ApiProcessor interface {
	Start() (err error)
	ProcessRequest(req *Packet) (resp Params)
}

type Connection

type Connection struct {
	Addr string
	// contains filtered or unexported fields
}

func GetConnection

func GetConnection(c *net.TCPConn) *Connection

func NewConnection

func NewConnection(addr string) *Connection

func (*Connection) Close

func (conn *Connection) Close() error

func (*Connection) Connect

func (conn *Connection) Connect() (err error)

func (*Connection) Send

func (conn *Connection) Send(packet *Packet) (*Packet, error)

func (*Connection) String

func (conn *Connection) String() string

type Node

type Node struct {
	Name      string
	Addr      string
	Processor ApiProcessor
	// contains filtered or unexported fields
}

func NewNode

func NewNode(name, addr string, processor ApiProcessor) (*Node, error)

func (*Node) Close

func (node *Node) Close() error

func (*Node) Run

func (node *Node) Run() (err error)

type Packet

type Packet struct {
	Type  bool
	CmdID int
	Data  Params
}

func (*Packet) String

func (p *Packet) String() string

type Params

type Params map[string]string

func NewParams

func NewParams() Params

func (Params) String

func (p Params) String() string