testEnv

Documentation

Index

• func EdgeServer(serverID string, listenPort int, concurrency int, opts ...edge.Option) *edge.Server
• func Init()
• func ReceivedMessages() int32
• func ReceivedUpdates() int32
• func ResetCounters()
• func TestServer(serverID string) *edgetest.Server
• type Handlers
  • func (h *Handlers) Echo(ctx *edge.RequestCtx, req *service.EchoRequest, res *service.EchoResponse)
  • func (h *Handlers) EchoDelay(ctx *edge.RequestCtx, req *service.EchoRequest, res *service.EchoResponse)
  • func (h *Handlers) EchoInternal(ctx *edge.RequestCtx, req *service.EchoRequest, res *service.EchoResponse)
  • func (h *Handlers) EchoTunnel(ctx *edge.RequestCtx, req *service.EchoRequest, res *service.EchoResponse)
  • func (h *Handlers) Get(ctx *edge.RequestCtx, req *service.GetRequest, res *service.GetResponse)
  • func (h *Handlers) Set(ctx *edge.RequestCtx, req *service.SetRequest, res *service.SetResponse)

Functions

func EdgeServer

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

func Init

func Init()

func ReceivedMessages

func ReceivedMessages() int32

func ReceivedUpdates

func ReceivedUpdates() int32

func ResetCounters

func ResetCounters()

func TestServer

func TestServer(serverID string) *edgetest.Server

Types

type Handlers

type Handlers struct {
	ServerID string
}

func (*Handlers) Echo

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

func (*Handlers) EchoDelay

func (h *Handlers) EchoDelay(ctx *edge.RequestCtx, req *service.EchoRequest, res *service.EchoResponse)

func (*Handlers) EchoInternal

func (h *Handlers) EchoInternal(ctx *edge.RequestCtx, req *service.EchoRequest, res *service.EchoResponse)

func (*Handlers) EchoTunnel

func (h *Handlers) EchoTunnel(ctx *edge.RequestCtx, req *service.EchoRequest, res *service.EchoResponse)

func (*Handlers) Get

func (h *Handlers) Get(ctx *edge.RequestCtx, req *service.GetRequest, res *service.GetResponse)

func (*Handlers) Set

func (h *Handlers) Set(ctx *edge.RequestCtx, req *service.SetRequest, res *service.SetResponse)