tpu

Documentation

Index

• func Cmd(command ...string) (string, error)
• func CmdLog(command []string, logln func(string)) (string, error)
• func CmdLogf(command []string, logf func(string, ...interface{})) (string, error)
• func IsYaml(name string) bool
• func Rlimit()
• func ShellLog(command string, logln func(string)) (string, error)
• type ArrayFlags
  • func (i *ArrayFlags) Set(value string) error
  • func (i *ArrayFlags) String() string
• type Keeper
  • func NewKeeper(prefix, command string) (k *Keeper)
  • func (k *Keeper) Start()
  • func (k *Keeper) Stop()
  • func (k *Keeper) Wait()
• type Latch
  • func NewLatch(n int) Latch
  • func (l Latch) Notify()
  • func (l Latch) Wait()
• type Semaphore
  • func NewSemaphore(n int) Semaphore
  • func (s Semaphore) Acquire()
  • func (s Semaphore) Release()

Functions

func Cmd

func Cmd(command ...string) (string, error)

func CmdLog

func CmdLog(command []string, logln func(string)) (string, error)

func CmdLogf

func CmdLogf(command []string, logf func(string, ...interface{})) (string, error)

func IsYaml

func IsYaml(name string) bool

func Rlimit

func Rlimit()

func ShellLog

func ShellLog(command string, logln func(string)) (string, error)

Types

type ArrayFlags

type ArrayFlags []string

func (*ArrayFlags) Set

func (i *ArrayFlags) Set(value string) error

func (*ArrayFlags) String

func (i *ArrayFlags) String() string

type Keeper

type Keeper struct {
	Prefix  string
	Command string
	Input   string
	Inspect string
	Limit   int
	// contains filtered or unexported fields
}

func NewKeeper

func NewKeeper(prefix, command string) (k *Keeper)

func (*Keeper) Start

func (k *Keeper) Start()

func (*Keeper) Stop

func (k *Keeper) Stop()

func (*Keeper) Wait

func (k *Keeper) Wait()

type Latch

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

func NewLatch

func NewLatch(n int) Latch

func (Latch) Notify

func (l Latch) Notify()

func (Latch) Wait

func (l Latch) Wait()

type Semaphore

type Semaphore chan empty

func NewSemaphore

func NewSemaphore(n int) Semaphore

func (Semaphore) Acquire

func (s Semaphore) Acquire()

func (Semaphore) Release

func (s Semaphore) Release()