awsnode

Documentation

Overview

Package awsnode is a latency timing source for the VPC CNI logs (aka aws-node DaemonSet)

Index

• Variables
• type Source
  • func New(path string) *Source
  • func (a Source) ClearCache()
  • func (a Source) Find(event *sources.Event) ([]sources.FindResult, error)
  • func (a Source) FindByRegex(re *regexp.Regexp) sources.FindFunc
  • func (a Source) Name() string
  • func (a Source) String() string

Variables

var (
	Name            = "aws-node"
	DefaultPath     = "/var/log/pods/kube-system_aws-node-*/aws-node/*.log"
	TimestampFormat = regexp.MustCompile(`[0-9]{4}\-[0-9]{2}\-[0-9]{2}T[0-9]{2}:[0-9]{2}:[0-9]{2}\.[0-9]+Z`)
	TimestampLayout = "2006-01-02T15:04:05.999999999Z"
)

Types

type Source

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

Source is the aws-node / VPC CNI log source

func New

func New(path string) *Source

New instantiates a new instance of the AWSNode source

func (Source) ClearCache

func (a Source) ClearCache()

ClearCache will clear the log reader cache

func (Source) Find

func (a Source) Find(event *sources.Event) ([]sources.FindResult, error)

Find will use the Event's FindFunc and CommentFunc to search the log source and return the results based on the Event's matcher

func (Source) FindByRegex

func (a Source) FindByRegex(re *regexp.Regexp) sources.FindFunc

FindByRegex is a helper func that returns a FindFunc to search for a regex in a log source that can be used in an Event

func (Source) Name

func (a Source) Name() string

Name is the log source name

func (Source) String

func (a Source) String() string

String is a human readable string of the source, usually the log file path