rpc

package
v0.0.0-...-ac9ef1f Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 5, 2017 License: Apache-2.0 Imports: 27 Imported by: 0

Documentation

Overview

server.go

server.go

Index

Constants

View Source 
const ClientsFileName string = "clients.json"
View Source 
const DBName string = "UsrConfDb.db"

Variables

This section is empty.

Functions

func StartAsicdClient 

func StartAsicdClient(logger *logging.Writer, filePath string,
	asicdClient chan *asicdServices.ASICDServicesClient)

func StartBfddClient 

func StartBfddClient(logger *logging.Writer, filePath string, bfddClient chan *bfdd.BFDDServicesClient)

func StartNdpdClient 

func StartNdpdClient(logger *logging.Writer, filePath string, ndpdClient chan *ndpd.NDPDServicesClient)

func StartRibdClient 

func StartRibdClient(logger *logging.Writer, filePath string, ribdClient chan *ribd.RIBDServicesClient)

func StartServer 

func StartServer(logger *logging.Writer, handler *BGPHandler, filePath string)

Types

type BGPHandler 

type BGPHandler struct {
	PeerCommandCh chan PeerConfigCommands
	// contains filtered or unexported fields
}

func NewBGPHandler 

func NewBGPHandler(server *server.BGPServer, policyMgr *bgppolicy.BGPPolicyManager, logger *logging.Writer,
	dbUtil *dbutils.DBUtil, filePath string) *BGPHandler

func (*BGPHandler) ConvertV4NeighborFromThrift 

func (h *BGPHandler) ConvertV4NeighborFromThrift(bgpNeighbor *bgpd.BGPv4Neighbor, ip net.IP, ifIndex int32) (
	pConf config.NeighborConfig, err error)

func (*BGPHandler) ConvertV6NeighborFromThrift 

func (h *BGPHandler) ConvertV6NeighborFromThrift(bgpNeighbor *bgpd.BGPv6Neighbor, ip net.IP, ifIndex int32,
	ifName string) (pConf config.NeighborConfig, err error)

func (*BGPHandler) CreateBGPGlobal 

func (h *BGPHandler) CreateBGPGlobal(bgpGlobal *bgpd.BGPGlobal) (bool, error)

func (*BGPHandler) CreateBGPPolicyAction 

func (h *BGPHandler) CreateBGPPolicyAction(cfg *bgpd.BGPPolicyAction) (val bool, err error)

func (*BGPHandler) CreateBGPPolicyCondition 

func (h *BGPHandler) CreateBGPPolicyCondition(cfg *bgpd.BGPPolicyCondition) (val bool, err error)

func (*BGPHandler) CreateBGPPolicyDefinition 

func (h *BGPHandler) CreateBGPPolicyDefinition(cfg *bgpd.BGPPolicyDefinition) (val bool, err error)

func (*BGPHandler) CreateBGPPolicyStmt 

func (h *BGPHandler) CreateBGPPolicyStmt(cfg *bgpd.BGPPolicyStmt) (val bool, err error)

func (*BGPHandler) CreateBGPv4Aggregate 

func (h *BGPHandler) CreateBGPv4Aggregate(bgpAgg *bgpd.BGPv4Aggregate) (bool, error)

func (*BGPHandler) CreateBGPv4Neighbor 

func (h *BGPHandler) CreateBGPv4Neighbor(bgpNeighbor *bgpd.BGPv4Neighbor) (bool, error)

func (*BGPHandler) CreateBGPv4PeerGroup 

func (h *BGPHandler) CreateBGPv4PeerGroup(peerGroup *bgpd.BGPv4PeerGroup) (bool, error)

func (*BGPHandler) CreateBGPv6Aggregate 

func (h *BGPHandler) CreateBGPv6Aggregate(bgpAgg *bgpd.BGPv6Aggregate) (bool, error)

func (*BGPHandler) CreateBGPv6Neighbor 

