rpc

Documentation

Index

• type Client
  • func NewClient() *Client
  • func (t *Client) Close()
  • func (t *Client) Connect(uri string) error
  • func (t *Client) Interrupt()
  • func (t *Client) NewServiceClient(serviceName string) ServiceClient
• type Server
  • func NewServer() *Server
  • func (t *Server) Close()
  • func (t *Server) PostEvent(id string, event interface{})
  • func (t *Server) RegisterService(serviceName string, service interface{}) error
  • func (t *Server) Serve() error
  • func (t *Server) Start(uri, eventsPath string) error
• type ServiceClient

Types

type Client

type Client struct {
	IsLogCalls        bool
	OnConnectionError func(err error)

	Latency      time.Duration
	BandWithMpbs float32
	// contains filtered or unexported fields
}

func NewClient

func NewClient() *Client

func (*Client) Close

func (t *Client) Close()

func (*Client) Connect

func (t *Client) Connect(uri string) error

func (*Client) Interrupt

func (t *Client) Interrupt()

func (*Client) NewServiceClient

func (t *Client) NewServiceClient(serviceName string) ServiceClient

type Server

type Server struct {
	URL       string
	EventsURL string
	// contains filtered or unexported fields
}

func NewServer

func NewServer() *Server

func (*Server) Close

func (t *Server) Close()

func (*Server) PostEvent

func (t *Server) PostEvent(id string, event interface{})

func (*Server) RegisterService

func (t *Server) RegisterService(serviceName string, service interface{}) error

func (*Server) Serve

func (t *Server) Serve() error

func (*Server) Start

func (t *Server) Start(uri, eventsPath string) error

type ServiceClient

type ServiceClient interface {
	Call(arg interface{}, rsp interface{}) error
}