jobrunner

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

type Config struct {
	BaseURL   string
	JobToken  string
	RunnerID  string
	BootID    uuid.UUID
	Timeout   time.Duration
	Heartbeat time.Duration
}

type Job struct {
	JobID           uuid.UUID                   `json:"job_id"`
	ExecutionID     uuid.UUID                   `json:"execution_id"`
	FlowID          uuid.UUID                   `json:"flow_id"`
	LeaseExpiresAt  time.Time                   `json:"lease_expires_at"`
	FlowDefinition  json.RawMessage             `json:"flow_definition"`
	Inputs          map[string]any              `json:"inputs"`
	SecretInputKeys []string                    `json:"secret_input_keys,omitempty"`
	ReferencedFlows flow.ReferencedFlowRegistry `json:"referenced_flows,omitempty"`
}

type Result struct {
	Status       string
	Execution    *spi.FlowExecutionResult
	ErrorMessage *string
}