keepalive

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

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

type Config struct {
	// Interval between two success pings
	Interval time.Duration
	// WaitForPong how long it will waits for pong response.
	WaitForPong time.Duration
	// NewRetryPolicy creates retry policy for the connection when ping fails.
	NewRetryPolicy RetryFuncFactory
}

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

type Option interface {
	// contains filtered or unexported methods
}

type RetryFunc = func() (when time.Time, err error)

type RetryFuncFactory = func() RetryFunc