Function NewClient

pkg/zebra/zapi.go:1431–1516

NewClient returns a Client instance (Client constructor)

(logger *slog.Logger, network, address string, typ RouteType, version uint8, software Software, mplsLabelRangeSize uint32)

// NewClient returns a Client instance (Client constructor)
func NewClient(logger *slog.Logger, network, address string, typ RouteType, version uint8, software Software, mplsLabelRangeSize uint32) (*Client, error) {
	conn, err := net.Dial(network, address)
	if err != nil {
		return nil, err
	}
	outgoing := make(chan *Message)
	incoming := make(chan *Message, 64)
	if version < MinZapiVer {
		version = MinZapiVer
	} else if version > MaxZapiVer {
		version = MaxZapiVer
	}
	c := &Client{
		outgoing:      outgoing,
		incoming:      incoming,
		redistDefault: typ,
		conn:          conn,
		Version:       version,
		Software:      software,
		logger:        logger,
	}

	go func() {
		for {
			m, more := <-outgoing
			if more {
				b, err := m.Serialize(software)
				if err != nil {
					logger.Warn(fmt.Sprintf("failed to serialize: %v", m), slog.String("Topic", "Zebra"))

					continue
				}

				_, err = conn.Write(b)
				if err != nil {
					logger.Error("failed to write",
						slog.String("Topic", "Zebra"),
						slog.String("Error", err.Error()),
					)
					closeChannel(outgoing)
					return
				}
			} else {
				logger.Debug("finish outgoing loop",
					slog.String("Topic", "Zebra"))
				return
			}
		}
	}()

	// Send Hello/RouterIDAdd messages to negotiate the Zebra message version.
	c.SendHello()
	c.SendRouterIDAdd()

	if mplsLabelRangeSize > 0 && c.SupportMpls() {
		if err := c.sendLabelManagerConnect(true); err != nil {
			logger.Warn("failed to send label manager connect",
				slog.String("Topic", "Zebra"),