flyteadmin

package

Go to main page

Versions in this module

v0

v0.18.14

Feb 26, 2021

v0.18.13

Feb 23, 2021

Changes in this version

type AdminExecutionSpec

+ SecurityContext *AdminSecurityContext

type AdminLaunchPlanSpec

+ SecurityContext *AdminSecurityContext

+ type AdminSecurityContext struct

+ Values map[string]string

type CoreTaskTemplate

+ TaskTypeVersion int32

v0.18.12

Feb 3, 2021

v0.18.11

Nov 30, 2020

Changes in this version

type AdminProjects

+ Token string

+ type ListProjectsOpts struct

+ Filters optional.String

+ Limit optional.Int64

+ SortByDirection optional.String

+ SortByKey optional.String

+ Token optional.String

v0.18.10

Nov 4, 2020

Changes in this version

type AdminProject

+ State *ProjectProjectState

+ type ProjectProjectState string

+ const ProjectProjectStateACTIVE

+ const ProjectProjectStateARCHIVED

+ const ProjectProjectStateSYSTEM_GENERATED

v0.18.9

Oct 7, 2020

v0.18.8

Oct 2, 2020

Changes in this version

+ type AdminCronSchedule struct

+ Offset string

+ Schedule string

type AdminSchedule

+ CronSchedule *AdminCronSchedule

v0.18.7

Sep 29, 2020

Changes in this version

type EventTaskExecutionEvent

+ Metadata *EventTaskExecutionMetadata

+ type EventTaskExecutionMetadata struct

+ InstanceClass *TaskExecutionMetadataInstanceClass

+ type TaskExecutionMetadataInstanceClass string

+ const TaskExecutionMetadataInstanceClassDEFAULT_

+ const TaskExecutionMetadataInstanceClassINTERRUPTIBLE

v0.18.6

Sep 17, 2020

Changes in this version

type AdminMatchingAttributes

+ PluginOverrides *AdminPluginOverrides

+ type AdminPluginOverrides struct

+ Overrides []AdminPluginOverride

v0.18.5

Sep 15, 2020

Changes in this version

type AdminMatchableResource

+ const AdminMatchableResourcePLUGIN_OVERRIDE

type AdminMatchingAttributes

+ PluginOverride *AdminPluginOverride

+ type AdminPluginOverride struct

+ MissingPluginBehavior *PluginOverrideMissingPluginBehavior

+ PluginId []string

+ TaskType string

+ type PluginOverrideMissingPluginBehavior string

+ const PluginOverrideMissingPluginBehaviorFAIL

+ const PluginOverrideMissingPluginBehaviorUSE_DEFAULT

v0.18.3

Aug 13, 2020

Changes in this version

type AdminProject

+ Labels *AdminLabels

+ type AdminProjectUpdateResponse struct

type AdminServiceApiService

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

v0.18.2

Aug 11, 2020

Changes in this version

type AdminNodeExecutionGetDataResponse

+ FullInputs *CoreLiteralMap

+ FullOutputs *CoreLiteralMap

type AdminTaskExecutionGetDataResponse

+ FullInputs *CoreLiteralMap

+ FullOutputs *CoreLiteralMap

type AdminWorkflowExecutionGetDataResponse

+ FullInputs *CoreLiteralMap

+ FullOutputs *CoreLiteralMap

v0.18.1

Jul 30, 2020

Changes in this version

type AdminLaunchPlanSpec

+ RawOutputDataConfig *AdminRawOutputDataConfig

+ type AdminRawOutputDataConfig struct

+ OutputLocationPrefix string

v0.18.0

Jul 30, 2020

v0.17.38

Jul 28, 2020

Changes in this version

type AdminNodeExecutionClosure

+ TaskNodeMetadata *FlyteidladminTaskNodeMetadata

+ 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 CoreResourceType

+ const CoreResourceTypeDATASET

type EventNodeExecutionEvent

+ TaskNodeMetadata *FlyteidleventTaskNodeMetadata

