tracer

Documentation

Index

• type BgTask
• type BgTaskManager
  • func NewBgTaskManager(hubble observerpb.ObserverClient, olap *tracer.Olap) *BgTaskManager
  • func (m *BgTaskManager) StartAll()
• type Endpoint
• type EndpointTask
  • func (t *EndpointTask) Run()
  • func (t *EndpointTask) Start()
• type NamespaceTask
  • func (t *NamespaceTask) DeleteNamespaceRelatedSpans(namespace string)
  • func (t *NamespaceTask) Run()
  • func (t *NamespaceTask) Start()

Types

type BgTask

type BgTask interface {
	Start()
}

type BgTaskManager

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

BgTaskManager manages background periodical tasks. Includes: - Sync t_Ep table - Sync namespace list - Run Assemble algorithm

func NewBgTaskManager

func NewBgTaskManager(hubble observerpb.ObserverClient, olap *tracer.Olap) *BgTaskManager

func (*BgTaskManager) StartAll

func (m *BgTaskManager) StartAll()

type Endpoint

type Endpoint struct {
	Namespace string `db:"namespace"`
	PodName   string `db:"pod_name"`
	SvcName   string `db:"svc_name"`
	Endpoint  uint32 `db:"endpoint"`
	Identity  string `db:"identity"`
	State     string `db:"state"`
	IP        string `db:"ip"` // now supported IPv4
}

通过数据库 t_Ep 小表，维持 Cilium 中的 endpoint 列表

type EndpointTask

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

func (*EndpointTask) Run

func (t *EndpointTask) Run()

func (*EndpointTask) Start

func (t *EndpointTask) Start()

type NamespaceTask

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

func (*NamespaceTask) DeleteNamespaceRelatedSpans

func (t *NamespaceTask) DeleteNamespaceRelatedSpans(namespace string)

级联删除 - 删除 olap 中某一 namespace 相关的 span（不活跃） - 删除 o.mapSpanCount 中的记录

func (*NamespaceTask) Run

func (t *NamespaceTask) Run()

全量更新

func (*NamespaceTask) Start

func (t *NamespaceTask) Start()