flyteadmin

Sep 27, 2023

Changes in this version

+ type EventEventReason struct

+ OccurredAt time.Time

+ Reason string

type EventTaskExecutionEvent

+ Reasons []EventEventReason

Sep 21, 2023

Changes in this version

type CoreOutputReference

+ AttrPath []CorePromiseAttribute

+ type CorePromiseAttribute struct

+ IntValue int32

+ StringValue string

Sep 20, 2023

Changes in this version

+ type CoreGpuAccelerator struct

+ Device string

+ PartitionSize string

+ Unpartitioned bool

+ type CoreResourceMetadata struct

+ GpuAccelerator *CoreGpuAccelerator

type CoreTaskMetadata

+ ResourceMetadata *CoreResourceMetadata

type CoreTaskNodeOverrides

+ ResourceMetadata *CoreResourceMetadata

Aug 14, 2023

Changes in this version

type CoreOperand

+ Scalar *CoreScalar

Aug 4, 2023

Changes in this version

type AdminExecutionSpec

+ Tags []string

Jul 18, 2023

Changes in this version

+ type FlyteidleventTaskExecutionMetadata struct

+ ExternalResources []EventExternalResourceInfo

+ GeneratedName string

+ InstanceClass *TaskExecutionMetadataInstanceClass

+ PluginIdentifier string

+ ResourcePoolInfo []EventResourcePoolInfo

Jun 27, 2023

Changes in this version

+ type CoreArrayNode struct

+ MinSuccessRatio float32

+ MinSuccesses int64

+ Node *CoreNode

+ Parallelism int64

type CoreNode

+ ArrayNode *CoreArrayNode

May 6, 2023

Changes in this version

type CoreIdentity

+ UserIdentifier string

Jun 28, 2023

Changes in this version

type AdminSystemMetadata

+ Namespace string

May 16, 2023

Changes in this version

+ type AdminEnvs struct

+ Values []CoreKeyValuePair

type AdminExecutionSpec

+ Envs *AdminEnvs

+ type AdminFlyteUrLs struct

+ Deck string

+ Inputs string

+ Outputs string

type AdminLaunchPlanSpec

+ Envs *AdminEnvs

type AdminNodeExecutionClosure

+ DynamicJobSpecUri string

type AdminNodeExecutionGetDataResponse

+ FlyteUrls *AdminFlyteUrLs

+ type AdminReason struct

+ Message string

+ OccurredAt time.Time

type AdminServiceApiService

+ func (a *AdminServiceApiService) GetExecutionMetrics(ctx context.Context, idProject string, idDomain string, idName string, ...) (AdminWorkflowExecutionGetMetricsResponse, *http.Response, error)

type AdminTaskExecutionClosure

+ Reasons []AdminReason

type AdminTaskExecutionGetDataResponse

+ FlyteUrls *AdminFlyteUrLs

type AdminWorkflowExecutionConfig

+ Envs *AdminEnvs

+ type AdminWorkflowExecutionGetMetricsResponse struct

+ Span *CoreSpan

type CoreIdentity

+ ExecutionIdentity string

type CoreK8sPod

+ DataConfig *CoreDataLoadingConfig

+ type CoreSpan struct

+ EndTime time.Time

+ NodeId *CoreNodeExecutionIdentifier

+ OperationId string

+ Spans []CoreSpan

+ StartTime time.Time

+ TaskId *CoreTaskExecutionIdentifier

+ WorkflowId *CoreWorkflowExecutionIdentifier

type EventNodeExecutionEvent

+ ReportedAt time.Time

type EventTaskExecutionEvent

+ ReportedAt time.Time

type FlyteidladminDynamicWorkflowNodeMetadata

+ DynamicJobSpecUri string

+ type FlyteidladminTaskCreateRequest struct

+ Id *CoreIdentifier

+ Spec *AdminTaskSpec

+ type FlyteidladminTaskCreateResponse struct

type FlyteidleventDynamicWorkflowNodeMetadata

+ DynamicJobSpecUri string

+ type GetExecutionMetricsOpts struct

+ Depth optional.Int32

Feb 22, 2023

Changes in this version

+ type CoreSchema struct

+ Type_ *CoreSchemaType

+ Uri string

type CoreTaskMetadata

+ PodTemplateName string

type EventNodeExecutionEvent

+ InputData *CoreLiteralMap

type EventTaskExecutionEvent

+ InputData *CoreLiteralMap

Dec 5, 2022

Changes in this version

type CoreTaskMetadata

+ Tags map[string]string

type CoreWorkflowMetadata

+ Tags map[string]string

Nov 9, 2022

Changes in this version

type CoreTaskMetadata

+ GeneratesDeck bool

Nov 7, 2022

Changes in this version

+ type AdminDescription struct

+ Format *AdminDescriptionFormat

+ IconLink string

+ Uri string

+ Value string

+ type AdminDescriptionEntity struct

+ Id *CoreIdentifier

+ LongDescription *AdminDescription

+ ShortDescription string

+ SourceCode *AdminSourceCode

+ Tags []string

+ type AdminDescriptionEntityList struct

+ DescriptionEntities []AdminDescriptionEntity

+ Token string

+ type AdminDescriptionFormat string

+ const AdminDescriptionFormatHTML

+ const AdminDescriptionFormatMARKDOWN

+ const AdminDescriptionFormatRST

+ const AdminDescriptionFormatUNKNOWN

type AdminServiceApiService

+ func (a *AdminServiceApiService) GetDescriptionEntity(ctx context.Context, idResourceType string, idProject string, idDomain string, ...) (AdminDescriptionEntity, *http.Response, error)

+ func (a *AdminServiceApiService) ListDescriptionEntities(ctx context.Context, resourceType string, idProject string, idDomain string, ...) (AdminDescriptionEntityList, *http.Response, error)

+ func (a *AdminServiceApiService) ListDescriptionEntities2(ctx context.Context, resourceType string, idProject string, idDomain string, ...) (AdminDescriptionEntityList, *http.Response, error)

+ type AdminSourceCode struct

+ Link string

type AdminTask

+ ShortDescription string

type AdminTaskSpec

+ Description *AdminDescriptionEntity

type AdminWorkflow

+ ShortDescription string

type AdminWorkflowSpec

+ Description *AdminDescriptionEntity

+ type ListDescriptionEntities2Opts struct

+ Filters optional.String

+ IdName optional.String

+ Limit optional.Int64

+ SortByDirection optional.String

+ SortByKey optional.String

+ Token optional.String

+ type ListDescriptionEntitiesOpts struct

+ Filters optional.String

+ Limit optional.Int64

+ SortByDirection optional.String

+ SortByKey optional.String

+ Token optional.String

Nov 2, 2022

Changes in this version

type AdminExecutionRelaunchRequest

+ OverwriteCache bool

type AdminExecutionSpec

+ OverwriteCache bool

type AdminLaunchPlanSpec

+ OverwriteCache bool

type AdminWorkflowExecutionConfig

+ OverwriteCache bool

type CoreCatalogCacheStatus

+ const CoreCatalogCacheStatusSKIPPED

Oct 25, 2022

Changes in this version

+ type CoreApproveCondition struct

+ SignalId string

+ type CoreGateNode struct

+ Approve *CoreApproveCondition

+ Signal *CoreSignalCondition

+ Sleep *CoreSleepCondition

type CoreNode

+ GateNode *CoreGateNode

+ type CoreSignalCondition struct

+ OutputVariableName string

+ SignalId string

+ Type_ *CoreLiteralType

+ type CoreSleepCondition struct

+ Duration string

Sep 30, 2022

Changes in this version

type AdminClusterAssignment

+ ClusterPoolName string

Sep 20, 2022

Changes in this version

type FlyteidladminTaskNodeMetadata

+ CheckpointUri string

type FlyteidleventTaskNodeMetadata

+ CheckpointUri string

Jun 1, 2022

Changes in this version

type AdminNodeExecutionClosure

+ DeckUri string

type EventNodeExecutionEvent

+ DeckUri string

May 2, 2022

Changes in this version

type AdminExecutionSpec

+ Interruptible bool

type AdminLaunchPlanSpec

+ Interruptible bool

type AdminWorkflowExecutionConfig

+ Interruptible bool

Apr 8, 2022

Changes in this version

type AdminTaskExecutionClosure

+ EventVersion int32

type EventTaskExecutionEvent

+ EventVersion int32

Apr 5, 2022

Changes in this version

type AdminClusterAssignment

+ Toleration *AdminToleration

+ type AdminToleration struct

+ Selectors []AdminSelector

Mar 31, 2022

Changes in this version

type EventNodeExecutionEvent

+ EventVersion int32

+ IsDynamic bool

+ IsParent bool

Mar 28, 2022

Changes in this version

type EventExternalResourceInfo

+ CacheStatus *CoreCatalogCacheStatus

+ Logs []CoreTaskLog