+ type FlyteidladminTaskNodeMetadata struct

+ CacheStatus *CoreCatalogCacheStatus

+ CatalogKey *CoreCatalogMetadata

+ type FlyteidleventTaskNodeMetadata struct

+ CacheStatus *CoreCatalogCacheStatus

+ CatalogKey *CoreCatalogMetadata

v0.17.37

Jul 22, 2020

Changes in this version

type AdminNodeExecutionMetaData

+ IsParentNode bool

+ RetryGroup string

+ SpecNodeId string

type EventNodeExecutionEvent

+ NodeName string

+ ParentNodeMetadata *EventParentNodeExecutionMetadata

+ RetryGroup string

+ SpecNodeId string

+ type EventParentNodeExecutionMetadata struct

+ NodeId string

type ListNodeExecutionsOpts

+ UniqueParentId optional.String

v0.17.36

Jul 8, 2020

Changes in this version

type AdminExecutionSpec

+ QualityOfService *CoreQualityOfService

type AdminLaunchPlanSpec

+ QualityOfService *CoreQualityOfService

type AdminMatchableResource

+ const AdminMatchableResourceQUALITY_OF_SERVICE_SPECIFICATION

type AdminMatchingAttributes

+ QualityOfService *CoreQualityOfService

+ type CoreQualityOfService struct

+ Spec *CoreQualityOfServiceSpec

+ Tier *QualityOfServiceTier

+ type CoreQualityOfServiceSpec struct

+ QueueingBudget string

type CoreWorkflowMetadata

+ QualityOfService *CoreQualityOfService

+ type QualityOfServiceTier string

+ const QualityOfServiceTierHIGH

+ const QualityOfServiceTierLOW

+ const QualityOfServiceTierMEDIUM

+ const QualityOfServiceTierUNDEFINED

v0.17.34

Jun 10, 2020

v0.17.33

Jun 8, 2020

Changes in this version

type CoreWorkflowMetadata

+ OnFailure *WorkflowMetadataOnFailurePolicy

+ type WorkflowMetadataOnFailurePolicy string

+ const WorkflowMetadataOnFailurePolicyAFTER_EXECUTABLE_NODES_COMPLETE

+ const WorkflowMetadataOnFailurePolicyAFTER_RUNNING_NODES_COMPLETE

+ const WorkflowMetadataOnFailurePolicyIMMEDIATELY

v0.17.32

May 26, 2020

Changes in this version

type CoreDataLoadingConfig

+ IoStrategy *CoreIoStrategy

+ type CoreIoStrategy struct

+ DownloadMode *IoStrategyDownloadMode

+ UploadMode *IoStrategyUploadMode

+ type DataLoadingConfigLiteralMapFormat string

+ const DataLoadingConfigLiteralMapFormatJSON

+ const DataLoadingConfigLiteralMapFormatPROTO

+ const DataLoadingConfigLiteralMapFormatYAML

+ 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

v0.17.31

May 17, 2020

Changes in this version

type CoreContainer

+ DataConfig *CoreDataLoadingConfig

+ type CoreDataLoadingConfig struct

+ Enabled bool

+ Format *DataLoadingConfigMetadataFormat

+ InputPath string

+ OutputPath string

+ type DataLoadingConfigMetadataFormat string

+ const DataLoadingConfigMetadataFormatJSON

+ const DataLoadingConfigMetadataFormatPROTO

+ const DataLoadingConfigMetadataFormatYAML

v0.17.30

May 12, 2020

Changes in this version

+ type AdminAuthRole struct

+ AssumableIamRole string

+ KubernetesServiceAccount string

type AdminExecutionSpec

+ AuthRole *AdminAuthRole

type AdminLaunchPlanSpec

+ AuthRole *AdminAuthRole

type AdminNamedEntityState

+ const AdminNamedEntityStateNAMED_ENTITY_ACTIVE

+ const AdminNamedEntityStateNAMED_ENTITY_ARCHIVED

