Method ipvsService

engine/vserver.go:111–145

ipvsService returns an IPVS Service for the given service.

()

// ipvsService returns an IPVS Service for the given service.
func (s *service) ipvsService() *ipvs.Service {
	var flags ipvs.ServiceFlags
	if s.ventry.Persistence > 0 {
		flags |= ipvs.SFPersistent
	}
	if s.ventry.OnePacket {
		flags |= ipvs.SFOnePacket
	}
	// Enables fallback and port for hashing schedulers.
	// Maps to ipvs sh-fallback, sh-port, mh-fallback and mh-port.
	switch s.ventry.Scheduler {
	case seesaw.LBSchedulerSH:
		flags |= ipvs.SFSchedSHFallback | ipvs.SFSchedSHPort
	case seesaw.LBSchedulerMH:
		flags |= ipvs.SFSchedMHFallback | ipvs.SFSchedMHPort
	}
	var ip net.IP
	switch {
	case s.fwm > 0 && s.af == seesaw.IPv4:
		ip = net.IPv4zero
	case s.fwm > 0 && s.af == seesaw.IPv6:
		ip = net.IPv6zero
	default:
		ip = s.ip.IP()
	}
	return &ipvs.Service{
		Address:      ip,
		Protocol:     ipvs.IPProto(s.proto),
		Port:         s.port,
		Scheduler:    s.ventry.Scheduler.String(),
		FirewallMark: s.fwm,
		Flags:        flags,
		Timeout:      uint32(s.ventry.Persistence),
	}
}

// ipvsEqual returns true if two services have the same IPVS configuration.
// Transient state and the services' destinations are ignored.