labeler

package
v0.0.0-...-b8a1a0e Latest Latest
Warning

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

Go to latest
Published: Jan 31, 2024 License: Apache-2.0 Imports: 23 Imported by: 0

README

Labeler主要任务

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

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

Documentation

Index

Constants

View Source
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
)

Variables

This section is empty.

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)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL