diff options
author | FUJITA Tomonori <fujita.tomonori@lab.ntt.co.jp> | 2018-10-28 21:09:16 +0900 |
---|---|---|
committer | FUJITA Tomonori <fujita.tomonori@lab.ntt.co.jp> | 2018-10-28 21:46:31 +0900 |
commit | 03cc4f441d6ad1dbf41dc51b365993c8f63fa91d (patch) | |
tree | 14c6e7177cbbe9f8de1cc4154c933823b1152d1a /pkg | |
parent | f8bea14d20a61c2947866a82ddd5a74af4c82c73 (diff) |
server: make NewNeighborFromAPIStruct() and NewPeerGroupFromAPIStruct() unexported
Signed-off-by: FUJITA Tomonori <fujita.tomonori@lab.ntt.co.jp>
Diffstat (limited to 'pkg')
-rw-r--r-- | pkg/server/grpc_server.go | 74 | ||||
-rw-r--r-- | pkg/server/server.go | 8 |
2 files changed, 41 insertions, 41 deletions
diff --git a/pkg/server/grpc_server.go b/pkg/server/grpc_server.go index 81244bb0..1d99cfc0 100644 --- a/pkg/server/grpc_server.go +++ b/pkg/server/grpc_server.go @@ -510,7 +510,7 @@ func (s *Server) DeleteVrf(ctx context.Context, r *api.DeleteVrfRequest) (*empty return &empty.Empty{}, s.bgpServer.DeleteVrf(ctx, r) } -func ReadMpGracefulRestartFromAPIStruct(c *config.MpGracefulRestart, a *api.MpGracefulRestart) { +func readMpGracefulRestartFromAPIStruct(c *config.MpGracefulRestart, a *api.MpGracefulRestart) { if c == nil || a == nil { return } @@ -519,7 +519,7 @@ func ReadMpGracefulRestartFromAPIStruct(c *config.MpGracefulRestart, a *api.MpGr } } -func ReadAfiSafiConfigFromAPIStruct(c *config.AfiSafiConfig, a *api.AfiSafiConfig) { +func readAfiSafiConfigFromAPIStruct(c *config.AfiSafiConfig, a *api.AfiSafiConfig) { if c == nil || a == nil { return } @@ -528,7 +528,7 @@ func ReadAfiSafiConfigFromAPIStruct(c *config.AfiSafiConfig, a *api.AfiSafiConfi c.Enabled = a.Enabled } -func ReadAfiSafiStateFromAPIStruct(s *config.AfiSafiState, a *api.AfiSafiConfig) { +func readAfiSafiStateFromAPIStruct(s *config.AfiSafiState, a *api.AfiSafiConfig) { if s == nil || a == nil { return } @@ -536,7 +536,7 @@ func ReadAfiSafiStateFromAPIStruct(s *config.AfiSafiState, a *api.AfiSafiConfig) s.Family = bgp.AfiSafiToRouteFamily(uint16(a.Family.Afi), uint8(a.Family.Safi)) } -func ReadPrefixLimitFromAPIStruct(c *config.PrefixLimit, a *api.PrefixLimit) { +func readPrefixLimitFromAPIStruct(c *config.PrefixLimit, a *api.PrefixLimit) { if c == nil || a == nil { return } @@ -544,7 +544,7 @@ func ReadPrefixLimitFromAPIStruct(c *config.PrefixLimit, a *api.PrefixLimit) { c.Config.ShutdownThresholdPct = config.Percentage(a.ShutdownThresholdPct) } -func ReadApplyPolicyFromAPIStruct(c *config.ApplyPolicy, a *api.ApplyPolicy) { +func readApplyPolicyFromAPIStruct(c *config.ApplyPolicy, a *api.ApplyPolicy) { if c == nil || a == nil { return } @@ -568,7 +568,7 @@ func ReadApplyPolicyFromAPIStruct(c *config.ApplyPolicy, a *api.ApplyPolicy) { } } -func ReadRouteSelectionOptionsFromAPIStruct(c *config.RouteSelectionOptions, a *api.RouteSelectionOptions) { +func readRouteSelectionOptionsFromAPIStruct(c *config.RouteSelectionOptions, a *api.RouteSelectionOptions) { if c == nil || a == nil { return } @@ -582,7 +582,7 @@ func ReadRouteSelectionOptionsFromAPIStruct(c *config.RouteSelectionOptions, a * } } -func ReadUseMultiplePathsFromAPIStruct(c *config.UseMultiplePaths, a *api.UseMultiplePaths) { +func readUseMultiplePathsFromAPIStruct(c *config.UseMultiplePaths, a *api.UseMultiplePaths) { if c == nil || a == nil { return } @@ -606,7 +606,7 @@ func ReadUseMultiplePathsFromAPIStruct(c *config.UseMultiplePaths, a *api.UseMul } } -func ReadRouteTargetMembershipFromAPIStruct(c *config.RouteTargetMembership, a *api.RouteTargetMembership) { +func readRouteTargetMembershipFromAPIStruct(c *config.RouteTargetMembership, a *api.RouteTargetMembership) { if c == nil || a == nil { return } @@ -615,7 +615,7 @@ func ReadRouteTargetMembershipFromAPIStruct(c *config.RouteTargetMembership, a * } } -func ReadLongLivedGracefulRestartFromAPIStruct(c *config.LongLivedGracefulRestart, a *api.LongLivedGracefulRestart) { +func readLongLivedGracefulRestartFromAPIStruct(c *config.LongLivedGracefulRestart, a *api.LongLivedGracefulRestart) { if c == nil || a == nil { return } @@ -625,7 +625,7 @@ func ReadLongLivedGracefulRestartFromAPIStruct(c *config.LongLivedGracefulRestar } } -func ReadAddPathsFromAPIStruct(c *config.AddPaths, a *api.AddPaths) { +func readAddPathsFromAPIStruct(c *config.AddPaths, a *api.AddPaths) { if c == nil || a == nil { return } @@ -635,7 +635,7 @@ func ReadAddPathsFromAPIStruct(c *config.AddPaths, a *api.AddPaths) { } } -func NewNeighborFromAPIStruct(a *api.Peer) (*config.Neighbor, error) { +func newNeighborFromAPIStruct(a *api.Peer) (*config.Neighbor, error) { pconf := &config.Neighbor{} if a.Conf != nil { pconf.Config.PeerAs = a.Conf.PeerAs @@ -673,16 +673,16 @@ func NewNeighborFromAPIStruct(a *api.Peer) (*config.Neighbor, error) { for _, af := range a.AfiSafis { afiSafi := config.AfiSafi{} - ReadMpGracefulRestartFromAPIStruct(&afiSafi.MpGracefulRestart, af.MpGracefulRestart) - ReadAfiSafiConfigFromAPIStruct(&afiSafi.Config, af.Config) - ReadAfiSafiStateFromAPIStruct(&afiSafi.State, af.Config) - ReadApplyPolicyFromAPIStruct(&afiSafi.ApplyPolicy, af.ApplyPolicy) - ReadRouteSelectionOptionsFromAPIStruct(&afiSafi.RouteSelectionOptions, af.RouteSelectionOptions) - ReadUseMultiplePathsFromAPIStruct(&afiSafi.UseMultiplePaths, af.UseMultiplePaths) - ReadPrefixLimitFromAPIStruct(&afiSafi.PrefixLimit, af.PrefixLimits) - ReadRouteTargetMembershipFromAPIStruct(&afiSafi.RouteTargetMembership, af.RouteTargetMembership) - ReadLongLivedGracefulRestartFromAPIStruct(&afiSafi.LongLivedGracefulRestart, af.LongLivedGracefulRestart) - ReadAddPathsFromAPIStruct(&afiSafi.AddPaths, af.AddPaths) + readMpGracefulRestartFromAPIStruct(&afiSafi.MpGracefulRestart, af.MpGracefulRestart) + readAfiSafiConfigFromAPIStruct(&afiSafi.Config, af.Config) + readAfiSafiStateFromAPIStruct(&afiSafi.State, af.Config) + readApplyPolicyFromAPIStruct(&afiSafi.ApplyPolicy, af.ApplyPolicy) + readRouteSelectionOptionsFromAPIStruct(&afiSafi.RouteSelectionOptions, af.RouteSelectionOptions) + readUseMultiplePathsFromAPIStruct(&afiSafi.UseMultiplePaths, af.UseMultiplePaths) + readPrefixLimitFromAPIStruct(&afiSafi.PrefixLimit, af.PrefixLimits) + readRouteTargetMembershipFromAPIStruct(&afiSafi.RouteTargetMembership, af.RouteTargetMembership) + readLongLivedGracefulRestartFromAPIStruct(&afiSafi.LongLivedGracefulRestart, af.LongLivedGracefulRestart) + readAddPathsFromAPIStruct(&afiSafi.AddPaths, af.AddPaths) pconf.AfiSafis = append(pconf.AfiSafis, afiSafi) } } @@ -717,7 +717,7 @@ func NewNeighborFromAPIStruct(a *api.Peer) (*config.Neighbor, error) { pconf.GracefulRestart.Config.LongLivedEnabled = a.GracefulRestart.LonglivedEnabled pconf.GracefulRestart.State.LocalRestarting = a.GracefulRestart.LocalRestarting } - ReadApplyPolicyFromAPIStruct(&pconf.ApplyPolicy, a.ApplyPolicy) + readApplyPolicyFromAPIStruct(&pconf.ApplyPolicy, a.ApplyPolicy) if a.Transport != nil { pconf.Transport.Config.LocalAddress = a.Transport.LocalAddress pconf.Transport.Config.PassiveMode = a.Transport.PassiveMode @@ -758,11 +758,11 @@ func NewNeighborFromAPIStruct(a *api.Peer) (*config.Neighbor, error) { } } } - ReadAddPathsFromAPIStruct(&pconf.AddPaths, a.AddPaths) + readAddPathsFromAPIStruct(&pconf.AddPaths, a.AddPaths) return pconf, nil } -func NewPeerGroupFromAPIStruct(a *api.PeerGroup) (*config.PeerGroup, error) { +func newPeerGroupFromAPIStruct(a *api.PeerGroup) (*config.PeerGroup, error) { pconf := &config.PeerGroup{} if a.Conf != nil { pconf.Config.PeerAs = a.Conf.PeerAs @@ -781,16 +781,16 @@ func NewPeerGroupFromAPIStruct(a *api.PeerGroup) (*config.PeerGroup, error) { for _, af := range a.AfiSafis { afiSafi := config.AfiSafi{} - ReadMpGracefulRestartFromAPIStruct(&afiSafi.MpGracefulRestart, af.MpGracefulRestart) - ReadAfiSafiConfigFromAPIStruct(&afiSafi.Config, af.Config) - ReadAfiSafiStateFromAPIStruct(&afiSafi.State, af.Config) - ReadApplyPolicyFromAPIStruct(&afiSafi.ApplyPolicy, af.ApplyPolicy) - ReadRouteSelectionOptionsFromAPIStruct(&afiSafi.RouteSelectionOptions, af.RouteSelectionOptions) - ReadUseMultiplePathsFromAPIStruct(&afiSafi.UseMultiplePaths, af.UseMultiplePaths) - ReadPrefixLimitFromAPIStruct(&afiSafi.PrefixLimit, af.PrefixLimits) - ReadRouteTargetMembershipFromAPIStruct(&afiSafi.RouteTargetMembership, af.RouteTargetMembership) - ReadLongLivedGracefulRestartFromAPIStruct(&afiSafi.LongLivedGracefulRestart, af.LongLivedGracefulRestart) - ReadAddPathsFromAPIStruct(&afiSafi.AddPaths, af.AddPaths) + readMpGracefulRestartFromAPIStruct(&afiSafi.MpGracefulRestart, af.MpGracefulRestart) + readAfiSafiConfigFromAPIStruct(&afiSafi.Config, af.Config) + readAfiSafiStateFromAPIStruct(&afiSafi.State, af.Config) + readApplyPolicyFromAPIStruct(&afiSafi.ApplyPolicy, af.ApplyPolicy) + readRouteSelectionOptionsFromAPIStruct(&afiSafi.RouteSelectionOptions, af.RouteSelectionOptions) + readUseMultiplePathsFromAPIStruct(&afiSafi.UseMultiplePaths, af.UseMultiplePaths) + readPrefixLimitFromAPIStruct(&afiSafi.PrefixLimit, af.PrefixLimits) + readRouteTargetMembershipFromAPIStruct(&afiSafi.RouteTargetMembership, af.RouteTargetMembership) + readLongLivedGracefulRestartFromAPIStruct(&afiSafi.LongLivedGracefulRestart, af.LongLivedGracefulRestart) + readAddPathsFromAPIStruct(&afiSafi.AddPaths, af.AddPaths) pconf.AfiSafis = append(pconf.AfiSafis, afiSafi) } } @@ -825,7 +825,7 @@ func NewPeerGroupFromAPIStruct(a *api.PeerGroup) (*config.PeerGroup, error) { pconf.GracefulRestart.Config.LongLivedEnabled = a.GracefulRestart.LonglivedEnabled pconf.GracefulRestart.State.LocalRestarting = a.GracefulRestart.LocalRestarting } - ReadApplyPolicyFromAPIStruct(&pconf.ApplyPolicy, a.ApplyPolicy) + readApplyPolicyFromAPIStruct(&pconf.ApplyPolicy, a.ApplyPolicy) if a.Transport != nil { pconf.Transport.Config.LocalAddress = a.Transport.LocalAddress pconf.Transport.Config.PassiveMode = a.Transport.PassiveMode @@ -841,7 +841,7 @@ func NewPeerGroupFromAPIStruct(a *api.PeerGroup) (*config.PeerGroup, error) { pconf.State.PeerAs = a.Info.PeerAs pconf.State.PeerType = config.IntToPeerTypeMap[int(a.Info.PeerType)] } - ReadAddPathsFromAPIStruct(&pconf.AddPaths, a.AddPaths) + readAddPathsFromAPIStruct(&pconf.AddPaths, a.AddPaths) return pconf, nil } @@ -1771,7 +1771,7 @@ func newGlobalFromAPIStruct(a *api.Global) *config.Global { } applyPolicy := &config.ApplyPolicy{} - ReadApplyPolicyFromAPIStruct(applyPolicy, a.ApplyPolicy) + readApplyPolicyFromAPIStruct(applyPolicy, a.ApplyPolicy) global := &config.Global{ Config: config.GlobalConfig{ diff --git a/pkg/server/server.go b/pkg/server/server.go index 0428a25b..d2953be7 100644 --- a/pkg/server/server.go +++ b/pkg/server/server.go @@ -2576,7 +2576,7 @@ func (server *BgpServer) addNeighbor(c *config.Neighbor) error { func (s *BgpServer) AddPeerGroup(ctx context.Context, r *api.AddPeerGroupRequest) error { return s.mgmtOperation(func() error { - c, err := NewPeerGroupFromAPIStruct(r.PeerGroup) + c, err := newPeerGroupFromAPIStruct(r.PeerGroup) if err != nil { return err } @@ -2586,7 +2586,7 @@ func (s *BgpServer) AddPeerGroup(ctx context.Context, r *api.AddPeerGroupRequest func (s *BgpServer) AddPeer(ctx context.Context, r *api.AddPeerRequest) error { return s.mgmtOperation(func() error { - c, err := NewNeighborFromAPIStruct(r.Peer) + c, err := newNeighborFromAPIStruct(r.Peer) if err != nil { return err } @@ -2712,7 +2712,7 @@ func (s *BgpServer) updatePeerGroup(pg *config.PeerGroup) (needsSoftResetIn bool func (s *BgpServer) UpdatePeerGroup(ctx context.Context, r *api.UpdatePeerGroupRequest) (rsp *api.UpdatePeerGroupResponse, err error) { doSoftreset := false err = s.mgmtOperation(func() error { - pg, err := NewPeerGroupFromAPIStruct(r.PeerGroup) + pg, err := newPeerGroupFromAPIStruct(r.PeerGroup) if err != nil { return err } @@ -2820,7 +2820,7 @@ func (s *BgpServer) updateNeighbor(c *config.Neighbor) (needsSoftResetIn bool, e func (s *BgpServer) UpdateNeighbor(ctx context.Context, r *api.UpdatePeerRequest) (rsp *api.UpdatePeerResponse, err error) { doSoftReset := false err = s.mgmtOperation(func() error { - c, err := NewNeighborFromAPIStruct(r.Peer) + c, err := newNeighborFromAPIStruct(r.Peer) if err != nil { return err } |