labeler

README

Labeler主要任务

给flow打上对应云平台信息，以及observatrace的控制信息

1.云平台相关信息，如设备所属项目，设备id，设备类型，子网等 2.flow所属observatrace平台的资源组，标签以及白名单

Documentation

Index

• Constants
• func RegisterCommand(moduleId debug.ModuleId) *cobra.Command
• type DumpKey
• type LabelerManager
  • func NewLabelerManager(packetQueueReaders []queue.QueueReader, packetQueueWriters []queue.QueueWriter, ...) *LabelerManager
  • func (l *LabelerManager) Closed() bool
  • func (l *LabelerManager) GetCounter() interface{}
  • func (c *LabelerManager) GetParsedIpGroupData() []*policy.IpGroupData
  • func (l *LabelerManager) GetPolicy(packet *datatype.MetaPacket, index int)
  • func (l *LabelerManager) OnAclDataChange(response *trident.SyncResponse)
  • func (c *LabelerManager) RecvCommand(conn *net.UDPConn, remote *net.UDPAddr, operate uint16, arg *bytes.Buffer)
  • func (l *LabelerManager) Start()
  • func (l *LabelerManager) Stop(wait bool)

Constants

const (
	LABELER_CMD_DUMP_PLATFORM = iota
	LABELER_CMD_DUMP_ACL
	LABELER_CMD_DUMP_FIRST_ACL
	LABELER_CMD_DUMP_FAST_ACL
	LABELER_CMD_SHOW_ACL
	LABELER_CMD_ADD_ACL
	LABELER_CMD_DEL_ACL
	LABELER_CMD_SHOW_IPGROUP
)

Functions

func RegisterCommand

func RegisterCommand(moduleId debug.ModuleId) *cobra.Command

Types

type DumpKey

type DumpKey struct {
	Mac    uint64
	Ip     uint32
	InPort uint32
}

type LabelerManager

type LabelerManager struct {
	PcapDataRetention time.Duration
	// contains filtered or unexported fields
}

func NewLabelerManager

func NewLabelerManager(packetQueueReaders []queue.QueueReader, packetQueueWriters []queue.QueueWriter, queueCount, level int, mapSize uint32, disable bool) *LabelerManager

func (*LabelerManager) Closed

func (l *LabelerManager) Closed() bool

func (*LabelerManager) GetCounter

func (l *LabelerManager) GetCounter() interface{}

func (*LabelerManager) GetParsedIpGroupData

func (c *LabelerManager) GetParsedIpGroupData() []*policy.IpGroupData

func (*LabelerManager) GetPolicy

func (l *LabelerManager) GetPolicy(packet *datatype.MetaPacket, index int)

func (*LabelerManager) OnAclDataChange

func (l *LabelerManager) OnAclDataChange(response *trident.SyncResponse)

func (*LabelerManager) RecvCommand

func (c *LabelerManager) RecvCommand(conn *net.UDPConn, remote *net.UDPAddr, operate uint16, arg *bytes.Buffer)

func (*LabelerManager) Start

func (l *LabelerManager) Start()

func (*LabelerManager) Stop

func (l *LabelerManager) Stop(wait bool)