actors

Documentation

Index

• type Client
  • func NewClient(conn *websocket.Conn, coordinator actors.PID) *Client
  • func (s *Client) PostStop(ctx context.Context) error
  • func (s *Client) PreStart(ctx context.Context) error
  • func (s *Client) Receive(ctx actors.ReceiveContext)
• type Coordinator
  • func NewCoordinator() *Coordinator
  • func (s *Coordinator) PostStop(ctx context.Context) error
  • func (s *Coordinator) PreStart(ctx context.Context) error
  • func (s *Coordinator) Receive(ctx actors.ReceiveContext)
• type Room
  • func NewRoom(name string) *Room
  • func (r *Room) PostStop(ctx context.Context) error
  • func (r *Room) PreStart(ctx context.Context) error
  • func (r *Room) Receive(ctx actors.ReceiveContext)

Types

type Client

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

func NewClient

func NewClient(conn *websocket.Conn, coordinator actors.PID) *Client

func (*Client) PostStop

func (s *Client) PostStop(ctx context.Context) error

PostStop handles post shutdown process

func (*Client) PreStart

func (s *Client) PreStart(ctx context.Context) error

PreStart handles pre-start process

func (*Client) Receive

func (s *Client) Receive(ctx actors.ReceiveContext)

Receive handle messages sent to the server

type Coordinator

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

func NewCoordinator

func NewCoordinator() *Coordinator

NewCoordinator creates a new instance of Coordinator

func (*Coordinator) PostStop

func (s *Coordinator) PostStop(ctx context.Context) error

PostStop implements actors.Actor.

func (*Coordinator) PreStart

func (s *Coordinator) PreStart(ctx context.Context) error

PreStart implements actors.Actor.

func (*Coordinator) Receive

func (s *Coordinator) Receive(ctx actors.ReceiveContext)

Receive implements actors.Actor.

type Room

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

Room represents the room

func NewRoom

func NewRoom(name string) *Room

NewRoom creates a new Room

func (*Room) PostStop

func (r *Room) PostStop(ctx context.Context) error

PostStop implements actors.Actor.

func (*Room) PreStart

func (r *Room) PreStart(ctx context.Context) error

PreStart implements actors.Actor.

func (*Room) Receive

func (r *Room) Receive(ctx actors.ReceiveContext)

Receive implements actors.Actor.