vr

README

vr: vrouter Sandesh binary protocol

Documentation

Index

• Constants
• Variables
• func Int32ToipAddr(i int32) net.IP
• type AgentVifConfig
  • func NewAgentVifConfig() *AgentVifConfig
• type BridgeRouteConfig
  • func NewBridgeRouteConfig() *BridgeRouteConfig
• type EncapNexthopConfig
  • func NewEncapNexthopConfig() *EncapNexthopConfig
• type FabricVifConfig
  • func NewFabricVifConfig() FabricVifConfig
• type Flow
  • func NewFlow(flowspec *flowSpec) (*Flow, error)
  • func NewInet6Flow(conf Inet6FlowConfig) (*Flow, error)
  • func NewInetFlow(conf InetFlowConfig) (*Flow, error)
  • func NewNatFlow(conf NatFlowConfig) (*Flow, error)
• type Inet6FlowConfig
  • func NewInet6FlowConfig() Inet6FlowConfig
• type Inet6RouteConfig
  • func NewInet6RouteConfig() *Inet6RouteConfig
• type InetFlowConfig
  • func NewInetFlowConfig() InetFlowConfig
• type InetRouteConfig
  • func NewInetRouteConfig() *InetRouteConfig
• type NatFlowConfig
  • func NewNatFlowConfig() NatFlowConfig
• type Netlink
  • func InitNetlink() (*Netlink, error)
  • func (nl *Netlink) SendAsync(s_req Sandesh) <-chan *NetlinkStream
• type NetlinkStream
• type Nexthop
  • func NewEncapNexthop(conf *EncapNexthopConfig) (*Nexthop, error)
  • func NewNextHop(nh_type uint8, nh_id int32, nh_family int8, nh_vrf int32, nh_flags uint32, ...) *Nexthop
  • func NewReceiveNexthop(conf *ReceiveNexthopConfig) (*Nexthop, error)
• type ReceiveNexthopConfig
  • func NewReceiveNexthopConfig() *ReceiveNexthopConfig
• type Route
  • func NewBridgeRoute(conf *BridgeRouteConfig) (*Route, error)
  • func NewInet6Route(conf *Inet6RouteConfig) (*Route, error)
  • func NewInetRoute(conf *InetRouteConfig) (*Route, error)
  • func NewRoute(oper, family, vrf int32, prefix net.IP, pref_len int32, mac string, ...) (*Route, error)
  • func (r *Route) GetMacAddressString() string
  • func (r *Route) GetPrefixString() string
• type Sandesh
• type TSandeshProtocol
  • func NewTSandeshProtocolConf(t th.TTransport, conf *th.TConfiguration) *TSandeshProtocol
  • func NewTSandeshProtocolTransport(t th.TTransport) *TSandeshProtocol
  • func (p *TSandeshProtocol) Flush(ctx context.Context) (err error)
  • func (p *TSandeshProtocol) GetProtocol(t th.TTransport) th.TProtocol
  • func (p *TSandeshProtocol) ReadBinary(ctx context.Context) ([]byte, error)
  • func (p *TSandeshProtocol) ReadBool(ctx context.Context) (bool, error)
  • func (p *TSandeshProtocol) ReadByte(ctx context.Context) (int8, error)
  • func (p *TSandeshProtocol) ReadDouble(ctx context.Context) (value float64, err error)
  • func (p *TSandeshProtocol) ReadFieldBegin(ctx context.Context) (name string, typeId th.TType, seqId int16, err error)
  • func (p *TSandeshProtocol) ReadFieldEnd(ctx context.Context) error
  • func (p *TSandeshProtocol) ReadI16(ctx context.Context) (value int16, err error)
  • func (p *TSandeshProtocol) ReadI32(ctx context.Context) (value int32, err error)
  • func (p *TSandeshProtocol) ReadI64(ctx context.Context) (value int64, err error)
  • func (p *TSandeshProtocol) ReadListBegin(ctx context.Context) (elemType th.TType, size int, err error)
  • func (p *TSandeshProtocol) ReadListEnd(ctx context.Context) error
  • func (p *TSandeshProtocol) ReadMapBegin(ctx context.Context) (kType, vType th.TType, size int, err error)
  • func (p *TSandeshProtocol) ReadMapEnd(ctx context.Context) error
  • func (p *TSandeshProtocol) ReadMessageBegin(ctx context.Context) (name string, typeId th.TMessageType, seqId int32, err error)
  • func (p *TSandeshProtocol) ReadMessageEnd(ctx context.Context) error
  • func (p *TSandeshProtocol) ReadSetBegin(ctx context.Context) (elemType th.TType, size int, err error)
  • func (p *TSandeshProtocol) ReadSetEnd(ctx context.Context) error
  • func (p *TSandeshProtocol) ReadString(ctx context.Context) (value string, err error)
  • func (p *TSandeshProtocol) ReadStructBegin(ctx context.Context) (name string, err error)
  • func (p *TSandeshProtocol) ReadStructEnd(ctx context.Context) error
  • func (p *TSandeshProtocol) SetTConfiguration(conf *th.TConfiguration)
  • func (p *TSandeshProtocol) Skip(ctx context.Context, fieldType th.TType) (err error)
  • func (p *TSandeshProtocol) Transport() th.TTransport
  • func (p *TSandeshProtocol) WriteBinary(ctx context.Context, value []byte) error
  • func (p *TSandeshProtocol) WriteBool(ctx context.Context, value bool) error
  • func (p *TSandeshProtocol) WriteByte(ctx context.Context, value int8) error
  • func (p *TSandeshProtocol) WriteDouble(ctx context.Context, value float64) error
  • func (p *TSandeshProtocol) WriteFieldBegin(ctx context.Context, name string, typeId th.TType, id int16) error
  • func (p *TSandeshProtocol) WriteFieldEnd(ctx context.Context) error
  • func (p *TSandeshProtocol) WriteFieldStop(ctx context.Context) error
  • func (p *TSandeshProtocol) WriteI16(ctx context.Context, value int16) error
  • func (p *TSandeshProtocol) WriteI32(ctx context.Context, value int32) error
  • func (p *TSandeshProtocol) WriteI64(ctx context.Context, value int64) error
  • func (p *TSandeshProtocol) WriteListBegin(ctx context.Context, elemType th.TType, size int) error
  • func (p *TSandeshProtocol) WriteListEnd(ctx context.Context) error
  • func (p *TSandeshProtocol) WriteMapBegin(ctx context.Context, keyType th.TType, valueType th.TType, size int) error
  • func (p *TSandeshProtocol) WriteMapEnd(ctx context.Context) error
  • func (p *TSandeshProtocol) WriteMessageBegin(ctx context.Context, name string, typeId th.TMessageType, seqId int32) error
  • func (p *TSandeshProtocol) WriteMessageEnd(ctx context.Context) error
  • func (p *TSandeshProtocol) WriteSetBegin(context.Context, th.TType, int) error
  • func (p *TSandeshProtocol) WriteSetEnd(ctx context.Context) error
  • func (p *TSandeshProtocol) WriteString(ctx context.Context, value string) error
  • func (p *TSandeshProtocol) WriteStructBegin(ctx context.Context, name string) error
  • func (p *TSandeshProtocol) WriteStructEnd(ctx context.Context) error
• type VhostVifConfig
  • func NewVhostVifConfig() *VhostVifConfig
• type Vif
  • func NewAgentVif(conf *AgentVifConfig) (*Vif, error)
  • func NewFabricVif(conf FabricVifConfig) (*Vif, error)
  • func NewVhostVif(conf *VhostVifConfig) (*Vif, error)
  • func NewVif(oper, idx, viftype int32, name, ipaddr, macaddr string, transport int8) (*Vif, error)
  • func NewVirtualVif(conf *VirtualVifConfig) (*Vif, error)
  • func (vif *Vif) GetIPAddressString() string
  • func (vif *Vif) GetMacAddressString() string
• type VirtualVifConfig
  • func NewVirtualVifConfig() *VirtualVifConfig
• type Vxlan
  • func NewVxlan(rid int16, vnid, nhid int32) (*Vxlan, error)

Constants

const (
	STOP     = 0
	VOID     = 1
	BOOL     = 2
	BYTE     = 3
	I08      = 3
	DOUBLE   = 4
	I16      = 6
	I32      = 8
	T_U64    = 9
	I64      = 10
	STRING   = 11
	UTF7     = 11
	STRUCT   = 12
	MAP      = 13
	SET      = 14
	LIST     = 15
	UTF8     = 16
	UTF16    = 17
	T_U16    = 19
	T_U32    = 20
	T_XML    = 21
	T_IPV4   = 22
	T_UUID   = 23
	T_IPADDR = 24
)

const AF_BRIDGE = 7

const AF_INET = 2

const AF_INET6 = 10

const AF_UNIX = 1

const DEST_UNREACH = 3

const ECHO_REPLY = 0

const ECHO_REQUEST = 8

const ETH_ALEN = 6

const FLOW_CONSUMED = 4

const FLOW_DROP = 2

const FLOW_EVICT_DROP = 5

const FLOW_FORWARD = 1

const FLOW_HELD = 0

const FLOW_OPER_LIST = 1

const FLOW_OPER_SET = 0

const FLOW_OPER_TABLE_GET = 2

const FLOW_TRAP = 3

const FMD_FLAG_ETREE_ENABLE = 0x04

const FMD_FLAG_ETREE_ROOT = 0x08

const FMD_FLAG_L2_CONTROL_DATA = 0x10

const FMD_FLAG_LABEL_IS_VXLAN_ID = 0x01

const FMD_FLAG_MAC_IS_MY_MAC = 0x02

const FMD_MIRROR_INVALID_DATA = 0xFFFF

const FMD_PKT_LOOP_TTL = 4

const MCAST_IP = (0xE0000000)

const MCAST_IP_MASK = (0xF0000000)

const NH_DISCARD_ID = 0

const NH_ECMP_CONFIG_HASH_BITS = 5

const NH_ECMP_CONFIG_HASH_DST_IP = 0x08

const NH_ECMP_CONFIG_HASH_DST_PORT = 0x10

const NH_ECMP_CONFIG_HASH_MASK = ((1 << NH_ECMP_CONFIG_HASH_BITS) - 1)

const NH_ECMP_CONFIG_HASH_PROTO = 0x01

const NH_ECMP_CONFIG_HASH_SRC_IP = 0x02

const NH_ECMP_CONFIG_HASH_SRC_PORT = 0x04

const NH_FLAG_COMPOSITE_ECMP = 0x000400

const NH_FLAG_COMPOSITE_ENCAP = 0x002000

const NH_FLAG_COMPOSITE_EVPN = 0x001000

const NH_FLAG_COMPOSITE_FABRIC = 0x000200

const NH_FLAG_COMPOSITE_LU_ECMP = 0x000800

const NH_FLAG_COMPOSITE_TOR = 0x004000

const NH_FLAG_CRYPT_TRAFFIC = 0x01000000

const NH_FLAG_ETREE_ROOT = 0x200000

const NH_FLAG_FLOW_LOOKUP = 0x040000

const NH_FLAG_INDIRECT = 0x400000

const NH_FLAG_L2_CONTROL_DATA = 0x800000

const NH_FLAG_L3_VXLAN = 0x02000000

const NH_FLAG_MAC_LEARN = 0x100000

const NH_FLAG_MCAST = 0x000020

const NH_FLAG_POLICY_ENABLED = 0x000002

const NH_FLAG_RELAXED_POLICY = 0x000100

const NH_FLAG_ROUTE_LOOKUP = 0x008000

const NH_FLAG_TUNNEL_GRE = 0x000008

const NH_FLAG_TUNNEL_MPLS_O_MPLS = 0x04000000

const NH_FLAG_TUNNEL_PBB = 0x080000

const NH_FLAG_TUNNEL_SIP_COPY = 0x020000

const NH_FLAG_TUNNEL_UDP = 0x000010

const NH_FLAG_TUNNEL_UDP_MPLS = 0x000040

const NH_FLAG_TUNNEL_UNDERLAY_ECMP = 0x10000000

const NH_FLAG_TUNNEL_VXLAN = 0x000080

const NH_FLAG_UNKNOWN_UC_FLOOD = 0x010000

const NH_FLAG_VALID = 0x000001

const NH_FLAG_VALIDATE_MCAST_SRC = 0x08000000

const NH_SOURCE_INVALID = 0

const NH_SOURCE_MISMATCH = 2

const NH_SOURCE_VALID = 1

const NH_TABLE_ENTRIES = VR_DEF_NEXTHOPS

const NH_TYPE_COMPOSITE = 6

const NH_TYPE_DEAD = 0

const NH_TYPE_DISCARD = 5

const NH_TYPE_ENCAP = 2

const NH_TYPE_L2_RCV = 8

const NH_TYPE_MAX = 9

const NH_TYPE_RCV = 1

const NH_TYPE_RESOLVE = 4

const NH_TYPE_TUNNEL = 3

const NH_TYPE_VRF_TRANSLATE = 7

const NH_VXLAN_VRF = NH_TYPE_VRF_TRANSLATE

const NL_ATTR_VR_MESSAGE_PROTOCOL = 1

const PKT_ENCAP_MPLS = 0x01

const PKT_ENCAP_VXLAN = 0x02

const PKT_MPLS_TUNNEL_INVALID = 0x00

const PKT_MPLS_TUNNEL_L2_CONTROL_DATA = 0x04

const PKT_MPLS_TUNNEL_L2_MCAST = 0x03

const PKT_MPLS_TUNNEL_L2_UCAST = 0x02

const PKT_MPLS_TUNNEL_L3 = 0x01

const PKT_RET_ERROR = 3

const PKT_RET_FAST_PATH = 1

const PKT_RET_SLOW_PATH = 2

const PKT_RET_UNHANDLED = 4

const PKT_SRC_EDGE_REPL_TREE = 0x4

const PKT_SRC_INGRESS_REPL_TREE = 0x2

const PKT_SRC_TOR_REPL_TREE = 0x1

const SANDESH_OPER_ADD = 0

const SANDESH_OPER_DEL = 2

const SANDESH_OPER_DUMP = 3

const SANDESH_OPER_GET = 1

const SANDESH_OPER_RESET = 5

const SANDESH_OPER_RESPONSE = 4

const SANDESH_REQUEST = 1

const VIF_ENCAP_TYPE_ETHER = 1

const VIF_ENCAP_TYPE_L3 = 2

const VIF_ENCAP_TYPE_L3_DECRYPT = 3

const VIF_FLAG_DHCP_ENABLED = 0x100

const VIF_FLAG_DROP_NEW_FLOWS = 0x40000

const VIF_FLAG_ETREE_ROOT = 0x200000