func (h *BGPHandler) CreateBGPv6Neighbor(bgpNeighbor *bgpd.BGPv6Neighbor) (bool, error)

func (*BGPHandler) CreateBGPv6PeerGroup 

func (h *BGPHandler) CreateBGPv6PeerGroup(peerGroup *bgpd.BGPv6PeerGroup) (bool, error)

func (*BGPHandler) DeleteBGPGlobal 

func (h *BGPHandler) DeleteBGPGlobal(bgpGlobal *bgpd.BGPGlobal) (bool, error)

func (*BGPHandler) DeleteBGPPolicyAction 

func (h *BGPHandler) DeleteBGPPolicyAction(cfg *bgpd.BGPPolicyAction) (val bool, err error)

func (*BGPHandler) DeleteBGPPolicyCondition 

func (h *BGPHandler) DeleteBGPPolicyCondition(cfg *bgpd.BGPPolicyCondition) (val bool, err error)

func (*BGPHandler) DeleteBGPPolicyDefinition 

func (h *BGPHandler) DeleteBGPPolicyDefinition(cfg *bgpd.BGPPolicyDefinition) (val bool, err error)

func (*BGPHandler) DeleteBGPPolicyStmt 

func (h *BGPHandler) DeleteBGPPolicyStmt(cfg *bgpd.BGPPolicyStmt) (val bool, err error)

func (*BGPHandler) DeleteBGPv4Aggregate 

func (h *BGPHandler) DeleteBGPv4Aggregate(bgpAgg *bgpd.BGPv4Aggregate) (bool, error)

func (*BGPHandler) DeleteBGPv4Neighbor 

func (h *BGPHandler) DeleteBGPv4Neighbor(bgpNeighbor *bgpd.BGPv4Neighbor) (bool, error)

func (*BGPHandler) DeleteBGPv4PeerGroup 

func (h *BGPHandler) DeleteBGPv4PeerGroup(peerGroup *bgpd.BGPv4PeerGroup) (bool, error)

func (*BGPHandler) DeleteBGPv6Aggregate 

func (h *BGPHandler) DeleteBGPv6Aggregate(bgpAgg *bgpd.BGPv6Aggregate) (bool, error)

func (*BGPHandler) DeleteBGPv6Neighbor 

func (h *BGPHandler) DeleteBGPv6Neighbor(bgpNeighbor *bgpd.BGPv6Neighbor) (bool, error)

func (*BGPHandler) DeleteBGPv6PeerGroup 

func (h *BGPHandler) DeleteBGPv6PeerGroup(peerGroup *bgpd.BGPv6PeerGroup) (bool, error)

func (*BGPHandler) ExecuteActionResetBGPv4NeighborByIPAddr 

func (h *BGPHandler) ExecuteActionResetBGPv4NeighborByIPAddr(resetIP *bgpd.ResetBGPv4NeighborByIPAddr) (bool, error)

func (*BGPHandler) ExecuteActionResetBGPv4NeighborByInterface 

func (h *BGPHandler) ExecuteActionResetBGPv4NeighborByInterface(resetIf *bgpd.ResetBGPv4NeighborByInterface) (bool,
	error)

func (*BGPHandler) ExecuteActionResetBGPv6NeighborByIPAddr 

func (h *BGPHandler) ExecuteActionResetBGPv6NeighborByIPAddr(resetIP *bgpd.ResetBGPv6NeighborByIPAddr) (bool, error)

func (*BGPHandler) ExecuteActionResetBGPv6NeighborByInterface 

func (h *BGPHandler) ExecuteActionResetBGPv6NeighborByInterface(resetIf *bgpd.ResetBGPv6NeighborByInterface) (bool,
	error)

func (*BGPHandler) GetBGPGlobalState 

func (h *BGPHandler) GetBGPGlobalState(vrfId string) (*bgpd.BGPGlobalState, error)

func (*BGPHandler) GetBGPPolicyActionState 

