keepalive

Documentation

Index

• Constants
• func ConsummateKeepaliveParams(kp *keepalive.ServerParameters)
• func KeepaliveMiddleware(kgetter func(ch *channel.Channel) *Keeper) less.Middleware
• type Keeper
  • func NewKeeper(kp *keepalive.ServerParameters, state state.Stater) *Keeper
  • func (k *Keeper) Close()
  • func (k *Keeper) Keepalive()

Constants

const (
	Ping   = "Ping"
	Pong   = "Pong"
	GoAway = "Go Away"
)

Keepalive messages

Functions

func ConsummateKeepaliveParams

func ConsummateKeepaliveParams(kp *keepalive.ServerParameters)

ConsummateKeepaliveParams consummates and checks keepalive parameters

func KeepaliveMiddleware

func KeepaliveMiddleware(kgetter func(ch *channel.Channel) *Keeper) less.Middleware

KeepaliveMiddleware returns a middleware to intercept and handle keepalive messages

Types

type Keeper

type Keeper struct {
	// contains filtered or unexported fields
}

func NewKeeper

func NewKeeper(kp *keepalive.ServerParameters, state state.Stater) *Keeper

func (*Keeper) Close

func (k *Keeper) Close()

func (*Keeper) Keepalive

func (k *Keeper) Keepalive()