FSMgr

Documentation

Index

• type FSBfdMgr
  • func NewFSBfdMgr(logger *logging.Writer, fileName string) (*FSBfdMgr, error)
  • func (mgr *FSBfdMgr) CreateBfdSession(ipAddr string, iface string, sessionParam string) (bool, error)
  • func (mgr *FSBfdMgr) DeleteBfdSession(ipAddr string, iface string) (bool, error)
  • func (mgr *FSBfdMgr) SetupSubSocket(address string) (*nanomsg.SubSocket, error)
  • func (mgr *FSBfdMgr) Start()
• type FSIntfMgr
  • func NewFSIntfMgr(logger *logging.Writer, fileName string) (*FSIntfMgr, error)
  • func (mgr *FSIntfMgr) GetIPv4Information(ifIndex int32) (string, error)
  • func (mgr *FSIntfMgr) GetIPv4Intfs() []*config.IntfStateInfo
  • func (mgr *FSIntfMgr) GetIPv6Information(ifIndex int32) (string, error)
  • func (mgr *FSIntfMgr) GetIPv6Intfs() []*config.IntfStateInfo
  • func (mgr *FSIntfMgr) GetIPv6Neighbors() []*config.IntfStateInfo
  • func (mgr *FSIntfMgr) GetIfIndex(ifIndex, ifType int) int32
  • func (m *FSIntfMgr) GetLogicalIntfInfo() []config.IntfMapInfo
  • func (m *FSIntfMgr) GetPortInfo() []config.IntfMapInfo
  • func (m *FSIntfMgr) GetVlanInfo() []config.IntfMapInfo
  • func (mgr *FSIntfMgr) PortStateChange()
  • func (mgr *FSIntfMgr) Start()
• type FSPolicyMgr
  • func NewFSPolicyMgr(logger *logging.Writer, fileName string) *FSPolicyMgr
  • func (mgr *FSPolicyMgr) Start()
• type FSRouteMgr
  • func NewFSRouteMgr(logger *logging.Writer, fileName string) (*FSRouteMgr, error)
  • func (mgr *FSRouteMgr) ApplyPolicy(applyList []*config.ApplyPolicyInfo, undoList []*config.ApplyPolicyInfo)
  • func (mgr *FSRouteMgr) CreateRoute(cfg *config.RouteConfig)
  • func (mgr *FSRouteMgr) DeleteRoute(cfg *config.RouteConfig)
  • func (mgr *FSRouteMgr) GetNextHopInfo(ipAddr string, ifIndex int32) (*config.NextHopInfo, error)
  • func (mgr *FSRouteMgr) GetRoutes() ([]*config.RouteInfo, []*config.RouteInfo)
  • func (mgr *FSRouteMgr) Start()
  • func (mgr *FSRouteMgr) UpdateRoute(cfg *config.RouteConfig, op string)
  • func (mgr *FSRouteMgr) UpdateV4Route(cfg *config.RouteConfig, nhInfo []*ribd.NextHopInfo, patch []*ribd.PatchOpInfo)
  • func (mgr *FSRouteMgr) UpdateV6Route(cfg *config.RouteConfig, nhInfo []*ribd.NextHopInfo, patch []*ribd.PatchOpInfo)

Types

type FSBfdMgr

type FSBfdMgr struct {
	// contains filtered or unexported fields
}

BFD manager will handle all the communication with bfd daemon

func NewFSBfdMgr

func NewFSBfdMgr(logger *logging.Writer, fileName string) (*FSBfdMgr, error)

Init bfd manager with bfd client as its core

func (*FSBfdMgr) CreateBfdSession

func (mgr *FSBfdMgr) CreateBfdSession(ipAddr string, iface string, sessionParam string) (bool, error)

func (*FSBfdMgr) DeleteBfdSession

func (mgr *FSBfdMgr) DeleteBfdSession(ipAddr string, iface string) (bool, error)

func (*FSBfdMgr) SetupSubSocket

func (mgr *FSBfdMgr) SetupSubSocket(address string) (*nanomsg.SubSocket, error)

func (*FSBfdMgr) Start

func (mgr *FSBfdMgr) Start()

Do any necessary init. Called from server..

type FSIntfMgr

type FSIntfMgr struct {
	AsicdClient *asicdServices.ASICDServicesClient
	NdpdClient  *ndpd.NDPDServicesClient
	// contains filtered or unexported fields
}