+ const AdminNamedEntityStateSYSTEM_GENERATED

v0.17.29

May 12, 2020

v0.17.28

May 7, 2020

v0.17.27

Apr 3, 2020

Changes in this version

type ListLaunchPlanIdsOpts

+ Filters optional.String

type ListNamedEntitiesOpts

+ Filters optional.String

type ListTaskIdsOpts

+ Filters optional.String

type ListWorkflowIdsOpts

+ Filters optional.String

v0.17.26

Apr 3, 2020

Changes in this version

type AdminNamedEntityMetadata

+ State *AdminNamedEntityState

+ type AdminNamedEntityState string

+ const AdminNamedEntityStateACTIVE

+ const AdminNamedEntityStateARCHIVED

v0.17.25

Apr 2, 2020

v0.17.24

Apr 2, 2020

Changes in this version

type CoreTaskExecutionPhase

+ const CoreTaskExecutionPhaseINITIALIZING

+ const CoreTaskExecutionPhaseWAITING_FOR_RESOURCES

v0.17.23

Apr 2, 2020

Changes in this version

type AdminServiceApiService

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

+ type AdminWorkflowState string

+ const AdminWorkflowStateACTIVE

+ const AdminWorkflowStateARCHIVED

+ type AdminWorkflowUpdateRequest struct

+ Id *CoreIdentifier

+ State *AdminWorkflowState

+ type AdminWorkflowUpdateResponse struct

v0.17.22

Mar 31, 2020

v0.17.21

Mar 27, 2020

Changes in this version

type CoreWorkflowMetadata

+ QueuingBudget string

v0.17.20

Mar 12, 2020

v0.17.9

Mar 10, 2020

v0.17.8

Mar 9, 2020

v0.17.7

Mar 2, 2020

v0.17.6

Feb 28, 2020

v0.17.5

Feb 28, 2020

v0.17.4

Feb 20, 2020

v0.17.3

Feb 12, 2020

v0.17.2

Feb 5, 2020

v0.17.1

Feb 5, 2020

v0.17.0

Jan 24, 2020

v0.16.6

Jan 10, 2020

v0.16.5

Jan 2, 2020

Changes in this version

+ type AdminProjectAttributesDeleteRequest struct

+ Project string

+ ResourceType *AdminMatchableResource

+ type AdminProjectAttributesDeleteResponse struct

+ type AdminProjectAttributesGetResponse struct

+ Attributes *AdminProjectAttributes

type AdminServiceApiService

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

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

+ type GetProjectAttributesOpts struct

+ ResourceType optional.String

v0.16.4

Dec 30, 2019

Changes in this version

+ type AdminProjectAttributes struct

+ MatchingAttributes *AdminMatchingAttributes

+ Project string

+ type AdminProjectAttributesUpdateRequest struct

+ Attributes *AdminProjectAttributes

+ type AdminProjectAttributesUpdateResponse struct

type AdminServiceApiService

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

v0.16.3

Dec 19, 2019

v0.16.2

Dec 11, 2019

v0.16.1

Oct 30, 2019

Changes in this version

type AdminProjectDomainAttributes

+ Attributes map[string]string

v0.16.0

Oct 9, 2019

v0.15.0

Oct 9, 2019

v0.14.1

Sep 6, 2019

v0.14.0

Sep 4, 2019

v0.4.20

Mar 12, 2020

Changes in this version

+ type AdminAbortMetadata struct

+ Cause string

+ Principal string

+ type AdminClusterResourceAttributes struct

+ Attributes map[string]string

type AdminExecutionClosure

+ AbortMetadata *AdminAbortMetadata

+ type AdminExecutionClusterLabel struct

+ Value string

type AdminExecutionCreateRequest

+ Inputs *CoreLiteralMap

type AdminExecutionMetadata

+ SystemMetadata *AdminSystemMetadata

+ type AdminExecutionQueueAttributes struct

+ Tags []string

