ec2

Documentation

Overview

Package ec2 is a latency timing source for ec2 API events

Index

• Variables
• type Source
  • func New(ec2Client *ec2.Client, instanceID string, nodeName string) *Source
  • func (s Source) ClearCache()
  • func (s *Source) Find(event *sources.Event) ([]sources.FindResult, error)
  • func (s *Source) FindFleetStart() sources.FindFunc
  • func (s Source) Name() string
  • func (s *Source) ParseTimeFor(event []byte) (time.Time, error)
  • func (s Source) String() string

Variables

var (
	Name = "EC2"
)

Types

type Source

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

Source is the EC2 Instance Metadata Service (IMDS) http source

func New

func New(ec2Client *ec2.Client, instanceID string, nodeName string) *Source

New instantiates a new instance of the EC2 API source

func (Source) ClearCache

func (s Source) ClearCache()

ClearCache is a noop for the EC2 Source since it is an http source, not a log file

func (*Source) Find

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

Find will use the Event's FindFunc and CommentFunc to search the source and return the result

func (*Source) FindFleetStart

func (s *Source) FindFleetStart() sources.FindFunc

FindFleetStart retrieves the Fleet request start time

func (Source) Name

func (s Source) Name() string

Name is the name of the source

func (*Source) ParseTimeFor

func (s *Source) ParseTimeFor(event []byte) (time.Time, error)

func (Source) String

func (s Source) String() string

String is a human readable string of the source