slo

type ESReader interface {
	// eareader read k8s audit event, then send to consumer queue
	SetConsumer(int, *queue.BoundedQueue)
	// starts to read audit events from es
	Run(<-chan struct{})
	// return a chan implies whether reader has done its job
	WaitChan() <-chan struct{}
	// get total processed item
	GetProcessed() int64
}

type PersistentVolumeClaimMileStone struct {
	Type            string
	Cluster         string
	Namespace       string
	PVCName         string
	PVCUID          string
	TriggerAuditLog string
	CreateResult    string
	CreatedTime     time.Time
	TimeoutTime     time.Time
	// contains filtered or unexported fields
}

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

type PodEvent struct {
	Pod   *v1.Pod
	Event *shares.AuditEvent
}

type PodStartupMilestones struct {
	Cluster                       string
	InitImage                     string
	Namespace                     string
	PodName                       string
	PodUID                        string
	Type                          string
	NodeIP                        string
	NodeName                      string // in some cases, when a pod is scheduled to a specified node, but kubelet doesn't post any pod status to apiserver, nodeIP is empty, but we do want know which node is not working properly.
	DebugUrl                      string
	OwnerRefStr                   string
	SchedulingStrategy            string
	StartUpResultFromCreate       string
	StartUpResultFromSchedule     string
	IsJob                         bool
	Cores                         int64
	WrittenToZsearch              bool
	Finished                      bool
	StopInterEvents               bool      //停止接受新的event
	Created                       time.Time //创建开始时间
	CreatedTime                   time.Time //创建开始时间
	FinishTime                    time.Time
	ActualFinishTimeAfterSchedule time.Time
	ActualFinishTimeAfterCreate   time.Time
	Scheduled                     time.Time //调度时间
	PodInitializedTime            time.Time
	ContainersReady               time.Time
	RunningAt                     time.Time
	SucceedAt                     time.Time
	FailedAt                      time.Time
	ReadyAt                       time.Time
	DeletedTime                   time.Time
	InitStartTime                 time.Time
	ImageNameToPullTime           map[string]float64 //每个镜像拉取的时间
	PossibleReason                *string            //创建失败或超时时针对未知原因附加说明（timeout_unknown和kubeletDelay）
	// SLO 越界推理
	SLOViolationReason  string
	PodSLO              int64
	DeliverySLO         int64
	DeliverySLOAdjusted bool
	DeliveryDuration    time.Duration
	DeliveryStatus      string
	DeliveryStatusOrig  string
	SloHint             string // why current slo class
	// contains filtered or unexported fields
}

type PodUpgradeMileStone struct {
	Cluster              string
	Namespace            string
	PodName              string
	PodUID               string
	Type                 string
	TriggerAuditLog      string
	UpgradeResult        string
	UpgradeContainerName string
	UpdateStatus         string
	NodeIP               string
	CreatedTime          time.Time //开始升级时间
	UpgradeEndTime       time.Time
	UpgradeTimeoutTime   time.Time
	DebugUrl             string
	// contains filtered or unexported fields
}

type RequestAction struct {
	ActionType string   `json:"action-type,omitempty"`
	Containers []string `json:"containers,omitempty"`
	Timestamp  string   `json:"timestamp,omitempty"`
}

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

type SpanSlice []spans.Span

type SpanSlicePtr []*spans.Span