const VIF_FLAG_FILTERING_OFFLOAD = 0x4000

const VIF_FLAG_GET_DROP_STATS = 0x01

const VIF_FLAG_GRO_NEEDED = 0x400000

const VIF_FLAG_HBS_LEFT = 0x8000000

const VIF_FLAG_HBS_RIGHT = 0x10000000

const VIF_FLAG_IGMP_ENABLED = 0x2000000

const VIF_FLAG_L2_ENABLED = 0x80

const VIF_FLAG_L3_ENABLED = 0x40

const VIF_FLAG_MAC_IP_LEARNING = 0x40000000

const VIF_FLAG_MAC_LEARN = 0x80000

const VIF_FLAG_MAC_PROXY = 0x100000

const VIF_FLAG_MIRROR_NOTAG = 0x1000000

const VIF_FLAG_MIRROR_RX = 0x8

const VIF_FLAG_MIRROR_TX = 0x10

const VIF_FLAG_MOCK_PHYSICAL = 0x4000000

const VIF_FLAG_MONITORED = 0x8000

const VIF_FLAG_MRG_RXBUF = 0x800000

const VIF_FLAG_NATIVE_VLAN_TAG = 0x800

const VIF_FLAG_NO_ARP_PROXY = 0x1000

const VIF_FLAG_PMD = 0x2000

const VIF_FLAG_POLICY_ENABLED = 0x1

const VIF_FLAG_PROMISCOUS = 0x400

const VIF_FLAG_SERVICE_IF = 0x4

const VIF_FLAG_TX_CSUM_OFFLOAD = 0x20

const VIF_FLAG_UNKNOWN_UC_FLOOD = 0x10000

const VIF_FLAG_VHOST_PHYS = 0x200

const VIF_FLAG_VLAN_OFFLOAD = 0x20000

const VIF_FLAG_XCONNECT = 0x2

const VIF_MAX_MIRROR_MD_SIZE = 255

const VIF_SRC_MACS = 4

const VIF_TRANSPORT_ETH = 1

const VIF_TRANSPORT_PMD = 2

const VIF_TRANSPORT_SOCKET = 3

const VIF_TRANSPORT_VIRTUAL = 0

const VIF_TYPE_AGENT = 1

const VIF_TYPE_GATEWAY = 5

const VIF_TYPE_HOST = 0

const VIF_TYPE_MAX = 10

const VIF_TYPE_MONITORING = 9

const VIF_TYPE_PHYSICAL = 2

const VIF_TYPE_STATS = 7

const VIF_TYPE_VIRTUAL = 3

const VIF_TYPE_VIRTUAL_VLAN = 6

const VIF_TYPE_VLAN = 8

const VIF_TYPE_XEN_LL_HOST = 4

const VIF_VRF_INVALID = 65535

const VIF_VRF_TABLE_ENTRIES = 1024

const VLAN_ID_INVALID = 0xFFFF

const VLAN_ID_MAX = 0xFFFF

const VP_DROP_BMAC_ISID_MISMATCH = 46

const VP_DROP_CKSUM_ERR = 32

const VP_DROP_CLONED_ORIGINAL = 34

const VP_DROP_CLONE_FAIL = 52

const VP_DROP_DISCARD = 0

const VP_DROP_DUPLICATED = 16

const VP_DROP_FLOW_ACTION_DROP = 10

const VP_DROP_FLOW_ACTION_INVALID = 11

const VP_DROP_FLOW_EVICT = 43

const VP_DROP_FLOW_INVALID_PROTOCOL = 8

const VP_DROP_FLOW_NAT_NO_RFLOW = 9

const VP_DROP_FLOW_NO_MEMORY = 7

const VP_DROP_FLOW_QUEUE_LIMIT_EXCEEDED = 6

const VP_DROP_FLOW_TABLE_FULL = 13

const VP_DROP_FLOW_UNUSABLE = 12

const VP_DROP_FRAGMENTS = 36

const VP_DROP_FRAGMENT_QUEUE_FAIL = 39

const VP_DROP_HEAD_ALLOC_FAIL = 24

const VP_DROP_ICMP_ERROR = 51

const VP_DROP_INTERFACE_DROP = 15

const VP_DROP_INTERFACE_RX_DISCARD = 22

const VP_DROP_INTERFACE_TX_DISCARD = 14

const VP_DROP_INVALID_ARP = 3

const VP_DROP_INVALID_HBS_PKT = 49

const VP_DROP_INVALID_IF = 2

const VP_DROP_INVALID_LABEL = 20

const VP_DROP_INVALID_MCAST_SOURCE = 23

const VP_DROP_INVALID_NH = 19

const VP_DROP_INVALID_PACKET = 31

const VP_DROP_INVALID_PROTOCOL = 21

const VP_DROP_INVALID_SOURCE = 37

const VP_DROP_INVALID_UNDERLAY_ECMP = 53

const VP_DROP_INVALID_VNID = 35

const VP_DROP_L2_NO_ROUTE = 38

const VP_DROP_LEAF_TO_LEAF = 45

const VP_DROP_MAX = 54

const VP_DROP_MCAST_CLONE_FAIL = 27

const VP_DROP_MCAST_DF_BIT = 26

const VP_DROP_MISC = 30

const VP_DROP_NEW_FLOWS = 42

const VP_DROP_NOWHERE_TO_GO = 5

const VP_DROP_NO_CRYPT_PATH = 48

const VP_DROP_NO_FMD = 33

const VP_DROP_NO_FRAG_ENTRY = 50

const VP_DROP_NO_MEMORY = 28

const VP_DROP_PCOW_FAIL = 25

const VP_DROP_PKT_LOOP = 47

const VP_DROP_PULL = 1

const VP_DROP_PUSH = 17

const VP_DROP_REWRITE_FAIL = 29

const VP_DROP_TRAP_NO_IF = 4

const VP_DROP_TRAP_ORIGINAL = 44

const VP_DROP_TTL_EXCEEDED = 18

const VP_DROP_VLAN_FWD_ENQ = 41

const VP_DROP_VLAN_FWD_TX = 40

const VP_FLAG_CSUM_PARTIAL = (1 << 5)

const VP_FLAG_DIAG = (1 << 8)

const VP_FLAG_FLOW_GET = (1 << 2)

const VP_FLAG_FLOW_SET = (1 << 3)

const VP_FLAG_FROM_DP = (1 << 0)

const VP_FLAG_GRO = (1 << 6)

const VP_FLAG_GROED = (1 << 9)

const VP_FLAG_GSO = (1 << 7)

const VP_FLAG_MULTICAST = (1 << 4)

const VP_FLAG_TO_ME = (1 << 1)

const VP_PRIORITY_INVALID = 0xF

const VP_QUEUE_INVALID = 0xFF

const VP_TYPE_AGENT = 6

const VP_TYPE_ARP = 1

const VP_TYPE_IP = 2

const VP_TYPE_IP6 = 3

const VP_TYPE_IP6OIP = 5

const VP_TYPE_IPOIP = 4

const VP_TYPE_MAX = VP_TYPE_UNKNOWN

const VP_TYPE_NULL = 0

const VP_TYPE_PBB = 7

const VP_TYPE_UNKNOWN = 8

const VRF_FLAG_HBS_L_VALID = 0x0002

const VRF_FLAG_HBS_R_VALID = 0x0004

const VRF_FLAG_VALID = 0x0001

const VROUTER_GENETLINK_FAMILY_NAME = "vrouter"