Mar 25, 2022

Changes in this version

type AdminWorkflowExecutionConfig

+ Annotations *AdminAnnotations

+ Labels *AdminLabels

+ RawOutputDataConfig *AdminRawOutputDataConfig

+ SecurityContext *CoreSecurityContext

Mar 22, 2022

Changes in this version

+ type AdminAffinity struct

+ Selectors []AdminSelector

+ type AdminClusterAssignment struct

+ Affinity *AdminAffinity

type AdminExecutionSpec

+ ClusterAssignment *AdminClusterAssignment

type AdminMatchableResource

+ const AdminMatchableResourceCLUSTER_ASSIGNMENT

type AdminMatchingAttributes

+ ClusterAssignment *AdminClusterAssignment

+ type AdminSelector struct

+ Key string

+ Operator *AdminSelectorOperator

+ Value []string

+ type AdminSelectorOperator string

+ const AdminSelectorOperatorEQUALS

+ const AdminSelectorOperatorEXISTS

+ const AdminSelectorOperatorIN

+ const AdminSelectorOperatorNOT_EQUALS

+ const AdminSelectorOperatorNOT_IN

+ type CoreComparisonExpressionOperator string

+ const CoreComparisonExpressionOperatorEQ

+ const CoreComparisonExpressionOperatorGT

+ const CoreComparisonExpressionOperatorGTE

+ const CoreComparisonExpressionOperatorLT

+ const CoreComparisonExpressionOperatorLTE

+ const CoreComparisonExpressionOperatorNEQ

Mar 16, 2022

Changes in this version

type CoreBindingData

+ Union *CoreUnionInfo

type CoreLiteralType

+ Structure *CoreTypeStructure

+ UnionType *CoreUnionType

type CoreScalar

+ Union *CoreUnion

+ type CoreTypeStructure struct

+ Tag string

+ type CoreUnion struct

+ Type_ *CoreLiteralType

+ Value *CoreLiteral

+ type CoreUnionInfo struct

+ TargetType *CoreLiteralType

+ type CoreUnionType struct

+ Variants []CoreLiteralType

Mar 9, 2022

Changes in this version

type AdminExecutionSpec

+ RawOutputDataConfig *AdminRawOutputDataConfig

Mar 2, 2022

Changes in this version

type CoreLiteral

+ Hash string

Feb 18, 2022

Changes in this version

type AdminNodeExecutionMetaData

+ IsDynamic bool

Feb 8, 2022

Changes in this version

type CoreLiteralType

+ Annotation *CoreTypeAnnotation

+ type CoreTypeAnnotation struct

+ Annotations *ProtobufStruct

Jan 19, 2022

Changes in this version

type AdminExecutionClosure

+ StateChangeDetails *AdminExecutionStateChangeDetails

+ type AdminExecutionState string

+ const AdminExecutionStateACTIVE

+ const AdminExecutionStateARCHIVED

+ type AdminExecutionStateChangeDetails struct

+ OccurredAt time.Time

+ Principal string

+ State *AdminExecutionState

+ type AdminExecutionUpdateRequest struct

+ Id *CoreWorkflowExecutionIdentifier

+ State *AdminExecutionState

+ type AdminExecutionUpdateResponse struct

type AdminServiceApiService

+ func (a *AdminServiceApiService) UpdateExecution(ctx context.Context, idProject string, idDomain string, idName string, ...) (AdminExecutionUpdateResponse, *http.Response, error)

Jan 12, 2022

Changes in this version

type EventExternalResourceInfo

+ Index int64

+ Phase *CoreTaskExecutionPhase

+ RetryAttempt int64

Jan 6, 2022

Changes in this version

type CoreLiteralType

+ StructuredDatasetType *CoreStructuredDatasetType

type CoreScalar

+ StructuredDataset *CoreStructuredDataset

+ type CoreStructuredDataset struct

+ Metadata *CoreStructuredDatasetMetadata

+ Uri string

+ type CoreStructuredDatasetMetadata struct

+ StructuredDatasetType *CoreStructuredDatasetType

+ type CoreStructuredDatasetType struct

+ Columns []StructuredDatasetTypeDatasetColumn

+ ExternalSchemaBytes string

+ ExternalSchemaType string

+ Format string

+ type StructuredDatasetTypeDatasetColumn struct

+ LiteralType *CoreLiteralType

+ Name string

Jan 5, 2022

Changes in this version

type CoreWorkflowExecutionPhase

+ const CoreWorkflowExecutionPhaseABORTING

Nov 23, 2021

Changes in this version

+ type CatalogReservationStatus string

+ const CatalogReservationStatusACQUIRED

+ const CatalogReservationStatusDISABLED

+ const CatalogReservationStatusEXISTS

+ const CatalogReservationStatusFAILURE

+ const CatalogReservationStatusRELEASED

type CoreTaskMetadata

+ CacheSerializable bool

type FlyteidleventTaskNodeMetadata

+ ReservationStatus *CatalogReservationStatus

Oct 20, 2021

Changes in this version

+ type ContainerArchitecture string

+ const ContainerArchitectureAMD64

+ const ContainerArchitectureARM64

+ const ContainerArchitectureARM_V6

+ const ContainerArchitectureARM_V7

+ const ContainerArchitectureUNKNOWN

type CoreContainer

+ Architecture *ContainerArchitecture

Aug 31, 2021

Changes in this version

+ type CoreSql struct

+ Dialect *SqlDialect

+ Statement string

type CoreTaskTemplate

+ Sql *CoreSql

+ type SqlDialect string

+ const SqlDialectANSI

+ const SqlDialectHIVE

+ const SqlDialectOTHER

+ const SqlDialectUNDEFINED

Aug 27, 2021

Changes in this version

+ type CoreParameterMapEntry struct

+ Name string

+ Parameter *CoreParameter

+ type CoreVariableMapEntry struct

+ Name string

+ Var_ *CoreVariable

Aug 17, 2021

Changes in this version

type AdminExecutionClosure

+ OutputData *CoreLiteralMap

type AdminNodeExecutionClosure

+ OutputData *CoreLiteralMap

type AdminTaskExecutionClosure

+ OutputData *CoreLiteralMap

Aug 12, 2021

Changes in this version

type AdminTaskResourceSpec

+ EphemeralStorage string

type EventNodeExecutionEvent

+ OutputData *CoreLiteralMap

type EventTaskExecutionEvent

+ OutputData *CoreLiteralMap

type EventWorkflowExecutionEvent

+ OutputData *CoreLiteralMap

type ResourcesResourceName

+ const ResourcesResourceNameEPHEMERAL_STORAGE

Jul 16, 2021

Changes in this version

+ type AdminExecutionRecoverRequest struct

+ Id *CoreWorkflowExecutionIdentifier

+ Metadata *AdminExecutionMetadata

+ Name string

type AdminServiceApiService

+ func (a *AdminServiceApiService) RecoverExecution(ctx context.Context, body AdminExecutionRecoverRequest) (AdminExecutionCreateResponse, *http.Response, error)

type CoreNodeExecutionPhase

+ const CoreNodeExecutionPhaseRECOVERED

type ExecutionMetadataExecutionMode

+ const ExecutionMetadataExecutionModeRECOVERED

Jun 24, 2021

Changes in this version

type CoreTaskNode

+ Overrides *CoreTaskNodeOverrides

+ type CoreTaskNodeOverrides struct

+ Resources *CoreResources

Jun 10, 2021

Changes in this version

type AdminExecutionSpec

+ MaxParallelism int32

type AdminLaunchPlanSpec

+ MaxParallelism int32

Jun 7, 2021

Changes in this version

+ type CoreEnumType struct

+ Values []string

type CoreLiteralType

+ EnumType *CoreEnumType

Jun 4, 2021

Changes in this version

type AdminMatchableResource

+ const AdminMatchableResourceWORKFLOW_EXECUTION_CONFIG

type AdminMatchingAttributes

+ WorkflowExecutionConfig *AdminWorkflowExecutionConfig

+ type AdminWorkflowExecutionConfig struct

+ MaxParallelism int32

May 26, 2021

Changes in this version

+ type CoreK8sObjectMetadata struct

+ Annotations map[string]string

+ Labels map[string]string

+ type CoreK8sPod struct

+ Metadata *CoreK8sObjectMetadata

+ PodSpec *ProtobufStruct

type CoreTaskTemplate

+ K8sPod *CoreK8sPod

Apr 22, 2021

Changes in this version

type CoreNodeExecutionPhase

+ const CoreNodeExecutionPhaseDYNAMIC_RUNNING

Apr 21, 2021

Changes in this version

type AdminNodeExecutionGetDataResponse

+ DynamicWorkflow *FlyteidladminDynamicWorkflowNodeMetadata

Apr 13, 2021

Changes in this version

+ type FlyteidladminDynamicWorkflowNodeMetadata struct

+ CompiledWorkflow *CoreCompiledWorkflowClosure

+ Id *CoreIdentifier

type FlyteidladminTaskNodeMetadata

+ DynamicWorkflow *FlyteidladminDynamicWorkflowNodeMetadata

+ type FlyteidleventDynamicWorkflowNodeMetadata struct

+ CompiledWorkflow *CoreCompiledWorkflowClosure

+ Id *CoreIdentifier

type FlyteidleventTaskNodeMetadata

+ DynamicWorkflow *FlyteidleventDynamicWorkflowNodeMetadata

Mar 19, 2021

Changes in this version

type EventExternalResourceInfo

+ ExternalId string

Mar 19, 2021

Changes in this version

type CoreSecret

+ GroupVersion string

Mar 18, 2021

Changes in this version

type AdminTaskExecutionClosure

+ Metadata *EventTaskExecutionMetadata

+ Reason string

+ TaskType string

+ type EventExternalResourceInfo struct

+ ExternalIds string

+ type EventResourcePoolInfo struct

+ AllocationToken string

+ Namespace string

type EventTaskExecutionEvent

+ Reason string

+ TaskType string

type EventTaskExecutionMetadata

+ ExternalResources []EventExternalResourceInfo

+ GeneratedName string

+ PluginIdentifier string

+ ResourcePoolInfo []EventResourcePoolInfo

Mar 13, 2021

Changes in this version

type CoreSecret

+ Group string

+ Key string

type SecretMountType

+ const SecretMountTypeANY

Mar 11, 2021

Changes in this version

+ type AdminGetVersionRequest struct

+ type AdminGetVersionResponse struct

+ ControlPlaneVersion *AdminVersion

type AdminServiceApiService

+ func (a *AdminServiceApiService) GetVersion(ctx context.Context, body AdminGetVersionRequest) (AdminGetVersionResponse, *http.Response, error)

+ type AdminVersion struct

+ Build string

+ BuildTime string

+ Version string

type CoreTaskTemplate

+ Config map[string]string

Mar 5, 2021

Changes in this version

+ type CoreIdentity struct

+ IamRole string

+ K8sServiceAccount string

+ Oauth2Client *CoreOAuth2Client

+ type CoreOAuth2Client struct

+ ClientId string

+ ClientSecret *CoreSecret

+ type CoreOAuth2TokenRequest struct

+ Client *CoreOAuth2Client

+ IdpDiscoveryEndpoint string

+ Name string

+ TokenEndpoint string

+ Type_ *CoreOAuth2TokenRequestType

+ type CoreOAuth2TokenRequestType string

+ const CoreOAuth2TokenRequestTypeCLIENT_CREDENTIALS

+ type CoreSecret struct

+ MountRequirement *SecretMountType

+ Name string

+ type CoreSecurityContext struct

+ RunAs *CoreIdentity

+ Secrets []CoreSecret

+ Tokens []CoreOAuth2TokenRequest

type CoreTaskTemplate

+ SecurityContext *CoreSecurityContext

+ type SecretMountType string

+ const SecretMountTypeENV_VAR

+ const SecretMountTypeFILE

Mar 5, 2021

Changes in this version

+ type AdminAuthRole struct

+ AssumableIamRole string

+ KubernetesServiceAccount string

+ type AdminCronSchedule struct

+ Offset string

+ Schedule string

+ type AdminExecutionClusterLabel struct

+ Value string

type AdminExecutionMetadata

+ SystemMetadata *AdminSystemMetadata

type AdminExecutionSpec

+ AuthRole *AdminAuthRole

+ QualityOfService *CoreQualityOfService

+ SecurityContext *AdminSecurityContext

type AdminLaunchPlanSpec

+ AuthRole *AdminAuthRole

+ QualityOfService *CoreQualityOfService

+ RawOutputDataConfig *AdminRawOutputDataConfig

+ SecurityContext *AdminSecurityContext

+ type AdminListMatchableAttributesResponse struct

+ Configurations []AdminMatchableAttributesConfiguration

+ type AdminMatchableAttributesConfiguration struct

+ Attributes *AdminMatchingAttributes

+ Domain string

+ LaunchPlan string

+ Project string

+ Workflow string

type AdminMatchableResource

+ const AdminMatchableResourceEXECUTION_CLUSTER_LABEL

+ const AdminMatchableResourcePLUGIN_OVERRIDE

+ const AdminMatchableResourceQUALITY_OF_SERVICE_SPECIFICATION

type AdminMatchingAttributes

+ ExecutionClusterLabel *AdminExecutionClusterLabel

+ PluginOverrides *AdminPluginOverrides

+ QualityOfService *CoreQualityOfService

type AdminNamedEntityMetadata

+ State *AdminNamedEntityState

+ type AdminNamedEntityState string

+ const AdminNamedEntityStateNAMED_ENTITY_ACTIVE

+ const AdminNamedEntityStateNAMED_ENTITY_ARCHIVED

+ const AdminNamedEntityStateSYSTEM_GENERATED

type AdminNodeExecutionClosure

+ TaskNodeMetadata *FlyteidladminTaskNodeMetadata

type AdminNodeExecutionGetDataResponse

+ FullInputs *CoreLiteralMap

+ FullOutputs *CoreLiteralMap

+ type AdminNodeExecutionMetaData struct

+ IsParentNode bool

+ RetryGroup string

+ SpecNodeId string

+ type AdminPluginOverride struct

+ MissingPluginBehavior *PluginOverrideMissingPluginBehavior

+ PluginId []string

+ TaskType string

+ type AdminPluginOverrides struct

+ Overrides []AdminPluginOverride

type AdminProject

+ Labels *AdminLabels

+ State *ProjectProjectState

+ type AdminProjectUpdateResponse struct

type AdminProjects

+ Token string

+ type AdminRawOutputDataConfig struct

+ OutputLocationPrefix string

type AdminSchedule

+ CronSchedule *AdminCronSchedule

+ type AdminSecurityContext struct

+ Values map[string]string

type AdminServiceApiService

+ func (a *AdminServiceApiService) ListMatchableAttributes(ctx context.Context, localVarOptionals *ListMatchableAttributesOpts) (AdminListMatchableAttributesResponse, *http.Response, error)

+ func (a *AdminServiceApiService) UpdateProject(ctx context.Context, id string, body AdminProject) (AdminProjectUpdateResponse, *http.Response, error)

+ type AdminSystemMetadata struct

+ ExecutionCluster string

type AdminTaskExecutionGetDataResponse

+ FullInputs *CoreLiteralMap

+ FullOutputs *CoreLiteralMap

type AdminWorkflowExecutionGetDataResponse

+ FullInputs *CoreLiteralMap

+ FullOutputs *CoreLiteralMap

type AdminWorkflowSpec

+ SubWorkflows []CoreWorkflowTemplate

+ type CoreCatalogArtifactTag struct

+ ArtifactId string

+ Name string

+ type CoreCatalogCacheStatus string

+ const CoreCatalogCacheStatusDISABLED

+ const CoreCatalogCacheStatusHIT

+ const CoreCatalogCacheStatusLOOKUP_FAILURE

+ const CoreCatalogCacheStatusMISS

+ const CoreCatalogCacheStatusPOPULATED

+ const CoreCatalogCacheStatusPUT_FAILURE

+ type CoreCatalogMetadata struct

+ ArtifactTag *CoreCatalogArtifactTag

+ DatasetId *CoreIdentifier

+ SourceTaskExecution *CoreTaskExecutionIdentifier

type CoreContainer

+ DataConfig *CoreDataLoadingConfig

+ type CoreDataLoadingConfig struct

+ Enabled bool

+ Format *DataLoadingConfigLiteralMapFormat

+ InputPath string

+ IoStrategy *CoreIoStrategy

+ OutputPath string

type CoreExecutionError

+ Kind *ExecutionErrorErrorKind

+ type CoreIoStrategy struct

+ DownloadMode *IoStrategyDownloadMode

+ UploadMode *IoStrategyUploadMode

type CoreNodeMetadata

+ Interruptible bool

+ type CoreQualityOfService struct

+ Spec *CoreQualityOfServiceSpec

+ Tier *QualityOfServiceTier

+ type CoreQualityOfServiceSpec struct

+ QueueingBudget string

type CoreResourceType

+ const CoreResourceTypeDATASET

type CoreTaskExecutionPhase

+ const CoreTaskExecutionPhaseINITIALIZING

+ const CoreTaskExecutionPhaseWAITING_FOR_RESOURCES

type CoreTaskMetadata

+ Interruptible bool

type CoreTaskTemplate

+ TaskTypeVersion int32

type CoreWorkflowMetadata

+ OnFailure *WorkflowMetadataOnFailurePolicy

+ QualityOfService *CoreQualityOfService

+ type CoreWorkflowMetadataDefaults struct

+ Interruptible bool

type CoreWorkflowTemplate

+ MetadataDefaults *CoreWorkflowMetadataDefaults

+ type DataLoadingConfigLiteralMapFormat string

+ const DataLoadingConfigLiteralMapFormatJSON

+ const DataLoadingConfigLiteralMapFormatPROTO

+ const DataLoadingConfigLiteralMapFormatYAML

type EventNodeExecutionEvent

+ NodeName string

+ ParentNodeMetadata *EventParentNodeExecutionMetadata

+ RetryGroup string

+ SpecNodeId string

+ TaskNodeMetadata *FlyteidleventTaskNodeMetadata

+ type EventParentNodeExecutionMetadata struct

+ NodeId string

type EventTaskExecutionEvent

+ Metadata *EventTaskExecutionMetadata

+ type EventTaskExecutionMetadata struct

+ InstanceClass *TaskExecutionMetadataInstanceClass

+ type ExecutionErrorErrorKind string

+ const ExecutionErrorErrorKindSYSTEM

+ const ExecutionErrorErrorKindUNKNOWN

+ const ExecutionErrorErrorKindUSER

type FlyteidladminNodeExecution

+ Metadata *AdminNodeExecutionMetaData

+ type FlyteidladminTaskNodeMetadata struct

+ CacheStatus *CoreCatalogCacheStatus

+ CatalogKey *CoreCatalogMetadata

+ type FlyteidleventTaskNodeMetadata struct

+ CacheStatus *CoreCatalogCacheStatus

+ CatalogKey *CoreCatalogMetadata

+ type IoStrategyDownloadMode string

+ const IoStrategyDownloadModeDOWNLOAD_EAGER

+ const IoStrategyDownloadModeDOWNLOAD_STREAM

+ const IoStrategyDownloadModeDO_NOT_DOWNLOAD

+ type IoStrategyUploadMode string

+ const IoStrategyUploadModeDO_NOT_UPLOAD

+ const IoStrategyUploadModeUPLOAD_EAGER

+ const IoStrategyUploadModeUPLOAD_ON_EXIT

type ListLaunchPlanIdsOpts

+ Filters optional.String

+ type ListMatchableAttributesOpts struct

+ ResourceType optional.String

type ListNamedEntitiesOpts

+ Filters optional.String

type ListNodeExecutionsOpts

+ UniqueParentId optional.String

+ type ListProjectsOpts struct

+ Filters optional.String

+ Limit optional.Int64

+ SortByDirection optional.String

+ SortByKey optional.String

+ Token optional.String

type ListTaskIdsOpts

+ Filters optional.String

type ListWorkflowIdsOpts

+ Filters optional.String

+ type PluginOverrideMissingPluginBehavior string

+ const PluginOverrideMissingPluginBehaviorFAIL

+ const PluginOverrideMissingPluginBehaviorUSE_DEFAULT

+ type ProjectProjectState string

+ const ProjectProjectStateACTIVE

+ const ProjectProjectStateARCHIVED

+ const ProjectProjectStateSYSTEM_GENERATED

+ type QualityOfServiceTier string

+ const QualityOfServiceTierHIGH

+ const QualityOfServiceTierLOW

+ const QualityOfServiceTierMEDIUM

+ const QualityOfServiceTierUNDEFINED

+ type TaskExecutionMetadataInstanceClass string

+ const TaskExecutionMetadataInstanceClassDEFAULT_

+ const TaskExecutionMetadataInstanceClassINTERRUPTIBLE

+ type WorkflowMetadataOnFailurePolicy string

+ const WorkflowMetadataOnFailurePolicyAFTER_EXECUTABLE_NODES_COMPLETE

+ const WorkflowMetadataOnFailurePolicyIMMEDIATELY

Jan 2, 2020

Changes in this version

+ type AdminMatchableResource string

+ const AdminMatchableResourceCLUSTER_RESOURCE

+ const AdminMatchableResourceEXECUTION_QUEUE

+ const AdminMatchableResourceTASK_RESOURCE

+ type AdminProjectAttributesDeleteRequest struct

+ Project string

+ ResourceType *AdminMatchableResource

+ type AdminProjectAttributesDeleteResponse struct

+ type AdminProjectAttributesGetResponse struct

+ Attributes *AdminProjectAttributes

+ type AdminProjectDomainAttributesDeleteRequest struct

+ Domain string

+ Project string

+ ResourceType *AdminMatchableResource

+ type AdminProjectDomainAttributesDeleteResponse struct

+ type AdminProjectDomainAttributesGetResponse struct

+ Attributes *AdminProjectDomainAttributes

type AdminServiceApiService

+ func (a *AdminServiceApiService) DeleteProjectAttributes(ctx context.Context, project string, body AdminProjectAttributesDeleteRequest) (AdminProjectAttributesDeleteResponse, *http.Response, error)

+ func (a *AdminServiceApiService) DeleteProjectDomainAttributes(ctx context.Context, project string, domain string, ...) (AdminProjectDomainAttributesDeleteResponse, *http.Response, error)

+ func (a *AdminServiceApiService) DeleteWorkflowAttributes(ctx context.Context, project string, domain string, workflow string, ...) (AdminWorkflowAttributesDeleteResponse, *http.Response, error)

+ func (a *AdminServiceApiService) GetProjectAttributes(ctx context.Context, project string, ...) (AdminProjectAttributesGetResponse, *http.Response, error)

+ func (a *AdminServiceApiService) GetProjectDomainAttributes(ctx context.Context, project string, domain string, ...) (AdminProjectDomainAttributesGetResponse, *http.Response, error)

+ func (a *AdminServiceApiService) GetWorkflowAttributes(ctx context.Context, project string, domain string, workflow string, ...) (AdminWorkflowAttributesGetResponse, *http.Response, error)

+ type AdminWorkflowAttributesDeleteRequest struct

+ Domain string

+ Project string

+ ResourceType *AdminMatchableResource

+ Workflow string

+ type AdminWorkflowAttributesDeleteResponse struct

+ type AdminWorkflowAttributesGetResponse struct

+ Attributes *AdminWorkflowAttributes

+ type GetProjectAttributesOpts struct

+ ResourceType optional.String

+ type GetProjectDomainAttributesOpts struct

+ ResourceType optional.String

+ type GetWorkflowAttributesOpts struct

+ ResourceType optional.String

Dec 30, 2019

Changes in this version

+ type AdminClusterResourceAttributes struct

+ Attributes map[string]string

+ type AdminExecutionQueueAttributes struct

+ Tags []string

+ type AdminMatchingAttributes struct

+ ClusterResourceAttributes *AdminClusterResourceAttributes

+ ExecutionQueueAttributes *AdminExecutionQueueAttributes

+ TaskResourceAttributes *AdminTaskResourceAttributes

+ type AdminProjectAttributes struct

+ MatchingAttributes *AdminMatchingAttributes

+ Project string

+ type AdminProjectAttributesUpdateRequest struct

+ Attributes *AdminProjectAttributes

+ type AdminProjectAttributesUpdateResponse struct

type AdminProjectDomainAttributes

+ MatchingAttributes *AdminMatchingAttributes

type AdminServiceApiService

+ func (a *AdminServiceApiService) UpdateProjectAttributes(ctx context.Context, attributesProject string, ...) (AdminProjectAttributesUpdateResponse, *http.Response, error)

+ func (a *AdminServiceApiService) UpdateWorkflowAttributes(ctx context.Context, attributesProject string, attributesDomain string, ...) (AdminWorkflowAttributesUpdateResponse, *http.Response, error)

+ type AdminTaskResourceAttributes struct

+ Defaults *AdminTaskResourceSpec

+ Limits *AdminTaskResourceSpec

+ type AdminTaskResourceSpec struct

+ Cpu string

+ Gpu string

+ Memory string

+ Storage string

+ type AdminWorkflowAttributes struct

+ Domain string

+ MatchingAttributes *AdminMatchingAttributes

+ Project string

+ Workflow string

+ type AdminWorkflowAttributesUpdateRequest struct

+ Attributes *AdminWorkflowAttributes

+ type AdminWorkflowAttributesUpdateResponse struct

Dec 11, 2019

Changes in this version

+ type AdminAbortMetadata struct

+ Cause string

+ Principal string

type AdminExecutionClosure

+ AbortMetadata *AdminAbortMetadata

Oct 30, 2019

Changes in this version

+ type AdminNamedEntity struct

+ Id *AdminNamedEntityIdentifier

+ Metadata *AdminNamedEntityMetadata

+ ResourceType *CoreResourceType

+ type AdminNamedEntityList struct

+ Entities []AdminNamedEntity

+ Token string

+ type AdminNamedEntityMetadata struct

+ Description string

+ type AdminNamedEntityUpdateRequest struct

+ Id *AdminNamedEntityIdentifier

+ Metadata *AdminNamedEntityMetadata

+ ResourceType *CoreResourceType

+ type AdminNamedEntityUpdateResponse struct

+ type AdminProjectDomainAttributes struct

+ Attributes map[string]string

+ Domain string

+ Project string

+ type AdminProjectDomainAttributesUpdateRequest struct

+ Attributes *AdminProjectDomainAttributes

+ type AdminProjectDomainAttributesUpdateResponse struct

type AdminServiceApiService

+ func (a *AdminServiceApiService) GetNamedEntity(ctx context.Context, resourceType string, idProject string, idDomain string, ...) (AdminNamedEntity, *http.Response, error)

+ func (a *AdminServiceApiService) ListNamedEntities(ctx context.Context, resourceType string, project string, domain string, ...) (AdminNamedEntityList, *http.Response, error)

+ func (a *AdminServiceApiService) UpdateNamedEntity(ctx context.Context, resourceType string, idProject string, idDomain string, ...) (AdminNamedEntityUpdateResponse, *http.Response, error)

+ func (a *AdminServiceApiService) UpdateProjectDomainAttributes(ctx context.Context, attributesProject string, attributesDomain string, ...) (AdminProjectDomainAttributesUpdateResponse, *http.Response, error)

+ type ListNamedEntitiesOpts struct

+ Limit optional.Int64

+ SortByDirection optional.String

+ SortByKey optional.String

+ Token optional.String

Oct 9, 2019

Changes in this version

type AdminProject

+ Description string

Oct 9, 2019

Changes in this version

type AdminExecutionCreateRequest

+ Inputs *CoreLiteralMap

type AdminWorkflowExecutionGetDataResponse

+ Inputs *AdminUrlBlob

Aug 30, 2019

Changes in this version

type AdminServiceApiService

+ func (a *AdminServiceApiService) GetActiveLaunchPlan(ctx context.Context, idProject string, idDomain string, idName string) (AdminLaunchPlan, *http.Response, error)

+ func (a *AdminServiceApiService) ListActiveLaunchPlans(ctx context.Context, project string, domain string, ...) (AdminLaunchPlanList, *http.Response, error)

+ type ListActiveLaunchPlansOpts struct

+ Limit optional.Int64

+ SortByDirection optional.String

+ SortByKey optional.String

+ Token optional.String

Aug 5, 2019

Changes in this version

+ var ContextAPIKey = contextKey("apikey")

+ var ContextAccessToken = contextKey("accesstoken")

+ var ContextBasicAuth = contextKey("basic")

+ var ContextOAuth2 = contextKey("token")

+ func CacheExpires(r *http.Response) time.Time

+ type APIClient struct

+ AdminServiceApi *AdminServiceApiService

+ func NewAPIClient(cfg *Configuration) *APIClient

+ func (c *APIClient) ChangeBasePath(path string)

+ type APIKey struct

+ Key string

+ Prefix string

+ type APIResponse struct

+ Message string

+ Method string

+ Operation string

+ Payload []byte

+ RequestURL string

+ func NewAPIResponse(r *http.Response) *APIResponse

+ func NewAPIResponseWithError(errorMessage string) *APIResponse

+ type AdminAnnotations struct

+ Values map[string]string

+ type AdminAuth struct

+ AssumableIamRole string

+ KubernetesServiceAccount string

+ type AdminDomain struct

+ Id string

+ Name string

+ type AdminEmailNotification struct

+ RecipientsEmail []string

+ type AdminExecution struct

+ Closure *AdminExecutionClosure

+ Id *CoreWorkflowExecutionIdentifier

+ Spec *AdminExecutionSpec

+ type AdminExecutionClosure struct

+ AbortCause string

+ ComputedInputs *CoreLiteralMap

+ CreatedAt time.Time

+ Duration string

+ Error_ *CoreExecutionError

+ Notifications []AdminNotification

+ Outputs *AdminLiteralMapBlob

+ Phase *CoreWorkflowExecutionPhase

+ StartedAt time.Time

+ UpdatedAt time.Time

+ WorkflowId *CoreIdentifier

+ type AdminExecutionCreateRequest struct

+ Domain string

+ Name string

+ Project string

+ Spec *AdminExecutionSpec

+ type AdminExecutionCreateResponse struct

+ Id *CoreWorkflowExecutionIdentifier

+ type AdminExecutionList struct

+ Executions []AdminExecution

+ Token string

+ type AdminExecutionMetadata struct

+ Mode *ExecutionMetadataExecutionMode

+ Nesting int64

+ ParentNodeExecution *CoreNodeExecutionIdentifier

+ Principal string

+ ReferenceExecution *CoreWorkflowExecutionIdentifier

+ ScheduledAt time.Time

+ type AdminExecutionRelaunchRequest struct

+ Id *CoreWorkflowExecutionIdentifier

+ Name string

+ type AdminExecutionSpec struct

+ Annotations *AdminAnnotations

+ DisableAll bool

+ Inputs *CoreLiteralMap

+ Labels *AdminLabels

+ LaunchPlan *CoreIdentifier

+ Metadata *AdminExecutionMetadata

+ Notifications *AdminNotificationList

+ type AdminExecutionTerminateRequest struct

+ Cause string

+ Id *CoreWorkflowExecutionIdentifier

+ type AdminExecutionTerminateResponse struct

+ type AdminFixedRate struct

+ Unit *AdminFixedRateUnit

+ Value int64

+ type AdminFixedRateUnit string

+ const AdminFixedRateUnitDAY

+ const AdminFixedRateUnitHOUR

+ const AdminFixedRateUnitMINUTE

+ type AdminLabels struct

+ Values map[string]string

+ type AdminLaunchPlan struct

+ Closure *AdminLaunchPlanClosure

+ Id *CoreIdentifier

+ Spec *AdminLaunchPlanSpec

+ type AdminLaunchPlanClosure struct

+ CreatedAt time.Time

+ ExpectedInputs *CoreParameterMap

+ ExpectedOutputs *CoreVariableMap

+ State *AdminLaunchPlanState

+ UpdatedAt time.Time

+ type AdminLaunchPlanCreateRequest struct

+ Id *CoreIdentifier

+ Spec *AdminLaunchPlanSpec

+ type AdminLaunchPlanCreateResponse struct

+ type AdminLaunchPlanList struct

+ LaunchPlans []AdminLaunchPlan

+ Token string

+ type AdminLaunchPlanMetadata struct

+ Notifications []AdminNotification

+ Schedule *AdminSchedule

+ type AdminLaunchPlanSpec struct

+ Annotations *AdminAnnotations

+ Auth *AdminAuth

+ DefaultInputs *CoreParameterMap

+ EntityMetadata *AdminLaunchPlanMetadata

+ FixedInputs *CoreLiteralMap

+ Labels *AdminLabels

+ Role string

+ WorkflowId *CoreIdentifier

+ type AdminLaunchPlanState string

+ const AdminLaunchPlanStateACTIVE

+ const AdminLaunchPlanStateINACTIVE

+ type AdminLaunchPlanUpdateRequest struct

+ Id *CoreIdentifier

+ State *AdminLaunchPlanState

+ type AdminLaunchPlanUpdateResponse struct

+ type AdminLiteralMapBlob struct

+ Uri string

+ Values *CoreLiteralMap

+ type AdminNamedEntityIdentifier struct

+ Domain string

+ Name string

+ Project string

+ type AdminNamedEntityIdentifierList struct

+ Entities []AdminNamedEntityIdentifier

+ Token string

+ type AdminNodeExecutionClosure struct

+ CreatedAt time.Time

+ Duration string

+ Error_ *CoreExecutionError

+ OutputUri string

+ Phase *CoreNodeExecutionPhase

+ StartedAt time.Time

+ UpdatedAt time.Time

+ WorkflowNodeMetadata *FlyteidladminWorkflowNodeMetadata

+ type AdminNodeExecutionEventRequest struct

+ Event *EventNodeExecutionEvent

+ RequestId string

+ type AdminNodeExecutionEventResponse struct

+ type AdminNodeExecutionGetDataResponse struct

+ Inputs *AdminUrlBlob

+ Outputs *AdminUrlBlob

+ type AdminNodeExecutionList struct

+ NodeExecutions []FlyteidladminNodeExecution

+ Token string

+ type AdminNotification struct

+ Email *AdminEmailNotification

+ PagerDuty *AdminPagerDutyNotification

+ Phases []CoreWorkflowExecutionPhase

+ Slack *AdminSlackNotification

+ type AdminNotificationList struct

+ Notifications []AdminNotification

+ type AdminPagerDutyNotification struct

+ RecipientsEmail []string

+ type AdminProject struct

+ Domains []AdminDomain

+ Id string

+ Name string

+ type AdminProjectRegisterRequest struct

+ Project *AdminProject

+ type AdminProjectRegisterResponse struct

+ type AdminProjects struct

+ Projects []AdminProject

+ type AdminSchedule struct

