awsnode

Documentation

Overview

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

Index

• Variables
• type AWSNodeSource
  • func New(path string) *AWSNodeSource
  • func (a AWSNodeSource) ClearCache()
  • func (a AWSNodeSource) Find(search string, firstOccurrence bool) (time.Time, error)
  • func (a AWSNodeSource) Name() string
  • func (a AWSNodeSource) 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 AWSNodeSource

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

AWSNodeSource is the aws-node / VPC CNI log source

func New

func New(path string) *AWSNodeSource

New instantiates a new instance of the AWSNode source

func (AWSNodeSource) ClearCache

func (a AWSNodeSource) ClearCache()

ClearCache will clear the log reader cache

func (AWSNodeSource) Find

func (a AWSNodeSource) Find(search string, firstOccurrence bool) (time.Time, error)

Find searches the aws-node log source based on the regexp string provided

func (AWSNodeSource) Name

func (a AWSNodeSource) Name() string

Name is the log source name

func (AWSNodeSource) String

func (a AWSNodeSource) String() string