inactivity

Documentation

Index

• func CloseClientConn(cc ClientConn)
• type ClientConn
• type KeepAlive
  • func NewKeepAlive(maxRetries uint32, onInactive OnInactiveFunc, ...) *KeepAlive
  • func (m *KeepAlive) OnInactive(cc ClientConn)
• type Monitor
  • func NewInactivityMonitor(duration time.Duration, onInactive OnInactiveFunc) Monitor
  • func NewNilMonitor() Monitor
• type OnInactiveFunc

Functions

func CloseClientConn

func CloseClientConn(cc ClientConn)

Types

type ClientConn

type ClientConn = interface {
	Context() context.Context
	Close() error
}

type KeepAlive

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

func NewKeepAlive

func NewKeepAlive(maxRetries uint32, onInactive OnInactiveFunc, sendPing func(cc ClientConn, receivePong func()) (func(), error)) *KeepAlive

func (*KeepAlive) OnInactive

func (m *KeepAlive) OnInactive(cc ClientConn)

type Monitor

type Monitor = interface {
	CheckInactivity(now time.Time, cc ClientConn)
	Notify()
}

func NewInactivityMonitor

func NewInactivityMonitor(duration time.Duration, onInactive OnInactiveFunc) Monitor

func NewNilMonitor

func NewNilMonitor() Monitor

type OnInactiveFunc

type OnInactiveFunc = func(cc ClientConn)