Documentation ¶
Index ¶
- 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) 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) EchoLeaderOnly(ctx *edge.RequestCtx, req *service.EchoRequest, res *service.EchoResponse)
- func (h *Handlers) EchoTunnel(ctx *edge.RequestCtx, req *service.EchoRequest, res *service.EchoResponse)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func InitTestServer ¶ added in v0.0.6
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 ¶ added in v0.1.9
func (h *Handlers) EchoDelay(ctx *edge.RequestCtx, req *service.EchoRequest, res *service.EchoResponse)
func (*Handlers) EchoLeaderOnly ¶ added in v0.1.5
func (h *Handlers) EchoLeaderOnly(ctx *edge.RequestCtx, req *service.EchoRequest, res *service.EchoResponse)
func (*Handlers) EchoTunnel ¶ added in v0.1.5
func (h *Handlers) EchoTunnel(ctx *edge.RequestCtx, req *service.EchoRequest, res *service.EchoResponse)
Click to show internal directories.
Click to hide internal directories.