// Code generated by GoVPP's binapi-generator. DO NOT EDIT. // versions: // binapi-generator: v0.4.0-dev // VPP: 20.01 // source: .vppapi/plugins/lb.api.json // Package lb contains generated bindings for API file lb.api. // // Contents: // 6 aliases // 15 enums // 7 structs // 1 union // 16 messages // package lb import ( "fmt" api "git.fd.io/govpp.git/api" codec "git.fd.io/govpp.git/codec" "net" "strconv" "strings" ) // This is a compile-time assertion to ensure that this generated file // is compatible with the GoVPP api package it is being compiled against. // A compilation error at this line likely means your copy of the // GoVPP api package needs to be updated. const _ = api.GoVppAPIPackageIsVersion2 const ( APIFile = "lb" APIVersion = "1.0.0" VersionCrc = 0x76c36b4c ) // AddressFamily defines enum 'address_family'. type AddressFamily uint32 const ( ADDRESS_IP4 AddressFamily = 0 ADDRESS_IP6 AddressFamily = 1 ) var ( AddressFamily_name = map[uint32]string{ 0: "ADDRESS_IP4", 1: "ADDRESS_IP6", } AddressFamily_value = map[string]uint32{ "ADDRESS_IP4": 0, "ADDRESS_IP6": 1, } ) func (x AddressFamily) String() string { s, ok := AddressFamily_name[uint32(x)] if ok { return s } return "AddressFamily(" + strconv.Itoa(int(x)) + ")" } // IfStatusFlags defines enum 'if_status_flags'. type IfStatusFlags uint32 const ( IF_STATUS_API_FLAG_ADMIN_UP IfStatusFlags = 1 IF_STATUS_API_FLAG_LINK_UP IfStatusFlags = 2 ) var ( IfStatusFlags_name = map[uint32]string{ 1: "IF_STATUS_API_FLAG_ADMIN_UP", 2: "IF_STATUS_API_FLAG_LINK_UP", } IfStatusFlags_value = map[string]uint32{ "IF_STATUS_API_FLAG_ADMIN_UP": 1, "IF_STATUS_API_FLAG_LINK_UP": 2, } ) func (x IfStatusFlags) String() string { s, ok := IfStatusFlags_name[uint32(x)] if ok { return s } str := func(n uint32) string { s, ok := IfStatusFlags_name[uint32(n)] if ok { return s } return "IfStatusFlags(" + strconv.Itoa(int(n)) + ")" } for i := uint32(0); i <= 32; i++ { val := uint32(x) if val&(1<<i) != 0 { if s != "" { s += "|" } s += str(1 << i) } } if s == "" { return str(uint32(x)) } return s } // IfType defines enum 'if_type'. type IfType uint32 const ( IF_API_TYPE_HARDWARE IfType = 1 IF_API_TYPE_SUB IfType = 2 IF_API_TYPE_P2P IfType = 3 IF_API_TYPE_PIPE IfType = 4 ) var ( IfType_name = map[uint32]string{ 1: "IF_API_TYPE_HARDWARE", 2: "IF_API_TYPE_SUB", 3: "IF_API_TYPE_P2P", 4: "IF_API_TYPE_PIPE", } IfType_value = map[string]uint32{ "IF_API_TYPE_HARDWARE": 1, "IF_API_TYPE_SUB": 2, "IF_API_TYPE_P2P": 3, "IF_API_TYPE_PIPE": 4, } ) func (x IfType) String() string { s, ok := IfType_name[uint32(x)] if ok { return s } return "IfType(" + strconv.Itoa(int(x)) + ")" } // IPDscp defines enum 'ip_dscp'. type IPDscp uint8 const ( IP_API_DSCP_CS0 IPDscp = 0 IP_API_DSCP_CS1 IPDscp = 8 IP_API_DSCP_AF11 IPDscp = 10 IP_API_DSCP_AF12 IPDscp = 12 IP_API_DSCP_AF13 IPDscp = 14 IP_API_DSCP_CS2 IPDscp = 16 IP_API_DSCP_AF21 IPDscp = 18 IP_API_DSCP_AF22 IPDscp = 20 IP_API_DSCP_AF23 IPDscp = 22 IP_API_DSCP_CS3 IPDscp = 24 IP_API_DSCP_AF31 IPDscp = 26 IP_API_DSCP_AF32 IPDscp = 28 IP_API_DSCP_AF33 IPDscp = 30 IP_API_DSCP_CS4 IPDscp = 32 IP_API_DSCP_AF41 IPDscp = 34 IP_API_DSCP_AF42 IPDscp = 36 IP_API_DSCP_AF43 IPDscp = 38 IP_API_DSCP_CS5 IPDscp = 40 IP_API_DSCP_EF IPDscp = 46 IP_API_DSCP_CS6 IPDscp = 48 IP_API_DSCP_CS7 IPDscp = 50 ) var ( IPDscp_name = map[uint8]string{ 0: "IP_API_DSCP_CS0", 8: "IP_API_DSCP_CS1", 10: "IP_API_DSCP_AF11", 12: "IP_API_DSCP_AF12", 14: "IP_API_DSCP_AF13", 16: "IP_API_DSCP_CS2", 18: "IP_API_DSCP_AF21", 20: "IP_API_DSCP_AF22", 22: "IP_API_DSCP_AF23", 24: "IP_API_DSCP_CS3", 26: "IP_API_DSCP_AF31", 28: "IP_API_DSCP_AF32", 30: "IP_API_DSCP_AF33", 32: "IP_API_DSCP_CS4", 34: "IP_API_DSCP_AF41", 36: "IP_API_DSCP_AF42", 38: "IP_API_DSCP_AF43", 40: "IP_API_DSCP_CS5", 46: "IP_API_DSCP_EF", 48: "IP_API_DSCP_CS6", 50: "IP_API_DSCP_CS7", } IPDscp_value = map[string]uint8{ "IP_API_DSCP_CS0": 0, "IP_API_DSCP_CS1": 8, "IP_API_DSCP_AF11": 10, "IP_API_DSCP_AF12": 12, "IP_API_DSCP_AF13": 14, "IP_API_DSCP_CS2": 16, "IP_API_DSCP_AF21": 18, "IP_API_DSCP_AF22": 20, "IP_API_DSCP_AF23": 22, "IP_API_DSCP_CS3": 24, "IP_API_DSCP_AF31": 26, "IP_API_DSCP_AF32": 28, "IP_API_DSCP_AF33": 30, "IP_API_DSCP_CS4": 32, "IP_API_DSCP_AF41": 34, "IP_API_DSCP_AF42": 36, "IP_API_DSCP_AF43": 38, "IP_API_DSCP_CS5": 40, "IP_API_DSCP_EF": 46, "IP_API_DSCP_CS6": 48, "IP_API_DSCP_CS7": 50, } ) func (x IPDscp) String() string { s, ok := IPDscp_name[uint8(x)] if ok { return s } return "IPDscp(" + strconv.Itoa(int(x)) + ")" } // IPEcn defines enum 'ip_ecn'. type IPEcn uint8 const ( IP_API_ECN_NONE IPEcn = 0 IP_API_ECN_ECT0 IPEcn = 1 IP_API_ECN_ECT1 IPEcn = 2 IP_API_ECN_CE IPEcn = 3 ) var ( IPEcn_name = map[uint8]string{ 0: "IP_API_ECN_NONE", 1: "IP_API_ECN_ECT0", 2: "IP_API_ECN_ECT1", 3: "IP_API_ECN_CE", } IPEcn_value = map[string]uint8{ "IP_API_ECN_NONE": 0, "IP_API_ECN_ECT0": 1, "IP_API_ECN_ECT1": 2, "IP_API_ECN_CE": 3, } ) func (x IPEcn) String() string { s, ok := IPEcn_name[uint8(x)] if ok { return s } return "IPEcn(" + strconv.Itoa(int(x)) + ")" } // IPProto defines enum 'ip_proto'. type IPProto uint32 const ( IP_API_PROTO_HOPOPT IPProto = 0 IP_API_PROTO_ICMP IPProto = 1 IP_API_PROTO_IGMP IPProto = 2 IP_API_PROTO_TCP IPProto = 6 IP_API_PROTO_UDP IPProto = 17 IP_API_PROTO_GRE IPProto = 47 IP_API_PROTO_AH IPProto = 50 IP_API_PROTO_ESP IPProto = 51 IP_API_PROTO_EIGRP IPProto = 88 IP_API_PROTO_OSPF IPProto = 89 IP_API_PROTO_SCTP IPProto = 132 IP_API_PROTO_RESERVED IPProto = 255 ) var ( IPProto_name = map[uint32]string{ 0: "IP_API_PROTO_HOPOPT", 1: "IP_API_PROTO_ICMP", 2: "IP_API_PROTO_IGMP", 6: "IP_API_PROTO_TCP", 17: "IP_API_PROTO_UDP", 47: "IP_API_PROTO_GRE", 50: "IP_API_PROTO_AH", 51: "IP_API_PROTO_ESP", 88: "IP_API_PROTO_EIGRP", 89: "IP_API_PROTO_OSPF", 132: "IP_API_PROTO_SCTP", 255: "IP_API_PROTO_RESERVED", } IPProto_value = map[string]uint32{ "IP_API_PROTO_HOPOPT": 0, "IP_API_PROTO_ICMP": 1, "IP_API_PROTO_IGMP": 2, "IP_API_PROTO_TCP": 6, "IP_API_PROTO_UDP": 17, "IP_API_PROTO_GRE": 47, "IP_API_PROTO_AH": 50, "IP_API_PROTO_ESP": 51, "IP_API_PROTO_EIGRP": 88, "IP_API_PROTO_OSPF": 89, "IP_API_PROTO_SCTP": 132, "IP_API_PROTO_RESERVED": 255, } ) func (x IPProto) String() string { s, ok := IPProto_name[uint32(x)] if ok { return s } return "IPProto(" + strconv.Itoa(int(x)) + ")" } // LbEncapType defines enum 'lb_encap_type'. type LbEncapType uint32 const ( LB_API_ENCAP_TYPE_GRE4 LbEncapType = 0 LB_API_ENCAP_TYPE_GRE6 LbEncapType = 1 LB_API_ENCAP_TYPE_L3DSR LbEncapType = 2 LB_API_ENCAP_TYPE_NAT4 LbEncapType = 3 LB_API_ENCAP_TYPE_NAT6 LbEncapType = 4 LB_API_ENCAP_N_TYPES LbEncapType = 5 ) var ( LbEncapType_name = map[uint32]string{ 0: "LB_API_ENCAP_TYPE_GRE4", 1: "LB_API_ENCAP_TYPE_GRE6", 2: "LB_API_ENCAP_TYPE_L3DSR", 3: "LB_API_ENCAP_TYPE_NAT4", 4: "LB_API_ENCAP_TYPE_NAT6", 5: "LB_API_ENCAP_N_TYPES", } LbEncapType_value = map[string]uint32{ "LB_API_ENCAP_TYPE_GRE4": 0, "LB_API_ENCAP_TYPE_GRE6": 1, "LB_API_ENCAP_TYPE_L3DSR": 2, "LB_API_ENCAP_TYPE_NAT4": 3, "LB_API_ENCAP_TYPE_NAT6": 4, "LB_API_ENCAP_N_TYPES": 5, } ) func (x LbEncapType) String() string { s, ok := LbEncapType_name[uint32(x)] if ok { return s } return "LbEncapType(" + strconv.Itoa(int(x)) + ")" } // LbLkpTypeT defines enum 'lb_lkp_type_t'. type LbLkpTypeT uint32 const ( LB_API_LKP_SAME_IP_PORT LbLkpTypeT = 0 LB_API_LKP_DIFF_IP_PORT LbLkpTypeT = 1 LB_API_LKP_ALL_PORT_IP LbLkpTypeT = 2 LB_API_LKP_N_TYPES LbLkpTypeT = 3 ) var ( LbLkpTypeT_name = map[uint32]string{ 0: "LB_API_LKP_SAME_IP_PORT", 1: "LB_API_LKP_DIFF_IP_PORT", 2: "LB_API_LKP_ALL_PORT_IP", 3: "LB_API_LKP_N_TYPES", } LbLkpTypeT_value = map[string]uint32{ "LB_API_LKP_SAME_IP_PORT": 0, "LB_API_LKP_DIFF_IP_PORT": 1, "LB_API_LKP_ALL_PORT_IP": 2, "LB_API_LKP_N_TYPES": 3, } ) func (x LbLkpTypeT) String() string { s, ok := LbLkpTypeT_name[uint32(x)] if ok { return s } return "LbLkpTypeT(" + strconv.Itoa(int(x)) + ")" } // LbNatProtocol defines enum 'lb_nat_protocol'. type LbNatProtocol uint32 const ( LB_API_NAT_PROTOCOL_UDP LbNatProtocol = 6 LB_API_NAT_PROTOCOL_TCP LbNatProtocol = 23 LB_API_NAT_PROTOCOL_ANY LbNatProtocol = 4294967295 ) var ( LbNatProtocol_name = map[uint32]string{ 6: "LB_API_NAT_PROTOCOL_UDP", 23: "LB_API_NAT_PROTOCOL_TCP", 4294967295: "LB_API_NAT_PROTOCOL_ANY", } LbNatProtocol_value = map[string]uint32{ "LB_API_NAT_PROTOCOL_UDP": 6, "LB_API_NAT_PROTOCOL_TCP": 23, "LB_API_NAT_PROTOCOL_ANY": 4294967295, } ) func (x LbNatProtocol) String() string { s, ok := LbNatProtocol_name[uint32(x)] if ok { return s } return "LbNatProtocol(" + strconv.Itoa(int(x)) + ")" } // LbSrvType defines enum 'lb_srv_type'. type LbSrvType uint32 const ( LB_API_SRV_TYPE_CLUSTERIP LbSrvType = 0 LB_API_SRV_TYPE_NODEPORT LbSrvType = 1 LB_API_SRV_N_TYPES LbSrvType = 2 ) var ( LbSrvType_name = map[uint32]string{ 0: "LB_API_SRV_TYPE_CLUSTERIP", 1: "LB_API_SRV_TYPE_NODEPORT", 2: "LB_API_SRV_N_TYPES", } LbSrvType_value = map[string]uint32{ "LB_API_SRV_TYPE_CLUSTERIP": 0, "LB_API_SRV_TYPE_NODEPORT": 1, "LB_API_SRV_N_TYPES": 2, } ) func (x LbSrvType) String() string { s, ok := LbSrvType_name[uint32(x)] if ok { return s } return "LbSrvType(" + strconv.Itoa(int(x)) + ")" } // LbVipType defines enum 'lb_vip_type'. type LbVipType uint32 const ( LB_API_VIP_TYPE_IP6_GRE6 LbVipType = 0 LB_API_VIP_TYPE_IP6_GRE4 LbVipType = 1 LB_API_VIP_TYPE_IP4_GRE6 LbVipType = 2 LB_API_VIP_TYPE_IP4_GRE4 LbVipType = 3 LB_API_VIP_TYPE_IP4_L3DSR LbVipType = 4 LB_API_VIP_TYPE_IP4_NAT4 LbVipType = 5 LB_API_VIP_TYPE_IP6_NAT6 LbVipType = 6 LB_API_VIP_N_TYPES LbVipType = 7 ) var ( LbVipType_name = map[uint32]string{ 0: "LB_API_VIP_TYPE_IP6_GRE6", 1: "LB_API_VIP_TYPE_IP6_GRE4", 2: "LB_API_VIP_TYPE_IP4_GRE6", 3: "LB_API_VIP_TYPE_IP4_GRE4", 4: "LB_API_VIP_TYPE_IP4_L3DSR", 5: "LB_API_VIP_TYPE_IP4_NAT4", 6: "LB_API_VIP_TYPE_IP6_NAT6", 7: "LB_API_VIP_N_TYPES", } LbVipType_value = map[string]uint32{ "LB_API_VIP_TYPE_IP6_GRE6": 0, "LB_API_VIP_TYPE_IP6_GRE4": 1, "LB_API_VIP_TYPE_IP4_GRE6": 2, "LB_API_VIP_TYPE_IP4_GRE4": 3, "LB_API_VIP_TYPE_IP4_L3DSR": 4, "LB_API_VIP_TYPE_IP4_NAT4": 5, "LB_API_VIP_TYPE_IP6_NAT6": 6, "LB_API_VIP_N_TYPES": 7, } ) func (x LbVipType) String() string { s, ok := LbVipType_name[uint32(x)] if ok { return s } return "LbVipType(" + strconv.Itoa(int(x)) + ")" } // LinkDuplex defines enum 'link_duplex'. type LinkDuplex uint32 const ( LINK_DUPLEX_API_UNKNOWN LinkDuplex = 0 LINK_DUPLEX_API_HALF LinkDuplex = 1 LINK_DUPLEX_API_FULL LinkDuplex = 2 ) var ( LinkDuplex_name = map[uint32]string{ 0: "LINK_DUPLEX_API_UNKNOWN", 1: "LINK_DUPLEX_API_HALF", 2: "LINK_DUPLEX_API_FULL", } LinkDuplex_value = map[string]uint32{ "LINK_DUPLEX_API_UNKNOWN": 0, "LINK_DUPLEX_API_HALF": 1, "LINK_DUPLEX_API_FULL": 2, } ) func (x LinkDuplex) String() string { s, ok := LinkDuplex_name[uint32(x)] if ok { return s } return "LinkDuplex(" + strconv.Itoa(int(x)) + ")" } // MtuProto defines enum 'mtu_proto'. type MtuProto uint32 const ( MTU_PROTO_API_L3 MtuProto = 1 MTU_PROTO_API_IP4 MtuProto = 2 MTU_PROTO_API_IP6 MtuProto = 3 MTU_PROTO_API_MPLS MtuProto = 4 MTU_PROTO_API_N MtuProto = 5 ) var ( MtuProto_name = map[uint32]string{ 1: "MTU_PROTO_API_L3", 2: "MTU_PROTO_API_IP4", 3: "MTU_PROTO_API_IP6", 4: "MTU_PROTO_API_MPLS", 5: "MTU_PROTO_API_N", } MtuProto_value = map[string]uint32{ "MTU_PROTO_API_L3": 1, "MTU_PROTO_API_IP4": 2, "MTU_PROTO_API_IP6": 3, "MTU_PROTO_API_MPLS": 4, "MTU_PROTO_API_N": 5, } ) func (x MtuProto) String() string { s, ok := MtuProto_name[uint32(x)] if ok { return s } return "MtuProto(" + strconv.Itoa(int(x)) + ")" } // RxMode defines enum 'rx_mode'. type RxMode uint32 const ( RX_MODE_API_UNKNOWN RxMode = 0 RX_MODE_API_POLLING RxMode = 1 RX_MODE_API_INTERRUPT RxMode = 2 RX_MODE_API_ADAPTIVE RxMode = 3 RX_MODE_API_DEFAULT RxMode = 4 ) var ( RxMode_name = map[uint32]string{ 0: "RX_MODE_API_UNKNOWN", 1: "RX_MODE_API_POLLING", 2: "RX_MODE_API_INTERRUPT", 3: "RX_MODE_API_ADAPTIVE", 4: "RX_MODE_API_DEFAULT", } RxMode_value = map[string]uint32{ "RX_MODE_API_UNKNOWN": 0, "RX_MODE_API_POLLING": 1, "RX_MODE_API_INTERRUPT": 2, "RX_MODE_API_ADAPTIVE": 3, "RX_MODE_API_DEFAULT": 4, } ) func (x RxMode) String() string { s, ok := RxMode_name[uint32(x)] if ok { return s } return "RxMode(" + strconv.Itoa(int(x)) + ")" } // SubIfFlags defines enum 'sub_if_flags'. type SubIfFlags uint32 const ( SUB_IF_API_FLAG_NO_TAGS SubIfFlags = 1 SUB_IF_API_FLAG_ONE_TAG SubIfFlags = 2 SUB_IF_API_FLAG_TWO_TAGS SubIfFlags = 4 SUB_IF_API_FLAG_DOT1AD SubIfFlags = 8 SUB_IF_API_FLAG_EXACT_MATCH SubIfFlags = 16 SUB_IF_API_FLAG_DEFAULT SubIfFlags = 32 SUB_IF_API_FLAG_OUTER_VLAN_ID_ANY SubIfFlags = 64 SUB_IF_API_FLAG_INNER_VLAN_ID_ANY SubIfFlags = 128 SUB_IF_API_FLAG_MASK_VNET SubIfFlags = 254 SUB_IF_API_FLAG_DOT1AH SubIfFlags = 256 ) var ( SubIfFlags_name = map[uint32]string{ 1: "SUB_IF_API_FLAG_NO_TAGS", 2: "SUB_IF_API_FLAG_ONE_TAG", 4: "SUB_IF_API_FLAG_TWO_TAGS", 8: "SUB_IF_API_FLAG_DOT1AD", 16: "SUB_IF_API_FLAG_EXACT_MATCH", 32: "SUB_IF_API_FLAG_DEFAULT", 64: "SUB_IF_API_FLAG_OUTER_VLAN_ID_ANY", 128: "SUB_IF_API_FLAG_INNER_VLAN_ID_ANY", 254: "SUB_IF_API_FLAG_MASK_VNET", 256: "SUB_IF_API_FLAG_DOT1AH", } SubIfFlags_value = map[string]uint32{ "SUB_IF_API_FLAG_NO_TAGS": 1, "SUB_IF_API_FLAG_ONE_TAG": 2, "SUB_IF_API_FLAG_TWO_TAGS": 4, "SUB_IF_API_FLAG_DOT1AD": 8, "SUB_IF_API_FLAG_EXACT_MATCH": 16, "SUB_IF_API_FLAG_DEFAULT": 32, "SUB_IF_API_FLAG_OUTER_VLAN_ID_ANY": 64, "SUB_IF_API_FLAG_INNER_VLAN_ID_ANY": 128, "SUB_IF_API_FLAG_MASK_VNET": 254, "SUB_IF_API_FLAG_DOT1AH": 256, } ) func (x SubIfFlags) String() string { s, ok := SubIfFlags_name[uint32(x)] if ok { return s } str := func(n uint32) string { s, ok := SubIfFlags_name[uint32(n)] if ok { return s } return "SubIfFlags(" + strconv.Itoa(int(n)) + ")" } for i := uint32(0); i <= 32; i++ { val := uint32(x) if val&(1<<i) != 0 { if s != "" { s += "|" } s += str(1 << i) } } if s == "" { return str(uint32(x)) } return s } // AddressWithPrefix defines alias 'address_with_prefix'. type AddressWithPrefix Prefix func ParseAddressWithPrefix(s string) (AddressWithPrefix, error) { prefix, err := ParsePrefix(s) if err != nil { return AddressWithPrefix{}, err } return AddressWithPrefix(prefix), nil } func (x AddressWithPrefix) String() string { return Prefix(x).String() } func (x *AddressWithPrefix) MarshalText() ([]byte, error) { return []byte(x.String()), nil } func (x *AddressWithPrefix) UnmarshalText(text []byte) error { prefix, err := ParseAddressWithPrefix(string(text)) if err != nil { return err } *x = prefix return nil } // InterfaceIndex defines alias 'interface_index'. type InterfaceIndex uint32 // IP4Address defines alias 'ip4_address'. type IP4Address [4]uint8 func ParseIP4Address(s string) (IP4Address, error) { ip := net.ParseIP(s).To4() if ip == nil { return IP4Address{}, fmt.Errorf("invalid IP address: %s", s) } var ipaddr IP4Address copy(ipaddr[:], ip.To4()) return ipaddr, nil } func (x IP4Address) ToIP() net.IP { return net.IP(x[:]).To4() } func (x IP4Address) String() string { return x.ToIP().String() } func (x *IP4Address) MarshalText() ([]byte, error) { return []byte(x.String()), nil } func (x *IP4Address) UnmarshalText(text []byte) error { ipaddr, err := ParseIP4Address(string(text)) if err != nil { return err } *x = ipaddr return nil } // IP4AddressWithPrefix defines alias 'ip4_address_with_prefix'. type IP4AddressWithPrefix IP4Prefix // IP6Address defines alias 'ip6_address'. type IP6Address [16]uint8 func ParseIP6Address(s string) (IP6Address, error) { ip := net.ParseIP(s).To16() if ip == nil { return IP6Address{}, fmt.Errorf("invalid IP address: %s", s) } var ipaddr IP6Address copy(ipaddr[:], ip.To16()) return ipaddr, nil } func (x IP6Address) ToIP() net.IP { return net.IP(x[:]).To16() } func (x IP6Address) String() string { return x.ToIP().String() } func (x *IP6Address) MarshalText() ([]byte, error) { return []byte(x.String()), nil } func (x *IP6Address) UnmarshalText(text []byte) error { ipaddr, err := ParseIP6Address(string(text)) if err != nil { return err } *x = ipaddr return nil } // IP6AddressWithPrefix defines alias 'ip6_address_with_prefix'. type IP6AddressWithPrefix IP6Prefix // Address defines type 'address'. type Address struct { Af AddressFamily `binapi:"address_family,name=af" json:"af,omitempty"` Un AddressUnion `binapi:"address_union,name=un" json:"un,omitempty"` } func ParseAddress(s string) (Address, error) { ip := net.ParseIP(s) if ip == nil { return Address{}, fmt.Errorf("invalid address: %s", s) } var addr Address if ip.To4() == nil { addr.Af = ADDRESS_IP6 var ip6 IP6Address copy(ip6[:], ip.To16()) addr.Un.SetIP6(ip6) } else { addr.Af = ADDRESS_IP4 var ip4 IP4Address copy(ip4[:], ip.To4()) addr.Un.SetIP4(ip4) } return addr, nil } func (x Address) ToIP() net.IP { if x.Af == ADDRESS_IP6 { ip6 := x.Un.GetIP6() return net.IP(ip6[:]).To16() } else { ip4 := x.Un.GetIP4() return net.IP(ip4[:]).To4() } } func (x Address) String() string { return x.ToIP().String() } func (x *Address) MarshalText() ([]byte, error) { return []byte(x.String()), nil } func (x *Address) UnmarshalText(text []byte) error { addr, err := ParseAddress(string(text)) if err != nil { return err } *x = addr return nil } // IP4Prefix defines type 'ip4_prefix'. type IP4Prefix struct { Address IP4Address `binapi:"ip4_address,name=address" json:"address,omitempty"` Len uint8 `binapi:"u8,name=len" json:"len,omitempty"` } func ParseIP4Prefix(s string) (prefix IP4Prefix, err error) { hasPrefix := strings.Contains(s, "/") if hasPrefix { ip, network, err := net.ParseCIDR(s) if err != nil { return IP4Prefix{}, fmt.Errorf("invalid IP %s: %s", s, err) } maskSize, _ := network.Mask.Size() prefix.Len = byte(maskSize) prefix.Address, err = ParseIP4Address(ip.String()) if err != nil { return IP4Prefix{}, fmt.Errorf("invalid IP %s: %s", s, err) } } else { ip := net.ParseIP(s) defaultMaskSize, _ := net.CIDRMask(32, 32).Size() if ip.To4() == nil { defaultMaskSize, _ = net.CIDRMask(128, 128).Size() } prefix.Len = byte(defaultMaskSize) prefix.Address, err = ParseIP4Address(ip.String()) if err != nil { return IP4Prefix{}, fmt.Errorf("invalid IP %s: %s", s, err) } } return prefix, nil } func (x IP4Prefix) ToIPNet() *net.IPNet { mask := net.CIDRMask(int(x.Len), 32) ipnet := &net.IPNet{IP: x.Address.ToIP(), Mask: mask} return ipnet } func (x IP4Prefix) String() string { ip := x.Address.String() return ip + "/" + strconv.Itoa(int(x.Len)) } func (x *IP4Prefix) MarshalText() ([]byte, error) { return []byte(x.String()), nil } func (x *IP4Prefix) UnmarshalText(text []byte) error { prefix, err := ParseIP4Prefix(string(text)) if err != nil { return err } *x = prefix return nil } // IP6Prefix defines type 'ip6_prefix'. type IP6Prefix struct { Address IP6Address `binapi:"ip6_address,name=address" json:"address,omitempty"` Len uint8 `binapi:"u8,name=len" json:"len,omitempty"` } func ParseIP6Prefix(s string) (prefix IP6Prefix, err error) { hasPrefix := strings.Contains(s, "/") if hasPrefix { ip, network, err := net.ParseCIDR(s) if err != nil { return IP6Prefix{}, fmt.Errorf("invalid IP %s: %s", s, err) } maskSize, _ := network.Mask.Size() prefix.Len = byte(maskSize) prefix.Address, err = ParseIP6Address(ip.String()) if err != nil { return IP6Prefix{}, fmt.Errorf("invalid IP %s: %s", s, err) } } else { ip := net.ParseIP(s) defaultMaskSize, _ := net.CIDRMask(32, 32).Size() if ip.To4() == nil { defaultMaskSize, _ = net.CIDRMask(128, 128).Size() } prefix.Len = byte(defaultMaskSize) prefix.Address, err = ParseIP6Address(ip.String()) if err != nil { return IP6Prefix{}, fmt.Errorf("invalid IP %s: %s", s, err) } } return prefix, nil } func (x IP6Prefix) ToIPNet() *net.IPNet { mask := net.CIDRMask(int(x.Len), 128) ipnet := &net.IPNet{IP: x.Address.ToIP(), Mask: mask} return ipnet } func (x IP6Prefix) String() string { ip := x.Address.String() return ip + "/" + strconv.Itoa(int(x.Len)) } func (x *IP6Prefix) MarshalText() ([]byte, error) { return []byte(x.String()), nil } func (x *IP6Prefix) UnmarshalText(text []byte) error { prefix, err := ParseIP6Prefix(string(text)) if err != nil { return err } *x = prefix return nil } // LbVip defines type 'lb_vip'. type LbVip struct { Pfx AddressWithPrefix `binapi:"address_with_prefix,name=pfx" json:"pfx,omitempty"` Protocol IPProto `binapi:"ip_proto,name=protocol" json:"protocol,omitempty"` Port uint16 `binapi:"u16,name=port" json:"port,omitempty"` } // Mprefix defines type 'mprefix'. type Mprefix struct { Af AddressFamily `binapi:"address_family,name=af" json:"af,omitempty"` GrpAddressLength uint16 `binapi:"u16,name=grp_address_length" json:"grp_address_length,omitempty"` GrpAddress AddressUnion `binapi:"address_union,name=grp_address" json:"grp_address,omitempty"` SrcAddress AddressUnion `binapi:"address_union,name=src_address" json:"src_address,omitempty"` } // Prefix defines type 'prefix'. type Prefix struct { Address Address `binapi:"address,name=address" json:"address,omitempty"` Len uint8 `binapi:"u8,name=len" json:"len,omitempty"` } func ParsePrefix(ip string) (prefix Prefix, err error) { hasPrefix := strings.Contains(ip, "/") if hasPrefix { netIP, network, err := net.ParseCIDR(ip) if err != nil { return Prefix{}, fmt.Errorf("invalid IP %s: %s", ip, err) } maskSize, _ := network.Mask.Size() prefix.Len = byte(maskSize) prefix.Address, err = ParseAddress(netIP.String()) if err != nil { return Prefix{}, fmt.Errorf("invalid IP %s: %s", ip, err) } } else { netIP := net.ParseIP(ip) defaultMaskSize, _ := net.CIDRMask(32, 32).Size() if netIP.To4() == nil { defaultMaskSize, _ = net.CIDRMask(128, 128).Size() } prefix.Len = byte(defaultMaskSize) prefix.Address, err = ParseAddress(netIP.String()) if err != nil { return Prefix{}, fmt.Errorf("invalid IP %s: %s", ip, err) } } return prefix, nil } func (x Prefix) ToIPNet() *net.IPNet { var mask net.IPMask if x.Address.Af == ADDRESS_IP4 { mask = net.CIDRMask(int(x.Len), 32) } else { mask = net.CIDRMask(int(x.Len), 128) } ipnet := &net.IPNet{IP: x.Address.ToIP(), Mask: mask} return ipnet } func (x Prefix) String() string { ip := x.Address.String() return ip + "/" + strconv.Itoa(int(x.Len)) } func (x *Prefix) MarshalText() ([]byte, error) { return []byte(x.String()), nil } func (x *Prefix) UnmarshalText(text []byte) error { prefix, err := ParsePrefix(string(text)) if err != nil { return err } *x = prefix return nil } // PrefixMatcher defines type 'prefix_matcher'. type PrefixMatcher struct { Le uint8 `binapi:"u8,name=le" json:"le,omitempty"` Ge uint8 `binapi:"u8,name=ge" json:"ge,omitempty"` } // AddressUnion defines union 'address_union'. type AddressUnion struct { // IP4 *IP4Address // IP6 *IP6Address XXX_UnionData [16]byte } func AddressUnionIP4(a IP4Address) (u AddressUnion) { u.SetIP4(a) return } func (u *AddressUnion) SetIP4(a IP4Address) { buf := codec.NewBuffer(u.XXX_UnionData[:]) buf.EncodeBytes(a[:], 4) } func (u *AddressUnion) GetIP4() (a IP4Address) { buf := codec.NewBuffer(u.XXX_UnionData[:]) copy(a[:], buf.DecodeBytes(4)) return } func AddressUnionIP6(a IP6Address) (u AddressUnion) { u.SetIP6(a) return } func (u *AddressUnion) SetIP6(a IP6Address) { buf := codec.NewBuffer(u.XXX_UnionData[:]) buf.EncodeBytes(a[:], 16) } func (u *AddressUnion) GetIP6() (a IP6Address) { buf := codec.NewBuffer(u.XXX_UnionData[:]) copy(a[:], buf.DecodeBytes(16)) return } // LbAddDelAs defines message 'lb_add_del_as'. type LbAddDelAs struct { Pfx AddressWithPrefix `binapi:"address_with_prefix,name=pfx" json:"pfx,omitempty"` Protocol uint8 `binapi:"u8,name=protocol,default=255" json:"protocol,omitempty"` Port uint16 `binapi:"u16,name=port" json:"port,omitempty"` AsAddress Address `binapi:"address,name=as_address" json:"as_address,omitempty"` IsDel bool `binapi:"bool,name=is_del" json:"is_del,omitempty"` IsFlush bool `binapi:"bool,name=is_flush" json:"is_flush,omitempty"` } func (m *LbAddDelAs) Reset() { *m = LbAddDelAs{} } func (*LbAddDelAs) GetMessageName() string { return "lb_add_del_as" } func (*LbAddDelAs) GetCrcString() string { return "78628987" } func (*LbAddDelAs) GetMessageType() api.MessageType { return api.RequestMessage } func (m *LbAddDelAs) Size() (size int) { if m == nil { return 0 } size += 4 // m.Pfx.Address.Af size += 1 * 16 // m.Pfx.Address.Un size += 1 // m.Pfx.Len size += 1 // m.Protocol size += 2 // m.Port size += 4 // m.AsAddress.Af size += 1 * 16 // m.AsAddress.Un size += 1 // m.IsDel size += 1 // m.IsFlush return size } func (m *LbAddDelAs) Marshal(b []byte) ([]byte, error) { if b == nil { b = make([]byte, m.Size()) } buf := codec.NewBuffer(b) buf.EncodeUint32(uint32(m.Pfx.Address.Af)) buf.EncodeBytes(m.Pfx.Address.Un.XXX_UnionData[:], 16) buf.EncodeUint8(m.Pfx.Len) buf.EncodeUint8(m.Protocol) buf.EncodeUint16(m.Port) buf.EncodeUint32(uint32(m.AsAddress.Af)) buf.EncodeBytes(m.AsAddress.Un.XXX_UnionData[:], 16) buf.EncodeBool(m.IsDel) buf.EncodeBool(m.IsFlush) return buf.Bytes(), nil } func (m *LbAddDelAs) Unmarshal(b []byte) error { buf := codec.NewBuffer(b) m.Pfx.Address.Af = AddressFamily(buf.DecodeUint32()) copy(m.Pfx.Address.Un.XXX_UnionData[:], buf.DecodeBytes(16)) m.Pfx.Len = buf.DecodeUint8() m.Protocol = buf.DecodeUint8() m.Port = buf.DecodeUint16() m.AsAddress.Af = AddressFamily(buf.DecodeUint32()) copy(m.AsAddress.Un.XXX_UnionData[:], buf.DecodeBytes(16)) m.IsDel = buf.DecodeBool() m.IsFlush = buf.DecodeBool() return nil } // LbAddDelAsReply defines message 'lb_add_del_as_reply'. type LbAddDelAsReply struct { Retval int32 `binapi:"i32,name=retval" json:"retval,omitempty"` } func (m *LbAddDelAsReply) Reset() { *m = LbAddDelAsReply{} } func (*LbAddDelAsReply) GetMessageName() string { return "lb_add_del_as_reply" } func (*LbAddDelAsReply) GetCrcString() string { return "e8d4e804" } func (*LbAddDelAsReply) GetMessageType() api.MessageType { return api.ReplyMessage } func (m *LbAddDelAsReply) Size() (size int) { if m == nil { return 0 } size += 4 // m.Retval return size } func (m *LbAddDelAsReply) Marshal(b []byte) ([]byte, error) { if b == nil { b = make([]byte, m.Size()) } buf := codec.NewBuffer(b) buf.EncodeInt32(m.Retval) return buf.Bytes(), nil } func (m *LbAddDelAsReply) Unmarshal(b []byte) error { buf := codec.NewBuffer(b) m.Retval = buf.DecodeInt32() return nil } // LbAddDelIntfNat4 defines message 'lb_add_del_intf_nat4'. type LbAddDelIntfNat4 struct { IsAdd bool `binapi:"bool,name=is_add" json:"is_add,omitempty"` SwIfIndex InterfaceIndex `binapi:"interface_index,name=sw_if_index" json:"sw_if_index,omitempty"` } func (m *LbAddDelIntfNat4) Reset() { *m = LbAddDelIntfNat4{} } func (*LbAddDelIntfNat4) GetMessageName() string { return "lb_add_del_intf_nat4" } func (*LbAddDelIntfNat4) GetCrcString() string { return "47d6e753" } func (*LbAddDelIntfNat4) GetMessageType() api.MessageType { return api.RequestMessage } func (m *LbAddDelIntfNat4) Size() (size int) { if m == nil { return 0 } size += 1 // m.IsAdd size += 4 // m.SwIfIndex return size } func (m *LbAddDelIntfNat4) Marshal(b []byte) ([]byte, error) { if b == nil { b = make([]byte, m.Size()) } buf := codec.NewBuffer(b) buf.EncodeBool(m.IsAdd) buf.EncodeUint32(uint32(m.SwIfIndex)) return buf.Bytes(), nil } func (m *LbAddDelIntfNat4) Unmarshal(b []byte) error { buf := codec.NewBuffer(b) m.IsAdd = buf.DecodeBool() m.SwIfIndex = InterfaceIndex(buf.DecodeUint32()) return nil } // LbAddDelIntfNat4Reply defines message 'lb_add_del_intf_nat4_reply'. type LbAddDelIntfNat4Reply struct { Retval int32 `binapi:"i32,name=retval" json:"retval,omitempty"` } func (m *LbAddDelIntfNat4Reply) Reset() { *m = LbAddDelIntfNat4Reply{} } func (*LbAddDelIntfNat4Reply) GetMessageName() string { return "lb_add_del_intf_nat4_reply" } func (*LbAddDelIntfNat4Reply) GetCrcString() string { return "e8d4e804" } func (*LbAddDelIntfNat4Reply) GetMessageType() api.MessageType { return api.ReplyMessage } func (m *LbAddDelIntfNat4Reply) Size() (size int) { if m == nil { return 0 } size += 4 // m.Retval return size } func (m *LbAddDelIntfNat4Reply) Marshal(b []byte) ([]byte, error) { if b == nil { b = make([]byte, m.Size()) } buf := codec.NewBuffer(b) buf.EncodeInt32(m.Retval) return buf.Bytes(), nil } func (m *LbAddDelIntfNat4Reply) Unmarshal(b []byte) error { buf := codec.NewBuffer(b) m.Retval = buf.DecodeInt32() return nil } // LbAddDelIntfNat6 defines message 'lb_add_del_intf_nat6'. type LbAddDelIntfNat6 struct { IsAdd bool `binapi:"bool,name=is_add" json:"is_add,omitempty"` SwIfIndex InterfaceIndex `binapi:"interface_index,name=sw_if_index" json:"sw_if_index,omitempty"` } func (m *LbAddDelIntfNat6) Reset() { *m = LbAddDelIntfNat6{} } func (*LbAddDelIntfNat6) GetMessageName() string { return "lb_add_del_intf_nat6" } func (*LbAddDelIntfNat6) GetCrcString() string { return "47d6e753" } func (*LbAddDelIntfNat6) GetMessageType() api.MessageType { return api.RequestMessage } func (m *LbAddDelIntfNat6) Size() (size int) { if m == nil { return 0 } size += 1 // m.IsAdd size += 4 // m.SwIfIndex return size } func (m *LbAddDelIntfNat6) Marshal(b []byte) ([]byte, error) { if b == nil { b = make([]byte, m.Size()) } buf := codec.NewBuffer(b) buf.EncodeBool(m.IsAdd) buf.EncodeUint32(uint32(m.SwIfIndex)) return buf.Bytes(), nil } func (m *LbAddDelIntfNat6) Unmarshal(b []byte) error { buf := codec.NewBuffer(b) m.IsAdd = buf.DecodeBool() m.SwIfIndex = InterfaceIndex(buf.DecodeUint32()) return nil } // LbAddDelIntfNat6Reply defines message 'lb_add_del_intf_nat6_reply'. type LbAddDelIntfNat6Reply struct { Retval int32 `binapi:"i32,name=retval" json:"retval,omitempty"` } func (m *LbAddDelIntfNat6Reply) Reset() { *m = LbAddDelIntfNat6Reply{} } func (*LbAddDelIntfNat6Reply) GetMessageName() string { return "lb_add_del_intf_nat6_reply" } func (*LbAddDelIntfNat6Reply) GetCrcString() string { return "e8d4e804" } func (*LbAddDelIntfNat6Reply) GetMessageType() api.MessageType { return api.ReplyMessage } func (m *LbAddDelIntfNat6Reply) Size() (size int) { if m == nil { return 0 } size += 4 // m.Retval return size } func (m *LbAddDelIntfNat6Reply) Marshal(b []byte) ([]byte, error) { if b == nil { b = make([]byte, m.Size()) } buf := codec.NewBuffer(b) buf.EncodeInt32(m.Retval) return buf.Bytes(), nil } func (m *LbAddDelIntfNat6Reply) Unmarshal(b []byte) error { buf := codec.NewBuffer(b) m.Retval = buf.DecodeInt32() return nil } // LbAddDelVip defines message 'lb_add_del_vip'. type LbAddDelVip struct { Pfx AddressWithPrefix `binapi:"address_with_prefix,name=pfx" json:"pfx,omitempty"` Protocol uint8 `binapi:"u8,name=protocol,default=255" json:"protocol,omitempty"` Port uint16 `binapi:"u16,name=port" json:"port,omitempty"` Encap LbEncapType `binapi:"lb_encap_type,name=encap" json:"encap,omitempty"` Dscp uint8 `binapi:"u8,name=dscp" json:"dscp,omitempty"` Type LbSrvType `binapi:"lb_srv_type,name=type" json:"type,omitempty"` TargetPort uint16 `binapi:"u16,name=target_port" json:"target_port,omitempty"` NodePort uint16 `binapi:"u16,name=node_port" json:"node_port,omitempty"` NewFlowsTableLength uint32 `binapi:"u32,name=new_flows_table_length,default=1024" json:"new_flows_table_length,omitempty"` IsDel bool `binapi:"bool,name=is_del" json:"is_del,omitempty"` } func (m *LbAddDelVip) Reset() { *m = LbAddDelVip{} } func (*LbAddDelVip) GetMessageName() string { return "lb_add_del_vip" } func (*LbAddDelVip) GetCrcString() string { return "d15b7ddc" } func (*LbAddDelVip) GetMessageType() api.MessageType { return api.RequestMessage } func (m *LbAddDelVip) Size() (size int) { if m == nil { return 0 } size += 4 // m.Pfx.Address.Af size += 1 * 16 // m.Pfx.Address.Un size += 1 // m.Pfx.Len size += 1 // m.Protocol size += 2 // m.Port size += 4 // m.Encap size += 1 // m.Dscp size += 4 // m.Type size += 2 // m.TargetPort size += 2 // m.NodePort size += 4 // m.NewFlowsTableLength size += 1 // m.IsDel return size } func (m *LbAddDelVip) Marshal(b []byte) ([]byte, error) { if b == nil { b = make([]byte, m.Size()) } buf := codec.NewBuffer(b) buf.EncodeUint32(uint32(m.Pfx.Address.Af)) buf.EncodeBytes(m.Pfx.Address.Un.XXX_UnionData[:], 16) buf.EncodeUint8(m.Pfx.Len) buf.EncodeUint8(m.Protocol) buf.EncodeUint16(m.Port) buf.EncodeUint32(uint32(m.Encap)) buf.EncodeUint8(m.Dscp) buf.EncodeUint32(uint32(m.Type)) buf.EncodeUint16(m.TargetPort) buf.EncodeUint16(m.NodePort) buf.EncodeUint32(m.NewFlowsTableLength) buf.EncodeBool(m.IsDel) return buf.Bytes(), nil } func (m *LbAddDelVip) Unmarshal(b []byte) error { buf := codec.NewBuffer(b) m.Pfx.Address.Af = AddressFamily(buf.DecodeUint32()) copy(m.Pfx.Address.Un.XXX_UnionData[:], buf.DecodeBytes(16)) m.Pfx.Len = buf.DecodeUint8() m.Protocol = buf.DecodeUint8() m.Port = buf.DecodeUint16() m.Encap = LbEncapType(buf.DecodeUint32()) m.Dscp = buf.DecodeUint8() m.Type = LbSrvType(buf.DecodeUint32()) m.TargetPort = buf.DecodeUint16() m.NodePort = buf.DecodeUint16() m.NewFlowsTableLength = buf.DecodeUint32() m.IsDel = buf.DecodeBool() return nil } // LbAddDelVipReply defines message 'lb_add_del_vip_reply'. type LbAddDelVipReply struct { Retval int32 `binapi:"i32,name=retval" json:"retval,omitempty"` } func (m *LbAddDelVipReply) Reset() { *m = LbAddDelVipReply{} } func (*LbAddDelVipReply) GetMessageName() string { return "lb_add_del_vip_reply" } func (*LbAddDelVipReply) GetCrcString() string { return "e8d4e804" } func (*LbAddDelVipReply) GetMessageType() api.MessageType { return api.ReplyMessage } func (m *LbAddDelVipReply) Size() (size int) { if m == nil { return 0 } size += 4 // m.Retval return size } func (m *LbAddDelVipReply) Marshal(b []byte) ([]byte, error) { if b == nil { b = make([]byte, m.Size()) } buf := codec.NewBuffer(b) buf.EncodeInt32(m.Retval) return buf.Bytes(), nil } func (m *LbAddDelVipReply) Unmarshal(b []byte) error { buf := codec.NewBuffer(b) m.Retval = buf.DecodeInt32() return nil } // LbAsDetails defines message 'lb_as_details'. type LbAsDetails struct { Vip LbVip `binapi:"lb_vip,name=vip" json:"vip,omitempty"` AppSrv Address `binapi:"address,name=app_srv" json:"app_srv,omitempty"` Flags uint8 `binapi:"u8,name=flags" json:"flags,omitempty"` InUseSince uint32 `binapi:"u32,name=in_use_since" json:"in_use_since,omitempty"` } func (m *LbAsDetails) Reset() { *m = LbAsDetails{} } func (*LbAsDetails) GetMessageName() string { return "lb_as_details" } func (*LbAsDetails) GetCrcString() string { return "9c39f60e" } func (*LbAsDetails) GetMessageType() api.MessageType { return api.ReplyMessage } func (m *LbAsDetails) Size() (size int) { if m == nil { return 0 } size += 4 // m.Vip.Pfx.Address.Af size += 1 * 16 // m.Vip.Pfx.Address.Un size += 1 // m.Vip.Pfx.Len size += 4 // m.Vip.Protocol size += 2 // m.Vip.Port size += 4 // m.AppSrv.Af size += 1 * 16 // m.AppSrv.Un size += 1 // m.Flags size += 4 // m.InUseSince return size } func (m *LbAsDetails) Marshal(b []byte) ([]byte, error) { if b == nil { b = make([]byte, m.Size()) } buf := codec.NewBuffer(b) buf.EncodeUint32(uint32(m.Vip.Pfx.Address.Af)) buf.EncodeBytes(m.Vip.Pfx.Address.Un.XXX_UnionData[:], 16) buf.EncodeUint8(m.Vip.Pfx.Len) buf.EncodeUint32(uint32(m.Vip.Protocol)) buf.EncodeUint16(m.Vip.Port) buf.EncodeUint32(uint32(m.AppSrv.Af)) buf.EncodeBytes(m.AppSrv.Un.XXX_UnionData[:], 16) buf.EncodeUint8(m.Flags) buf.EncodeUint32(m.InUseSince) return buf.Bytes(), nil } func (m *LbAsDetails) Unmarshal(b []byte) error { buf := codec.NewBuffer(b) m.Vip.Pfx.Address.Af = AddressFamily(buf.DecodeUint32()) copy(m.Vip.Pfx.Address.Un.XXX_UnionData[:], buf.DecodeBytes(16)) m.Vip.Pfx.Len = buf.DecodeUint8() m.Vip.Protocol = IPProto(buf.DecodeUint32()) m.Vip.Port = buf.DecodeUint16() m.AppSrv.Af = AddressFamily(buf.DecodeUint32()) copy(m.AppSrv.Un.XXX_UnionData[:], buf.DecodeBytes(16)) m.Flags = buf.DecodeUint8() m.InUseSince = buf.DecodeUint32() return nil } // LbAsDump defines message 'lb_as_dump'. type LbAsDump struct { Pfx AddressWithPrefix `binapi:"address_with_prefix,name=pfx" json:"pfx,omitempty"` Protocol uint8 `binapi:"u8,name=protocol" json:"protocol,omitempty"` Port uint16 `binapi:"u16,name=port" json:"port,omitempty"` } func (m *LbAsDump) Reset() { *m = LbAsDump{} } func (*LbAsDump) GetMessageName() string { return "lb_as_dump" } func (*LbAsDump) GetCrcString() string { return "1063f819" } func (*LbAsDump) GetMessageType() api.MessageType { return api.RequestMessage } func (m *LbAsDump) Size() (size int) { if m == nil { return 0 } size += 4 // m.Pfx.Address.Af size += 1 * 16 // m.Pfx.Address.Un size += 1 // m.Pfx.Len size += 1 // m.Protocol size += 2 // m.Port return size } func (m *LbAsDump) Marshal(b []byte) ([]byte, error) { if b == nil { b = make([]byte, m.Size()) } buf := codec.NewBuffer(b) buf.EncodeUint32(uint32(m.Pfx.Address.Af)) buf.EncodeBytes(m.Pfx.Address.Un.XXX_UnionData[:], 16) buf.EncodeUint8(m.Pfx.Len) buf.EncodeUint8(m.Protocol) buf.EncodeUint16(m.Port) return buf.Bytes(), nil } func (m *LbAsDump) Unmarshal(b []byte) error { buf := codec.NewBuffer(b) m.Pfx.Address.Af = AddressFamily(buf.DecodeUint32()) copy(m.Pfx.Address.Un.XXX_UnionData[:], buf.DecodeBytes(16)) m.Pfx.Len = buf.DecodeUint8() m.Protocol = buf.DecodeUint8() m.Port = buf.DecodeUint16() return nil } // LbConf defines message 'lb_conf'. type LbConf struct { IP4SrcAddress IP4Address `binapi:"ip4_address,name=ip4_src_address" json:"ip4_src_address,omitempty"` IP6SrcAddress IP6Address `binapi:"ip6_address,name=ip6_src_address" json:"ip6_src_address,omitempty"` StickyBucketsPerCore uint32 `binapi:"u32,name=sticky_buckets_per_core" json:"sticky_buckets_per_core,omitempty"` FlowTimeout uint32 `binapi:"u32,name=flow_timeout" json:"flow_timeout,omitempty"` } func (m *LbConf) Reset() { *m = LbConf{} } func (*LbConf) GetMessageName() string { return "lb_conf" } func (*LbConf) GetCrcString() string { return "22ddb739" } func (*LbConf) GetMessageType() api.MessageType { return api.RequestMessage } func (m *LbConf) Size() (size int) { if m == nil { return 0 } size += 1 * 4 // m.IP4SrcAddress size += 1 * 16 // m.IP6SrcAddress size += 4 // m.StickyBucketsPerCore size += 4 // m.FlowTimeout return size } func (m *LbConf) Marshal(b []byte) ([]byte, error) { if b == nil { b = make([]byte, m.Size()) } buf := codec.NewBuffer(b) buf.EncodeBytes(m.IP4SrcAddress[:], 4) buf.EncodeBytes(m.IP6SrcAddress[:], 16) buf.EncodeUint32(m.StickyBucketsPerCore) buf.EncodeUint32(m.FlowTimeout) return buf.Bytes(), nil } func (m *LbConf) Unmarshal(b []byte) error { buf := codec.NewBuffer(b) copy(m.IP4SrcAddress[:], buf.DecodeBytes(4)) copy(m.IP6SrcAddress[:], buf.DecodeBytes(16)) m.StickyBucketsPerCore = buf.DecodeUint32() m.FlowTimeout = buf.DecodeUint32() return nil } // LbConfReply defines message 'lb_conf_reply'. type LbConfReply struct { Retval int32 `binapi:"i32,name=retval" json:"retval,omitempty"` } func (m *LbConfReply) Reset() { *m = LbConfReply{} } func (*LbConfReply) GetMessageName() string { return "lb_conf_reply" } func (*LbConfReply) GetCrcString() string { return "e8d4e804" } func (*LbConfReply) GetMessageType() api.MessageType { return api.ReplyMessage } func (m *LbConfReply) Size() (size int) { if m == nil { return 0 } size += 4 // m.Retval return size } func (m *LbConfReply) Marshal(b []byte) ([]byte, error) { if b == nil { b = make([]byte, m.Size()) } buf := codec.NewBuffer(b) buf.EncodeInt32(m.Retval) return buf.Bytes(), nil } func (m *LbConfReply) Unmarshal(b []byte) error { buf := codec.NewBuffer(b) m.Retval = buf.DecodeInt32() return nil } // LbFlushVip defines message 'lb_flush_vip'. type LbFlushVip struct { Pfx AddressWithPrefix `binapi:"address_with_prefix,name=pfx" json:"pfx,omitempty"` Protocol uint8 `binapi:"u8,name=protocol" json:"protocol,omitempty"` Port uint16 `binapi:"u16,name=port" json:"port,omitempty"` } func (m *LbFlushVip) Reset() { *m = LbFlushVip{} } func (*LbFlushVip) GetMessageName() string { return "lb_flush_vip" } func (*LbFlushVip) GetCrcString() string { return "1063f819" } func (*LbFlushVip) GetMessageType() api.MessageType { return api.RequestMessage } func (m *LbFlushVip) Size() (size int) { if m == nil { return 0 } size += 4 // m.Pfx.Address.Af size += 1 * 16 // m.Pfx.Address.Un size += 1 // m.Pfx.Len size += 1 // m.Protocol size += 2 // m.Port return size } func (m *LbFlushVip) Marshal(b []byte) ([]byte, error) { if b == nil { b = make([]byte, m.Size()) } buf := codec.NewBuffer(b) buf.EncodeUint32(uint32(m.Pfx.Address.Af)) buf.EncodeBytes(m.Pfx.Address.Un.XXX_UnionData[:], 16) buf.EncodeUint8(m.Pfx.Len) buf.EncodeUint8(m.Protocol) buf.EncodeUint16(m.Port) return buf.Bytes(), nil } func (m *LbFlushVip) Unmarshal(b []byte) error { buf := codec.NewBuffer(b) m.Pfx.Address.Af = AddressFamily(buf.DecodeUint32()) copy(m.Pfx.Address.Un.XXX_UnionData[:], buf.DecodeBytes(16)) m.Pfx.Len = buf.DecodeUint8() m.Protocol = buf.DecodeUint8() m.Port = buf.DecodeUint16() return nil } // LbFlushVipReply defines message 'lb_flush_vip_reply'. type LbFlushVipReply struct { Retval int32 `binapi:"i32,name=retval" json:"retval,omitempty"` } func (m *LbFlushVipReply) Reset() { *m = LbFlushVipReply{} } func (*LbFlushVipReply) GetMessageName() string { return "lb_flush_vip_reply" } func (*LbFlushVipReply) GetCrcString() string { return "e8d4e804" } func (*LbFlushVipReply) GetMessageType() api.MessageType { return api.ReplyMessage } func (m *LbFlushVipReply) Size() (size int) { if m == nil { return 0 } size += 4 // m.Retval return size } func (m *LbFlushVipReply) Marshal(b []byte) ([]byte, error) { if b == nil { b = make([]byte, m.Size()) } buf := codec.NewBuffer(b) buf.EncodeInt32(m.Retval) return buf.Bytes(), nil } func (m *LbFlushVipReply) Unmarshal(b []byte) error { buf := codec.NewBuffer(b) m.Retval = buf.DecodeInt32() return nil } // LbVipDetails defines message 'lb_vip_details'. type LbVipDetails struct { Vip LbVip `binapi:"lb_vip,name=vip" json:"vip,omitempty"` Encap LbEncapType `binapi:"lb_encap_type,name=encap" json:"encap,omitempty"` Dscp IPDscp `binapi:"ip_dscp,name=dscp" json:"dscp,omitempty"` SrvType LbSrvType `binapi:"lb_srv_type,name=srv_type" json:"srv_type,omitempty"` TargetPort uint16 `binapi:"u16,name=target_port" json:"target_port,omitempty"` FlowTableLength uint16 `binapi:"u16,name=flow_table_length" json:"flow_table_length,omitempty"` } func (m *LbVipDetails) Reset() { *m = LbVipDetails{} } func (*LbVipDetails) GetMessageName() string { return "lb_vip_details" } func (*LbVipDetails) GetCrcString() string { return "08f39bed" } func (*LbVipDetails) GetMessageType() api.MessageType { return api.ReplyMessage } func (m *LbVipDetails) Size() (size int) { if m == nil { return 0 } size += 4 // m.Vip.Pfx.Address.Af size += 1 * 16 // m.Vip.Pfx.Address.Un size += 1 // m.Vip.Pfx.Len size += 4 // m.Vip.Protocol size += 2 // m.Vip.Port size += 4 // m.Encap size += 1 // m.Dscp size += 4 // m.SrvType size += 2 // m.TargetPort size += 2 // m.FlowTableLength return size } func (m *LbVipDetails) Marshal(b []byte) ([]byte, error) { if b == nil { b = make([]byte, m.Size()) } buf := codec.NewBuffer(b) buf.EncodeUint32(uint32(m.Vip.Pfx.Address.Af)) buf.EncodeBytes(m.Vip.Pfx.Address.Un.XXX_UnionData[:], 16) buf.EncodeUint8(m.Vip.Pfx.Len) buf.EncodeUint32(uint32(m.Vip.Protocol)) buf.EncodeUint16(m.Vip.Port) buf.EncodeUint32(uint32(m.Encap)) buf.EncodeUint8(uint8(m.Dscp)) buf.EncodeUint32(uint32(m.SrvType)) buf.EncodeUint16(m.TargetPort) buf.EncodeUint16(m.FlowTableLength) return buf.Bytes(), nil } func (m *LbVipDetails) Unmarshal(b []byte) error { buf := codec.NewBuffer(b) m.Vip.Pfx.Address.Af = AddressFamily(buf.DecodeUint32()) copy(m.Vip.Pfx.Address.Un.XXX_UnionData[:], buf.DecodeBytes(16)) m.Vip.Pfx.Len = buf.DecodeUint8() m.Vip.Protocol = IPProto(buf.DecodeUint32()) m.Vip.Port = buf.DecodeUint16() m.Encap = LbEncapType(buf.DecodeUint32()) m.Dscp = IPDscp(buf.DecodeUint8()) m.SrvType = LbSrvType(buf.DecodeUint32()) m.TargetPort = buf.DecodeUint16() m.FlowTableLength = buf.DecodeUint16() return nil } // LbVipDump defines message 'lb_vip_dump'. type LbVipDump struct { Pfx AddressWithPrefix `binapi:"address_with_prefix,name=pfx" json:"pfx,omitempty"` PfxMatcher PrefixMatcher `binapi:"prefix_matcher,name=pfx_matcher" json:"pfx_matcher,omitempty"` Protocol uint8 `binapi:"u8,name=protocol,default=255" json:"protocol,omitempty"` Port uint16 `binapi:"u16,name=port" json:"port,omitempty"` } func (m *LbVipDump) Reset() { *m = LbVipDump{} } func (*LbVipDump) GetMessageName() string { return "lb_vip_dump" } func (*LbVipDump) GetCrcString() string { return "c7bcb124" } func (*LbVipDump) GetMessageType() api.MessageType { return api.RequestMessage } func (m *LbVipDump) Size() (size int) { if m == nil { return 0 } size += 4 // m.Pfx.Address.Af size += 1 * 16 // m.Pfx.Address.Un size += 1 // m.Pfx.Len size += 1 // m.PfxMatcher.Le size += 1 // m.PfxMatcher.Ge size += 1 // m.Protocol size += 2 // m.Port return size } func (m *LbVipDump) Marshal(b []byte) ([]byte, error) { if b == nil { b = make([]byte, m.Size()) } buf := codec.NewBuffer(b) buf.EncodeUint32(uint32(m.Pfx.Address.Af)) buf.EncodeBytes(m.Pfx.Address.Un.XXX_UnionData[:], 16) buf.EncodeUint8(m.Pfx.Len) buf.EncodeUint8(m.PfxMatcher.Le) buf.EncodeUint8(m.PfxMatcher.Ge) buf.EncodeUint8(m.Protocol) buf.EncodeUint16(m.Port) return buf.Bytes(), nil } func (m *LbVipDump) Unmarshal(b []byte) error { buf := codec.NewBuffer(b) m.Pfx.Address.Af = AddressFamily(buf.DecodeUint32()) copy(m.Pfx.Address.Un.XXX_UnionData[:], buf.DecodeBytes(16)) m.Pfx.Len = buf.DecodeUint8() m.PfxMatcher.Le = buf.DecodeUint8() m.PfxMatcher.Ge = buf.DecodeUint8() m.Protocol = buf.DecodeUint8() m.Port = buf.DecodeUint16() return nil } func init() { file_lb_binapi_init() } func file_lb_binapi_init() { api.RegisterMessage((*LbAddDelAs)(nil), "lb_add_del_as_78628987") api.RegisterMessage((*LbAddDelAsReply)(nil), "lb_add_del_as_reply_e8d4e804") api.RegisterMessage((*LbAddDelIntfNat4)(nil), "lb_add_del_intf_nat4_47d6e753") api.RegisterMessage((*LbAddDelIntfNat4Reply)(nil), "lb_add_del_intf_nat4_reply_e8d4e804") api.RegisterMessage((*LbAddDelIntfNat6)(nil), "lb_add_del_intf_nat6_47d6e753") api.RegisterMessage((*LbAddDelIntfNat6Reply)(nil), "lb_add_del_intf_nat6_reply_e8d4e804") api.RegisterMessage((*LbAddDelVip)(nil), "lb_add_del_vip_d15b7ddc") api.RegisterMessage((*LbAddDelVipReply)(nil), "lb_add_del_vip_reply_e8d4e804") api.RegisterMessage((*LbAsDetails)(nil), "lb_as_details_9c39f60e") api.RegisterMessage((*LbAsDump)(nil), "lb_as_dump_1063f819") api.RegisterMessage((*LbConf)(nil), "lb_conf_22ddb739") api.RegisterMessage((*LbConfReply)(nil), "lb_conf_reply_e8d4e804") api.RegisterMessage((*LbFlushVip)(nil), "lb_flush_vip_1063f819") api.RegisterMessage((*LbFlushVipReply)(nil), "lb_flush_vip_reply_e8d4e804") api.RegisterMessage((*LbVipDetails)(nil), "lb_vip_details_08f39bed") api.RegisterMessage((*LbVipDump)(nil), "lb_vip_dump_c7bcb124") } // Messages returns list of all messages in this module. func AllMessages() []api.Message { return []api.Message{ (*LbAddDelAs)(nil), (*LbAddDelAsReply)(nil), (*LbAddDelIntfNat4)(nil), (*LbAddDelIntfNat4Reply)(nil), (*LbAddDelIntfNat6)(nil), (*LbAddDelIntfNat6Reply)(nil), (*LbAddDelVip)(nil), (*LbAddDelVipReply)(nil), (*LbAsDetails)(nil), (*LbAsDump)(nil), (*LbConf)(nil), (*LbConfReply)(nil), (*LbFlushVip)(nil), (*LbFlushVipReply)(nil), (*LbVipDetails)(nil), (*LbVipDump)(nil), } }