Versions in this module Expand all Collapse all v1 v1.0.0 May 31, 2024 Changes in this version + var File_internal_proto_step_proto protoreflect.FileDescriptor + func ToDagStep(pbStep *Step) (*dag.Step, error) + type Condition struct + Condition string + Expected string + func (*Condition) Descriptor() ([]byte, []int) + func (*Condition) ProtoMessage() + func (x *Condition) GetCondition() string + func (x *Condition) GetExpected() string + func (x *Condition) ProtoReflect() protoreflect.Message + func (x *Condition) Reset() + func (x *Condition) String() string + type ContinueOn struct + Failure bool + Skipped bool + func (*ContinueOn) Descriptor() ([]byte, []int) + func (*ContinueOn) ProtoMessage() + func (x *ContinueOn) GetFailure() bool + func (x *ContinueOn) GetSkipped() bool + func (x *ContinueOn) ProtoReflect() protoreflect.Message + func (x *ContinueOn) Reset() + func (x *ContinueOn) String() string + type ExecutorConfig struct + Config map[string]*anypb.Any + Type string + func (*ExecutorConfig) Descriptor() ([]byte, []int) + func (*ExecutorConfig) ProtoMessage() + func (x *ExecutorConfig) GetConfig() map[string]*anypb.Any + func (x *ExecutorConfig) GetType() string + func (x *ExecutorConfig) ProtoReflect() protoreflect.Message + func (x *ExecutorConfig) Reset() + func (x *ExecutorConfig) String() string + type RepeatPolicy struct + Interval *durationpb.Duration + Repeat bool + func (*RepeatPolicy) Descriptor() ([]byte, []int) + func (*RepeatPolicy) ProtoMessage() + func (x *RepeatPolicy) GetInterval() *durationpb.Duration + func (x *RepeatPolicy) GetRepeat() bool + func (x *RepeatPolicy) ProtoReflect() protoreflect.Message + func (x *RepeatPolicy) Reset() + func (x *RepeatPolicy) String() string + type RetryPolicy struct + Interval *durationpb.Duration + Limit int32 + func (*RetryPolicy) Descriptor() ([]byte, []int) + func (*RetryPolicy) ProtoMessage() + func (x *RetryPolicy) GetInterval() *durationpb.Duration + func (x *RetryPolicy) GetLimit() int32 + func (x *RetryPolicy) ProtoReflect() protoreflect.Message + func (x *RetryPolicy) Reset() + func (x *RetryPolicy) String() string + type Step struct + Args []string + CmdWithArgs string + Command string + ContinueOn *ContinueOn + Depends []string + Description string + Dir string + ExecutorConfig *ExecutorConfig + MailOnError bool + Name string + Output string + Preconditions []*Condition + RepeatPolicy *RepeatPolicy + RetryPolicy *RetryPolicy + Script string + SignalOnStop string + Stderr string + Stdout string + Variables []string + func ToPbStep(dagStep *dag.Step) (*Step, error) + func (*Step) Descriptor() ([]byte, []int) + func (*Step) ProtoMessage() + func (x *Step) GetArgs() []string + func (x *Step) GetCmdWithArgs() string + func (x *Step) GetCommand() string + func (x *Step) GetContinueOn() *ContinueOn + func (x *Step) GetDepends() []string + func (x *Step) GetDescription() string + func (x *Step) GetDir() string + func (x *Step) GetExecutorConfig() *ExecutorConfig + func (x *Step) GetMailOnError() bool + func (x *Step) GetName() string + func (x *Step) GetOutput() string + func (x *Step) GetPreconditions() []*Condition + func (x *Step) GetRepeatPolicy() *RepeatPolicy + func (x *Step) GetRetryPolicy() *RetryPolicy + func (x *Step) GetScript() string + func (x *Step) GetSignalOnStop() string + func (x *Step) GetStderr() string + func (x *Step) GetStdout() string + func (x *Step) GetVariables() []string + func (x *Step) ProtoReflect() protoreflect.Message + func (x *Step) Reset() + func (x *Step) String() string