func (h *BGPHandler) GetBGPPolicyActionState(name string) (*bgpd.BGPPolicyActionState, error)

func (*BGPHandler) GetBGPPolicyConditionState 

func (h *BGPHandler) GetBGPPolicyConditionState(name string) (*bgpd.BGPPolicyConditionState, error)

func (*BGPHandler) GetBGPPolicyDefinitionState 

func (h *BGPHandler) GetBGPPolicyDefinitionState(name string) (*bgpd.BGPPolicyDefinitionState, error)

func (*BGPHandler) GetBGPPolicyStmtState 

func (h *BGPHandler) GetBGPPolicyStmtState(name string) (*bgpd.BGPPolicyStmtState, error)

func (*BGPHandler) GetBGPv4NeighborState 

func (h *BGPHandler) GetBGPv4NeighborState(neighborAddr string, intfref string) (*bgpd.BGPv4NeighborState, error)

func (*BGPHandler) GetBGPv4RouteState 

func (h *BGPHandler) GetBGPv4RouteState(network string, cidrLen int16) (*bgpd.BGPv4RouteState, error)

func (*BGPHandler) GetBGPv6NeighborState 

func (h *BGPHandler) GetBGPv6NeighborState(neighborAddr string, intfref string) (*bgpd.BGPv6NeighborState, error)

func (*BGPHandler) GetBGPv6RouteState 

func (h *BGPHandler) GetBGPv6RouteState(network string, cidrLen int16) (*bgpd.BGPv6RouteState, error)

func (*BGPHandler) GetBulkBGPGlobalState 

func (h *BGPHandler) GetBulkBGPGlobalState(index bgpd.Int,
	count bgpd.Int) (*bgpd.BGPGlobalStateGetInfo, error)

func (*BGPHandler) GetBulkBGPPolicyActionState 

func (h *BGPHandler) GetBulkBGPPolicyActionState(fromIndex bgpd.Int, rcount bgpd.Int) (
	policyActions *bgpd.BGPPolicyActionStateGetInfo, err error)

func (*BGPHandler) GetBulkBGPPolicyConditionState 

func (h *BGPHandler) GetBulkBGPPolicyConditionState(fromIndex bgpd.Int, rcount bgpd.Int) (
	policyConditions *bgpd.BGPPolicyConditionStateGetInfo, err error)

func (*BGPHandler) GetBulkBGPPolicyDefinitionState 

func (h *BGPHandler) GetBulkBGPPolicyDefinitionState(fromIndex bgpd.Int, rcount bgpd.Int) (
	policyStmts *bgpd.BGPPolicyDefinitionStateGetInfo, err error)

func (*BGPHandler) GetBulkBGPPolicyStmtState 

func (h *BGPHandler) GetBulkBGPPolicyStmtState(fromIndex bgpd.Int, rcount bgpd.Int) (
	policyStmts *bgpd.BGPPolicyStmtStateGetInfo, err error)

func (*BGPHandler) GetBulkBGPv4NeighborState 

func (h *BGPHandler) GetBulkBGPv4NeighborState(index bgpd.Int, count bgpd.Int) (*bgpd.BGPv4NeighborStateGetInfo, error)

func (*BGPHandler) GetBulkBGPv4RouteState 

func (h *BGPHandler) GetBulkBGPv4RouteState(index bgpd.Int, count bgpd.Int) (*bgpd.BGPv4RouteStateGetInfo, error)

func (*BGPHandler) GetBulkBGPv6NeighborState 

func (h *BGPHandler) GetBulkBGPv6NeighborState(index bgpd.Int, count bgpd.Int) (*bgpd.BGPv6NeighborStateGetInfo,
	error)

func (*BGPHandler) GetBulkBGPv6RouteState 

func (h *BGPHandler) GetBulkBGPv6RouteState(index bgpd.Int, count bgpd.Int) (*bgpd.BGPv6RouteStateGetInfo, error)

