pb

package
v1.0.5 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 29, 2024 License: GPL-3.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_internal_proto_step_proto protoreflect.FileDescriptor

Functions

func ToDagStep 

func ToDagStep(pbStep *Step) (*dag.Step, error)

Types

type Condition 

type Condition struct {
	Condition string `protobuf:"bytes,1,opt,name=condition,proto3" json:"condition,omitempty"`
	Expected  string `protobuf:"bytes,2,opt,name=expected,proto3" json:"expected,omitempty"`
	// contains filtered or unexported fields
}

func (*Condition) Descriptor deprecated 

func (*Condition) Descriptor() ([]byte, []int)

Deprecated: Use Condition.ProtoReflect.Descriptor instead.

func (*Condition) GetCondition 

func (x *Condition) GetCondition() string

func (*Condition) GetExpected 

func (x *Condition) GetExpected() string

func (*Condition) ProtoMessage 

func (*Condition) ProtoMessage()

func (*Condition) ProtoReflect 

func (x *Condition) ProtoReflect() protoreflect.Message

func (*Condition) Reset 

func (x *Condition) Reset()

func (*Condition) String 

func (x *Condition) String() string

type ContinueOn 

type ContinueOn struct {
	Failure bool `protobuf:"varint,1,opt,name=failure,proto3" json:"failure,omitempty"`
	Skipped bool `protobuf:"varint,2,opt,name=skipped,proto3" json:"skipped,omitempty"`
	// contains filtered or unexported fields
}

func (*ContinueOn) Descriptor deprecated 

func (*ContinueOn) Descriptor() ([]byte, []int)

Deprecated: Use ContinueOn.ProtoReflect.Descriptor instead.

func (*ContinueOn) GetFailure 

func (x *ContinueOn) GetFailure() bool

func (*ContinueOn) GetSkipped 

func (x *ContinueOn) GetSkipped() bool

func (*ContinueOn) ProtoMessage 

func (*ContinueOn) ProtoMessage()

func (*ContinueOn) ProtoReflect 

func (x *ContinueOn) ProtoReflect() protoreflect.Message

func (*ContinueOn) Reset 

func (x *ContinueOn) Reset()

func (*ContinueOn) String 

func (x *ContinueOn) String() string

type ExecutorConfig 

type ExecutorConfig struct {
	Type   string                `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	Config map[string]*anypb.Any `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ExecutorConfig) Descriptor deprecated 

func (*ExecutorConfig) Descriptor() ([]byte, []int)

Deprecated: Use ExecutorConfig.ProtoReflect.Descriptor instead.

func (*ExecutorConfig) GetConfig 

func (x *ExecutorConfig) GetConfig() map[string]*anypb.Any

func (*ExecutorConfig) GetType 

func (x *ExecutorConfig) GetType() string

func (*ExecutorConfig) ProtoMessage 

func (*ExecutorConfig) ProtoMessage()

func (*ExecutorConfig) ProtoReflect 

func (x *ExecutorConfig) ProtoReflect() protoreflect.Message

func (*ExecutorConfig) Reset 

func (x *ExecutorConfig) Reset()

func (*ExecutorConfig) String 

func (x *ExecutorConfig) String() string

type RepeatPolicy 

type RepeatPolicy struct {
	Repeat   bool                 `protobuf:"varint,1,opt,name=repeat,proto3" json:"repeat,omitempty"`
	Interval *durationpb.Duration `protobuf:"bytes,2,opt,name=interval,proto3" json:"interval,omitempty"`
	// contains filtered or unexported fields
}

func (*RepeatPolicy) Descriptor deprecated 

func (*RepeatPolicy) Descriptor() ([]byte, []int)

Deprecated: Use RepeatPolicy.ProtoReflect.Descriptor instead.

func (*RepeatPolicy) GetInterval 

func (x *RepeatPolicy) GetInterval() *durationpb.Duration

func (*RepeatPolicy) GetRepeat 

func (x *RepeatPolicy) GetRepeat() bool

func (*RepeatPolicy) ProtoMessage 

func (*RepeatPolicy) ProtoMessage()

func (*RepeatPolicy) ProtoReflect 

func (x *RepeatPolicy) ProtoReflect() protoreflect.Message

func (*RepeatPolicy) Reset 

func (x *RepeatPolicy) Reset()

func (*RepeatPolicy) String 

func (x *RepeatPolicy) String() string

type RetryPolicy 

type RetryPolicy struct {
	Limit    int32                `protobuf:"varint,1,opt,name=limit,proto3" json:"limit,omitempty"`
	Interval *durationpb.Duration `protobuf:"bytes,2,opt,name=interval,proto3" json:"interval,omitempty"`
	// contains filtered or unexported fields
}

func (*RetryPolicy) Descriptor deprecated 

func (*RetryPolicy) Descriptor() ([]byte, []int)

Deprecated: Use RetryPolicy.ProtoReflect.Descriptor instead.

func (*RetryPolicy) GetInterval 

func (x *RetryPolicy) GetInterval() *durationpb.Duration

