pkg

Documentation

Index

• func LogReader(prefix string, in <-chan *api.StreamFrame, out chan<- string)
• func LogRecordsPrinter(outputCh <-chan string, filterStr []string, excludeStr []string)
• func Run(_ context.Context, conf *Config) error
• func Subscriber(client *api.Client, conf *Config, subs <-chan Subscription, out chan<- string, ...)
• func SubscriptionFinder(client *api.Client, subsCh chan<- Subscription, prefix string, task string)
• type AllocSpec
  • func (a *AllocSpec) String() string
• type Config
  • func ParseCLIArguments(prefix string, opts *Options) (*Config, error)
• type Options
• type Subscription
  • func NewSubscription(node, job, alloc, task string) *Subscription
  • func (s *Subscription) String() string

Functions

func LogReader

func LogReader(prefix string, in <-chan *api.StreamFrame, out chan<- string)

func LogRecordsPrinter

func LogRecordsPrinter(outputCh <-chan string, filterStr []string, excludeStr []string)

func Run

func Run(_ context.Context, conf *Config) error

func Subscriber

func Subscriber(client *api.Client, conf *Config, subs <-chan Subscription, out chan<- string, wg *sync.WaitGroup)

func SubscriptionFinder

func SubscriptionFinder(client *api.Client, subsCh chan<- Subscription, prefix string, task string)

Types

type AllocSpec

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

func (*AllocSpec) String

func (a *AllocSpec) String() string

type Config

type Config struct {
	JobsOrAllocPrefix string
	NomadAddress      string
	Timestamps        bool
	Follow            bool
	ShowStdout        bool
	ShowStderr        bool
	TaskName          string
	FilterStr         *[]string
	ExcludeStr        *[]string
	TailBytes         int64
	Raw               bool
}

Config contains the config (Where is my rock?)

func ParseCLIArguments

func ParseCLIArguments(prefix string, opts *Options) (*Config, error)

type Options

type Options struct {
	NomadAddr  string
	Follow     bool
	TailBytes  int64
	New        bool
	OnlyStdout bool
	OnlyStderr bool
	TaskName   string
	FilterStr  *[]string
	ExcludeStr *[]string
	Color      string
	Version    bool
	Raw        bool
}

type Subscription

type Subscription struct {
	Node       string
	Job        string
	Alloc      string
	AllocShort string
	Task       string
}

func NewSubscription

func NewSubscription(node, job, alloc, task string) *Subscription

func (*Subscription) String

func (s *Subscription) String() string