semirpc

Documentation

Index

• Variables
• type ARClient
  • func (c *ARClient) Close() (err error)
  • func (c *ARClient) Do(req Request, resp Response) error
  • func (c *ARClient) DoAsyncSupport(req Request, resp Response, errch chan error)
  • func (c *ARClient) DoTimeout(req Request, resp Response, timeout <-chan time.Time) error
• type Client
  • func NewClient(client ClientCodec, respmk func() Response) *Client
  • func (c *Client) Close() error
  • func (c *Client) Do(req Request, resp Response) error
  • func (c *Client) DoAsyncSupport(req Request, resp Response, errch chan error)
  • func (c *Client) DoTimeout(req Request, resp Response, timeout <-chan time.Time) error
• type ClientCodec
• type Dialer
• type ErrorHandler
• type Request
• type Response
• type Server
  • func (s *Server) Serve(sc ServerCodec) error
• type ServerCodec
• type ServerError
  • func (s ServerError) Error() string
• type ServerHandler

Variables

var EClosed = errors.New("Connection Closed")

var EPipelineStall = errors.New("Pipeline-Stall")

Types

type ARClient

type ARClient struct {
	Addr   string
	Dial   Dialer
	MkResp func() Response
	// contains filtered or unexported fields
}

Auto-Reconnect-Client

func (*ARClient) Close

func (c *ARClient) Close() (err error)

func (*ARClient) Do

func (c *ARClient) Do(req Request, resp Response) error

func (*ARClient) DoAsyncSupport

func (c *ARClient) DoAsyncSupport(req Request, resp Response, errch chan error)

func (*ARClient) DoTimeout

func (c *ARClient) DoTimeout(req Request, resp Response, timeout <-chan time.Time) error

type Client

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

func NewClient

func NewClient(client ClientCodec, respmk func() Response) *Client

func (*Client) Close

func (c *Client) Close() error

func (*Client) Do

func (c *Client) Do(req Request, resp Response) error

func (*Client) DoAsyncSupport

func (c *Client) DoAsyncSupport(req Request, resp Response, errch chan error)

func (*Client) DoTimeout

func (c *Client) DoTimeout(req Request, resp Response, timeout <-chan time.Time) error

type ClientCodec

type ClientCodec interface {
	Close() error

	// Threadsafe
	Send(id uint64, r Request) error

	// Not threadsafe
	RecvId() (uint64, error)
	Recv(r Response) error
}

type Dialer

type Dialer func(addr string) (ClientCodec, error)

type ErrorHandler

type ErrorHandler func(e ServerError, req Request, resp Response)

type Request

type Request interface {
	ReadReq(r *bufio.Reader) error
	WriteReq(w *bufio.Writer) error
}

type Response

type Response interface {
	ReadResp(r *bufio.Reader) error
	WriteResp(w *bufio.Writer) error
}

type Server

type Server struct {
	Handle      ServerHandler
	Error       ErrorHandler
	Allocator   func() (req Request, resp Response)
	Concurrency int
	QueueMulti  int
	// contains filtered or unexported fields
}

func (*Server) Serve

func (s *Server) Serve(sc ServerCodec) error

type ServerCodec

type ServerCodec interface {
	Close() error

	// Threadsafe
	Send(id uint64, r Response) error

	// Not threadsafe
	RecvId() (uint64, error)
	Recv(r Request) error
}

type ServerError

type ServerError int

const (
	SE_None ServerError = iota
	SE_QueueOverflow
)

func (ServerError) Error

func (s ServerError) Error() string

type ServerHandler

type ServerHandler func(req Request, resp Response)