shares

Documentation

Index

• Variables
• type AuditEvent
  • func NewAuditEvent(event *k8s_audit.Event) *AuditEvent
  • func (a *AuditEvent) CanProcess(DAGNodeName string)
  • func (a *AuditEvent) FinishProcess(DAGNodeName string)
  • func (a *AuditEvent) GetObjectUID() (types.UID, error)
  • func (a *AuditEvent) GetResponseOrRequestObj() runtime.Object
  • func (a *AuditEvent) Process()
  • func (a *AuditEvent) TryGetPodFromEvent() *v1.Pod
• type AuditProcessDAG
  • func InitAuditProcessADG() *AuditProcessDAG
  • func (d *AuditProcessDAG) IsParentsReady() bool
• type AuditType
• type BaseProcessor
  • func NewBaseProcessor() *BaseProcessor
  • func (l *BaseProcessor) CanProcess(event *AuditEvent) bool
  • func (l *BaseProcessor) Process(event *AuditEvent) error
  • func (l *BaseProcessor) Register(name string, p Processor)
• type HitEvent
  • func NewHitEvent() *HitEvent
  • func (h *HitEvent) UnmarshalToEvent(hit *json.RawMessage)
• type HitEventSlice
  • func NewHitEventSlice(capacity int) *HitEventSlice
  • func (h *HitEventSlice) Append(hit *HitEvent)
  • func (h *HitEventSlice) Hits() []*HitEvent
  • func (h *HitEventSlice) SortByTimeStamp(ascending bool)
  • func (h *HitEventSlice) Wait()
• type MetaProcessor
  • func (m *MetaProcessor) CanProcess(event *AuditEvent) bool
  • func (m *MetaProcessor) Process(event *AuditEvent) error
• type MilestoneExtractor
  • func NewMilestoneExtractor() *MilestoneExtractor
  • func (l *MilestoneExtractor) CanProcess(event *AuditEvent) bool
  • func (l *MilestoneExtractor) Process(event *AuditEvent) error
  • func (l *MilestoneExtractor) Register(name string, p Processor)
• type ProcessState
• type Processor

Variables

var (
	ProcessingState ProcessState = "Processing"
	FinishedState   ProcessState = "Finished"

	SLOProcessNode  string = "SLONode"
	SpanProcessNode string = "SpanNode"
)

var (
	BaseObjectProcessor = NewBaseProcessor()
	MilestoneProcessor  = NewMilestoneExtractor()
)

Types

type AuditEvent

type AuditEvent struct {
	sync.WaitGroup
	*k8s_audit.Event
	ResponseRuntimeObj runtime.Object
	RequestRuntimeObj  runtime.Object
	RequestMetaJson    map[string]interface{}

	Type      AuditType
	Operation map[string][]string //Operation操作
	Reason    string              //event类型的reason
	// contains filtered or unexported fields
}

func NewAuditEvent

func NewAuditEvent(event *k8s_audit.Event) *AuditEvent

func (*AuditEvent) CanProcess

func (a *AuditEvent) CanProcess(DAGNodeName string)

判断依赖的父亲节点是否已经结束

func (*AuditEvent) FinishProcess

func (a *AuditEvent) FinishProcess(DAGNodeName string)

func (*AuditEvent) GetObjectUID

func (a *AuditEvent) GetObjectUID() (types.UID, error)

func (*AuditEvent) GetResponseOrRequestObj

func (a *AuditEvent) GetResponseOrRequestObj() runtime.Object

func (*AuditEvent) Process

func (a *AuditEvent) Process()

func (*AuditEvent) TryGetPodFromEvent

func (a *AuditEvent) TryGetPodFromEvent() *v1.Pod

type AuditProcessDAG

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

func InitAuditProcessADG

func InitAuditProcessADG() *AuditProcessDAG

func (*AuditProcessDAG) IsParentsReady

func (d *AuditProcessDAG) IsParentsReady() bool

type AuditType

type AuditType string

const (
	AuditTypeEvent     AuditType = "event"
	AuditTypeOperation AuditType = "operation"
)

type BaseProcessor

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

BaseProcessor 用于基础的信息提取

func NewBaseProcessor

func NewBaseProcessor() *BaseProcessor

func (*BaseProcessor) CanProcess

func (l *BaseProcessor) CanProcess(event *AuditEvent) bool

func (*BaseProcessor) Process

func (l *BaseProcessor) Process(event *AuditEvent) error

func (*BaseProcessor) Register

func (l *BaseProcessor) Register(name string, p Processor)

type HitEvent

type HitEvent struct {
	Event    *k8s_audit.Event
	HasError bool
	sync.WaitGroup
}

func NewHitEvent

func NewHitEvent() *HitEvent

func (*HitEvent) UnmarshalToEvent

func (h *HitEvent) UnmarshalToEvent(hit *json.RawMessage)

type HitEventSlice

type HitEventSlice struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewHitEventSlice

func NewHitEventSlice(capacity int) *HitEventSlice

func (*HitEventSlice) Append

func (h *HitEventSlice) Append(hit *HitEvent)

func (*HitEventSlice) Hits

func (h *HitEventSlice) Hits() []*HitEvent

func (*HitEventSlice) SortByTimeStamp

func (h *HitEventSlice) SortByTimeStamp(ascending bool)

func (*HitEventSlice) Wait

func (h *HitEventSlice) Wait()

type MetaProcessor

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

MetaProcessor 元数据处理总入口

func (*MetaProcessor) CanProcess

func (m *MetaProcessor) CanProcess(event *AuditEvent) bool

func (*MetaProcessor) Process

func (m *MetaProcessor) Process(event *AuditEvent) error

type MilestoneExtractor

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

MilestoneExtractor 用于 hyper event 生命周期提取

func NewMilestoneExtractor

func NewMilestoneExtractor() *MilestoneExtractor

func (*MilestoneExtractor) CanProcess

func (l *MilestoneExtractor) CanProcess(event *AuditEvent) bool

func (*MilestoneExtractor) Process

func (l *MilestoneExtractor) Process(event *AuditEvent) error

func (*MilestoneExtractor) Register

func (l *MilestoneExtractor) Register(name string, p Processor)

type ProcessState

type ProcessState string

type Processor

type Processor interface {
	CanProcess(event *AuditEvent) bool
	Process(event *AuditEvent) error
}