execution

package

v0.1.13 Latest Latest Go to latest Published: Mar 5, 2024 License: Apache-2.0 Imports: 24 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/google/fleetspeak

Links

Open Source Insights

Documentation ¶

Overview ¶

Package execution provides an abstraction for a single execution of a command with the context of daemonservice.

Index ¶

Variables
type Execution
- func New(ctx context.Context, daemonServiceName string, cfg *dspb.Config, ...) (*Execution, error)

Constants ¶

This section is empty.

Variables ¶

View Source

var (
	// ErrShuttingDown is returned once an execution has started shutting down and
	// is no longer accepting messages.
	ErrShuttingDown = errors.New("shutting down")
)

Functions ¶

This section is empty.

Types ¶

type Execution ¶

type Execution struct {
	StartTime time.Time
	// contains filtered or unexported fields
}

An Execution represents a specific execution of a daemonservice.

func New ¶

func New(ctx context.Context, daemonServiceName string, cfg *dspb.Config, sc service.Context) (*Execution, error)

New creates and starts an execution of the command described in cfg. Messages received from the resulting process are passed to sc, as are StdOutput and ResourceUsage messages.

The context needs to be valid for the lifetime of the whole process execution!

func (*Execution) LastActive ¶

func (e *Execution) LastActive() time.Time

LastActive returns the last time that a message was sent or received, to the nearest second.

func (*Execution) SendMsg ¶

func (e *Execution) SendMsg(ctx context.Context, m *fspb.Message) error

SendMsg sends m to the execution.

It returns nil on success, ErrShuttingDown if the output channel was already closed, and context.Cause(ctx) if ctx was canceled.

func (*Execution) Shutdown ¶

func (e *Execution) Shutdown()

Shutdown shuts down this execution.

func (*Execution) Wait ¶

func (e *Execution) Wait() error

Wait waits for all aspects of this execution to finish. This should happen soon after shutdown is called. Wait must be called to free up resources and to reap the child process.

Source Files ¶

View all Source files

execution.go

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