Unlock 30% off on Manual Testing Annual Plans this Holiday Season.

Copied to Clipboard!

Automation Advisor
K6
lib
NewHostAddress

How to use NewHostAddress method of lib Package

Best K6 code snippet using lib.NewHostAddress

dialer.go

Source:dialer.go

...54}55// HostAddress stores information about IP and port56// for a host.57type HostAddress net.TCPAddr58// NewHostAddress creates a pointer to a new address with an IP object.59func NewHostAddress(ip net.IP, portString string) (*HostAddress, error) {60	var port int61	if portString != "" {62		var err error63		if port, err = strconv.Atoi(portString); err != nil {64			return nil, err65		}66	}67	return &HostAddress{68		IP:   ip,69		Port: port,70	}, nil71}72// String converts a HostAddress into a string.73func (h *HostAddress) String() string {74	return (*net.TCPAddr)(h).String()75}76// MarshalText implements the encoding.TextMarshaler interface.77// The encoding is the same as returned by String, with one exception:78// When len(ip) is zero, it returns an empty slice.79func (h *HostAddress) MarshalText() ([]byte, error) {80	if h == nil || len(h.IP) == 0 {81		return []byte(""), nil82	}83	if len(h.IP) != net.IPv4len && len(h.IP) != net.IPv6len {84		return nil, &net.AddrError{Err: "invalid IP address", Addr: h.IP.String()}85	}86	return []byte(h.String()), nil87}88// UnmarshalText implements the encoding.TextUnmarshaler interface.89// The IP address is expected in a form accepted by ParseIP.90func (h *HostAddress) UnmarshalText(text []byte) error {91	if len(text) == 0 {92		return &net.ParseError{Type: "IP address", Text: "<nil>"}93	}94	ip, port, err := splitHostPort(text)95	if err != nil {96		return err97	}98	nh, err := NewHostAddress(ip, port)99	if err != nil {100		return err101	}102	*h = *nh103	return nil104}105func splitHostPort(text []byte) (net.IP, string, error) {106	host, port, err := net.SplitHostPort(string(text))107	if err != nil {108		// This error means that there is no port.109		// Make host the full text.110		host = string(text)111	}112	ip := net.ParseIP(host)113	if ip == nil {114		return nil, "", &net.ParseError{Type: "IP address", Text: host}115	}116	return ip, port, nil117}118// Dialer wraps net.Dialer and provides k6 specific functionality -119// tracing, blacklists and DNS cache and aliases.120type Dialer struct {121	net.Dialer122	Resolver         Resolver123	Blacklist        []*IPNet124	BlockedHostnames *types.HostnameTrie125	Hosts            map[string]*HostAddress126	BytesRead    int64127	BytesWritten int64128}129// NewDialer constructs a new Dialer with the given DNS resolver.130func NewDialer(dialer net.Dialer, resolver Resolver) *Dialer {131	return &Dialer{132		Dialer:   dialer,133		Resolver: resolver,134	}135}136// BlackListedIPError is an error that is returned when a given IP is blacklisted137type BlackListedIPError struct {138	ip  net.IP139	net *IPNet140}141func (b BlackListedIPError) Error() string {142	return fmt.Sprintf("IP (%s) is in a blacklisted range (%s)", b.ip, b.net)143}144// BlockedHostError is returned when a given hostname is blocked145type BlockedHostError struct {146	hostname string147	match    string148}149func (b BlockedHostError) Error() string {150	return fmt.Sprintf("hostname (%s) is in a blocked pattern (%s)", b.hostname, b.match)151}152// DialContext wraps the net.Dialer.DialContext and handles the k6 specifics153func (d *Dialer) DialContext(ctx context.Context, proto, addr string) (net.Conn, error) {154	dialAddr, err := d.getDialAddr(addr)155	if err != nil {156		return nil, err157	}158	conn, err := d.Dialer.DialContext(ctx, proto, dialAddr)159	if err != nil {160		return nil, err161	}162	conn = &Conn{conn, &d.BytesRead, &d.BytesWritten}163	return conn, err164}165// GetTrail creates a new NetTrail instance with the Dialer166// sent and received data metrics and the supplied times and tags.167// TODO: Refactor this according to168// https://github.com/loadimpact/k6/pull/1203#discussion_r337938370169func (d *Dialer) GetTrail(170	startTime, endTime time.Time, tags *stats.SampleTags,171) *NetTrail {172	bytesWritten := atomic.SwapInt64(&d.BytesWritten, 0)173	bytesRead := atomic.SwapInt64(&d.BytesRead, 0)174	samples := []stats.Sample{175		{176			Time:   endTime,177			Metric: metrics.DataSent,178			Value:  float64(bytesWritten),179			Tags:   tags,180		},181		{182			Time:   endTime,183			Metric: metrics.DataReceived,184			Value:  float64(bytesRead),185			Tags:   tags,186		},187	}188	// if fullIteration {189	// 	samples = append(samples, stats.Sample{190	// 		Time:   endTime,191	// 		//Metric: metrics.IterationDuration,192	// 		Value:  stats.D(endTime.Sub(startTime)),193	// 		Tags:   tags,194	// 	})195	// 	if emitIterations {196	// 		samples = append(samples, stats.Sample{197	// 			Time:   endTime,198	// 			//Metric: metrics.Iterations,199	// 			Value:  1,200	// 			Tags:   tags,201	// 		})202	// 	}203	// }204	return &NetTrail{205		BytesRead:    bytesRead,206		BytesWritten: bytesWritten,207		// FullIteration: fullIteration,208		StartTime: startTime,209		EndTime:   endTime,210		Tags:      tags,211		Samples:   samples,212	}213}214func (d *Dialer) getDialAddr(addr string) (string, error) {215	remote, err := d.findRemote(addr)216	if err != nil {217		return "", err218	}219	for _, ipnet := range d.Blacklist {220		if ipnet.Contains(remote.IP) {221			return "", BlackListedIPError{ip: remote.IP, net: ipnet}222		}223	}224	return remote.String(), nil225}226func (d *Dialer) findRemote(addr string) (*HostAddress, error) {227	host, port, err := net.SplitHostPort(addr)228	if err != nil {229		return nil, err230	}231	ip := net.ParseIP(host)232	if d.BlockedHostnames != nil && ip == nil {233		if match, blocked := d.BlockedHostnames.Contains(host); blocked {234			return nil, BlockedHostError{hostname: host, match: match}235		}236	}237	remote, err := d.getConfiguredHost(addr, host, port)238	if err != nil || remote != nil {239		return remote, err240	}241	if ip != nil {242		return NewHostAddress(ip, port)243	}244	ip, err = d.Resolver.LookupIP(host)245	if err != nil {246		return nil, err247	}248	if ip == nil {249		return nil, fmt.Errorf("lookup %s: no such host", host)250	}251	return NewHostAddress(ip, port)252}253func (d *Dialer) getConfiguredHost(addr, host, port string) (*HostAddress, error) {254	if remote, ok := d.Hosts[addr]; ok {255		return remote, nil256	}257	if remote, ok := d.Hosts[host]; ok {258		if remote.Port != 0 || port == "" {259			return remote, nil260		}261		newPort, err := strconv.Atoi(port)262		if err != nil {263			return nil, err264		}265		newRemote := *remote...

NewHostAddress

Using AI Code Generation

1import (2func main() {3	h, err := lib.NewHostAddress("localhost", 8080)4	if err != nil {5		fmt.Println(err)6	}7	fmt.Println(h)8}

NewHostAddress

Using AI Code Generation

1import (2type MyPlugin struct {3}4func main() {5	plugin.Start(new(MyPlugin))6}7func (p *MyPlugin) Run(context plugin.PluginContext, args []string) {8	fmt.Println("Hello world")9}10func (p *MyPlugin) GetMetadata() plugin.PluginMetadata {11	return plugin.PluginMetadata{12		Version: plugin.VersionType{13		},14		Commands: []plugin.Command{15			{16				Flags: []plugin.Flag{17					plugin.StringFlag{18					},19				},20			},21		},22	}23}

NewHostAddress

Using AI Code Generation

1import (2type args struct {3}4func (args) Version() string {5}6func (args) Description() string {7}8func main() {9	arg.MustParse(&args)10	ip := net.ParseIP(args.IP)11	if ip == nil {12		fmt.Printf("'%s' is not a valid IP address.\n", args.IP)13	}14	host, err := lib.NewHostAddress(ip)15	if err != nil {16		fmt.Printf("'%s' is not a valid host address.\n", args.IP)17	}18	fmt.Printf("Host address for '%s' is '%s'.\n", ip, host)19}

NewHostAddress

Using AI Code Generation

1import (2type args struct {3}4func (args) Version() string {5}6func (args) Description() string {7}8func main() {9	arg.MustParse(&args)10	ip := net.ParseIP(args.IP)11	if ip == nil {12		fmt.Printf("'%s' is not a valid IP address.\n", args.IP)13	}14	host, err := lib.NewHostAddress(ip)15	if err != nil {16		fmt.Printf("'%s' is not a valid host address.\n", args.IP)17	}18	fmt.Printf("Host address for '%s' is '%s'.\n", ip, host)19}

NewHostAddress

Using AI Code Generation

1import (2func main() {3	lib1 := lib.NewHostAddress()4	lib1.SetHostAddress("localhost")5	fmt.Println("Address: ", lib1.GetHostAddress())6}

Automation Testing Tutorials

Learn to execute automation testing from scratch with LambdaTest Learning Hub. Right from setting up the prerequisites to run your first automation test, to following best practices and diving deeper into advanced test scenarios. LambdaTest Learning Hubs compile a list of step-by-step guides to help you be proficient with different test automation frameworks i.e. Selenium, Cypress, TestNG etc.