func (*BGPHandler) PeerCommand 

func (h *BGPHandler) PeerCommand(in *PeerConfigCommands, out *bool) error

func (*BGPHandler) ReadBGPConfigFromDB 

func (h *BGPHandler) ReadBGPConfigFromDB() error

func (*BGPHandler) SendBGPAggregate 

func (h *BGPHandler) SendBGPAggregate(oldConfig *bgpd.BGPv4Aggregate, newConfig *bgpd.BGPv4Aggregate, attrSet []bool) (
	bool, error)

func (*BGPHandler) SendBGPGlobal 

func (h *BGPHandler) SendBGPGlobal(oldConfig *bgpd.BGPGlobal, newConfig *bgpd.BGPGlobal, attrSet []bool, patchOp []*bgpd.PatchOpInfo, op string) (bool, error)

func (*BGPHandler) SendBGPv4Neighbor 

func (h *BGPHandler) SendBGPv4Neighbor(oldNeigh *bgpd.BGPv4Neighbor, newNeigh *bgpd.BGPv4Neighbor, attrSet []bool,
	patchOp []*bgpd.PatchOpInfo, op string) (
	bool, error)

func (*BGPHandler) SendBGPv4PeerGroup 

func (h *BGPHandler) SendBGPv4PeerGroup(oldGroup *bgpd.BGPv4PeerGroup, newGroup *bgpd.BGPv4PeerGroup, attrSet []bool) (
	bool, error)

func (*BGPHandler) SendBGPv6Aggregate 

func (h *BGPHandler) SendBGPv6Aggregate(oldConfig *bgpd.BGPv6Aggregate, newConfig *bgpd.BGPv6Aggregate,
	attrSet []bool) (bool, error)

func (*BGPHandler) SendBGPv6Neighbor 

func (h *BGPHandler) SendBGPv6Neighbor(oldNeigh *bgpd.BGPv6Neighbor, newNeigh *bgpd.BGPv6Neighbor, attrSet []bool, patchOp []*bgpd.PatchOpInfo, op string) (
	bool, error)

func (*BGPHandler) SendBGPv6PeerGroup 

func (h *BGPHandler) SendBGPv6PeerGroup(oldGroup *bgpd.BGPv6PeerGroup, newGroup *bgpd.BGPv6PeerGroup, attrSet []bool) (
	bool, error)

func (*BGPHandler) UpdateBGPGlobal 

func (h *BGPHandler) UpdateBGPGlobal(origG *bgpd.BGPGlobal, updatedG *bgpd.BGPGlobal,
	attrSet []bool, op []*bgpd.PatchOpInfo) (bool, error)

func (*BGPHandler) UpdateBGPPolicyAction 

func (h *BGPHandler) UpdateBGPPolicyAction(origC *bgpd.BGPPolicyAction, updatedC *bgpd.BGPPolicyAction,
	attrSet []bool, op []*bgpd.PatchOpInfo) (val bool, err error)

func (*BGPHandler) UpdateBGPPolicyCondition 

func (h *BGPHandler) UpdateBGPPolicyCondition(origC *bgpd.BGPPolicyCondition,
	updatedC *bgpd.BGPPolicyCondition,
	attrSet []bool, op []*bgpd.PatchOpInfo) (val bool, err error)

func (*BGPHandler) UpdateBGPPolicyDefinition 

func (h *BGPHandler) UpdateBGPPolicyDefinition(origC *bgpd.BGPPolicyDefinition,
	updatedC *bgpd.BGPPolicyDefinition,
	attrSet []bool, op []*bgpd.PatchOpInfo) (val bool, err error)

func (*BGPHandler) UpdateBGPPolicyStmt 

func (h *BGPHandler) UpdateBGPPolicyStmt(origC *bgpd.BGPPolicyStmt,
	updatedC *bgpd.BGPPolicyStmt, attrSet []bool, op []*bgpd.PatchOpInfo) (
	val bool, err error)

