universal_tag

Documentation

Index

• type DeviceType
  • func (t DeviceType) String() string
• type Labels
• type UniversalTagMaps
• type UniversalTags
• type UniversalTagsManager
  • func NewUniversalTagsManager(customK8sLabelsRegexp string, baseCfg *config.Config) *UniversalTagsManager
  • func (u *UniversalTagsManager) Close()
  • func (u *UniversalTagsManager) GetUniversalTagMaps(response *trident.UniversalTagNameMapsResponse) *UniversalTagMaps
  • func (u *UniversalTagsManager) HandleSimpleCommand(operate uint16, arg string) string
  • func (u *UniversalTagsManager) QueryCustomK8sLabels(podID uint32) Labels
  • func (u *UniversalTagsManager) QueryUniversalTags(l7FlowLog *log_data.L7FlowLog) (*UniversalTags, *UniversalTags)
  • func (u *UniversalTagsManager) Reload() error
  • func (u *UniversalTagsManager) Start()

Types

type DeviceType

type DeviceType uint8

const (
	TYPE_INTERNET       DeviceType = 0
	TYPE_VM             DeviceType = 1
	TYPE_VROUTER        DeviceType = 5
	TYPE_HOST           DeviceType = 6
	TYPE_DHCP_GW        DeviceType = 9
	TYPE_POD            DeviceType = 10
	TYPE_POD_SERVICE    DeviceType = 11
	TYPE_REDIS_INSTANCE DeviceType = 12
	TYPE_RDS_INSTANCE   DeviceType = 13
	TYPE_POD_NODE       DeviceType = 14
	TYPE_LB             DeviceType = 15
	TYPE_NAT_GATEWAY    DeviceType = 16
	TYPE_POD_GROUP      DeviceType = 101
	TYPE_SERVICE        DeviceType = 102
	TYPE_GPROCESS       DeviceType = 120
	TYPE_IP             DeviceType = 255
)

func (DeviceType) String

func (t DeviceType) String() string

type Labels

type Labels map[string]string

type UniversalTagMaps

type UniversalTagMaps struct {
	// contains filtered or unexported fields
}

type UniversalTags

type UniversalTags struct {
	Region       string
	AZ           string
	Host         string
	L3DeviceType string
	L3Device     string
	PodNode      string
	PodNS        string
	PodGroup     string
	Pod          string
	PodCluster   string
	L3Epc        string
	Subnet       string
	Service      string
	GProcess     string
	Vtap         string

	CHost      string
	Router     string
	DhcpGW     string
	PodService string
	Redis      string
	RDS        string
	LB         string
	NatGW      string

	TapPortName string

	AutoInstanceType string
	AutoInstance     string
	AutoServiceType  string
	AutoService      string
}

type UniversalTagsManager

type UniversalTagsManager struct {
	// contains filtered or unexported fields
}

func NewUniversalTagsManager

func NewUniversalTagsManager(customK8sLabelsRegexp string, baseCfg *config.Config) *UniversalTagsManager

func (*UniversalTagsManager) Close

func (u *UniversalTagsManager) Close()

func (*UniversalTagsManager) GetUniversalTagMaps

func (u *UniversalTagsManager) GetUniversalTagMaps(response *trident.UniversalTagNameMapsResponse) *UniversalTagMaps

func (*UniversalTagsManager) HandleSimpleCommand

func (u *UniversalTagsManager) HandleSimpleCommand(operate uint16, arg string) string

func (*UniversalTagsManager) QueryCustomK8sLabels

func (u *UniversalTagsManager) QueryCustomK8sLabels(podID uint32) Labels

func (*UniversalTagsManager) QueryUniversalTags

func (u *UniversalTagsManager) QueryUniversalTags(l7FlowLog *log_data.L7FlowLog) (*UniversalTags, *UniversalTags)

func (*UniversalTagsManager) Reload

func (u *UniversalTagsManager) Reload() error

func (*UniversalTagsManager) Start

func (u *UniversalTagsManager) Start()