const VROUTER_L2_OVERLAY_LEN = 62

const VROUTER_OVERLAY_LEN = 40

const VR_ARP_HW_LEN = 6

const VR_ARP_HW_TYPE_ETHER = 1

const VR_ARP_OP_REPLY = 2

const VR_ARP_OP_REQUEST = 1

const VR_ARP_PROTO_LEN_IPV4 = 4

const VR_BE_EVPN_CONTROL_PROCESSING_FLAG = 0x40

const VR_BE_FLOOD_DHCP_FLAG = 0x04

const VR_BE_L2_CONTROL_DATA_FLAG = 0x10

const VR_BE_LABEL_VALID_FLAG = 0x02

const VR_BE_MAC_MOVED_FLAG = 0x08

const VR_BE_MAC_NEW_FLAG = 0x20

const VR_BE_VALID_FLAG = 0x01

const VR_DEF_NEXTHOPS = 524288

const VR_DHCP6_SRC_PORT = 546

const VR_DHCP_SRC_PORT = 68

const VR_DIAG_CSUM = 0xFFFF

const VR_DYNAMIC_PORT_END = 65535

const VR_DYNAMIC_PORT_START = 0

const VR_ETHER_DMAC_OFF = 0

const VR_ETHER_PROTO_MAC_LEN = 2

const VR_ETHER_PROTO_MAC_OFF = 1

const VR_ETHER_PROTO_OFF = 12

const VR_ETHER_SMAC_OFF = 6

const VR_ETHER_VLAN_PROTO_OFF = 16

const VR_ETH_PROTO_ARP = 0x806

const VR_ETH_PROTO_IP = 0x800

const VR_ETH_PROTO_IP6 = 0x86DD

const VR_ETH_PROTO_PBB = 0x88E7

const VR_ETH_PROTO_VLAN = 0x8100

const VR_FLOW_ACTION_DROP = 0x0

const VR_FLOW_ACTION_FORWARD = 0x2

const VR_FLOW_ACTION_HOLD = 0x1

const VR_FLOW_ACTION_NAT = 0x3

const VR_FLOW_BGP_SERVICE = 0x80

const VR_FLOW_DR_AUDIT_ENTRY = 0x06

const VR_FLOW_DR_FAILED_VROUTER_INSTALL = 0x0d

const VR_FLOW_DR_FAT_FLOW_NAT_CONFLICT = 0x14

const VR_FLOW_DR_FLOW_LIMIT = 0x0b

const VR_FLOW_DR_FLOW_ON_TSN = 0x0f

const VR_FLOW_DR_FWAAS_POLICY = 0x1f

const VR_FLOW_DR_FW_POLICY = 0x1b

const VR_FLOW_DR_INVALID_L2_FLOW = 0x0e

const VR_FLOW_DR_IPv4_FWD_DIS = 0x02

const VR_FLOW_DR_LINKLOCAL_SRC_NAT = 0x0c

const VR_FLOW_DR_NAT_CHANGE = 0x0a

const VR_FLOW_DR_NO_DST_ROUTE = 0x05

const VR_FLOW_DR_NO_MIRROR_ENTRY = 0x10

const VR_FLOW_DR_NO_REVERSE_FLOW = 0x08

const VR_FLOW_DR_NO_SRC_ROUTE = 0x04

const VR_FLOW_DR_NO_SRC_ROUTE_L2RPF = 0x13

const VR_FLOW_DR_OUT_FWAAS_POLICY = 0x20

const VR_FLOW_DR_OUT_FW_POLICY = 0x1c

const VR_FLOW_DR_OUT_POLICY = 0x16

const VR_FLOW_DR_OUT_SG = 0x18

const VR_FLOW_DR_POLICY = 0x15

const VR_FLOW_DR_PORT_MAP_DROP = 0x12

const VR_FLOW_DR_REVERSE_FLOW_CHANGE = 0x09

const VR_FLOW_DR_REVERSE_FWAAS_POLICY = 0x21

const VR_FLOW_DR_REVERSE_FW_POLICY = 0x1d

const VR_FLOW_DR_REVERSE_OUT_FWAAS_POLICY = 0x22

const VR_FLOW_DR_REVERSE_OUT_FW_POLICY = 0x1e

const VR_FLOW_DR_REVERSE_OUT_SG = 0x1a

const VR_FLOW_DR_REVERSE_SG = 0x19

const VR_FLOW_DR_SAME_FLOW_RFLOW_KEY = 0x11

const VR_FLOW_DR_SG = 0x17

const VR_FLOW_DR_UNAVAILABLE_VRF = 0x03

const VR_FLOW_DR_UNAVIALABLE_INTF = 0x01

const VR_FLOW_DR_UNKNOWN = 0x00

const VR_FLOW_DR_VRF_CHANGE = 0x07

const VR_FLOW_EXT_FLAG_FORCE_EVICT = 0x0001

const VR_FLOW_EXT_FLAG_MOCK_SRC_UDP = 0x0002

const VR_FLOW_FLAG1_HBS_LEFT = 0x1000

const VR_FLOW_FLAG1_HBS_RIGHT = 0x2000

const VR_FLOW_FLAG_ACTIVE = 0x0001

const VR_FLOW_FLAG_DELETE_MARKED = 0x40

const VR_FLOW_FLAG_DNAT = 0x8

const VR_FLOW_FLAG_DPAT = 0x10

const VR_FLOW_FLAG_EVICTED = 0x0800

const VR_FLOW_FLAG_EVICT_CANDIDATE = 0x0400

const VR_FLOW_FLAG_LINK_LOCAL = 0x8000

const VR_FLOW_FLAG_MIRROR = 0x2000

const VR_FLOW_FLAG_MODIFIED = 0x0100

const VR_FLOW_FLAG_NAT_MASK = VR_FLOW_FLAG_SNAT | VR_FLOW_FLAG_SPAT | VR_FLOW_FLAG_DNAT | VR_FLOW_FLAG_DPAT

const VR_FLOW_FLAG_NEW_FLOW = 0x0200

const VR_FLOW_FLAG_SNAT = 0x2

const VR_FLOW_FLAG_SPAT = 0x4

const VR_FLOW_FLAG_TRAP_ECMP = 0x20

const VR_FLOW_FLAG_TRAP_MASK = VR_FLOW_FLAG_TRAP_ECMP

const VR_FLOW_FLAG_VRFT = 0x4000

const VR_FLOW_KEY_ALL = 0x1F

const VR_FLOW_KEY_DST_IP = 0x08

const VR_FLOW_KEY_DST_PORT = 0x10

const VR_FLOW_KEY_NONE = 0x00

const VR_FLOW_KEY_PROTO = 0x01

const VR_FLOW_KEY_SRC_IP = 0x02

const VR_FLOW_KEY_SRC_PORT = 0x04

const VR_FLOW_MOCK_SRC_UDP_PORT = 0x12b5

const VR_FLOW_RESP_FLAG_DELETED = 0x0001

const VR_GRE_BASIC_HDR_LEN = 4

const VR_GRE_CKSUM_HDR_LEN = 8

const VR_GRE_FLAG_CSUM = 128

const VR_GRE_FLAG_KEY = 32

const VR_GRE_KEY_HDR_LEN = 8

const VR_ICMP6_NEIGH_AD_FLAG_OVERRIDE = 0x2000

const VR_ICMP6_NEIGH_AD_FLAG_ROUTER = 0x8000

const VR_ICMP6_NEIGH_AD_FLAG_SOLCITED = 0x4000

const VR_ICMP6_TYPE_ECHO_REPLY = 129

const VR_ICMP6_TYPE_ECHO_REQ = 128

const VR_ICMP6_TYPE_NEIGH_AD = 136

const VR_ICMP6_TYPE_NEIGH_SOL = 135

const VR_ICMP6_TYPE_PKT_TOO_BIG = 2

const VR_ICMP6_TYPE_ROUTER_SOL = 133

const VR_ICMP_TYPE_DEST_UNREACH = 3

const VR_ICMP_TYPE_ECHO = 8

const VR_ICMP_TYPE_ECHO_REPLY = 0

const VR_ICMP_TYPE_TIME_EXCEEDED = 11

const VR_IF_ADD = 0

const VR_IF_DEL = 1

const VR_INTERFACE_NAME_LEN = 64

const VR_IP6_ADDRESS_LEN = 16

const VR_IP6_FRAG_OFFSET_BITS = 3

const VR_IP6_MF = 0x1

const VR_IP6_PROTO_FRAG = 44

const VR_IP_ADDRESS_LEN = 4

const VR_IP_DF = (0x1 << 14)

const VR_IP_FRAG_OFFSET_MASK = (VR_IP_MF - 1)

const VR_IP_MF = (0x1 << 13)

const VR_IP_PROTO_GRE = 47

const VR_IP_PROTO_ICMP = 1

const VR_IP_PROTO_ICMP6 = 58

const VR_IP_PROTO_IGMP = 2

const VR_IP_PROTO_SCTP = 132

const VR_IP_PROTO_TCP = 6

const VR_IP_PROTO_UDP = 17

const VR_L2_CTRL_DATA = (0x0000)

const VR_L2_CTRL_DATA_LEN = 4

const VR_LL_RP_ICMP_INDEX = 0x2

const VR_LL_RP_MAX = 0x3

const VR_LL_RP_TCP_INDEX = 0x0

const VR_LL_RP_UDP_INDEX = 0x1

const VR_NEXTHOP_COMPONENT_DUMP_LIMIT = 16

const VR_RFLOW_VALID = 0x1000

const VR_RT_ARP_FLOOD_FLAG = 0x8

const VR_RT_ARP_PROXY_FLAG = 0x2

const VR_RT_ARP_TRAP_FLAG = 0x4

const VR_RT_LABEL_VALID_FLAG = 0x1

const VR_RT_MAC_IP_LEARNT_FLAG = 0x10

const VR_TCP_FLAG_ACK = 0x0010

const VR_TCP_FLAG_CWR = 0x0080

const VR_TCP_FLAG_ECN = 0x0040

const VR_TCP_FLAG_FIN = 0x0001

const VR_TCP_FLAG_PSH = 0x0008

const VR_TCP_FLAG_RST = 0x0004

const VR_TCP_FLAG_SYN = 0x0002

const VR_TCP_FLAG_URG = 0x0020

const VR_TCP_OLEN_MSS = 4

const VR_TCP_OPT_EOL = 0

const VR_TCP_OPT_MSS = 2

const VR_TCP_OPT_NOP = 1

const VR_UDP_PORT_RANGE_END = 65535

const VR_UDP_PORT_RANGE_START = 49152

const VR_VLAN_PRIORITY_SHIFT = 13

const VR_VXLAN_IBIT = 0x08000000

const VR_VXLAN_RABIT = 0x01000000

Variables

