execdeps

Documentation

Index

• func HaveExecutionDependencies(ctx context.Context) bool
• type ExecutionDependencies
  • func DefaultExecutionDependencies() ExecutionDependencies
  • func GetExecutionDependencies(ctx context.Context) ExecutionDependencies
  • func NewExecutionDependencies(allocator *memory.Allocator, now *time.Time, logger *zap.Logger) ExecutionDependencies
  • func (d ExecutionDependencies) Inject(ctx context.Context) context.Context

Functions

func HaveExecutionDependencies

func HaveExecutionDependencies(ctx context.Context) bool

Types

type ExecutionDependencies

type ExecutionDependencies struct {
	// Must be set
	Allocator *memory.Allocator
	Now       *time.Time

	// Allowed to be nil
	Logger *zap.Logger

	// Metadata is passed up from any invocations of execution up to the parent
	// execution, and out through the statistics.
	Metadata metadata.Metadata
}

ExecutionDependencies represents the dependencies that a function call executed by the Interpreter needs in order to trigger the execution of a flux.Program

func DefaultExecutionDependencies

func DefaultExecutionDependencies() ExecutionDependencies

func GetExecutionDependencies

func GetExecutionDependencies(ctx context.Context) ExecutionDependencies

func NewExecutionDependencies

func NewExecutionDependencies(allocator *memory.Allocator, now *time.Time, logger *zap.Logger) ExecutionDependencies

Create some execution dependencies. Any arg may be nil, this will choose some suitable defaults.

func (ExecutionDependencies) Inject

func (d ExecutionDependencies) Inject(ctx context.Context) context.Context