utils

Documentation

Index

• type AgentPodFilter
  • func (f *AgentPodFilter) Filter(pod *corev1.Pod, isJob bool) *FilteredMessageResult
• type FilteredMessageContainerResult
• type FilteredMessageResult
• type Incident
  • func NewIncident(releaseName, namespace string, timestamp int64) *Incident
  • func NewIncidentFromString(id string) (*Incident, error)
  • func (inc *Incident) GetNamespace() string
  • func (inc *Incident) GetReleaseName() string
  • func (inc *Incident) GetTimestamp() int64
  • func (inc *Incident) GetTimestampAsTime() time.Time
  • func (inc *Incident) ToString() string
• type Log
  • func NewLog(incident *Incident, timestamp int64) *Log
  • func NewLogFromString(id string) (*Log, error)
  • func (l *Log) GetIncident() *Incident
  • func (l *Log) GetTimestamp() int64
  • func (l *Log) GetTimestampAsTime() time.Time
• type PodFilter
  • func NewAgentPodFilter(kubeClient *kubernetes.Clientset) PodFilter

Types

type AgentPodFilter

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

func (*AgentPodFilter) Filter

func (f *AgentPodFilter) Filter(pod *corev1.Pod, isJob bool) *FilteredMessageResult

type FilteredMessageContainerResult

type FilteredMessageContainerResult struct {
	ContainerName string
	Summary       string
	Details       string
}

type FilteredMessageResult

type FilteredMessageResult struct {
	PodSummary        string
	PodDetails        string
	ContainerStatuses []*FilteredMessageContainerResult
}

type Incident

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

incidents are of the form "incident:<release_name>:<namespace>:<timestamp>"

func NewIncident

func NewIncident(releaseName, namespace string, timestamp int64) *Incident

func NewIncidentFromString

func NewIncidentFromString(id string) (*Incident, error)

func (*Incident) GetNamespace

func (inc *Incident) GetNamespace() string

func (*Incident) GetReleaseName

func (inc *Incident) GetReleaseName() string

func (*Incident) GetTimestamp

func (inc *Incident) GetTimestamp() int64

func (*Incident) GetTimestampAsTime

func (inc *Incident) GetTimestampAsTime() time.Time

func (*Incident) ToString

func (inc *Incident) ToString() string

type Log

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

logs are of the form "log:<incident_id>:<timestamp>"

func NewLog

func NewLog(incident *Incident, timestamp int64) *Log

func NewLogFromString

func NewLogFromString(id string) (*Log, error)

func (*Log) GetIncident

func (l *Log) GetIncident() *Incident

func (*Log) GetTimestamp

func (l *Log) GetTimestamp() int64

func (*Log) GetTimestampAsTime

func (l *Log) GetTimestampAsTime() time.Time

type PodFilter

type PodFilter interface {
	Filter(*corev1.Pod, bool) *FilteredMessageResult
}

func NewAgentPodFilter

func NewAgentPodFilter(kubeClient *kubernetes.Clientset) PodFilter