Function InitialConfig

pkg/config/config.go:240–396

InitialConfig applies initial configuration to a pristine gobgp instance. It can only be called once for an instance. Subsequent changes to the configuration can be applied using UpdateConfig. The BgpConfigSet can be obtained by calling ReadConfigFile. If graceful restart behavior is desired, pass t

(ctx context.Context, bgpServer *server.BgpServer, newConfig *oc.BgpConfigSet, isGracefulRestart bool)

// obtained by calling ReadConfigFile. If graceful restart behavior is desired,
// pass true for isGracefulRestart. Otherwise, pass false.
func InitialConfig(ctx context.Context, bgpServer *server.BgpServer, newConfig *oc.BgpConfigSet, isGracefulRestart bool) (*oc.BgpConfigSet, error) {
	if err := bgpServer.StartBgp(ctx, &api.StartBgpRequest{
		Global: oc.NewGlobalFromConfigStruct(&newConfig.Global),
	}); err != nil {
		return nil, err
	}

	if newConfig.Zebra.Config.Enabled {
		tps := newConfig.Zebra.Config.RedistributeRouteTypeList
		l := make([]string, 0, len(tps))
		l = append(l, tps...)
		if err := bgpServer.EnableZebra(ctx, &api.EnableZebraRequest{
			Url:                  newConfig.Zebra.Config.Url,
			RouteTypes:           l,
			Version:              uint32(newConfig.Zebra.Config.Version),
			NexthopTriggerEnable: newConfig.Zebra.Config.NexthopTriggerEnable,
			NexthopTriggerDelay:  uint32(newConfig.Zebra.Config.NexthopTriggerDelay),
			MplsLabelRangeSize:   newConfig.Zebra.Config.MplsLabelRangeSize,
			SoftwareName:         newConfig.Zebra.Config.SoftwareName,
		}); err != nil {
			bgpServer.Log().Error("failed to set zebra config",
				slog.String("Topic", "config"), slog.Any("Error", err))
		}
	}

	if len(newConfig.Collector.Config.Url) > 0 {
		bgpServer.Log().Error("collector feature is not supported",
			slog.String("Topic", "config"))
	}

	for _, c := range newConfig.RpkiServers {
		if err := bgpServer.AddRpki(ctx, &api.AddRpkiRequest{
			Address:  c.Config.Address.String(),
			Port:     c.Config.Port,
			Lifetime: c.Config.RecordLifetime,
		}); err != nil {
			bgpServer.Log().Error("failed to set rpki config",
				slog.String("Topic", "config"), slog.Any("Error", err))
		}
	}
	f := func(t oc.BmpRouteMonitoringPolicyType) api.AddBmpRequest_MonitoringPolicy {
		switch t {
		case oc.BMP_ROUTE_MONITORING_POLICY_TYPE_PRE_POLICY:
			return api.AddBmpRequest_MONITORING_POLICY_PRE
		case oc.BMP_ROUTE_MONITORING_POLICY_TYPE_POST_POLICY:
			return api.AddBmpRequest_MONITORING_POLICY_POST
		case oc.BMP_ROUTE_MONITORING_POLICY_TYPE_BOTH:
			return api.AddBmpRequest_MONITORING_POLICY_BOTH
		case oc.BMP_ROUTE_MONITORING_POLICY_TYPE_LOCAL_RIB:
			return api.AddBmpRequest_MONITORING_POLICY_LOCAL
		case oc.BMP_ROUTE_MONITORING_POLICY_TYPE_ALL:
			return api.AddBmpRequest_MONITORING_POLICY_ALL
		}
		return api.AddBmpRequest_MONITORING_POLICY_UNSPECIFIED
	}

	for _, c := range newConfig.BmpServers {
		if err := bgpServer.AddBmp(ctx, &api.AddBmpRequest{