mycelium

Documentation

Index

• type HostError
• type HostFilter
• type Network
  • func New(options ...Option) (*Network, error)
  • func (n *Network) Add(hosts ...host.Host) error
  • func (n *Network) Hosts() (hosts []host.Host)
  • func (n *Network) Run(ctx context.Context, concurrency uint16, ...) <-chan *HostError
  • func (n *Network) Size() int
  • func (n *Network) StreamHosts(ctx context.Context) chan host.Host
  • func (n *Network) Sub(filter HostFilter) *Network
• type Option

Types

type HostError

type HostError struct {
	Host  host.Host
	Error error
}

type HostFilter

type HostFilter func(host.Host) bool

type Network

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

func New

func New(options ...Option) (*Network, error)

func (*Network) Add

func (n *Network) Add(hosts ...host.Host) error

func (*Network) Hosts

func (n *Network) Hosts() (hosts []host.Host)

func (*Network) Run

func (n *Network) Run(ctx context.Context, concurrency uint16, handler func(context.Context, host.Host) error) <-chan *HostError

to stop at first error set concurrency=1 and stop at first error

func (*Network) Size

func (n *Network) Size() int

func (*Network) StreamHosts

func (n *Network) StreamHosts(ctx context.Context) chan host.Host

func (*Network) Sub

func (n *Network) Sub(filter HostFilter) *Network

type Option

type Option func(*Network) error