Interface manager will handle all the communication with asicd

func NewFSIntfMgr

func NewFSIntfMgr(logger *logging.Writer, fileName string) (*FSIntfMgr, error)

Interface manager is responsible for handling asicd notifications and hence

* we are creating asicd client

func (*FSIntfMgr) GetIPv4Information

func (mgr *FSIntfMgr) GetIPv4Information(ifIndex int32) (string, error)

func (*FSIntfMgr) GetIPv4Intfs

func (mgr *FSIntfMgr) GetIPv4Intfs() []*config.IntfStateInfo

func (*FSIntfMgr) GetIPv6Information

func (mgr *FSIntfMgr) GetIPv6Information(ifIndex int32) (string, error)

func (*FSIntfMgr) GetIPv6Intfs

func (mgr *FSIntfMgr) GetIPv6Intfs() []*config.IntfStateInfo

func (*FSIntfMgr) GetIPv6Neighbors

func (mgr *FSIntfMgr) GetIPv6Neighbors() []*config.IntfStateInfo

func (*FSIntfMgr) GetIfIndex

func (mgr *FSIntfMgr) GetIfIndex(ifIndex, ifType int) int32

func (*FSIntfMgr) GetLogicalIntfInfo

func (m *FSIntfMgr) GetLogicalIntfInfo() []config.IntfMapInfo

func (*FSIntfMgr) GetPortInfo

func (m *FSIntfMgr) GetPortInfo() []config.IntfMapInfo

func (*FSIntfMgr) GetVlanInfo

func (m *FSIntfMgr) GetVlanInfo() []config.IntfMapInfo

func (*FSIntfMgr) PortStateChange

func (mgr *FSIntfMgr) PortStateChange()

func (*FSIntfMgr) Start

func (mgr *FSIntfMgr) Start()

Do any necessary init. Called from server..

type FSPolicyMgr

type FSPolicyMgr struct {
	// contains filtered or unexported fields
}

@FUTURE: this will be using in future if FlexSwitch is planning to support

* daemon which is handling policy statments

func NewFSPolicyMgr

func NewFSPolicyMgr(logger *logging.Writer, fileName string) *FSPolicyMgr

Init policy manager with specific needs

func (*FSPolicyMgr) Start

func (mgr *FSPolicyMgr) Start()

Start nano msg socket with ribd

type FSRouteMgr

type FSRouteMgr struct {
	// contains filtered or unexported fields
}

Router manager will handle all the communication with ribd

func NewFSRouteMgr

func NewFSRouteMgr(logger *logging.Writer, fileName string) (*FSRouteMgr, error)

Init route manager with ribd client as its core

func (*FSRouteMgr) ApplyPolicy

func (mgr *FSRouteMgr) ApplyPolicy(applyList []*config.ApplyPolicyInfo, undoList []*config.ApplyPolicyInfo)

func (*FSRouteMgr) CreateRoute

func (mgr *FSRouteMgr) CreateRoute(cfg *config.RouteConfig)

func (*FSRouteMgr) DeleteRoute

func (mgr *FSRouteMgr) DeleteRoute(cfg *config.RouteConfig)

func (*FSRouteMgr) GetNextHopInfo

func (mgr *FSRouteMgr) GetNextHopInfo(ipAddr string, ifIndex int32) (*config.NextHopInfo, error)

func (*FSRouteMgr) GetRoutes

func (mgr *FSRouteMgr) GetRoutes() ([]*config.RouteInfo, []*config.RouteInfo)

func (*FSRouteMgr) Start

func (mgr *FSRouteMgr) Start()

Start nano msg socket with ribd

func (*FSRouteMgr) UpdateRoute

func (mgr *FSRouteMgr) UpdateRoute(cfg *config.RouteConfig, op string)

func (*FSRouteMgr) UpdateV4Route

func (mgr *FSRouteMgr) UpdateV4Route(cfg *config.RouteConfig, nhInfo []*ribd.NextHopInfo, patch []*ribd.PatchOpInfo)

func (*FSRouteMgr) UpdateV6Route

func (mgr *FSRouteMgr) UpdateV6Route(cfg *config.RouteConfig, nhInfo []*ribd.NextHopInfo, patch []*ribd.PatchOpInfo)