var SIGNEDNESS = map[string]map[int16]bool{
	"sandesh_hdr": {
		1: false,
		2: false,
	},

	"vr_nexthop_req": {
		1:  false,
		2:  false,
		3:  false,
		4:  false,
		5:  false,
		6:  false,
		7:  false,
		8:  false,
		9:  false,
		10: true,
		11: true,
		12: false,
		13: false,
		14: false,
		15: false,
		16: true,
		17: false,
		18: false,
		19: false,
		20: false,
		21: false,
		22: false,
		23: false,
		24: false,
		25: false,
		26: false,
		27: false,
		28: false,
		29: true,
		30: false,
	},

	"vr_interface_req": {
		1:  false,
		2:  true,
		3:  false,
		4:  false,
		5:  false,
		6:  false,
		7:  false,
		8:  false,
		9:  false,
		10: false,
		11: false,
		12: false,
		13: false,
		14: false,
		15: false,
		16: false,
		17: false,
		18: false,
		19: false,
		20: false,
		21: false,
		22: false,
		23: false,
		24: false,
		25: false,
		26: false,
		27: false,
		28: false,
		29: false,
		30: false,
		31: false,
		32: false,
		33: false,
		34: false,
		35: false,
		36: false,
		37: false,
		38: false,
		39: true,
		40: true,
		41: true,
		42: false,
		43: false,
		44: false,
		45: false,
		46: false,
		47: false,
		48: false,
		49: false,
		50: false,
		51: false,
		52: false,
		53: false,
		54: false,
		55: false,
		56: false,
		57: false,
		58: true,
		59: false,
		60: true,
		61: false,
		62: false,
		63: false,
		64: false,
		65: true,
		66: true,
		67: true,
		68: true,
		77: true,
		78: true,
		79: false,
		80: false,
		81: true,
		82: true,
		83: false,
		84: false,
		85: false,
		86: false,
		87: false,
		88: false,
		89: false,
		90: false,
		91: true,
		92: false,
		93: true,
	},

	"vr_vxlan_req": {
		1: false,
		2: false,
		3: false,
		4: false,
	},

	"vr_route_req": {
		1:  false,
		2:  false,
		3:  false,
		4:  false,
		5:  false,
		6:  false,
		7:  false,
		8:  false,
		9:  false,
		10: false,
		11: false,
		12: false,
		13: false,
		14: false,
	},

	"vr_mpls_req": {
		1: false,
		2: false,
		3: false,
		4: false,
		5: false,
	},

	"vr_mirror_req": {
		1: false,
		2: false,
		3: false,
		4: false,
		5: false,
		6: false,
		7: false,
		8: false,
		9: false,
	},

	"vr_vrf_req": {
		1: false,
		2: false,
		3: false,
		4: false,
		5: false,
		6: false,
		7: false,
	},

	"vr_flow_req": {
		1:  false,
		2:  false,
		3:  false,
		4:  false,
		5:  false,
		6:  false,
		7:  false,
		8:  true,
		9:  true,
		10: true,
		11: true,
		12: true,
		13: true,
		14: false,
		15: true,
		16: true,
		17: true,
		18: true,
		19: true,
		20: true,
		21: false,
		22: true,
		23: true,
		24: true,
		25: true,
		26: true,
		27: false,
		28: true,
		29: true,
		30: true,
		31: true,
		32: true,
		33: true,
		34: true,
		35: true,
		36: false,
		37: false,
		38: false,
		39: false,
	},

	"vr_vrf_assign_req": {
		1: false,
		2: false,
		3: false,
		4: false,
		5: false,
		6: false,
		7: false,
	},

	"vr_vrf_stats_req": {
		1:  false,
		2:  false,
		3:  false,
		4:  false,
		5:  false,
		6:  false,
		7:  false,
		8:  false,
		9:  false,
		10: false,
		11: false,
		12: false,
		13: false,
		14: false,
		15: false,
		16: false,
		17: false,
		18: false,
		19: false,
		20: false,
		21: false,
		22: false,
		23: false,
		24: false,
		25: false,
		26: false,
		27: false,
		28: false,
		29: false,
		30: false,
		31: false,
		32: false,
		33: false,
	},

	"vr_response": {
		1: false,
		2: false,
	},

	"vrouter_ops": {
		1:  false,
		2:  false,
		3:  false,
		4:  false,
		5:  false,
		6:  false,
		7:  false,
		8:  false,
		9:  false,
		10: false,
		11: false,
		12: false,
		13: true,
		14: false,
		15: false,
		16: false,
		17: false,
		18: false,
		19: false,
		20: false,
		21: false,
		22: false,
		23: false,
		24: false,
		25: false,
		26: false,
		27: false,
		28: false,
		29: false,
		30: true,
		31: true,
		32: true,
		33: true,
		34: false,
		35: false,
		36: false,
		37: false,
		38: true,
		39: false,
		40: false,
		41: false,
		42: false,
		43: false,
		44: false,
		45: false,
		46: false,
		47: false,
	},

	"vr_mem_stats_req": {
		1:  false,
		2:  false,
		3:  false,
		4:  false,
		5:  false,
		6:  false,
		7:  false,
		8:  false,
		9:  false,
		10: false,
		11: false,
		12: false,
		13: false,
		14: false,
		15: false,
		16: false,
		17: false,
		18: false,
		19: false,
		20: false,
		21: false,
		22: false,
		23: false,
		24: false,
		25: false,
		26: false,
		27: false,
		28: false,
		29: false,
		30: false,
		31: false,
		32: false,
		33: false,
		34: false,
		35: false,
		36: false,
		37: false,
		38: false,
		39: false,
		40: false,
		41: false,
		42: false,
		43: false,
		44: false,
		45: false,
		46: false,
		47: false,
		48: false,
		49: false,
		50: false,
		51: false,
		52: false,
		53: false,
		54: false,
		55: false,
		56: false,
		57: false,
		58: false,
		59: false,
		60: false,
		61: false,
		62: false,
		63: false,
		64: false,
		65: false,
		66: false,
		67: false,
		68: false,
		69: false,
		70: false,
		71: false,
		72: false,
	},

	"vr_info_req": {
		1: false,
		2: false,
		3: false,
		4: false,
		5: false,
		6: false,
		7: false,
		8: false,
		9: false,
	},

	"vr_pkt_drop_log_req": {
		1:  false,
		2:  false,
		3:  false,
		4:  false,
		5:  false,
		6:  false,
		7:  false,
		8:  false,
		9:  false,
		10: false,
		11: false,
		12: false,
	},

	"vr_drop_stats_req": {
		1:  false,
		2:  false,
		3:  false,
		4:  false,
		5:  false,
		6:  false,
		7:  false,
		8:  false,
		9:  false,
		10: false,
		11: false,
		12: false,
		13: false,
		14: false,
		15: false,
		16: false,
		17: false,
		18: false,
		19: false,
		20: false,
		21: false,
		22: false,
		23: false,
		24: false,
		25: false,
		26: false,
		27: false,
		28: false,
		29: false,
		30: false,
		31: false,
		32: false,
		33: false,
		34: false,
		35: false,
		36: false,
		37: false,
		38: false,
		39: false,
		40: false,
		41: false,
		42: false,
		43: false,
		44: false,
		45: false,
		46: false,
		47: false,
		48: false,
		49: false,
		50: false,
		51: false,
		52: false,
		53: false,
		54: false,
		55: false,
		56: false,
		57: false,
		58: false,
	},

	"vr_qos_map_req": {
		1:  false,
		2:  true,
		3:  true,
		4:  false,
		5:  false,
		6:  false,
		7:  false,
		8:  false,
		9:  false,
		10: false,
	},

	"vr_fc_map_req": {
		1: false,
		2: true,
		3: false,
		4: false,
		5: false,
		6: false,
		7: false,
		8: false,
	},

	"vr_flow_response": {
		1: false,
		2: true,
		3: true,
		4: true,
		5: true,
		6: true,
		7: true,
		8: false,
	},

	"vr_flow_table_data": {
		1:  false,
		2:  true,
		3:  true,
		4:  true,
		5:  false,
		6:  true,
		7:  true,
		8:  true,
		9:  true,
		10: true,
		11: true,
		12: true,
		13: true,
		14: true,
		15: true,
		16: true,
		17: true,
	},

	"vr_bridge_table_data": {
		1: false,
		2: true,
		3: true,
		4: true,
		5: false,
	},

	"vr_hugepage_config": {
		1: false,
		2: true,
		3: true,
		4: true,
		5: true,
		6: false,
		7: true,
	},
}

Functions

func Int32ToipAddr

func Int32ToipAddr(i int32) net.IP

Types

type AgentVifConfig

type AgentVifConfig struct {
	// Mandatory Parameters
	Name string
	Idx  int32
	// Optional Parameters
	Vrf      int32 `default:"65535"`
	McastVrf int32 `default:"65535"`
	Mtu      int32 `default:"1514"`
	Flags    int32 `default:"320"`
}

AgentVif config

func NewAgentVifConfig

func NewAgentVifConfig() *AgentVifConfig

Create agentif config with default values

type BridgeRouteConfig

type BridgeRouteConfig struct {
	// Mandatory Parameters
	Vrf        int32
	NhIdx      int32
	MacAddress string
	LabelFlag  int16
	Label      int32
}

Bridge Route config

func NewBridgeRouteConfig

func NewBridgeRouteConfig() *BridgeRouteConfig

Bridge Route config with default values

type EncapNexthopConfig

type EncapNexthopConfig struct {
	// Mandatory parameters
	Idx             int32
	EncapOuterVifId []int32
	Encap           []byte
	// Optional Parameters
	Flags       uint32 `default:"1"` // NH_FLAG_VALID
	Family      int8   `default:"2"` // syscall.AF_INET
	EncapFamily int32
	Vrf         int32
}

Encap nexthop config

func NewEncapNexthopConfig

func NewEncapNexthopConfig() *EncapNexthopConfig

Create Encap Nexthop config with default values

type FabricVifConfig

type FabricVifConfig struct {
	// Mandatory Parameters
	Idx     int32
	Name    string
	MacAddr string `default:"00:00:00:00:00:00"`
	// Optional Parameters
	IpAddr    string `default:"0.0.0.0"`
	McastVrf  uint32 `default:"65535"`
	Mtu       int32  `default:"1514"`
	Flags     int32  `default:"322"`
	Transport int8   `default:"1"`
	Vrf       int32
}

FabricVif config

func NewFabricVifConfig

func NewFabricVifConfig() FabricVifConfig

Create vhost config with default values

type Flow

type Flow struct {
	*vr.VrFlowReq
}

Flow Base struct

func NewFlow

func NewFlow(flowspec *flowSpec) (*Flow, error)

func NewInet6Flow

func NewInet6Flow(conf Inet6FlowConfig) (*Flow, error)

func NewInetFlow

func NewInetFlow(conf InetFlowConfig) (*Flow, error)

func NewNatFlow

func NewNatFlow(conf NatFlowConfig) (*Flow, error)

type Inet6FlowConfig

type Inet6FlowConfig struct {
	// Mandatory Parameters
	SrcIP    string `default:"::"`
	DstIP    string `default:"::"`
	SrcPort  uint16
	DstPort  uint16
	Protocol int8
	// Optional Parameters
	Flags          int16 `default:"1"`
	Nexthop        int32
	ReverseNexthop int32
	Vrf            int16
}