+ CronExpression string

+ KickoffTimeInputArg string

+ Rate *AdminFixedRate

+ type AdminServiceApiService service

+ func (a *AdminServiceApiService) CreateExecution(ctx context.Context, body AdminExecutionCreateRequest) (AdminExecutionCreateResponse, *http.Response, error)

+ func (a *AdminServiceApiService) CreateLaunchPlan(ctx context.Context, body AdminLaunchPlanCreateRequest) (AdminLaunchPlanCreateResponse, *http.Response, error)

+ func (a *AdminServiceApiService) CreateNodeEvent(ctx context.Context, body AdminNodeExecutionEventRequest) (AdminNodeExecutionEventResponse, *http.Response, error)

+ func (a *AdminServiceApiService) CreateTask(ctx context.Context, body AdminTaskCreateRequest) (AdminTaskCreateResponse, *http.Response, error)

+ func (a *AdminServiceApiService) CreateTaskEvent(ctx context.Context, body AdminTaskExecutionEventRequest) (AdminTaskExecutionEventResponse, *http.Response, error)

+ func (a *AdminServiceApiService) CreateWorkflow(ctx context.Context, body AdminWorkflowCreateRequest) (AdminWorkflowCreateResponse, *http.Response, error)

+ func (a *AdminServiceApiService) CreateWorkflowEvent(ctx context.Context, body AdminWorkflowExecutionEventRequest) (AdminWorkflowExecutionEventResponse, *http.Response, error)

+ func (a *AdminServiceApiService) GetExecution(ctx context.Context, idProject string, idDomain string, idName string) (AdminExecution, *http.Response, error)

+ func (a *AdminServiceApiService) GetExecutionData(ctx context.Context, idProject string, idDomain string, idName string) (AdminWorkflowExecutionGetDataResponse, *http.Response, error)

+ func (a *AdminServiceApiService) GetLaunchPlan(ctx context.Context, idProject string, idDomain string, idName string, ...) (AdminLaunchPlan, *http.Response, error)

+ func (a *AdminServiceApiService) GetNodeExecution(ctx context.Context, idExecutionIdProject string, idExecutionIdDomain string, ...) (FlyteidladminNodeExecution, *http.Response, error)

+ func (a *AdminServiceApiService) GetNodeExecutionData(ctx context.Context, idExecutionIdProject string, idExecutionIdDomain string, ...) (AdminNodeExecutionGetDataResponse, *http.Response, error)

+ func (a *AdminServiceApiService) GetTask(ctx context.Context, idProject string, idDomain string, idName string, ...) (AdminTask, *http.Response, error)

+ func (a *AdminServiceApiService) GetTaskExecution(ctx context.Context, idNodeExecutionIdExecutionIdProject string, ...) (FlyteidladminTaskExecution, *http.Response, error)

+ func (a *AdminServiceApiService) GetTaskExecutionData(ctx context.Context, idNodeExecutionIdExecutionIdProject string, ...) (AdminTaskExecutionGetDataResponse, *http.Response, error)

+ func (a *AdminServiceApiService) GetWorkflow(ctx context.Context, idProject string, idDomain string, idName string, ...) (AdminWorkflow, *http.Response, error)

+ func (a *AdminServiceApiService) ListExecutions(ctx context.Context, idProject string, idDomain string, ...) (AdminExecutionList, *http.Response, error)

+ func (a *AdminServiceApiService) ListLaunchPlanIds(ctx context.Context, project string, domain string, ...) (AdminNamedEntityIdentifierList, *http.Response, error)

+ func (a *AdminServiceApiService) ListLaunchPlans(ctx context.Context, idProject string, idDomain string, idName string, ...) (AdminLaunchPlanList, *http.Response, error)

+ func (a *AdminServiceApiService) ListLaunchPlans2(ctx context.Context, idProject string, idDomain string, ...) (AdminLaunchPlanList, *http.Response, error)

+ func (a *AdminServiceApiService) ListNodeExecutions(ctx context.Context, workflowExecutionIdProject string, ...) (AdminNodeExecutionList, *http.Response, error)

+ func (a *AdminServiceApiService) ListNodeExecutionsForTask(ctx context.Context, taskExecutionIdNodeExecutionIdExecutionIdProject string, ...) (AdminNodeExecutionList, *http.Response, error)

+ func (a *AdminServiceApiService) ListProjects(ctx context.Context) (AdminProjects, *http.Response, error)

+ func (a *AdminServiceApiService) ListTaskExecutions(ctx context.Context, nodeExecutionIdExecutionIdProject string, ...) (AdminTaskExecutionList, *http.Response, error)

+ func (a *AdminServiceApiService) ListTaskIds(ctx context.Context, project string, domain string, ...) (AdminNamedEntityIdentifierList, *http.Response, error)

+ func (a *AdminServiceApiService) ListTasks(ctx context.Context, idProject string, idDomain string, idName string, ...) (AdminTaskList, *http.Response, error)

+ func (a *AdminServiceApiService) ListTasks2(ctx context.Context, idProject string, idDomain string, ...) (AdminTaskList, *http.Response, error)

+ func (a *AdminServiceApiService) ListWorkflowIds(ctx context.Context, project string, domain string, ...) (AdminNamedEntityIdentifierList, *http.Response, error)

+ func (a *AdminServiceApiService) ListWorkflows(ctx context.Context, idProject string, idDomain string, idName string, ...) (AdminWorkflowList, *http.Response, error)

+ func (a *AdminServiceApiService) ListWorkflows2(ctx context.Context, idProject string, idDomain string, ...) (AdminWorkflowList, *http.Response, error)

+ func (a *AdminServiceApiService) RegisterProject(ctx context.Context, body AdminProjectRegisterRequest) (AdminProjectRegisterResponse, *http.Response, error)

+ func (a *AdminServiceApiService) RelaunchExecution(ctx context.Context, body AdminExecutionRelaunchRequest) (AdminExecutionCreateResponse, *http.Response, error)

+ func (a *AdminServiceApiService) TerminateExecution(ctx context.Context, idProject string, idDomain string, idName string, ...) (AdminExecutionTerminateResponse, *http.Response, error)

+ func (a *AdminServiceApiService) UpdateLaunchPlan(ctx context.Context, idProject string, idDomain string, idName string, ...) (AdminLaunchPlanUpdateResponse, *http.Response, error)

+ type AdminSlackNotification struct

+ RecipientsEmail []string

+ type AdminSort struct

+ Direction *SortDirection

+ Key string

+ type AdminTask struct

+ Closure *AdminTaskClosure

+ Id *CoreIdentifier

+ type AdminTaskClosure struct

+ CompiledTask *CoreCompiledTask

+ CreatedAt time.Time

+ type AdminTaskCreateRequest struct

+ Id *CoreIdentifier

+ Spec *AdminTaskSpec

+ type AdminTaskCreateResponse struct

+ type AdminTaskExecutionClosure struct

+ CreatedAt time.Time

+ CustomInfo *ProtobufStruct

+ Duration string

+ Error_ *CoreExecutionError

+ Logs []CoreTaskLog

+ OutputUri string

+ Phase *CoreTaskExecutionPhase

+ StartedAt time.Time

+ UpdatedAt time.Time

+ type AdminTaskExecutionEventRequest struct

+ Event *EventTaskExecutionEvent

+ RequestId string

+ type AdminTaskExecutionEventResponse struct

+ type AdminTaskExecutionGetDataResponse struct

+ Inputs *AdminUrlBlob

+ Outputs *AdminUrlBlob

+ type AdminTaskExecutionList struct

+ TaskExecutions []FlyteidladminTaskExecution

+ Token string

+ type AdminTaskList struct

+ Tasks []AdminTask

+ Token string

+ type AdminTaskSpec struct

+ Template *CoreTaskTemplate

+ type AdminUrlBlob struct

+ Bytes string

+ Url string

+ type AdminWorkflow struct

+ Closure *AdminWorkflowClosure

+ Id *CoreIdentifier

+ type AdminWorkflowClosure struct

+ CompiledWorkflow *CoreCompiledWorkflowClosure

+ CreatedAt time.Time

+ type AdminWorkflowCreateRequest struct

+ Id *CoreIdentifier

+ Spec *AdminWorkflowSpec

+ type AdminWorkflowCreateResponse struct

+ type AdminWorkflowExecutionEventRequest struct

+ Event *EventWorkflowExecutionEvent

+ RequestId string

+ type AdminWorkflowExecutionEventResponse struct

+ type AdminWorkflowExecutionGetDataResponse struct

+ Outputs *AdminUrlBlob

+ type AdminWorkflowList struct

+ Token string

+ Workflows []AdminWorkflow

+ type AdminWorkflowSpec struct

+ Template *CoreWorkflowTemplate

+ type BasicAuth struct

+ Password string

+ UserName string

+ type BlobTypeBlobDimensionality string

