sources

type ListWorkflowMetadataRequest struct {

	// don_families is the list of DON families to filter workflows by.
	DonFamilies []string `protobuf:"bytes,1,rep,name=don_families,json=donFamilies,proto3" json:"don_families,omitempty"`
	// start is the pagination offset (0-indexed). Defaults to 0.
	Start int64 `protobuf:"varint,2,opt,name=start,proto3" json:"start,omitempty"`
	// limit is the maximum number of workflows to return. Defaults to 1000 if not specified.
	Limit int64 `protobuf:"varint,3,opt,name=limit,proto3" json:"limit,omitempty"`
	// status_filter filters workflows by status. Empty = all, [0] = active only, [1] = paused only.
	// Multiple values can be provided to include workflows matching any of the specified statuses.
	StatusFilter []uint32 `protobuf:"varint,4,rep,packed,name=status_filter,json=statusFilter,proto3" json:"status_filter,omitempty"`
	// contains filtered or unexported fields
}

type ListWorkflowMetadataResponse struct {

	// workflows is the list of workflow metadata entries.
	Workflows []*WorkflowMetadata `protobuf:"bytes,1,rep,name=workflows,proto3" json:"workflows,omitempty"`
	// has_more indicates whether there are more workflows available beyond this page.
	HasMore bool `protobuf:"varint,2,opt,name=has_more,json=hasMore,proto3" json:"has_more,omitempty"`
	// contains filtered or unexported fields
}

type UnimplementedWorkflowMetadataSourceServiceServer struct{}

type UnsafeWorkflowMetadataSourceServiceServer interface {
	// contains filtered or unexported methods
}

type WorkflowManagedBy int32

type WorkflowMetadata struct {
	WorkflowId []byte `protobuf:"bytes,1,opt,name=workflow_id,json=workflowId,proto3" json:"workflow_id,omitempty"`
	Owner      string `protobuf:"bytes,2,opt,name=owner,proto3" json:"owner,omitempty"`
	// created_at is the Unix timestamp when the workflow was created.
	CreatedAt uint64 `protobuf:"varint,3,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// status indicates the workflow status (0=active, 1=paused).
	Status WorkflowStatus `protobuf:"varint,4,opt,name=status,proto3,enum=sources.v1.WorkflowStatus" json:"status,omitempty"`
	// workflow_name is the human-readable name of the workflow.
	WorkflowName string `protobuf:"bytes,5,opt,name=workflow_name,json=workflowName,proto3" json:"workflow_name,omitempty"`
	// binary_url is the URL to fetch the workflow binary.
	BinaryUrl string `protobuf:"bytes,6,opt,name=binary_url,json=binaryUrl,proto3" json:"binary_url,omitempty"`
	// config_url is the URL to fetch the workflow config.
	ConfigUrl string `protobuf:"bytes,7,opt,name=config_url,json=configUrl,proto3" json:"config_url,omitempty"`
	// tag is the version tag of the workflow.
	Tag string `protobuf:"bytes,8,opt,name=tag,proto3" json:"tag,omitempty"`
	// attributes is optional JSON-encoded attributes.
	Attributes []byte `protobuf:"bytes,9,opt,name=attributes,proto3" json:"attributes,omitempty"`
	// don_family is the DON family this workflow belongs to.
	DonFamily string `protobuf:"bytes,10,opt,name=don_family,json=donFamily,proto3" json:"don_family,omitempty"`
	// managed_by is the origin of this workflow (CLI, CREC, etc.)
	ManagedBy      WorkflowManagedBy `protobuf:"varint,11,opt,name=managed_by,json=managedBy,proto3,enum=sources.v1.WorkflowManagedBy" json:"managed_by,omitempty"`
	OrganizationId string            `protobuf:"bytes,12,opt,name=organization_id,json=organizationId,proto3" json:"organization_id,omitempty"`
	// contains filtered or unexported fields
}

type WorkflowMetadataSourceServiceClient interface {
	// ListWorkflowMetadata returns all workflow metadata for the given DON.
	ListWorkflowMetadata(ctx context.Context, in *ListWorkflowMetadataRequest, opts ...grpc.CallOption) (*ListWorkflowMetadataResponse, error)
}

type WorkflowMetadataSourceServiceServer interface {
	// ListWorkflowMetadata returns all workflow metadata for the given DON.
	ListWorkflowMetadata(context.Context, *ListWorkflowMetadataRequest) (*ListWorkflowMetadataResponse, error)
	// contains filtered or unexported methods
}

type WorkflowStatus int32