Documentation
¶
Overview ¶
Package client provides clients for querying external services from the WFE controller.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type OgenWorkflowQuerier ¶
type OgenWorkflowQuerier struct {
// contains filtered or unexported fields
}
OgenWorkflowQuerier implements WorkflowQuerier using the ogen-generated DS client. DD-API-001 compliant: uses generated OpenAPI client for type safety.
func NewOgenWorkflowQuerier ¶
func NewOgenWorkflowQuerier(client WorkflowCatalogClient) *OgenWorkflowQuerier
NewOgenWorkflowQuerier creates a WorkflowQuerier from an existing ogen client wrapper.
func NewOgenWorkflowQuerierFromConfig ¶
func NewOgenWorkflowQuerierFromConfig(baseURL string, timeout time.Duration) (*OgenWorkflowQuerier, error)
NewOgenWorkflowQuerierFromConfig creates a WorkflowQuerier with a standalone ogen client configured from the DataStorage URL and timeout. Uses ServiceAccount auth transport (same pattern as DSHistoryAdapter).
func (*OgenWorkflowQuerier) GetWorkflowDependencies ¶
func (q *OgenWorkflowQuerier) GetWorkflowDependencies(ctx context.Context, workflowID string) (*models.WorkflowDependencies, error)
GetWorkflowDependencies fetches the workflow from DS by ID and extracts schema-declared dependencies from the Content field (raw YAML). Returns nil if the workflow has no dependencies declared.
type WorkflowCatalogClient ¶
type WorkflowCatalogClient interface {
GetWorkflowByID(ctx context.Context, params ogenclient.GetWorkflowByIDParams) (ogenclient.GetWorkflowByIDRes, error)
}
WorkflowCatalogClient is a narrow interface satisfied by the ogen-generated *ogenclient.Client. Defined here for testability (mock injection).
type WorkflowQuerier ¶
type WorkflowQuerier interface {
GetWorkflowDependencies(ctx context.Context, workflowID string) (*models.WorkflowDependencies, error)
}
WorkflowQuerier retrieves workflow dependencies from the Data Storage catalog. DD-WE-006: WFE queries DS on demand using the workflow ID.
Source Files