bl

type BL struct {
	TLSEnable                       bool
	TLSEnableClientCertificateCheck bool
	TLSCertFile                     string
	TLSKeyFile                      string
	TLSCAFile                       string
	InterruptServe                  chan os.Signal
	ServerReady                     bool

	ValveCtx       context.Context
	ShutdownValve  *valve.Valve
	CancelValveCtx context.CancelFunc

	JobQueueType JOBQueueType

	PendingRecursionDepthLimit int

	InstanceId string

	DAO    *dao.DAO
	Client *client.CLI
	// contains filtered or unexported fields
}

type DO interface {
	Describe() string
}

type Decision struct {
	Name   string `json:"name,omitempty"`
	Label  string `json:"label,omitempty"`
	Result string `json:"result,omitempty"`
}

type DoType string

type DoubleCurlyToken struct {
	Start int
	End   int
}

type Event struct {
	Decisions []RulesDecision `json:"decisions,omitempty"`
	Rules     []Rule          `json:"rules,omitempty"`
}

type Expiration struct {
	CompleteBy int64           `json:"complete-by,omitempty" mapstructure:"complete-by" yaml:"complete-by,omitempty"`
	Decisions  []RulesDecision `json:"decisions,omitempty"`
	Rules      []Rule          `json:"rules,omitempty"`
}

type JOBQueueType int

type On struct {
	InProgress Event `json:"in-progress,omitempty" mapstructure:"in-progress" yaml:"in-progress,omitempty"`
	Pending    Event `json:"pending,omitempty" mapstructure:"pending" yaml:"pending,omitempty"`
	Done       Event `json:"done,omitempty" mapstructure:"done" yaml:"done,omitempty"`
	Failed     Event `json:"failed,omitempty" mapstructure:"failed" yaml:"failed,omitempty"`
}

type RabbitMQ struct {
	// contains filtered or unexported fields
}

type RecoveryMessage struct {
	InstanceUUID string `json:"instance-uuid"`
	ReachedLimit bool
}

type Rego struct {
	// contains filtered or unexported fields
}

type Rule struct {
	If   string `json:"if,omitempty"`
	Then *Then  `json:"then,omitempty"`
}

type RulesDecision struct {
	Label string `json:"label"`
	Input string `json:"input,omitempty"`
}

type Step struct {
	Name        string         `json:"name,omitempty"`
	Tags        pq.StringArray `json:"tags,omitempty"`
	Label       string         `json:"label,omitempty"`
	Description string         `json:"description,omitempty"`
	Parameters  api.Parameters `json:"parameters,omitempty"`
	Do          interface{}    `json:"do,omitempty"`
	On          On             `json:"on,omitempty"`
	Retries     int            `json:"retries,omitempty"`
	// contains filtered or unexported fields
}

type StepDo struct {
	Type             DoType `json:"type,omitempty" mapstructure:"type" yaml:"type,omitempty"`
	HeartBeatTimeout int64  `json:"heartbeat-timeout,omitempty" mapstructure:"heartbeat-timeout" yaml:"heartbeat-timeout,omitempty"`
	Retries          int64  `json:"retries,omitempty" mapstructure:"retries" yaml:"retries,omitempty"`
	CompleteBy       int64  `json:"complete-by,omitempty" mapstructure:"complete-by" yaml:"complete-by,omitempty"`
}

type StepDoEvaluate struct {
	StepDo  `yaml:",inline" mapstructure:",squash"`
	Options StepDoEvaluateOptions `json:"options,omitempty"`
}

type StepDoEvaluateOptions struct {
	Result string `json:"result,omitempty"`
}

type StepDoREST struct {
	StepDo  `yaml:",inline" mapstructure:",squash"`
	Options StepDoRESTOptions `json:"options,omitempty"`
}

type StepDoRESTOptions struct {
	Timeout              int64       `json:"timeout,omitempty"`
	Method               string      `json:"method,omitempty"`
	Url                  string      `json:"url,omitempty"`
	Headers              http.Header `json:"headers,omitempty"`
	MaxResponseBodyBytes int64       `json:"max-response-body-bytes,omitempty" mapstructure:"max-response-body-bytes" yaml:"max-response-body-bytes,omitempty"`
	Body                 string      `json:"body,omitempty"`
}

type StepStateRest struct {
	Body         interface{}         `json:"body,omitempty" mapstructure:"body" yaml:"body,omitempty"`
	ContentType  string              `json:"content-type,omitempty" mapstructure:"content-type" yaml:"content-type,omitempty"`
	StatusCode   int                 `json:"status-code,omitempty" mapstructure:"status-code" yaml:"status-code,omitempty"`
	StatusPhrase string              `json:"status-phrase,omitempty" mapstructure:"status-phrase" yaml:"status-phrase,omitempty"`
	Header       map[string][]string `json:"header,omitempty" mapstructure:"header" yaml:"header,omitempty"`
}

type Template struct {
	Title      string         `json:"title,omitempty"`
	Version    int            `json:"version,omitempty"`
	Expiration Expiration     `json:"expiration,omitempty"`
	Steps      []Step         `json:"steps,omitempty"`
	Tags       pq.StringArray `json:"tags,omitempty"`
	Decisions  []Decision     `json:"decisions,omitempty"`
	Parameters api.Parameters `json:"parameters,omitempty"`
	// contains filtered or unexported fields
}

type Then struct {
	SetRunStatus *api.RunStatusType `json:"set-run-status,omitempty" mapstructure:"set-run-status,omitempty" yaml:"set-run-status,omitempty"`
	Error        *ThenError         `json:"error,omitempty"`
	Do           []ThenDo           `json:"do,omitempty"`
}

type ThenDo struct {
	Label   string `json:"label,omitempty"`
	Context string `json:"context,omitempty"`
}

type ThenError struct {
	Propagate *bool  `json:"propagate,omitempty"`
	Message   string `json:"message,omitempty"`
	Data      string `json:"data,omitempty"`
}

type WorkType bool