+ const BlobTypeBlobDimensionalityMULTIPART

+ const BlobTypeBlobDimensionalitySINGLE

+ type ComparisonExpressionOperator string

+ const ComparisonExpressionOperatorEQ

+ const ComparisonExpressionOperatorGT

+ const ComparisonExpressionOperatorGTE

+ const ComparisonExpressionOperatorLT

+ const ComparisonExpressionOperatorLTE

+ const ComparisonExpressionOperatorNEQ

+ type Configuration struct

+ BasePath string

+ DefaultHeader map[string]string

+ HTTPClient *http.Client

+ Host string

+ Scheme string

+ UserAgent string

+ func NewConfiguration() *Configuration

+ func (c *Configuration) AddDefaultHeader(key string, value string)

+ type ConjunctionExpressionLogicalOperator string

+ const ConjunctionExpressionLogicalOperatorAND

+ const ConjunctionExpressionLogicalOperatorOR

+ type ConnectionSetIdList struct

+ Ids []string

+ type CoreAlias struct

+ Alias string

+ Var_ string

+ type CoreBinary struct

+ Tag string

+ Value string

+ type CoreBinding struct

+ Binding *CoreBindingData

+ Var_ string

+ type CoreBindingData struct

+ Collection *CoreBindingDataCollection

+ Map_ *CoreBindingDataMap

+ Promise *CoreOutputReference

+ Scalar *CoreScalar

+ type CoreBindingDataCollection struct

+ Bindings []CoreBindingData

+ type CoreBindingDataMap struct

+ Bindings map[string]CoreBindingData

+ type CoreBlob struct

+ Metadata *CoreBlobMetadata

+ Uri string

+ type CoreBlobMetadata struct

+ Type_ *CoreBlobType

+ type CoreBlobType struct

+ Dimensionality *BlobTypeBlobDimensionality

+ Format string

+ type CoreBooleanExpression struct

+ Comparison *CoreComparisonExpression

+ Conjunction *CoreConjunctionExpression

+ type CoreBranchNode struct

+ IfElse *CoreIfElseBlock

+ type CoreComparisonExpression struct

+ LeftValue *CoreOperand

+ Operator *ComparisonExpressionOperator

+ RightValue *CoreOperand

+ type CoreCompiledTask struct

+ Template *CoreTaskTemplate

+ type CoreCompiledWorkflow struct

+ Connections *CoreConnectionSet

+ Template *CoreWorkflowTemplate

+ type CoreCompiledWorkflowClosure struct

+ Primary *CoreCompiledWorkflow

+ SubWorkflows []CoreCompiledWorkflow

+ Tasks []CoreCompiledTask

+ type CoreConjunctionExpression struct

+ LeftExpression *CoreBooleanExpression

+ Operator *ConjunctionExpressionLogicalOperator

+ RightExpression *CoreBooleanExpression

+ type CoreConnectionSet struct

+ Downstream map[string]ConnectionSetIdList

+ Upstream map[string]ConnectionSetIdList

+ type CoreContainer struct

+ Args []string

+ Command []string

+ Config []CoreKeyValuePair

+ Env []CoreKeyValuePair

+ Image string

+ Ports []CoreContainerPort

+ Resources *CoreResources

+ type CoreContainerPort struct

+ ContainerPort int64

+ type CoreError struct

+ FailedNodeId string

+ Message string

+ type CoreExecutionError struct

+ Code string

+ ErrorUri string

+ Message string

+ type CoreIdentifier struct

+ Domain string

+ Name string

+ Project string

+ ResourceType *CoreResourceType

+ Version string

+ type CoreIfBlock struct

+ Condition *CoreBooleanExpression

+ ThenNode *CoreNode

+ type CoreIfElseBlock struct

+ Case_ *CoreIfBlock

+ ElseNode *CoreNode

+ Error_ *CoreError

+ Other []CoreIfBlock

+ type CoreKeyValuePair struct

+ Key string

+ Value string

+ type CoreLiteral struct

+ Collection *CoreLiteralCollection

+ Map_ *CoreLiteralMap

+ Scalar *CoreScalar

+ type CoreLiteralCollection struct

+ Literals []CoreLiteral

+ type CoreLiteralMap struct

+ Literals map[string]CoreLiteral

+ type CoreLiteralType struct

+ Blob *CoreBlobType

+ CollectionType *CoreLiteralType

+ MapValueType *CoreLiteralType

+ Metadata *ProtobufStruct

+ Schema *CoreSchemaType

+ Simple *CoreSimpleType

+ type CoreNode struct

+ BranchNode *CoreBranchNode

+ Id string

+ Inputs []CoreBinding

+ Metadata *CoreNodeMetadata

+ OutputAliases []CoreAlias

+ TaskNode *CoreTaskNode

+ UpstreamNodeIds []string

+ WorkflowNode *CoreWorkflowNode

+ type CoreNodeExecutionIdentifier struct

+ ExecutionId *CoreWorkflowExecutionIdentifier

+ NodeId string

+ type CoreNodeExecutionPhase string

+ const CoreNodeExecutionPhaseABORTED

+ const CoreNodeExecutionPhaseFAILED

+ const CoreNodeExecutionPhaseFAILING

+ const CoreNodeExecutionPhaseQUEUED

+ const CoreNodeExecutionPhaseRUNNING

+ const CoreNodeExecutionPhaseSKIPPED

+ const CoreNodeExecutionPhaseSUCCEEDED

+ const CoreNodeExecutionPhaseTIMED_OUT

+ const CoreNodeExecutionPhaseUNDEFINED

+ type CoreNodeMetadata struct

+ Name string

+ Retries *CoreRetryStrategy

+ Timeout string

+ type CoreOperand struct

+ Primitive *CorePrimitive

+ Var_ string

+ type CoreOutputReference struct

+ NodeId string

+ Var_ string

+ type CoreParameter struct

+ Default_ *CoreLiteral

+ Required bool

+ Var_ *CoreVariable

+ type CoreParameterMap struct

+ Parameters map[string]CoreParameter

+ type CorePrimitive struct

+ Boolean bool

+ Datetime time.Time

+ Duration string

+ FloatValue float64

+ Integer string

+ StringValue string

+ type CoreResourceType string

+ const CoreResourceTypeLAUNCH_PLAN

+ const CoreResourceTypeTASK

+ const CoreResourceTypeUNSPECIFIED

+ const CoreResourceTypeWORKFLOW

+ type CoreResources struct

+ Limits []ResourcesResourceEntry

+ Requests []ResourcesResourceEntry

+ type CoreRetryStrategy struct

+ Retries int64

+ type CoreRuntimeMetadata struct

+ Flavor string

+ Type_ *RuntimeMetadataRuntimeType

+ Version string

+ type CoreScalar struct

+ Binary *CoreBinary

+ Blob *CoreBlob

+ Error_ *CoreError

+ Generic *ProtobufStruct

+ NoneType *CoreVoid

+ Primitive *CorePrimitive

+ Schema *FlyteidlcoreSchema

+ type CoreSchemaType struct

+ Columns []SchemaTypeSchemaColumn

+ type CoreSimpleType string

+ const CoreSimpleTypeBINARY

+ const CoreSimpleTypeBOOLEAN

+ const CoreSimpleTypeDATETIME

+ const CoreSimpleTypeDURATION

+ const CoreSimpleTypeERROR_

+ const CoreSimpleTypeFLOAT

+ const CoreSimpleTypeINTEGER

+ const CoreSimpleTypeNONE

+ const CoreSimpleTypeSTRING_

+ const CoreSimpleTypeSTRUCT_

+ type CoreTaskExecutionIdentifier struct

+ NodeExecutionId *CoreNodeExecutionIdentifier

+ RetryAttempt int64

+ TaskId *CoreIdentifier

+ type CoreTaskExecutionPhase string

+ const CoreTaskExecutionPhaseABORTED

+ const CoreTaskExecutionPhaseFAILED

+ const CoreTaskExecutionPhaseQUEUED

+ const CoreTaskExecutionPhaseRUNNING

+ const CoreTaskExecutionPhaseSUCCEEDED

+ const CoreTaskExecutionPhaseUNDEFINED

+ type CoreTaskLog struct

+ MessageFormat *TaskLogMessageFormat

+ Name string

+ Ttl string

+ Uri string

+ type CoreTaskMetadata struct

+ DeprecatedErrorMessage string

+ Discoverable bool

+ DiscoveryVersion string

+ Retries *CoreRetryStrategy

+ Runtime *CoreRuntimeMetadata

+ Timeout string

+ type CoreTaskNode struct

+ ReferenceId *CoreIdentifier

+ type CoreTaskTemplate struct

+ Container *CoreContainer

+ Custom *ProtobufStruct

+ Id *CoreIdentifier

+ Interface_ *CoreTypedInterface

+ Metadata *CoreTaskMetadata

+ Type_ string

+ type CoreTypedInterface struct

+ Inputs *CoreVariableMap

+ Outputs *CoreVariableMap

+ type CoreVariable struct

+ Description string

+ Type_ *CoreLiteralType

+ type CoreVariableMap struct

+ Variables map[string]CoreVariable

+ type CoreVoid struct

+ type CoreWorkflowExecutionIdentifier struct

+ Domain string

+ Name string

+ Project string

+ type CoreWorkflowExecutionPhase string

+ const CoreWorkflowExecutionPhaseABORTED

+ const CoreWorkflowExecutionPhaseFAILED

+ const CoreWorkflowExecutionPhaseFAILING

+ const CoreWorkflowExecutionPhaseQUEUED

+ const CoreWorkflowExecutionPhaseRUNNING

+ const CoreWorkflowExecutionPhaseSUCCEEDED

+ const CoreWorkflowExecutionPhaseSUCCEEDING

+ const CoreWorkflowExecutionPhaseTIMED_OUT

+ const CoreWorkflowExecutionPhaseUNDEFINED

+ type CoreWorkflowMetadata struct

+ type CoreWorkflowNode struct

+ LaunchplanRef *CoreIdentifier

+ SubWorkflowRef *CoreIdentifier

+ type CoreWorkflowTemplate struct

+ FailureNode *CoreNode

+ Id *CoreIdentifier

+ Interface_ *CoreTypedInterface

+ Metadata *CoreWorkflowMetadata

+ Nodes []CoreNode

+ Outputs []CoreBinding

+ type EventNodeExecutionEvent struct

+ Error_ *CoreExecutionError

+ Id *CoreNodeExecutionIdentifier

+ InputUri string

+ OccurredAt time.Time

+ OutputUri string

+ ParentTaskMetadata *EventParentTaskExecutionMetadata

+ Phase *CoreNodeExecutionPhase

+ ProducerId string

+ WorkflowNodeMetadata *FlyteidleventWorkflowNodeMetadata

+ type EventParentTaskExecutionMetadata struct

+ Id *CoreTaskExecutionIdentifier

+ type EventTaskExecutionEvent struct

+ CustomInfo *ProtobufStruct

+ Error_ *CoreExecutionError

+ InputUri string

+ Logs []CoreTaskLog

+ OccurredAt time.Time

+ OutputUri string

+ ParentNodeExecutionId *CoreNodeExecutionIdentifier

+ Phase *CoreTaskExecutionPhase

+ PhaseVersion int64

+ ProducerId string

+ RetryAttempt int64

+ TaskId *CoreIdentifier

+ type EventWorkflowExecutionEvent struct

+ Error_ *CoreExecutionError

+ ExecutionId *CoreWorkflowExecutionIdentifier

+ OccurredAt time.Time

+ OutputUri string

+ Phase *CoreWorkflowExecutionPhase

+ ProducerId string

+ type ExecutionMetadataExecutionMode string

+ const ExecutionMetadataExecutionModeCHILD_WORKFLOW

+ const ExecutionMetadataExecutionModeMANUAL

+ const ExecutionMetadataExecutionModeRELAUNCH

+ const ExecutionMetadataExecutionModeSCHEDULED

+ const ExecutionMetadataExecutionModeSYSTEM

+ type FlyteidladminNodeExecution struct

+ Closure *AdminNodeExecutionClosure

+ Id *CoreNodeExecutionIdentifier

+ InputUri string

+ type FlyteidladminTaskExecution struct

+ Closure *AdminTaskExecutionClosure

+ Id *CoreTaskExecutionIdentifier

+ InputUri string

+ IsParent bool

+ type FlyteidladminWorkflowNodeMetadata struct

+ ExecutionId *CoreWorkflowExecutionIdentifier

+ type FlyteidlcoreSchema struct

+ Type_ *CoreSchemaType

+ Uri string

+ type FlyteidleventWorkflowNodeMetadata struct

+ ExecutionId *CoreWorkflowExecutionIdentifier

+ type GenericSwaggerError struct

+ func (e GenericSwaggerError) Body() []byte

+ func (e GenericSwaggerError) Error() string

+ func (e GenericSwaggerError) Model() interface{}

+ type GetLaunchPlanOpts struct

+ IdResourceType optional.String

+ type GetTaskExecutionDataOpts struct

+ IdTaskIdResourceType optional.String

+ type GetTaskExecutionOpts struct

+ IdTaskIdResourceType optional.String

+ type GetTaskOpts struct

+ IdResourceType optional.String

+ type GetWorkflowOpts struct

+ IdResourceType optional.String

+ type ListExecutionsOpts struct

+ Filters optional.String

+ IdName optional.String

+ Limit optional.Int64

+ SortByDirection optional.String

+ SortByKey optional.String

+ Token optional.String

+ type ListLaunchPlanIdsOpts struct

+ Limit optional.Int64

+ SortByDirection optional.String

+ SortByKey optional.String

+ Token optional.String

+ type ListLaunchPlans2Opts struct

+ Filters optional.String

+ IdName optional.String

+ Limit optional.Int64

+ SortByDirection optional.String

+ SortByKey optional.String

+ Token optional.String

+ type ListLaunchPlansOpts struct

+ Filters optional.String

+ Limit optional.Int64

+ SortByDirection optional.String

+ SortByKey optional.String

+ Token optional.String

+ type ListNodeExecutionsForTaskOpts struct

+ Filters optional.String

+ Limit optional.Int64

+ SortByDirection optional.String

+ SortByKey optional.String

+ TaskExecutionIdTaskIdResourceType optional.String

+ Token optional.String

+ type ListNodeExecutionsOpts struct

+ Filters optional.String

+ Limit optional.Int64

+ SortByDirection optional.String

+ SortByKey optional.String

+ Token optional.String

+ type ListTaskExecutionsOpts struct

+ Filters optional.String

+ Limit optional.Int64

+ SortByDirection optional.String

+ SortByKey optional.String

+ Token optional.String

+ type ListTaskIdsOpts struct

+ Limit optional.Int64

+ SortByDirection optional.String

+ SortByKey optional.String

+ Token optional.String

+ type ListTasks2Opts struct

+ Filters optional.String

+ IdName optional.String

+ Limit optional.Int64

+ SortByDirection optional.String

+ SortByKey optional.String

+ Token optional.String

+ type ListTasksOpts struct

+ Filters optional.String

+ Limit optional.Int64

+ SortByDirection optional.String

+ SortByKey optional.String

+ Token optional.String

+ type ListWorkflowIdsOpts struct

+ Limit optional.Int64

+ SortByDirection optional.String

+ SortByKey optional.String

+ Token optional.String

+ type ListWorkflows2Opts struct

+ Filters optional.String

+ IdName optional.String

+ Limit optional.Int64

+ SortByDirection optional.String

+ SortByKey optional.String

+ Token optional.String

+ type ListWorkflowsOpts struct

+ Filters optional.String

+ Limit optional.Int64

+ SortByDirection optional.String

+ SortByKey optional.String

+ Token optional.String

+ type ProtobufListValue struct

+ Values []ProtobufValue

+ type ProtobufNullValue string

+ const ProtobufNullValueNULL_VALUE

+ type ProtobufStruct struct

+ Fields map[string]ProtobufValue

+ type ProtobufValue struct

+ BoolValue bool

+ ListValue *ProtobufListValue

+ NullValue *ProtobufNullValue

+ NumberValue float64

+ StringValue string

+ StructValue *ProtobufStruct

+ type ResourcesResourceEntry struct

+ Name *ResourcesResourceName

+ Value string

+ type ResourcesResourceName string

+ const ResourcesResourceNameCPU

+ const ResourcesResourceNameGPU

+ const ResourcesResourceNameMEMORY

+ const ResourcesResourceNameSTORAGE

+ const ResourcesResourceNameUNKNOWN

+ type RuntimeMetadataRuntimeType string

+ const RuntimeMetadataRuntimeTypeFLYTE_SDK

+ const RuntimeMetadataRuntimeTypeOTHER

+ type SchemaColumnSchemaColumnType string

+ const SchemaColumnSchemaColumnTypeBOOLEAN

+ const SchemaColumnSchemaColumnTypeDATETIME

+ const SchemaColumnSchemaColumnTypeDURATION

+ const SchemaColumnSchemaColumnTypeFLOAT

+ const SchemaColumnSchemaColumnTypeINTEGER

+ const SchemaColumnSchemaColumnTypeSTRING_

+ type SchemaTypeSchemaColumn struct

+ Name string

+ Type_ *SchemaColumnSchemaColumnType

+ type SortDirection string

+ const SortDirectionASCENDING

+ const SortDirectionDESCENDING

+ type TaskLogMessageFormat string

+ const TaskLogMessageFormatCSV

+ const TaskLogMessageFormatJSON

+ const TaskLogMessageFormatUNKNOWN