server

Documentation

Index

• Constants
• func Run(opts []as.Option)
• type MessageReply
• type MessageRequest
  • func (msg *MessageRequest) Handle(stream as.ContextStream) (reply interface{})
• type MessageTimeout
  • func (msg MessageTimeout) Handle(stream as.ContextStream) (reply interface{})
• type SubWhoElseEvent
  • func (msg SubWhoElseEvent) Handle(stream as.ContextStream) (reply interface{})
• type WhoElse
  • func (msg WhoElse) Handle(stream as.ContextStream) (reply interface{})

Constants

const (
	// Publisher is the service(s) publisher
	Publisher = "example"
	// ServiceEcho is the echo service
	ServiceEcho = "echo.v1.0"
)

Functions

func Run

func Run(opts []as.Option)

Run runs the server.

Types

type MessageReply

type MessageReply struct {
	*MessageRequest
	Signature string
}

MessageReply is the message replied by server, with Num+1 and a signature of "yours echo.v1.0".

type MessageRequest

type MessageRequest struct {
	Msg string
	Num int32
}

MessageRequest is the message sent by client. Return MessageReply.

func (*MessageRequest) Handle

func (msg *MessageRequest) Handle(stream as.ContextStream) (reply interface{})

Handle handles msg.

type MessageTimeout

type MessageTimeout struct{}

MessageTimeout is for timeout test

func (MessageTimeout) Handle

func (msg MessageTimeout) Handle(stream as.ContextStream) (reply interface{})

Handle handles msg.

type SubWhoElseEvent

type SubWhoElseEvent struct{}

SubWhoElseEvent is used for clients to subscribe who else event which reports new incoming connection to the server. Return string.

func (SubWhoElseEvent) Handle

func (msg SubWhoElseEvent) Handle(stream as.ContextStream) (reply interface{})

Handle handles msg.

type WhoElse

type WhoElse struct{}

WhoElse reports all client addresses the server has so far. Return string.

func (WhoElse) Handle

func (msg WhoElse) Handle(stream as.ContextStream) (reply interface{})

Handle handles msg.