sync

package
v0.0.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jul 13, 2020 License: Apache-2.0 Imports: 4 Imported by: 0

Documentation

Index

Constants

View Source
const (
	EventRequire = iota
	EventChange
)

Variables

This section is empty.

Functions

func NodeError

func NodeError(node Node) error

func RunNode

func RunNode(node Node)

func WaitForNode

func WaitForNode(node Node)

Types

type Event

type Event int

type Kernel

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

Kernel must be embedded into a struct that implements Node

func NewKernel

func NewKernel(name string, lock *Lock, fullEnv bool) *Kernel
type Link struct {
	// contains filtered or unexported fields
}
func NodeLink(node Node, t LinkType) Link

type LinkType

type LinkType int
const (
	LinkNone LinkType = iota
	LinkRequire
	LinkContent
	LinkVersion
	LinkSerial
)

type Lock

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

func NewLock

func NewLock() *Lock

func (*Lock) Add

func (l *Lock) Add(n int)

type Node

type Node interface {
	Run() error
	Skip() error
	Test() (exists, matched bool, err error)
	Links() []Link
	// contains filtered or unexported methods
}

type PTeeReader

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

func NewPTeeReader

func NewPTeeReader(r io.Reader, w io.Writer) *PTeeReader

func (*PTeeReader) Read

func (t *PTeeReader) Read(p []byte) (n int, err error)

func (*PTeeReader) Sync

func (t *PTeeReader) Sync() (n int64, err error)

type Streamer

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

func NewStreamer

func NewStreamer() *Streamer

func (*Streamer) Close

func (s *Streamer) Close() error

func (Streamer) Stderr

func (s Streamer) Stderr() io.Writer

func (Streamer) Stdout

func (s Streamer) Stdout() io.Writer

func (*Streamer) Stream

func (s *Streamer) Stream(out, err io.Writer) error

type Writer

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

func (*Writer) Write

func (w *Writer) Write(p []byte) (n int, err error)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL