Documentation ¶
Index ¶
- Constants
- Variables
- type DHCPDescriptor
- func (d *DHCPDescriptor) Close() error
- func (d *DHCPDescriptor) Create(key string, emptyVal proto.Message) (metadata kvs.Metadata, err error)
- func (d *DHCPDescriptor) Delete(key string, emptyVal proto.Message, metadata kvs.Metadata) error
- func (d *DHCPDescriptor) DerivedValues(key string, dhcpData proto.Message) (derValues []kvs.KeyValuePair)
- func (d *DHCPDescriptor) GetDescriptor() *kvs.KVDescriptor
- func (d *DHCPDescriptor) InterfaceNameFromKey(key string) string
- func (d *DHCPDescriptor) IsDHCPRelatedKey(key string) bool
- func (d *DHCPDescriptor) Retrieve(correlate []kvs.KVWithMetadata) (leases []kvs.KVWithMetadata, err error)
- func (d *DHCPDescriptor) SetInterfaceIndex(ifIndex ifaceidx.IfaceMetadataIndex)
- func (d *DHCPDescriptor) WatchDHCPNotifications(ctx context.Context, dhcpChan chan govppapi.Message)
- type InterfaceDescriptor
- func (d *InterfaceDescriptor) Create(key string, intf *interfaces.Interface) (metadata *ifaceidx.IfaceMetadata, err error)
- func (d *InterfaceDescriptor) Delete(key string, intf *interfaces.Interface, metadata *ifaceidx.IfaceMetadata) error
- func (d *InterfaceDescriptor) Dependencies(key string, intf *interfaces.Interface) (dependencies []kvs.Dependency)
- func (d *InterfaceDescriptor) DerivedValues(key string, intf *interfaces.Interface) (derValues []kvs.KeyValuePair)
- func (d *InterfaceDescriptor) EquivalentInterfaces(key string, oldIntf, newIntf *interfaces.Interface) bool
- func (d *InterfaceDescriptor) GetDescriptor() *adapter.InterfaceDescriptor
- func (d *InterfaceDescriptor) MetadataFactory() idxmap.NamedMappingRW
- func (d *InterfaceDescriptor) Retrieve(correlate []adapter.InterfaceKVWithMetadata) (retrieved []adapter.InterfaceKVWithMetadata, err error)
- func (d *InterfaceDescriptor) SetInterfaceIndex(intfIndex ifaceidx.IfaceMetadataIndex)
- func (d *InterfaceDescriptor) Update(key string, oldIntf, newIntf *interfaces.Interface, ...) (newMetadata *ifaceidx.IfaceMetadata, err error)
- func (d *InterfaceDescriptor) UpdateWithRecreate(key string, oldIntf, newIntf *interfaces.Interface, ...) bool
- func (d *InterfaceDescriptor) Validate(key string, intf *interfaces.Interface) error
- type LinuxPluginAPI
- type NetlinkAPI
- type UnnumberedIfDescriptor
- func (d *UnnumberedIfDescriptor) Create(key string, unIntf *interfaces.Interface_Unnumbered) (metadata interface{}, err error)
- func (d *UnnumberedIfDescriptor) Delete(key string, unIntf *interfaces.Interface_Unnumbered, metadata interface{}) error
- func (d *UnnumberedIfDescriptor) Dependencies(key string, unIntf *interfaces.Interface_Unnumbered) []kvs.Dependency
- func (d *UnnumberedIfDescriptor) GetDescriptor() *adapter.UnnumberedDescriptor
- func (d *UnnumberedIfDescriptor) IsUnnumberedInterfaceKey(key string) bool
- func (d *UnnumberedIfDescriptor) SetInterfaceIndex(ifIndex ifaceidx.IfaceMetadataIndex)
Constants ¶
const ( // DHCPDescriptorName is the name of the descriptor configuring DHCP for VPP // interfaces. DHCPDescriptorName = "vpp-dhcp" )
const (
// InterfaceDescriptorName is the name of the descriptor for VPP interfaces.
InterfaceDescriptorName = "vpp-interface"
)
const ( // UnnumberedIfDescriptorName is the name of the descriptor for the unnumbered // config-subsection of VPP interfaces. UnnumberedIfDescriptorName = "vpp-unnumbered-interface" )
Variables ¶
var ( // ErrUnsupportedVPPInterfaceType is returned for VPP interfaces of unknown type. ErrUnsupportedVPPInterfaceType = errors.New("unsupported VPP interface type") // ErrInterfaceWithoutName is returned when VPP interface configuration has undefined // Name attribute. ErrInterfaceWithoutName = errors.New("VPP interface defined without logical name") // ErrInterfaceNameTooLong is returned when VPP interface logical name exceeds the length limit. ErrInterfaceNameTooLong = errors.New("VPP interface logical name exceeds the length limit (63 characters)") // ErrInterfaceWithoutType is returned when VPP interface configuration has undefined // Type attribute. ErrInterfaceWithoutType = errors.New("VPP interface defined without type") // ErrUnnumberedWithIP is returned when configuration of a VPP unnumbered interface // includes an IP address. ErrUnnumberedWithIP = errors.New("VPP unnumbered interface was defined with IP address") // ErrAfPacketWithoutHostName is returned when AF-Packet configuration is missing host interface name. ErrAfPacketWithoutHostName = errors.New("VPP AF-Packet interface was defined without host interface name") // ErrInterfaceLinkMismatch is returned when interface type does not match the link configuration. ErrInterfaceLinkMismatch = errors.New("VPP interface type and link configuration do not match") // ErrUnsupportedRxMode is returned when the given interface type does not support the chosen // RX mode. ErrUnsupportedRxMode = errors.New("unsupported RX Mode") // ErrSubInterfaceWithoutParent is returned when interface of type sub-interface is defined without parent. ErrSubInterfaceWithoutParent = errors.Errorf("subinterface with no parent interface defined") )
A list of non-retriable errors:
Functions ¶
This section is empty.
Types ¶
type DHCPDescriptor ¶
type DHCPDescriptor struct {
// contains filtered or unexported fields
}
DHCPDescriptor enables/disables DHCP for VPP interfaces and notifies about new DHCP leases.
func NewDHCPDescriptor ¶
func NewDHCPDescriptor(kvscheduler kvs.KVScheduler, ifHandler vppcalls.IfVppAPI, log logging.PluginLogger) *DHCPDescriptor
NewDHCPDescriptor creates a new instance of DHCPDescriptor.
func (*DHCPDescriptor) Close ¶
func (d *DHCPDescriptor) Close() error
Close stops watching of DHCP notifications.
func (*DHCPDescriptor) Create ¶
func (d *DHCPDescriptor) Create(key string, emptyVal proto.Message) (metadata kvs.Metadata, err error)
Create enables DHCP client.
func (*DHCPDescriptor) DerivedValues ¶
func (d *DHCPDescriptor) DerivedValues(key string, dhcpData proto.Message) (derValues []kvs.KeyValuePair)
DerivedValues derives empty value for leased IP address.
func (*DHCPDescriptor) GetDescriptor ¶
func (d *DHCPDescriptor) GetDescriptor() *kvs.KVDescriptor
GetDescriptor returns descriptor suitable for registration with the KVScheduler.
func (*DHCPDescriptor) InterfaceNameFromKey ¶
func (d *DHCPDescriptor) InterfaceNameFromKey(key string) string
InterfaceNameFromKey returns interface name from DHCP-related key.
func (*DHCPDescriptor) IsDHCPRelatedKey ¶
func (d *DHCPDescriptor) IsDHCPRelatedKey(key string) bool
IsDHCPRelatedKey returns true if the key is identifying DHCP client (derived value) or DHCP lease (notification).
func (*DHCPDescriptor) Retrieve ¶
func (d *DHCPDescriptor) Retrieve(correlate []kvs.KVWithMetadata) ( leases []kvs.KVWithMetadata, err error, )
Retrieve returns all existing DHCP leases.
func (*DHCPDescriptor) SetInterfaceIndex ¶
func (d *DHCPDescriptor) SetInterfaceIndex(ifIndex ifaceidx.IfaceMetadataIndex)
SetInterfaceIndex should be used to provide interface index immediately after the descriptor registration.
func (*DHCPDescriptor) WatchDHCPNotifications ¶
func (d *DHCPDescriptor) WatchDHCPNotifications(ctx context.Context, dhcpChan chan govppapi.Message)
WatchDHCPNotifications starts watching for DHCP notifications.
type InterfaceDescriptor ¶
type InterfaceDescriptor struct {
// contains filtered or unexported fields
}
InterfaceDescriptor teaches KVScheduler how to configure VPP interfaces.
func NewInterfaceDescriptor ¶
func NewInterfaceDescriptor(ifHandler vppcalls.IfVppAPI, defaultMtu uint32, linuxIfHandler NetlinkAPI, linuxIfPlugin LinuxPluginAPI, nsPlugin nsplugin.API, log logging.PluginLogger) *InterfaceDescriptor
NewInterfaceDescriptor creates a new instance of the Interface descriptor.
func (*InterfaceDescriptor) Create ¶
func (d *InterfaceDescriptor) Create(key string, intf *interfaces.Interface) (metadata *ifaceidx.IfaceMetadata, err error)
Create creates a VPP interface.
func (*InterfaceDescriptor) Delete ¶
func (d *InterfaceDescriptor) Delete(key string, intf *interfaces.Interface, metadata *ifaceidx.IfaceMetadata) error
Delete removes VPP interface.
func (*InterfaceDescriptor) Dependencies ¶
func (d *InterfaceDescriptor) Dependencies(key string, intf *interfaces.Interface) (dependencies []kvs.Dependency)
Dependencies lists dependencies for a VPP interface.
func (*InterfaceDescriptor) DerivedValues ¶
func (d *InterfaceDescriptor) DerivedValues(key string, intf *interfaces.Interface) (derValues []kvs.KeyValuePair)
DerivedValues derives:
- key-value for unnumbered configuration sub-section
- empty value for enabled DHCP client
- one empty value for every IP address assigned to the interface.
func (*InterfaceDescriptor) EquivalentInterfaces ¶
func (d *InterfaceDescriptor) EquivalentInterfaces(key string, oldIntf, newIntf *interfaces.Interface) bool
EquivalentInterfaces is case-insensitive comparison function for interfaces.Interface, also ignoring the order of assigned IP addresses.
func (*InterfaceDescriptor) GetDescriptor ¶
func (d *InterfaceDescriptor) GetDescriptor() *adapter.InterfaceDescriptor
GetDescriptor returns descriptor suitable for registration (via adapter) with the KVScheduler.
func (*InterfaceDescriptor) MetadataFactory ¶
func (d *InterfaceDescriptor) MetadataFactory() idxmap.NamedMappingRW
MetadataFactory is a factory for index-map customized for VPP interfaces.
func (*InterfaceDescriptor) Retrieve ¶
func (d *InterfaceDescriptor) Retrieve(correlate []adapter.InterfaceKVWithMetadata) (retrieved []adapter.InterfaceKVWithMetadata, err error)
Retrieve returns all configured VPP interfaces.
func (*InterfaceDescriptor) SetInterfaceIndex ¶
func (d *InterfaceDescriptor) SetInterfaceIndex(intfIndex ifaceidx.IfaceMetadataIndex)
SetInterfaceIndex should be used to provide interface index immediately after the descriptor registration.
func (*InterfaceDescriptor) Update ¶
func (d *InterfaceDescriptor) Update(key string, oldIntf, newIntf *interfaces.Interface, oldMetadata *ifaceidx.IfaceMetadata) (newMetadata *ifaceidx.IfaceMetadata, err error)
Update is able to change Type-unspecific attributes.
func (*InterfaceDescriptor) UpdateWithRecreate ¶
func (d *InterfaceDescriptor) UpdateWithRecreate(key string, oldIntf, newIntf *interfaces.Interface, metadata *ifaceidx.IfaceMetadata) bool
UpdateWithRecreate returns true if Type, VRF (or VRF IP version) or Type-specific attributes are different.
func (*InterfaceDescriptor) Validate ¶
func (d *InterfaceDescriptor) Validate(key string, intf *interfaces.Interface) error
Validate validates VPP interface configuration.
type LinuxPluginAPI ¶
type LinuxPluginAPI interface { // GetInterfaceIndex gives read-only access to map with metadata of all configured // linux interfaces. GetInterfaceIndex() linux_ifaceidx.LinuxIfMetadataIndex }
LinuxPluginAPI is defined here to avoid import cycles.
type NetlinkAPI ¶
type NetlinkAPI interface { // InterfaceExists verifies interface existence InterfaceExists(ifName string) (bool, error) }
NetlinkAPI here lists only those Netlink methods that are actually used by InterfaceDescriptor.
type UnnumberedIfDescriptor ¶
type UnnumberedIfDescriptor struct {
// contains filtered or unexported fields
}
UnnumberedIfDescriptor sets/unsets VPP interfaces as unnumbered. Values = Interface_Unnumbered{} derived from interfaces where IsUnnumbered==true
func NewUnnumberedIfDescriptor ¶
func NewUnnumberedIfDescriptor(ifHandler vppcalls.IfVppAPI, log logging.PluginLogger) *UnnumberedIfDescriptor
NewUnnumberedIfDescriptor creates a new instance of UnnumberedIfDescriptor.
func (*UnnumberedIfDescriptor) Create ¶
func (d *UnnumberedIfDescriptor) Create(key string, unIntf *interfaces.Interface_Unnumbered) (metadata interface{}, err error)
Create sets interface as unnumbered.
func (*UnnumberedIfDescriptor) Delete ¶
func (d *UnnumberedIfDescriptor) Delete(key string, unIntf *interfaces.Interface_Unnumbered, metadata interface{}) error
Delete un-sets interface as unnumbered.
func (*UnnumberedIfDescriptor) Dependencies ¶
func (d *UnnumberedIfDescriptor) Dependencies(key string, unIntf *interfaces.Interface_Unnumbered) []kvs.Dependency
Dependencies lists dependencies for an unnumbered VPP interface.
func (*UnnumberedIfDescriptor) GetDescriptor ¶
func (d *UnnumberedIfDescriptor) GetDescriptor() *adapter.UnnumberedDescriptor
GetDescriptor returns descriptor suitable for registration (via adapter) with the KVScheduler.
func (*UnnumberedIfDescriptor) IsUnnumberedInterfaceKey ¶
func (d *UnnumberedIfDescriptor) IsUnnumberedInterfaceKey(key string) bool
IsUnnumberedInterfaceKey returns true if the key is identifying unnumbered VPP interface.
func (*UnnumberedIfDescriptor) SetInterfaceIndex ¶
func (d *UnnumberedIfDescriptor) SetInterfaceIndex(ifIndex ifaceidx.IfaceMetadataIndex)
SetInterfaceIndex should be used to provide interface index immediately after the descriptor registration.