beam: github.com/apache/beam/sdks/go/pkg/beam/core/runtime/harness/init Index | Files

package init

import "github.com/apache/beam/sdks/go/pkg/beam/core/runtime/harness/init"

Package init contains the harness initialization code defined by the FnAPI. It is a separate package to avoid flags in the harness package and must be imported by the runner to ensure the init hook is registered.

Index

Package Files

init.go

Constants

const (
    // Terminate means the hook should exit itself when the worker harness returns.
    Terminate exitMode = iota
    // Return means that the hook should return out, and allow the calling code to
    // determine if and when the process exits.
    // This may cause errors that caused worker failure to be ignored.
    Return
)

Variables

var (
    // ShutdownMode allows the runner to set how the worker harness should exit.
    ShutdownMode = Terminate
)

Package init imports 10 packages (graph) and is imported by 2 packages. Updated 2020-01-20. Refresh now. Tools for package owners.