Inet6Flow config

func NewInet6FlowConfig

func NewInet6FlowConfig() Inet6FlowConfig

Create inetflow config with default values

type Inet6RouteConfig

type Inet6RouteConfig struct {
	// Mandatory Parameters
	Vrf       int32
	NhIdx     int32
	IPAddress string `default:"::"`
	PrefixLen int32  `default:"128"`
}

Inet6 Route config

func NewInet6RouteConfig

func NewInet6RouteConfig() *Inet6RouteConfig

Bridge Route config with default values

type InetFlowConfig

type InetFlowConfig struct {
	// Mandatory Parameters
	SrcIP    string `default:"0.0.0.0"`
	DstIP    string `default:"0.0.0.0"`
	SrcPort  uint16
	DstPort  uint16
	Protocol int8
	Action   int16 `default:"2"`
	// Optional Parameters
	Index          int32 `default:"-1"`
	Flags          int16 `default:"1"`
	Nexthop        int32
	ReverseNexthop int32 `default:"0"`
	Vrf            int16
}

InetFlow config

func NewInetFlowConfig

func NewInetFlowConfig() InetFlowConfig

Create inetflow config with default values

type InetRouteConfig

type InetRouteConfig struct {
	// Mandatory Parameters
	Vrf        int32
	NhIdx      int32
	IPAddress  string `default:"0.0.0.0"`
	PrefixLen  int32  `default:"32"`
	MacAddress string `default:"00:00:00:00:00:00"`
	LabelFlag  int16
	Label      int32
}

Inet Route config

func NewInetRouteConfig

func NewInetRouteConfig() *InetRouteConfig

Inet Route config with default values

type NatFlowConfig

type NatFlowConfig struct {
	// Mandatory Parameters
	SrcIP          string `default:"0.0.0.0"`
	DstIP          string `default:"0.0.0.0"`
	SrcPort        uint16 `default:"0"`
	DstPort        uint16 `default:"0"`
	Protocol       int8
	Dvrf           int16
	ReverseSrcIP   string `default:"0.0.0.0"`
	ReverseDstIP   string `default:"0.0.0.0"`
	Flags          uint16 `default:"1"`
	Nexthop        int32
	SrcNexthop     int32
	QosId          int16
	Action         int16
	EcmpNexthop    int32
	Vrf            int16
	ReverseNexthop int32
	ReverseSrcPort uint16 `default:"0"`
}

NatFlow config

func NewNatFlowConfig

func NewNatFlowConfig() NatFlowConfig

Create inetflow config with default values

type Netlink

type Netlink struct {
	*genetlink.Conn
	*genetlink.Family
	Ctx       context.Context
	Protocol  *TSandeshProtocol
	Transport *thrift.TMemoryBuffer
}

vrouter netlink client

func InitNetlink

func InitNetlink() (*Netlink, error)

Instantiate netlink

func (*Netlink) SendAsync

func (nl *Netlink) SendAsync(s_req Sandesh) <-chan *NetlinkStream

type NetlinkStream

type NetlinkStream struct {
	Buffer *bytes.Buffer
	Error  *error
}

netlink stream

type Nexthop

type Nexthop struct {
	*vr.VrNexthopReq
}

nexthop Base struct

func NewEncapNexthop

func NewEncapNexthop(conf *EncapNexthopConfig) (*Nexthop, error)

Create Encap nexthop

func NewNextHop

func NewNextHop(
	nh_type uint8, nh_id int32, nh_family int8,
	nh_vrf int32, nh_flags uint32, encap_oif_id []int32,
	encap []byte, encap_family int32) *Nexthop

func NewReceiveNexthop

func NewReceiveNexthop(conf *ReceiveNexthopConfig) (*Nexthop, error)

Create Encap nexthop

type ReceiveNexthopConfig

type ReceiveNexthopConfig struct {
	// Mandatory parameters
	Idx        int32
	EncapOifId []int32
	Encap      []byte
	// Optional Parameters
	Flags       uint32 `default:"1"` // NH_FLAG_VALID
	Family      byte   `default:"2"` // syscall.AF_INET
	EncapFamily int32
	Vrf         int32
}

Encap nexthop config

func NewReceiveNexthopConfig

func NewReceiveNexthopConfig() *ReceiveNexthopConfig

Create Encap Nexthop config with default values

type Route

type Route struct {
	*vr.VrRouteReq
}

Route Base struct

func NewBridgeRoute

func NewBridgeRoute(conf *BridgeRouteConfig) (*Route, error)

Create Bridge Route

func NewInet6Route

func NewInet6Route(conf *Inet6RouteConfig) (*Route, error)

Create Bridge Route

func NewInetRoute

func NewInetRoute(conf *InetRouteConfig) (*Route, error)

Create Inet Route

func NewRoute

func NewRoute(
	oper, family, vrf int32, prefix net.IP, pref_len int32,
	mac string, nh_idx int32, rtr_label_flag int16,
	rtr_label int32,
) (*Route, error)

Create Route interface base object

func (*Route) GetMacAddressString

func (r *Route) GetMacAddressString() string

func (*Route) GetPrefixString

func (r *Route) GetPrefixString() string

type Sandesh

type Sandesh interface {
	// For vr.sandesh functions
	Read(context.Context, thrift.TProtocol) error
	Write(context.Context, thrift.TProtocol) error
}

Sandesh mesages

type TSandeshProtocol

type TSandeshProtocol struct {
	Buffer [64]byte
	// contains filtered or unexported fields
}

func NewTSandeshProtocolConf

func NewTSandeshProtocolConf(t th.TTransport, conf *th.TConfiguration) *TSandeshProtocol

func NewTSandeshProtocolTransport

func NewTSandeshProtocolTransport(t th.TTransport) *TSandeshProtocol

func (*TSandeshProtocol) Flush

func (p *TSandeshProtocol) Flush(ctx context.Context) (err error)

func (*TSandeshProtocol) GetProtocol

func (p *TSandeshProtocol) GetProtocol(t th.TTransport) th.TProtocol

func (*TSandeshProtocol) ReadBinary

func (p *TSandeshProtocol) ReadBinary(ctx context.Context) ([]byte, error)

func (*TSandeshProtocol) ReadBool

func (p *TSandeshProtocol) ReadBool(ctx context.Context) (bool, error)

func (*TSandeshProtocol) ReadByte

func (p *TSandeshProtocol) ReadByte(ctx context.Context) (int8, error)

func (*TSandeshProtocol) ReadDouble

func (p *TSandeshProtocol) ReadDouble(ctx context.Context) (value float64, err error)

func (*TSandeshProtocol) ReadFieldBegin

func (p *TSandeshProtocol) ReadFieldBegin(ctx context.Context) (name string, typeId th.TType, seqId int16, err error)

func (*TSandeshProtocol) ReadFieldEnd

func (p *TSandeshProtocol) ReadFieldEnd(ctx context.Context) error

func (*TSandeshProtocol) ReadI16

func (p *TSandeshProtocol) ReadI16(ctx context.Context) (value int16, err error)

func (*TSandeshProtocol) ReadI32

func (p *TSandeshProtocol) ReadI32(ctx context.Context) (value int32, err error)

func (*TSandeshProtocol) ReadI64

func (p *TSandeshProtocol) ReadI64(ctx context.Context) (value int64, err error)

func (*TSandeshProtocol) ReadListBegin

func (p *TSandeshProtocol) ReadListBegin(ctx context.Context) (elemType th.TType, size int, err error)

func (*TSandeshProtocol) ReadListEnd

func (p *TSandeshProtocol) ReadListEnd(ctx context.Context) error

func (*TSandeshProtocol) ReadMapBegin

func (p *TSandeshProtocol) ReadMapBegin(ctx context.Context) (kType, vType th.TType, size int, err error)

func (*TSandeshProtocol) ReadMapEnd

func (p *TSandeshProtocol) ReadMapEnd(ctx context.Context) error

func (*TSandeshProtocol) ReadMessageBegin

func (p *TSandeshProtocol) ReadMessageBegin(ctx context.Context) (name string, typeId th.TMessageType, seqId int32, err error)

func (*TSandeshProtocol) ReadMessageEnd

func (p *TSandeshProtocol) ReadMessageEnd(ctx context.Context) error

func (*TSandeshProtocol) ReadSetBegin

func (p *TSandeshProtocol) ReadSetBegin(ctx context.Context) (elemType th.TType, size int, err error)

func (*TSandeshProtocol) ReadSetEnd

func (p *TSandeshProtocol) ReadSetEnd(ctx context.Context) error

func (*TSandeshProtocol) ReadString

func (p *TSandeshProtocol) ReadString(ctx context.Context) (value string, err error)

func (*TSandeshProtocol) ReadStructBegin

func (p *TSandeshProtocol) ReadStructBegin(ctx context.Context) (name string, err error)

func (*TSandeshProtocol) ReadStructEnd

func (p *TSandeshProtocol) ReadStructEnd(ctx context.Context) error

func (*TSandeshProtocol) SetTConfiguration

func (p *TSandeshProtocol) SetTConfiguration(conf *th.TConfiguration)

func (*TSandeshProtocol) Skip

func (p *TSandeshProtocol) Skip(ctx context.Context, fieldType th.TType) (err error)

func (*TSandeshProtocol) Transport

func (p *TSandeshProtocol) Transport() th.TTransport

func (*TSandeshProtocol) WriteBinary

func (p *TSandeshProtocol) WriteBinary(ctx context.Context, value []byte) error

func (*TSandeshProtocol) WriteBool

func (p *TSandeshProtocol) WriteBool(ctx context.Context, value bool) error

func (*TSandeshProtocol) WriteByte

func (p *TSandeshProtocol) WriteByte(ctx context.Context, value int8) error

func (*TSandeshProtocol) WriteDouble

func (p *TSandeshProtocol) WriteDouble(ctx context.Context, value float64) error

func (*TSandeshProtocol) WriteFieldBegin

func (p *TSandeshProtocol) WriteFieldBegin(ctx context.Context, name string, typeId th.TType, id int16) error

func (*TSandeshProtocol) WriteFieldEnd

func (p *TSandeshProtocol) WriteFieldEnd(ctx context.Context) error

func (*TSandeshProtocol) WriteFieldStop

func (p *TSandeshProtocol) WriteFieldStop(ctx context.Context) error

func (*TSandeshProtocol) WriteI16

func (p *TSandeshProtocol) WriteI16(ctx context.Context, value int16) error

func (*TSandeshProtocol) WriteI32

func (p *TSandeshProtocol) WriteI32(ctx context.Context, value int32) error

func (*TSandeshProtocol) WriteI64

func (p *TSandeshProtocol) WriteI64(ctx context.Context, value int64) error

func (*TSandeshProtocol) WriteListBegin

func (p *TSandeshProtocol) WriteListBegin(ctx context.Context, elemType th.TType, size int) error

func (*TSandeshProtocol) WriteListEnd

func (p *TSandeshProtocol) WriteListEnd(ctx context.Context) error

func (*TSandeshProtocol) WriteMapBegin

func (p *TSandeshProtocol) WriteMapBegin(ctx context.Context, keyType th.TType, valueType th.TType, size int) error

func (*TSandeshProtocol) WriteMapEnd

func (p *TSandeshProtocol) WriteMapEnd(ctx context.Context) error

func (*TSandeshProtocol) WriteMessageBegin

func (p *TSandeshProtocol) WriteMessageBegin(ctx context.Context, name string, typeId th.TMessageType, seqId int32) error

func (*TSandeshProtocol) WriteMessageEnd

func (p *TSandeshProtocol) WriteMessageEnd(ctx context.Context) error

func (*TSandeshProtocol) WriteSetBegin

func (p *TSandeshProtocol) WriteSetBegin(context.Context, th.TType, int) error

func (*TSandeshProtocol) WriteSetEnd

func (p *TSandeshProtocol) WriteSetEnd(ctx context.Context) error

func (*TSandeshProtocol) WriteString

func (p *TSandeshProtocol) WriteString(ctx context.Context, value string) error

func (*TSandeshProtocol) WriteStructBegin

func (p *TSandeshProtocol) WriteStructBegin(ctx context.Context, name string) error

func (*TSandeshProtocol) WriteStructEnd

func (p *TSandeshProtocol) WriteStructEnd(ctx context.Context) error

type VhostVifConfig

type VhostVifConfig struct {
	// Mandatory Parameters
	Idx     int32
	Name    string
	IpAddr  string `default:"0.0.0.0"`
	MacAddr string `default:"00:00:00:00:00:00"`
	// Optional Parameters
	NextHop   int32
	McastVrf  uint32 `default:"65535"`
	Mtu       int32  `default:"1514"`
	Flags     int32  `default:"384"`
	Transport int8   `default:"1"`
	Vrf       int32
	XConnect  []string
}

Vhost config

func NewVhostVifConfig

func NewVhostVifConfig() *VhostVifConfig

Create vhost config with default values

type Vif

type Vif struct {
	*vr.VrInterfaceReq
}

Virtual Interface Base struct

func NewAgentVif

func NewAgentVif(conf *AgentVifConfig) (*Vif, error)

Create VhostVif

func NewFabricVif

func NewFabricVif(conf FabricVifConfig) (*Vif, error)

Create VhostVif

func NewVhostVif

func NewVhostVif(conf *VhostVifConfig) (*Vif, error)

Create VhostVif

func NewVif

func NewVif(oper, idx, viftype int32, name, ipaddr, macaddr string, transport int8) (*Vif, error)

Create virtual interface base struct

func NewVirtualVif

func NewVirtualVif(conf *VirtualVifConfig) (*Vif, error)

Create VhostVif

func (*Vif) GetIPAddressString

func (vif *Vif) GetIPAddressString() string

func (*Vif) GetMacAddressString

func (vif *Vif) GetMacAddressString() string

type VirtualVifConfig

type VirtualVifConfig struct {
	// Mandatory Parameters
	Idx     int32
	Name    string
	MacAddr string `default:"00:00:00:00:00:00"`
	IpAddr  string `default:"0.0.0.0"`
	// Optional Parameters
	Nexthop   int32
	Mtu       int32 `default:"1514"`
	Flags     int32 `default:"1"`
	Transport int8  `default:"1"`
	Vrf       int32
	McastVrf  uint32 `default:"65535"`
}

VirtualVif config

func NewVirtualVifConfig

func NewVirtualVifConfig() *VirtualVifConfig

Create vhost config with default values

type Vxlan

type Vxlan struct {
	*vr.VrVxlanReq
}

VXLAN interface

func NewVxlan

func NewVxlan(rid int16, vnid, nhid int32) (*Vxlan, error)