func (*RetryPolicy) GetLimit 

func (x *RetryPolicy) GetLimit() int32

func (*RetryPolicy) ProtoMessage 

func (*RetryPolicy) ProtoMessage()

func (*RetryPolicy) ProtoReflect 

func (x *RetryPolicy) ProtoReflect() protoreflect.Message

func (*RetryPolicy) Reset 

func (x *RetryPolicy) Reset()

func (*RetryPolicy) String 

func (x *RetryPolicy) String() string

type Step 

type Step struct {
	Name           string          `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Description    string          `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	Variables      []string        `protobuf:"bytes,3,rep,name=variables,proto3" json:"variables,omitempty"`
	Dir            string          `protobuf:"bytes,4,opt,name=dir,proto3" json:"dir,omitempty"`
	ExecutorConfig *ExecutorConfig `protobuf:"bytes,5,opt,name=executor_config,json=executorConfig,proto3" json:"executor_config,omitempty"`
	CmdWithArgs    string          `protobuf:"bytes,6,opt,name=cmd_with_args,json=cmdWithArgs,proto3" json:"cmd_with_args,omitempty"`
	Command        string          `protobuf:"bytes,7,opt,name=command,proto3" json:"command,omitempty"`
	Script         string          `protobuf:"bytes,8,opt,name=script,proto3" json:"script,omitempty"`
	Stdout         string          `protobuf:"bytes,9,opt,name=stdout,proto3" json:"stdout,omitempty"`
	Stderr         string          `protobuf:"bytes,10,opt,name=stderr,proto3" json:"stderr,omitempty"`
	Output         string          `protobuf:"bytes,11,opt,name=output,proto3" json:"output,omitempty"`
	Args           []string        `protobuf:"bytes,12,rep,name=args,proto3" json:"args,omitempty"`
	Depends        []string        `protobuf:"bytes,13,rep,name=depends,proto3" json:"depends,omitempty"`
	ContinueOn     *ContinueOn     `protobuf:"bytes,14,opt,name=continue_on,json=continueOn,proto3" json:"continue_on,omitempty"`
	RetryPolicy    *RetryPolicy    `protobuf:"bytes,15,opt,name=retry_policy,json=retryPolicy,proto3" json:"retry_policy,omitempty"`
	RepeatPolicy   *RepeatPolicy   `protobuf:"bytes,16,opt,name=repeat_policy,json=repeatPolicy,proto3" json:"repeat_policy,omitempty"`
	MailOnError    bool            `protobuf:"varint,17,opt,name=mail_on_error,json=mailOnError,proto3" json:"mail_on_error,omitempty"`
	Preconditions  []*Condition    `protobuf:"bytes,18,rep,name=preconditions,proto3" json:"preconditions,omitempty"`
	SignalOnStop   string          `protobuf:"bytes,19,opt,name=signal_on_stop,json=signalOnStop,proto3" json:"signal_on_stop,omitempty"`
	// contains filtered or unexported fields
}

func ToPbStep 

func ToPbStep(dagStep *dag.Step) (*Step, error)

func (*Step) Descriptor deprecated 

func (*Step) Descriptor() ([]byte, []int)

Deprecated: Use Step.ProtoReflect.Descriptor instead.

func (*Step) GetArgs 

func (x *Step) GetArgs() []string

func (*Step) GetCmdWithArgs 

func (x *Step) GetCmdWithArgs() string

func (*Step) GetCommand 

func (x *Step) GetCommand() string

func (*Step) GetContinueOn 

func (x *Step) GetContinueOn() *ContinueOn

func (*Step) GetDepends 

func (x *Step) GetDepends() []string

func (*Step) GetDescription 

func (x *Step) GetDescription() string

func (*Step) GetDir 

func (x *Step) GetDir() string

func (*Step) GetExecutorConfig 

func (x *Step) GetExecutorConfig() *ExecutorConfig

func (*Step) GetMailOnError 

func (x *Step) GetMailOnError() bool

func (*Step) GetName 

func (x *Step) GetName() string

func (*Step) GetOutput 

func (x *Step) GetOutput() string

func (*Step) GetPreconditions 

func (x *Step) GetPreconditions() []*Condition

func (*Step) GetRepeatPolicy 

func (x *Step) GetRepeatPolicy() *RepeatPolicy

func (*Step) GetRetryPolicy 

func (x *Step) GetRetryPolicy() *RetryPolicy

func (*Step) GetScript 

func (x *Step) GetScript() string

func (*Step) GetSignalOnStop 

func (x *Step) GetSignalOnStop() string

func (*Step) GetStderr 

func (x *Step) GetStderr() string

func (*Step) GetStdout 

func (x *Step) GetStdout() string

func (*Step) GetVariables 

func (x *Step) GetVariables() []string

func (*Step) ProtoMessage 

func (*Step) ProtoMessage()

func (*Step) ProtoReflect 

func (x *Step) ProtoReflect() protoreflect.Message

func (*Step) Reset 

func (x *Step) Reset()

func (*Step) String 

func (x *Step) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.