+ type AdminListMatchableAttributesResponse struct

+ Configurations []AdminMatchableAttributesConfiguration

+ type AdminMatchableAttributesConfiguration struct

+ Attributes *AdminMatchingAttributes

+ Domain string

+ LaunchPlan string

+ Project string

+ Workflow string

+ type AdminMatchableResource string

+ const AdminMatchableResourceCLUSTER_RESOURCE

+ const AdminMatchableResourceEXECUTION_CLUSTER_LABEL

+ const AdminMatchableResourceEXECUTION_QUEUE

+ const AdminMatchableResourceTASK_RESOURCE

+ type AdminMatchingAttributes struct

+ ClusterResourceAttributes *AdminClusterResourceAttributes

+ ExecutionClusterLabel *AdminExecutionClusterLabel

+ ExecutionQueueAttributes *AdminExecutionQueueAttributes

+ TaskResourceAttributes *AdminTaskResourceAttributes

+ 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 AdminNodeExecutionMetaData struct

type AdminProject

+ Description string

+ type AdminProjectDomainAttributes struct

+ Domain string

+ MatchingAttributes *AdminMatchingAttributes

+ Project string

+ type AdminProjectDomainAttributesDeleteRequest struct

+ Domain string

+ Project string

+ ResourceType *AdminMatchableResource

+ type AdminProjectDomainAttributesDeleteResponse struct

+ type AdminProjectDomainAttributesGetResponse struct

+ Attributes *AdminProjectDomainAttributes

+ type AdminProjectDomainAttributesUpdateRequest struct

+ Attributes *AdminProjectDomainAttributes

+ type AdminProjectDomainAttributesUpdateResponse struct

type AdminServiceApiService

+ 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) GetNamedEntity(ctx context.Context, resourceType string, idProject string, idDomain string, ...) (AdminNamedEntity, *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)

+ func (a *AdminServiceApiService) ListMatchableAttributes(ctx context.Context, localVarOptionals *ListMatchableAttributesOpts) (AdminListMatchableAttributesResponse, *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)

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

+ type AdminSystemMetadata struct

+ ExecutionCluster string

+ 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 AdminWorkflowAttributesDeleteRequest struct

+ Domain string

+ Project string

+ ResourceType *AdminMatchableResource

+ Workflow string

+ type AdminWorkflowAttributesDeleteResponse struct

+ type AdminWorkflowAttributesGetResponse struct

+ Attributes *AdminWorkflowAttributes

+ type AdminWorkflowAttributesUpdateRequest struct

+ Attributes *AdminWorkflowAttributes

+ type AdminWorkflowAttributesUpdateResponse struct

type AdminWorkflowExecutionGetDataResponse

+ Inputs *AdminUrlBlob

type AdminWorkflowSpec

+ SubWorkflows []CoreWorkflowTemplate

type CoreExecutionError

+ Kind *ExecutionErrorErrorKind

type CoreNodeMetadata

+ Interruptible bool

type CoreTaskMetadata

+ Interruptible bool

+ type CoreWorkflowMetadataDefaults struct

+ Interruptible bool

type CoreWorkflowTemplate

+ MetadataDefaults *CoreWorkflowMetadataDefaults

+ type ExecutionErrorErrorKind string

+ const ExecutionErrorErrorKindSYSTEM

+ const ExecutionErrorErrorKindUNKNOWN

+ const ExecutionErrorErrorKindUSER

type FlyteidladminNodeExecution

+ Metadata *AdminNodeExecutionMetaData

+ type GetProjectDomainAttributesOpts struct

+ ResourceType optional.String

+ type GetWorkflowAttributesOpts struct

+ ResourceType optional.String

+ type ListMatchableAttributesOpts struct

+ ResourceType optional.String

+ type ListNamedEntitiesOpts struct

+ Limit optional.Int64

+ SortByDirection optional.String

+ SortByKey optional.String

+ Token optional.String

v0.1.1

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

v0.1.0

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

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL