internal

Documentation

Index

• Variables
• type BaseHandler
• type Client
  • func NewClient(host string, newHandler func() Handler) *Client
  • func (g *Client) IsRunning() bool
  • func (g *Client) Start(reconnect bool) error
  • func (g *Client) Stop()
• type ClientHander
  • func (s *ClientHander) OnRecv(msg *actor_msg.ActorMessage)
  • func (s *ClientHander) OnSessionClosed()
  • func (s *ClientHander) OnSessionCreated()
• type Handler
• type Server
  • func NewServer(host string, newHandler func() Handler, ext interface{}) (*Server, error)
  • func (this *Server) Receive(stream actor_msg.ActorService_ReceiveServer) error
• type Session
  • func NewSession(stream Stream, handler Handler) *Session
  • func (s *Session) Id() int64
  • func (s *Session) Send(msg *actor_msg.ActorMessage) (err error)
  • func (s *Session) Stop()
• type Stream

Variables

var (
	NotRunning = errors.New("client has stopped")
)

var SessionId = _gen_session_id()

Types

type BaseHandler

type BaseHandler struct {
	*Session
}

type Client

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

func NewClient

func NewClient(host string, newHandler func() Handler) *Client

func (*Client) IsRunning

func (g *Client) IsRunning() bool

func (*Client) Start

func (g *Client) Start(reconnect bool) error

func (*Client) Stop

func (g *Client) Stop()

type ClientHander

type ClientHander struct {
	BaseHandler
	// contains filtered or unexported fields
}

func (*ClientHander) OnRecv

func (s *ClientHander) OnRecv(msg *actor_msg.ActorMessage)

func (*ClientHander) OnSessionClosed

func (s *ClientHander) OnSessionClosed()

func (*ClientHander) OnSessionCreated

func (s *ClientHander) OnSessionCreated()

type Handler

type Handler interface {
	OnRecv(*actor_msg.ActorMessage)
	OnSessionCreated()
	OnSessionClosed()
	// contains filtered or unexported methods
}

type Server

type Server struct {
	*grpc.Server
	// contains filtered or unexported fields
}

func NewServer

func NewServer(host string, newHandler func() Handler, ext interface{}) (*Server, error)

func (*Server) Receive

func (this *Server) Receive(stream actor_msg.ActorService_ReceiveServer) error

type Session

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

func NewSession

func NewSession(stream Stream, handler Handler) *Session

func (*Session) Id

func (s *Session) Id() int64

func (*Session) Send

func (s *Session) Send(msg *actor_msg.ActorMessage) (err error)

func (*Session) Stop

func (s *Session) Stop()

type Stream

type Stream interface {
	Send(*actor_msg.ActorMessage) error
	Recv() (*actor_msg.ActorMessage, error)
}