Documentation
¶
Index ¶
- Constants
- func ConvertSecondToDuration(t TimeSecond) time.Duration
- type CommandDescriptor
- type CommandEntrypoint
- type CommandInvocation
- type ExecutionState
- type Executor
- func (e *Executor) GetNewPipeChain() func() PipeChainRunner
- func (e *Executor) GetSettings(resourceName string) []string
- func (e *Executor) Register(descriptor *CommandDescriptor, names ...string) error
- func (e *Executor) ResolveCommandDescriptor(opts *CommandInvocation) (*CommandDescriptor, *string, *string, error)
- func (e *Executor) Run(ib io.Reader, opts *CommandInvocation, ob io.Writer, eb io.Writer) (*ExecutionState, error)
- func (e *Executor) RunOnRawData(opts *CommandInvocation, inData []byte) ([]byte, []byte, *ExecutionState, error)
- func (e *Executor) StoreSettings(prefix string, settings map[string]interface{}, format string, ...) error
- type ExecutorOptions
- type PipeChain
- type PipeChainRunner
- type TimeSecond
Constants ¶
View Source
const BLANK string = ""
View Source
const MAIN_RESOURCE string = ":default-resource:"
Variables ¶
This section is empty.
Functions ¶
func ConvertSecondToDuration ¶ added in v1.0.6
func ConvertSecondToDuration(t TimeSecond) time.Duration
Types ¶
type CommandDescriptor ¶
type CommandDescriptor struct {
CommandString string `json:"command"`
ExecutionTimeout TimeSecond `json:"timeout"`
// contains filtered or unexported fields
}
type CommandEntrypoint ¶
type CommandEntrypoint struct {
Default *CommandDescriptor `json:"default"`
Methods map[string]*CommandDescriptor `json:"methods"`
Pattern *string `json:"pattern"`
Settings map[string]interface{} `json:"settings"`
SettingsFormat *string `json:"settings-format"`
// contains filtered or unexported fields
}
type CommandInvocation ¶
type ExecutionState ¶
type Executor ¶
type Executor struct {
// contains filtered or unexported fields
}
func NewExecutor ¶
func NewExecutor(opts *ExecutorOptions) (*Executor, error)
func (*Executor) GetNewPipeChain ¶ added in v1.0.4
func (e *Executor) GetNewPipeChain() func() PipeChainRunner
func (*Executor) GetSettings ¶ added in v1.0.5
func (*Executor) Register ¶
func (e *Executor) Register(descriptor *CommandDescriptor, names ...string) error
func (*Executor) ResolveCommandDescriptor ¶ added in v1.0.5
func (e *Executor) ResolveCommandDescriptor(opts *CommandInvocation) (*CommandDescriptor, *string, *string, error)
func (*Executor) Run ¶
func (e *Executor) Run(ib io.Reader, opts *CommandInvocation, ob io.Writer, eb io.Writer) (*ExecutionState, error)
func (*Executor) RunOnRawData ¶
func (e *Executor) RunOnRawData(opts *CommandInvocation, inData []byte) ([]byte, []byte, *ExecutionState, error)
type ExecutorOptions ¶
type ExecutorOptions struct {
DefaultCommand *CommandDescriptor
}
type PipeChain ¶
type PipeChain struct {
// contains filtered or unexported fields
}
type PipeChainRunner ¶ added in v1.0.4
type TimeSecond ¶ added in v1.0.2
type TimeSecond float64
func ConvertDurationToSecond ¶ added in v1.0.6
func ConvertDurationToSecond(t time.Duration) TimeSecond
func GetExecutionTimeout ¶ added in v1.0.5
func GetExecutionTimeout(cd *CommandDescriptor, ci *CommandInvocation) TimeSecond
Click to show internal directories.
Click to hide internal directories.