testEnv

Documentation

Index

• func Init()
• func InitEdgeServer(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) 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) EchoLeaderOnly(ctx *edge.RequestCtx, req *service.EchoRequest, res *service.EchoResponse)
  • func (h *Handlers) EchoTunnel(ctx *edge.RequestCtx, req *service.EchoRequest, res *service.EchoResponse)

Functions

func Init

func Init()

func InitEdgeServer

func InitEdgeServer(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 {
	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) EchoLeaderOnly

func (h *Handlers) EchoLeaderOnly(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)