ping

Documentation

Overview

addr [4]byte use big endian

addr [4]byte use big endian

Index

• Variables
• func Call(ips [][4]byte, timeout int, retry int) ([]bool, error)
• func Kill() error
• func Run(rate uint32) error
• func Wait()
• type Server
  • func NewServer(ctx context.Context) *Server
  • func (p *Server) Go(ips [][4]byte, timeout, retry int, done chan *Task) *Task
  • func (p *Server) Kill() error
  • func (p *Server) Run(rate uint32) error
  • func (p *Server) Wait()
• type Task
  • func Go(ips [][4]byte, timeout, retry int, done chan *Task) *Task

Variables

var (
	ErrAcces      = errors.New("Permission denied (you must be root)")
	ErrNoRun      = errors.New("ping server is not running")
	ErrEmpty      = errors.New("empty list")
	DefaultServer = NewServer(context.Background())
)

Functions

func Call

func Call(ips [][4]byte, timeout int, retry int) ([]bool, error)

func Kill

func Kill() error

func Run

func Run(rate uint32) error

func Wait

func Wait()

Types

type Server

type Server struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewServer

func NewServer(ctx context.Context) *Server

func (*Server) Go

func (p *Server) Go(ips [][4]byte, timeout, retry int, done chan *Task) *Task

func (*Server) Kill

func (p *Server) Kill() error

func (*Server) Run

func (p *Server) Run(rate uint32) error

func (*Server) Wait

func (p *Server) Wait()

type Task

type Task struct {
	sync.RWMutex // for entry_list

	Timeout int64

	RetryLimit int
	Ips        [][4]byte
	Ret        []bool
	Done       chan *Task
	Error      error
	// contains filtered or unexported fields
}

func Go

func Go(ips [][4]byte, timeout, retry int, done chan *Task) *Task