rpc

package
v0.0.0-...-be0592b Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 31, 2019 License: GPL-3.0 Imports: 22 Imported by: 0

README

cc rpc

相对 go rpc 优势

  • 使用function接口而非反射, 提高调用效率
  • client 支持服务发现
  • client 支持连接池, 可以同时连接多个服务端
  • client 支持断链重连, 而 go rpc 的client一旦连接断掉后不在重连, 调用Call会直接报错

Documentation

Index

Constants

View Source 
const (
	// MagicVersion is the cc rpc protocol version
	MagicVersion = uint16(0x1b01) // cmdb01
)

Variables

View Source 
var (
	//ErrRWTimeout r/w operation timeout
	ErrRWTimeout       = errors.New("r/w timeout")
	ErrPingTimeout     = errors.New("Ping timeout")
	ErrCommandNotFount = errors.New("Command not found")
	ErrStreamStoped    = errors.New("Stream stoped")
)

Errors define

Functions

func Dial 

func Dial(connect string) (*client, error)

func DialHTTPPath 

func DialHTTPPath(network, address, path string) (*client, error)

DialHTTPPath connects to an HTTP RPC server at the specified network address and path.

func NewClient 

func NewClient(conn net.Conn, compress string) (*client, error)

NewClient replica client

Types

type BinaryWire 

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

BinaryWire implements Wire interface

func NewBinaryWire 

func NewBinaryWire(rwc io.ReadWriteCloser, compress string) (*BinaryWire, error)

NewBinaryWire returns a new BinaryWire

func (*BinaryWire) Close 

func (w *BinaryWire) Close() error

Close close the wire

func (*BinaryWire) Read 

func (w *BinaryWire) Read(msg *Message) error

func (*BinaryWire) Write 

func (w *BinaryWire) Write(msg *Message) error

type Client 

type Client interface {
	Call(cmd string, input interface{}, result interface{}) error
	CallStream(cmd string, input interface{}) (*StreamMessage, error)
	Ping() error
	TargetID() string
	Close() error
}

type ClientConfig 

type ClientConfig struct {
	Address string
}

type Codec 

type Codec interface {
	Decode(data []byte, v interface{}) error
	Encode(v interface{}) ([]byte, error)
}

Codec define a codec 

var BSONCodec Codec = new(bsonCodec)

BSONCodec implements Codec interface 

var JSONCodec Codec = new(jsonCodec)

JSONCodec implements Codec interface

type Compressor 

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

func (*Compressor) Flush 

func (c *Compressor) Flush() (err error)

func (*Compressor) Read 

func (c *Compressor) Read(p []byte) (n int, err error)

func (*Compressor) Write 

func (c *Compressor) Write(p []byte) (n int, err error)

type HandlerFunc 

type HandlerFunc func(Request) (interface{}, error)

HandlerFunc define a HandlerFunc

type HandlerStreamFunc 

type HandlerStreamFunc func(Request, ServerStream) error

HandlerStreamFunc define a HandlerStreamFunc

type Message 

type Message struct {
	Data []byte
	// contains filtered or unexported fields
}

Message define a rpc message

func (*Message) Decode 

func (msg *Message) Decode(value interface{}) error

Decode decode the message data

func (*Message) Encode 

func (msg *Message) Encode(value interface{}) error

Encode encode the value to message data

func (*Message) String 

func (msg *Message) String() string

type MessageType 

type MessageType uint32

MessageType define 

const (
	TypeRequest MessageType = iota
	TypeResponse
	TypeStream
	TypeError
	TypeClose
	TypePing
	TypeStreamClose
)

MessageType enumeration

func (MessageType) String 

func (t MessageType) String() string

type Pool 

type Pool struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewClientPool 

func NewClientPool(network string, getServer types.GetServerFunc, path string) (*Pool, error)

func (*Pool) Call 

func (p *Pool) Call(cmd string, input interface{}, result interface{}) (err error)

func (*Pool) CallStream 

func (p *Pool) CallStream(cmd string, input interface{}) (*StreamMessage, error)

func (*Pool) Close 

func (p *Pool) Close() (err error)

func (*Pool) Ping 

func (p *Pool) Ping() (err error)

func (*Pool) TargetID 

func (p *Pool) TargetID() string

type Request 

type Request interface {
	Decode(value interface{}) error
}

Request define a request interface

type Server 

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

Server define

func NewServer 

func NewServer() *Server

NewServer returns new server

func (*Server) Handle 

func (s *Server) Handle(name string, f HandlerFunc)

Handle regist new handler

func (*Server) HandleStream 

func (s *Server) HandleStream(name string, f HandlerStreamFunc)

HandleStream regist new stream handler

func (*Server) ServeHTTP 

func (s *Server) ServeHTTP(resp http.ResponseWriter, req *http.Request)

ServeHTTP implements http.Handler interface

func (*Server) SetCodec 

func (s *Server) SetCodec(codec Codec)

SetCodec set server codec

type ServerSession 

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

ServerSession define a server session

func NewServerSession 

func NewServerSession(srv *Server, conn io.ReadWriteCloser, compress string) (*ServerSession, error)

NewServerSession returns a new ServerSession

func (*ServerSession) Run 

func (s *ServerSession) Run() error

Run run the Serssion

func (*ServerSession) Stop 

func (s *ServerSession) Stop()

Stop stop the server session

type ServerStream 

type ServerStream interface {
	Recv(result interface{}) error
	Send(data interface{}) error
}

ServerStream define interface

type StreamMessage 

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

StreamMessage define

func NewStreamMessage 

func NewStreamMessage(root *Message) *StreamMessage

NewStreamMessage returns a new StreamMessage

func (StreamMessage) Close 

func (m StreamMessage) Close() error

Close should only call by client

func (StreamMessage) Recv 

func (m StreamMessage) Recv(result interface{}) error

Recv receive message

func (StreamMessage) Send 

func (m StreamMessage) Send(data interface{}) error

Send send message

type Wire 

type Wire interface {
	Write(*Message) error
	Read(*Message) error
	Close() error
}

Wire define a wire

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.