common

Documentation

Index

• Constants
• func GetAutoInstance(podID, gpID, podNodeID, l3DeviceID, subnetID uint32, l3DeviceType uint8, ...) (uint32, uint8)
• func GetAutoService(serviceID, podGroupID, gpID, podClusterID, l3DeviceID, subnetID uint32, ...) (uint32, uint8)
• func IsPodServiceIP(deviceType flow_metrics.DeviceType, podId, podNodeId uint32) bool
• func NewCKConnection(addr, username, password string) (*sql.DB, error)
• func RegetInfoFromIP(orgId uint16, isIPv6 bool, ip6 net.IP, ip4 uint32, epcID int32, ...) *grpc.Info
• func RegisterCountableForIngester(name string, countable stats.Countable, opts ...stats.Option) error
• type DBs
  • func NewCKConnections(addrs []string, username, password string) (DBs, error)
  • func (s DBs) Close() error
  • func (s DBs) Exec(query string, args ...any) (sql.Result, error)
  • func (s DBs) ExecParallel(query string, args ...any) (sql.Result, error)
  • func (s DBs) Query(query string, args ...any) ([]*sql.Rows, error)

Constants

const (
	MODULE_INGESTER             = "ingester_"
	QUEUE_STATS_MODULE_INGESTER = queue.OptionModule(MODULE_INGESTER)
)

const (
	IpType         = 255
	InternetIpType = 0

	PodType     = uint8(trident.AutoServiceType_AUTO_SERVICE_TYPE_POD)      // 10
	PodNodeType = uint8(trident.AutoServiceType_AUTO_SERVICE_TYPE_POD_NODE) // 14

	PodServiceType = uint8(trident.AutoServiceType_AUTO_SERVICE_TYPE_POD_SERVICE) // 12
	PodClusterType = uint8(trident.AutoServiceType_AUTO_SERVICE_TYPE_POD_CLUSTER) // 103

	ProcessType = uint8(trident.AutoServiceType_AUTO_SERVICE_TYPE_PROCESS) // 120

)

const (
	CK_VERSION = "v6.6.3.0" // 用于表示clickhouse的表版本号
)

Functions

func GetAutoInstance

func GetAutoInstance(podID, gpID, podNodeID, l3DeviceID, subnetID uint32, l3DeviceType uint8, l3EpcID int32) (uint32, uint8)

func GetAutoService

func GetAutoService(serviceID, podGroupID, gpID, podClusterID, l3DeviceID, subnetID uint32, l3DeviceType, podGroupType uint8, l3EpcID int32) (uint32, uint8)

func IsPodServiceIP

func IsPodServiceIP(deviceType flow_metrics.DeviceType, podId, podNodeId uint32) bool

func NewCKConnection

func NewCKConnection(addr, username, password string) (*sql.DB, error)

func RegetInfoFromIP

func RegetInfoFromIP(orgId uint16, isIPv6 bool, ip6 net.IP, ip4 uint32, epcID int32, platformData *grpc.PlatformInfoTable) *grpc.Info

如果通过MAC匹配平台信息失败，则需要通过IP再获取, 解决工单122/126问题

func RegisterCountableForIngester

func RegisterCountableForIngester(name string, countable stats.Countable, opts ...stats.Option) error

Types

type DBs

type DBs []*sql.DB

func NewCKConnections

func NewCKConnections(addrs []string, username, password string) (DBs, error)

func (DBs) Close

func (s DBs) Close() error

func (DBs) Exec

func (s DBs) Exec(query string, args ...any) (sql.Result, error)

func (DBs) ExecParallel

func (s DBs) ExecParallel(query string, args ...any) (sql.Result, error)

func (DBs) Query

func (s DBs) Query(query string, args ...any) ([]*sql.Rows, error)