testEnv

Documentation

Index

• Variables
• func EchoHold(ctx *edge.RequestCtx, in *rony.MessageEnvelope)
• func EchoSimple(ctx *edge.RequestCtx, in *rony.MessageEnvelope)
• func Init()
• func InitEdgeServerWithWebsocket(serverID string, listenPort int, concurrency int, opts ...edge.Option) *edge.Server
• func InitTestServer(serverID string) *edgetest.Server
• func ReceivedMessages() int32
• func ReceivedUpdates() int32
• func ResetCounters()
• type Handlers
  • func (h Handlers) Ask(ctx *edge.RequestCtx, req *pb.AskRequest, res *pb.AskResponse)
  • func (h Handlers) Echo(ctx *edge.RequestCtx, req *pb.EchoRequest, res *pb.EchoResponse)
  • func (h Handlers) Func1(ctx *edge.RequestCtx, req *pb.Req1, res *pb.Res1)
  • func (h Handlers) Func2(ctx *edge.RequestCtx, req *pb.Req2, res *pb.Res2)

Variables

var (
	Server *edgetest.Server
)

Functions

func EchoHold

func EchoHold(ctx *edge.RequestCtx, in *rony.MessageEnvelope)

func EchoSimple

func EchoSimple(ctx *edge.RequestCtx, in *rony.MessageEnvelope)

func Init

func Init()

func InitEdgeServerWithWebsocket

func InitEdgeServerWithWebsocket(serverID string, listenPort int, concurrency int, opts ...edge.Option) *edge.Server

func InitTestServer

func InitTestServer(serverID string) *edgetest.Server

func ReceivedMessages

func ReceivedMessages() int32

func ReceivedUpdates

func ReceivedUpdates() int32

func ResetCounters

func ResetCounters()

Types

type Handlers

type Handlers struct{}

func (Handlers) Ask

func (h Handlers) Ask(ctx *edge.RequestCtx, req *pb.AskRequest, res *pb.AskResponse)

func (Handlers) Echo

func (h Handlers) Echo(ctx *edge.RequestCtx, req *pb.EchoRequest, res *pb.EchoResponse)

func (Handlers) Func1

func (h Handlers) Func1(ctx *edge.RequestCtx, req *pb.Req1, res *pb.Res1)

func (Handlers) Func2

func (h Handlers) Func2(ctx *edge.RequestCtx, req *pb.Req2, res *pb.Res2)