seeker

Documentation

Index

• Constants
• func JournalctlGetLogsCmd(name, destDir string, since, until time.Time) string
• type Commander
  • func (c Commander) Run() (result interface{}, err error)
• type Copier
  • func (c Copier) Run() (result interface{}, err error)
• type HTTPer
  • func (h HTTPer) Run() (interface{}, error)
• type Runner
• type Seeker
  • func Exclude(excludes []string, seekers []*Seeker) ([]*Seeker, error)
  • func JournaldGetter(name, destDir string, since, until time.Time) *Seeker
  • func NewCommander(command string, format string) *Seeker
  • func NewCopier(path, destDir string, since, until time.Time) *Seeker
  • func NewHTTPer(client *client.APIClient, path string) *Seeker
  • func NewSheller(command string) *Seeker
  • func Select(selects []string, seekers []*Seeker) ([]*Seeker, error)
  • func (s *Seeker) Run() (result interface{}, err error)
• type Sheller
  • func (s *Sheller) Run() (result interface{}, err error)

Constants

const JournaldTimeLayout = "2006-01-02 15:04:05"

JournaldTimeLayout custom go time layouts must match the reference time Jan 2 15:04:05 2006 MST

Functions

func JournalctlGetLogsCmd

func JournalctlGetLogsCmd(name, destDir string, since, until time.Time) string

JournalctlGetLogsCmd takes the service name, destination to write logs to, two timestamps for the time range, and

arranges them into a runnable command string.

Types

type Commander

type Commander struct {
	Command string `json:"command"`
	// contains filtered or unexported fields
}

Commander runs shell commands.

func (Commander) Run

func (c Commander) Run() (result interface{}, err error)

type Copier

type Copier struct {
	SourceDir string    `json:"source_directory"`
	Filter    string    `json:"filter"`
	DestDir   string    `json:"destination_directory"`
	Since     time.Time `json:"since"`
	Until     time.Time `json:"until"`
}

Copier copies files to temp dir based on a filter.

func (Copier) Run

func (c Copier) Run() (result interface{}, err error)

Run satisfies the Runner interface and copies the filtered source files to the destination.

type HTTPer

type HTTPer struct {
	Path   string            `json:"path"`
	Client *client.APIClient `json:"client"`
}

HTTPer hits APIs.

func (HTTPer) Run

func (h HTTPer) Run() (interface{}, error)

type Runner

type Runner interface {
	Run() (interface{}, error)
}

Runner runs things to get information.

type Seeker

type Seeker struct {
	Runner     Runner      `json:"runner"`
	Identifier string      `json:"-"`
	Result     interface{} `json:"result"`
	ErrString  string      `json:"error"` // this simplifies json marshaling
	Error      error       `json:"-"`
}

Seeker seeks information via its Runner then stores the results.

func Exclude

func Exclude(excludes []string, seekers []*Seeker) ([]*Seeker, error)

Exclude takes a slice of matcher strings and a slice of seekers. If any of the seeker identifiers match the exclude according to filepath.Match() then it will not be present in the returned seeker slice. NOTE(mkcp): This is precisely identical to Select() except we flip the match check. Maybe we can perform both rounds

of filtering in one pass one rather than iterating over all the seekers several times. Not likely to be a huge speed
increase though... we're not even remotely bottlenecked on seeker filtering.

func JournaldGetter

func JournaldGetter(name, destDir string, since, until time.Time) *Seeker

JournaldGetter attempts to pull logs from journald via shell command, e.g.: journalctl -x -u {name} --since '3 days ago' --no-pager > {destDir}/journald-{name}.log

func NewCommander

func NewCommander(command string, format string) *Seeker

NewCommander provides a Seeker for running shell commands.

func NewCopier

func NewCopier(path, destDir string, since, until time.Time) *Seeker

NewCopier provides a Seeker for copying files to temp dir based on a filter.

func NewHTTPer

func NewHTTPer(client *client.APIClient, path string) *Seeker

func NewSheller

func NewSheller(command string) *Seeker

NewSheller provides a Seeker for running shell commands.

func Select

func Select(selects []string, seekers []*Seeker) ([]*Seeker, error)

Select takes a slice of matcher strings and a slice of seekers. The only seekers returned will be those matching the given select strings according to filepath.Match()

func (*Seeker) Run

func (s *Seeker) Run() (result interface{}, err error)

type Sheller

type Sheller struct {
	Command string `json:"command"`
	Shell   string `json:"shell"`
}

Sheller runs shell commands in a real unix shell.

func (*Sheller) Run

func (s *Sheller) Run() (result interface{}, err error)