func (*BGPHandler) UpdateBGPv4Aggregate 

func (h *BGPHandler) UpdateBGPv4Aggregate(origA *bgpd.BGPv4Aggregate, updatedA *bgpd.BGPv4Aggregate, attrSet []bool,
	op []*bgpd.PatchOpInfo) (bool, error)

func (*BGPHandler) UpdateBGPv4Neighbor 

func (h *BGPHandler) UpdateBGPv4Neighbor(origN *bgpd.BGPv4Neighbor, updatedN *bgpd.BGPv4Neighbor, attrSet []bool,
	op []*bgpd.PatchOpInfo) (bool, error)

func (*BGPHandler) UpdateBGPv4PeerGroup 

func (h *BGPHandler) UpdateBGPv4PeerGroup(origG *bgpd.BGPv4PeerGroup, updatedG *bgpd.BGPv4PeerGroup, attrSet []bool,
	op []*bgpd.PatchOpInfo) (bool, error)

func (*BGPHandler) UpdateBGPv6Aggregate 

func (h *BGPHandler) UpdateBGPv6Aggregate(origA *bgpd.BGPv6Aggregate, updatedA *bgpd.BGPv6Aggregate, attrSet []bool,
	op []*bgpd.PatchOpInfo) (bool, error)

func (*BGPHandler) UpdateBGPv6Neighbor 

func (h *BGPHandler) UpdateBGPv6Neighbor(origN *bgpd.BGPv6Neighbor, updatedN *bgpd.BGPv6Neighbor, attrSet []bool,
	op []*bgpd.PatchOpInfo) (bool, error)

func (*BGPHandler) UpdateBGPv6PeerGroup 

func (h *BGPHandler) UpdateBGPv6PeerGroup(origG *bgpd.BGPv6PeerGroup, updatedG *bgpd.BGPv6PeerGroup, attrSet []bool,
	op []*bgpd.PatchOpInfo) (bool, error)

func (*BGPHandler) ValidateBGPv4PeerGroup 

func (h *BGPHandler) ValidateBGPv4PeerGroup(peerGroup *bgpd.BGPv4PeerGroup) (group config.PeerGroupConfig,
	err error)

func (*BGPHandler) ValidateBGPv6PeerGroup 

func (h *BGPHandler) ValidateBGPv6PeerGroup(peerGroup *bgpd.BGPv6PeerGroup) (group config.PeerGroupConfig,
	err error)

func (*BGPHandler) ValidateV4Neighbor 

func (h *BGPHandler) ValidateV4Neighbor(bgpNeighbor *bgpd.BGPv4Neighbor) (pConf config.NeighborConfig, err error)

func (*BGPHandler) ValidateV4NeighborForUpdate 

func (h *BGPHandler) ValidateV4NeighborForUpdate(oldNeigh *bgpd.BGPv4Neighbor, oldNeighConfig config.NeighborConfig,
	newNeigh *bgpd.BGPv4Neighbor, attrSet []bool) (pConf config.NeighborConfig, err error)

func (*BGPHandler) ValidateV6Neighbor 

func (h *BGPHandler) ValidateV6Neighbor(bgpNeighbor *bgpd.BGPv6Neighbor) (pConf config.NeighborConfig, err error)

func (*BGPHandler) ValidateV6NeighborForUpdate 

func (h *BGPHandler) ValidateV6NeighborForUpdate(oldNeigh *bgpd.BGPv6Neighbor, oldNeighConfig config.NeighborConfig,
	newNeigh *bgpd.BGPv6Neighbor, attrSet []bool) (pConf config.NeighborConfig, err error)

type ClientJson 

type ClientJson struct {
	Name string `json:Name`
	Port int    `json:Port`
}

type PeerConfigCommands 

type PeerConfigCommands struct {
	IP      net.IP
	Command int
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.