gen

package
v0.1.0-debug.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 22, 2025 License: MIT Imports: 14 Imported by: 0

Documentation

Overview

Package gen provides primitives to interact with the openapi HTTP API.

Code generated by github.com/deepmap/oapi-codegen/v2 version v2.0.0 DO NOT EDIT.

Index

Constants

View Source
const (
	BearerAuthScopes = "bearerAuth.Scopes"
	CookieAuthScopes = "cookieAuth.Scopes"
)

Variables

This section is empty.

Functions

func GetSwagger

func GetSwagger() (swagger *openapi3.T, err error)

GetSwagger returns the Swagger specification corresponding to the generated code in this file. The external references of Swagger specification are resolved. The logic of resolving external references is tightly connected to "import-mapping" feature. Externally referenced files must be embedded in the corresponding golang packages. Urls can be supported but this task was out of the scope.

func PathToRawSpec

func PathToRawSpec(pathToFile string) map[string]func() ([]byte, error)

Constructs a synthetic filesystem for resolving external references when loading openapi specifications.

func RegisterHandlers

func RegisterHandlers(router EchoRouter, si ServerInterface)

RegisterHandlers adds each server route to the EchoRouter.

func RegisterHandlersWithBaseURL

func RegisterHandlersWithBaseURL(router EchoRouter, si ServerInterface, baseURL string)

Registers handlers, and prepends BaseURL to the paths, so that the paths can be served under a prefix.

Types

type APIError

type APIError struct {
	// Code a custom Hatchet error code
	Code *uint64 `json:"code,omitempty"`

	// Description a description for this error
	Description string `json:"description"`

	// DocsLink a link to the documentation for this error, if it exists
	DocsLink *string `json:"docs_link,omitempty"`

	// Field the field that this error is associated with, if applicable
	Field *string `json:"field,omitempty"`
}

APIError defines model for APIError.

type APIErrors

type APIErrors struct {
	Errors []APIError `json:"errors"`
}

APIErrors defines model for APIErrors.

type APIMeta

type APIMeta struct {
	// AllowChangePassword whether or not users can change their password
	AllowChangePassword *bool `json:"allowChangePassword,omitempty"`

	// AllowCreateTenant whether or not users can create new tenants
	AllowCreateTenant *bool `json:"allowCreateTenant,omitempty"`

	// AllowInvites whether or not users can invite other users to this instance
	AllowInvites *bool `json:"allowInvites,omitempty"`

	// AllowSignup whether or not users can sign up for this instance
	AllowSignup *bool           `json:"allowSignup,omitempty"`
	Auth        *APIMetaAuth    `json:"auth,omitempty"`
	Posthog     *APIMetaPosthog `json:"posthog,omitempty"`

	// PylonAppId the Pylon app ID for usepylon.com chat support
	PylonAppId *string `json:"pylonAppId,omitempty"`
}

APIMeta defines model for APIMeta.

type APIMetaAuth

type APIMetaAuth struct {
	// Schemes the supported types of authentication
	Schemes *[]string `json:"schemes,omitempty"`
}

APIMetaAuth defines model for APIMetaAuth.

type APIMetaIntegration

type APIMetaIntegration struct {
	// Enabled whether this integration is enabled on the instance
	Enabled bool `json:"enabled"`

	// Name the name of the integration
	Name string `json:"name"`
}

APIMetaIntegration defines model for APIMetaIntegration.

type APIMetaPosthog

type APIMetaPosthog struct {
	// ApiHost the PostHog API host
	ApiHost *string `json:"apiHost,omitempty"`

	// ApiKey the PostHog API key
	ApiKey *string `json:"apiKey,omitempty"`
}

APIMetaPosthog defines model for APIMetaPosthog.

type APIResourceMeta

type APIResourceMeta struct {
	// CreatedAt the time that this resource was created
	CreatedAt time.Time `json:"createdAt"`

	// Id the id of this resource, in UUID format
	Id string `json:"id"`

	// UpdatedAt the time that this resource was last updated
	UpdatedAt time.Time `json:"updatedAt"`
}

APIResourceMeta defines model for APIResourceMeta.

type APIToken

type APIToken struct {
	// ExpiresAt When the API token expires.
	ExpiresAt time.Time       `json:"expiresAt"`
	Metadata  APIResourceMeta `json:"metadata"`

	// Name The name of the API token.
	Name string `json:"name"`
}

APIToken defines model for APIToken.

type AcceptInviteRequest

type AcceptInviteRequest struct {
	Invite string `json:"invite" validate:"required,uuid"`
}

AcceptInviteRequest defines model for AcceptInviteRequest.

type AlertEmailGroupCreate201JSONResponse

type AlertEmailGroupCreate201JSONResponse TenantAlertEmailGroup

func (AlertEmailGroupCreate201JSONResponse) VisitAlertEmailGroupCreateResponse

func (response AlertEmailGroupCreate201JSONResponse) VisitAlertEmailGroupCreateResponse(w http.ResponseWriter) error

type AlertEmailGroupCreate400JSONResponse

type AlertEmailGroupCreate400JSONResponse APIErrors

func (AlertEmailGroupCreate400JSONResponse) VisitAlertEmailGroupCreateResponse

func (response AlertEmailGroupCreate400JSONResponse) VisitAlertEmailGroupCreateResponse(w http.ResponseWriter) error

type AlertEmailGroupCreate403JSONResponse

type AlertEmailGroupCreate403JSONResponse APIError

func (AlertEmailGroupCreate403JSONResponse) VisitAlertEmailGroupCreateResponse

func (response AlertEmailGroupCreate403JSONResponse) VisitAlertEmailGroupCreateResponse(w http.ResponseWriter) error

type AlertEmailGroupCreateJSONRequestBody

type AlertEmailGroupCreateJSONRequestBody = CreateTenantAlertEmailGroupRequest

AlertEmailGroupCreateJSONRequestBody defines body for AlertEmailGroupCreate for application/json ContentType.

type AlertEmailGroupCreateRequestObject

type AlertEmailGroupCreateRequestObject struct {
	Tenant openapi_types.UUID `json:"tenant"`
	Body   *AlertEmailGroupCreateJSONRequestBody
}

type AlertEmailGroupCreateResponseObject

type AlertEmailGroupCreateResponseObject interface {
	VisitAlertEmailGroupCreateResponse(w http.ResponseWriter) error
}

type AlertEmailGroupDelete204Response

type AlertEmailGroupDelete204Response struct {
}

func (AlertEmailGroupDelete204Response) VisitAlertEmailGroupDeleteResponse

func (response AlertEmailGroupDelete204Response) VisitAlertEmailGroupDeleteResponse(w http.ResponseWriter) error

type AlertEmailGroupDelete400JSONResponse

type AlertEmailGroupDelete400JSONResponse APIErrors

func (AlertEmailGroupDelete400JSONResponse) VisitAlertEmailGroupDeleteResponse

func (response AlertEmailGroupDelete400JSONResponse) VisitAlertEmailGroupDeleteResponse(w http.ResponseWriter) error

type AlertEmailGroupDelete403JSONResponse

type AlertEmailGroupDelete403JSONResponse APIError

func (AlertEmailGroupDelete403JSONResponse) VisitAlertEmailGroupDeleteResponse

func (response AlertEmailGroupDelete403JSONResponse) VisitAlertEmailGroupDeleteResponse(w http.ResponseWriter) error

type AlertEmailGroupDeleteRequestObject

type AlertEmailGroupDeleteRequestObject struct {
	AlertEmailGroup openapi_types.UUID `json:"alert-email-group"`
}

type AlertEmailGroupDeleteResponseObject

type AlertEmailGroupDeleteResponseObject interface {
	VisitAlertEmailGroupDeleteResponse(w http.ResponseWriter) error
}

type AlertEmailGroupList200JSONResponse

type AlertEmailGroupList200JSONResponse TenantAlertEmailGroupList

func (AlertEmailGroupList200JSONResponse) VisitAlertEmailGroupListResponse

func (response AlertEmailGroupList200JSONResponse) VisitAlertEmailGroupListResponse(w http.ResponseWriter) error

type AlertEmailGroupList400JSONResponse

type AlertEmailGroupList400JSONResponse APIErrors

func (AlertEmailGroupList400JSONResponse) VisitAlertEmailGroupListResponse

func (response AlertEmailGroupList400JSONResponse) VisitAlertEmailGroupListResponse(w http.ResponseWriter) error

type AlertEmailGroupList403JSONResponse

type AlertEmailGroupList403JSONResponse APIError

func (AlertEmailGroupList403JSONResponse) VisitAlertEmailGroupListResponse

func (response AlertEmailGroupList403JSONResponse) VisitAlertEmailGroupListResponse(w http.ResponseWriter) error

type AlertEmailGroupListRequestObject

type AlertEmailGroupListRequestObject struct {
	Tenant openapi_types.UUID `json:"tenant"`
}

type AlertEmailGroupListResponseObject

type AlertEmailGroupListResponseObject interface {
	VisitAlertEmailGroupListResponse(w http.ResponseWriter) error
}

type AlertEmailGroupUpdate200JSONResponse

type AlertEmailGroupUpdate200JSONResponse TenantAlertEmailGroup

func (AlertEmailGroupUpdate200JSONResponse) VisitAlertEmailGroupUpdateResponse

func (response AlertEmailGroupUpdate200JSONResponse) VisitAlertEmailGroupUpdateResponse(w http.ResponseWriter) error

type AlertEmailGroupUpdate400JSONResponse

type AlertEmailGroupUpdate400JSONResponse APIErrors

func (AlertEmailGroupUpdate400JSONResponse) VisitAlertEmailGroupUpdateResponse

func (response AlertEmailGroupUpdate400JSONResponse) VisitAlertEmailGroupUpdateResponse(w http.ResponseWriter) error

type AlertEmailGroupUpdate403JSONResponse

type AlertEmailGroupUpdate403JSONResponse APIError

func (AlertEmailGroupUpdate403JSONResponse) VisitAlertEmailGroupUpdateResponse

func (response AlertEmailGroupUpdate403JSONResponse) VisitAlertEmailGroupUpdateResponse(w http.ResponseWriter) error

type AlertEmailGroupUpdateJSONRequestBody

type AlertEmailGroupUpdateJSONRequestBody = UpdateTenantAlertEmailGroupRequest

AlertEmailGroupUpdateJSONRequestBody defines body for AlertEmailGroupUpdate for application/json ContentType.

type AlertEmailGroupUpdateRequestObject

type AlertEmailGroupUpdateRequestObject struct {
	AlertEmailGroup openapi_types.UUID `json:"alert-email-group"`
	Body            *AlertEmailGroupUpdateJSONRequestBody
}

type AlertEmailGroupUpdateResponseObject

type AlertEmailGroupUpdateResponseObject interface {
	VisitAlertEmailGroupUpdateResponse(w http.ResponseWriter) error
}

type ApiTokenCreate200JSONResponse

type ApiTokenCreate200JSONResponse CreateAPITokenResponse

func (ApiTokenCreate200JSONResponse) VisitApiTokenCreateResponse

func (response ApiTokenCreate200JSONResponse) VisitApiTokenCreateResponse(w http.ResponseWriter) error

type ApiTokenCreate400JSONResponse

type ApiTokenCreate400JSONResponse APIErrors

func (ApiTokenCreate400JSONResponse) VisitApiTokenCreateResponse

func (response ApiTokenCreate400JSONResponse) VisitApiTokenCreateResponse(w http.ResponseWriter) error

type ApiTokenCreate403JSONResponse

type ApiTokenCreate403JSONResponse APIErrors

func (ApiTokenCreate403JSONResponse) VisitApiTokenCreateResponse

func (response ApiTokenCreate403JSONResponse) VisitApiTokenCreateResponse(w http.ResponseWriter) error

type ApiTokenCreateJSONRequestBody

type ApiTokenCreateJSONRequestBody = CreateAPITokenRequest

ApiTokenCreateJSONRequestBody defines body for ApiTokenCreate for application/json ContentType.

type ApiTokenCreateRequestObject

type ApiTokenCreateRequestObject struct {
	Tenant openapi_types.UUID `json:"tenant"`
	Body   *ApiTokenCreateJSONRequestBody
}

type ApiTokenCreateResponseObject

type ApiTokenCreateResponseObject interface {
	VisitApiTokenCreateResponse(w http.ResponseWriter) error
}

type ApiTokenList200JSONResponse

type ApiTokenList200JSONResponse ListAPITokensResponse

func (ApiTokenList200JSONResponse) VisitApiTokenListResponse

func (response ApiTokenList200JSONResponse) VisitApiTokenListResponse(w http.ResponseWriter) error

type ApiTokenList400JSONResponse

type ApiTokenList400JSONResponse APIErrors

func (ApiTokenList400JSONResponse) VisitApiTokenListResponse

func (response ApiTokenList400JSONResponse) VisitApiTokenListResponse(w http.ResponseWriter) error

type ApiTokenList403JSONResponse

type ApiTokenList403JSONResponse APIErrors

func (ApiTokenList403JSONResponse) VisitApiTokenListResponse

func (response ApiTokenList403JSONResponse) VisitApiTokenListResponse(w http.ResponseWriter) error

type ApiTokenListRequestObject

type ApiTokenListRequestObject struct {
	Tenant openapi_types.UUID `json:"tenant"`
}

type ApiTokenListResponseObject

type ApiTokenListResponseObject interface {
	VisitApiTokenListResponse(w http.ResponseWriter) error
}

type ApiTokenUpdateRevoke204Response

type ApiTokenUpdateRevoke204Response struct {
}

func (ApiTokenUpdateRevoke204Response) VisitApiTokenUpdateRevokeResponse

func (response ApiTokenUpdateRevoke204Response) VisitApiTokenUpdateRevokeResponse(w http.ResponseWriter) error

type ApiTokenUpdateRevoke400JSONResponse

type ApiTokenUpdateRevoke400JSONResponse APIErrors

func (ApiTokenUpdateRevoke400JSONResponse) VisitApiTokenUpdateRevokeResponse

func (response ApiTokenUpdateRevoke400JSONResponse) VisitApiTokenUpdateRevokeResponse(w http.ResponseWriter) error

type ApiTokenUpdateRevoke403JSONResponse

type ApiTokenUpdateRevoke403JSONResponse APIErrors

func (ApiTokenUpdateRevoke403JSONResponse) VisitApiTokenUpdateRevokeResponse

func (response ApiTokenUpdateRevoke403JSONResponse) VisitApiTokenUpdateRevokeResponse(w http.ResponseWriter) error

type ApiTokenUpdateRevokeRequestObject

type ApiTokenUpdateRevokeRequestObject struct {
	ApiToken openapi_types.UUID `json:"api-token"`
}

type ApiTokenUpdateRevokeResponseObject

type ApiTokenUpdateRevokeResponseObject interface {
	VisitApiTokenUpdateRevokeResponse(w http.ResponseWriter) error
}

type BulkCreateEventRequest

type BulkCreateEventRequest struct {
	Events []CreateEventRequest `json:"events"`
}

BulkCreateEventRequest defines model for BulkCreateEventRequest.

type CancelEventRequest

type CancelEventRequest struct {
	EventIds []openapi_types.UUID `json:"eventIds"`
}

CancelEventRequest defines model for CancelEventRequest.

type CloudMetadataGet200JSONResponse

type CloudMetadataGet200JSONResponse APIErrors

func (CloudMetadataGet200JSONResponse) VisitCloudMetadataGetResponse

func (response CloudMetadataGet200JSONResponse) VisitCloudMetadataGetResponse(w http.ResponseWriter) error

type CloudMetadataGet400JSONResponse

type CloudMetadataGet400JSONResponse APIErrors

func (CloudMetadataGet400JSONResponse) VisitCloudMetadataGetResponse

func (response CloudMetadataGet400JSONResponse) VisitCloudMetadataGetResponse(w http.ResponseWriter) error

type CloudMetadataGetRequestObject

type CloudMetadataGetRequestObject struct {
}

type CloudMetadataGetResponseObject

type CloudMetadataGetResponseObject interface {
	VisitCloudMetadataGetResponse(w http.ResponseWriter) error
}

type ConcurrencyLimitStrategy

type ConcurrencyLimitStrategy string

ConcurrencyLimitStrategy defines model for ConcurrencyLimitStrategy.

const (
	CANCELINPROGRESS ConcurrencyLimitStrategy = "CANCEL_IN_PROGRESS"
	DROPNEWEST       ConcurrencyLimitStrategy = "DROP_NEWEST"
	GROUPROUNDROBIN  ConcurrencyLimitStrategy = "GROUP_ROUND_ROBIN"
	QUEUENEWEST      ConcurrencyLimitStrategy = "QUEUE_NEWEST"
)

Defines values for ConcurrencyLimitStrategy.

type CreateAPITokenRequest

type CreateAPITokenRequest struct {
	// ExpiresIn The duration for which the token is valid.
	ExpiresIn *string `json:"expiresIn,omitempty" validate:"omitnil,duration"`

	// Name A name for the API token.
	Name string `json:"name"`
}

CreateAPITokenRequest defines model for CreateAPITokenRequest.

type CreateAPITokenResponse

type CreateAPITokenResponse struct {
	// Token The API token.
	Token string `json:"token"`
}

CreateAPITokenResponse defines model for CreateAPITokenResponse.

type CreateCronWorkflowTriggerRequest

type CreateCronWorkflowTriggerRequest struct {
	AdditionalMetadata map[string]interface{} `json:"additionalMetadata"`
	CronExpression     string                 `json:"cronExpression"`
	CronName           string                 `json:"cronName"`
	Input              map[string]interface{} `json:"input"`
}

CreateCronWorkflowTriggerRequest defines model for CreateCronWorkflowTriggerRequest.

type CreateEventRequest

type CreateEventRequest struct {
	// AdditionalMetadata Additional metadata for the event.
	AdditionalMetadata *map[string]interface{} `json:"additionalMetadata,omitempty"`

	// Data The data for the event.
	Data map[string]interface{} `json:"data"`

	// Key The key for the event.
	Key string `json:"key"`
}

CreateEventRequest defines model for CreateEventRequest.

type CreateSNSIntegrationRequest

type CreateSNSIntegrationRequest struct {
	// TopicArn The Amazon Resource Name (ARN) of the SNS topic.
	TopicArn string `json:"topicArn" validate:"required,min=1,max=256"`
}

CreateSNSIntegrationRequest defines model for CreateSNSIntegrationRequest.

type CreateTenantAlertEmailGroupRequest

type CreateTenantAlertEmailGroupRequest struct {
	// Emails A list of emails for users
	Emails []string `json:"emails" validate:"required,dive,email"`
}

CreateTenantAlertEmailGroupRequest defines model for CreateTenantAlertEmailGroupRequest.

type CreateTenantInviteRequest

type CreateTenantInviteRequest struct {
	// Email The email of the user to invite.
	Email string           `json:"email" validate:"required,email"`
	Role  TenantMemberRole `json:"role"`
}

CreateTenantInviteRequest defines model for CreateTenantInviteRequest.

type CreateTenantRequest

type CreateTenantRequest struct {
	// Name The name of the tenant.
	Name string `json:"name" validate:"required"`

	// Slug The slug of the tenant.
	Slug string `json:"slug" validate:"required,hatchetName"`
}

CreateTenantRequest defines model for CreateTenantRequest.

type CronWorkflowList200JSONResponse

type CronWorkflowList200JSONResponse CronWorkflowsList

func (CronWorkflowList200JSONResponse) VisitCronWorkflowListResponse

func (response CronWorkflowList200JSONResponse) VisitCronWorkflowListResponse(w http.ResponseWriter) error

type CronWorkflowList400JSONResponse

type CronWorkflowList400JSONResponse APIErrors

func (CronWorkflowList400JSONResponse) VisitCronWorkflowListResponse

func (response CronWorkflowList400JSONResponse) VisitCronWorkflowListResponse(w http.ResponseWriter) error

type CronWorkflowList403JSONResponse

type CronWorkflowList403JSONResponse APIErrors

func (CronWorkflowList403JSONResponse) VisitCronWorkflowListResponse

func (response CronWorkflowList403JSONResponse) VisitCronWorkflowListResponse(w http.ResponseWriter) error

type CronWorkflowListParams

type CronWorkflowListParams struct {
	// Offset The number to skip
	Offset *int64 `form:"offset,omitempty" json:"offset,omitempty"`

	// Limit The number to limit by
	Limit *int64 `form:"limit,omitempty" json:"limit,omitempty"`

	// WorkflowId The workflow id to get runs for.
	WorkflowId *openapi_types.UUID `form:"workflowId,omitempty" json:"workflowId,omitempty"`

	// AdditionalMetadata A list of metadata key value pairs to filter by
	AdditionalMetadata *[]string `form:"additionalMetadata,omitempty" json:"additionalMetadata,omitempty"`

	// OrderByField The order by field
	OrderByField *CronWorkflowsOrderByField `form:"orderByField,omitempty" json:"orderByField,omitempty"`

	// OrderByDirection The order by direction
	OrderByDirection *WorkflowRunOrderByDirection `form:"orderByDirection,omitempty" json:"orderByDirection,omitempty"`
}

CronWorkflowListParams defines parameters for CronWorkflowList.

type CronWorkflowListRequestObject

type CronWorkflowListRequestObject struct {
	Tenant openapi_types.UUID `json:"tenant"`
	Params CronWorkflowListParams
}

type CronWorkflowListResponseObject

type CronWorkflowListResponseObject interface {
	VisitCronWorkflowListResponse(w http.ResponseWriter) error
}

type CronWorkflowTriggerCreate200JSONResponse

type CronWorkflowTriggerCreate200JSONResponse CronWorkflows

func (CronWorkflowTriggerCreate200JSONResponse) VisitCronWorkflowTriggerCreateResponse

func (response CronWorkflowTriggerCreate200JSONResponse) VisitCronWorkflowTriggerCreateResponse(w http.ResponseWriter) error

type CronWorkflowTriggerCreate400JSONResponse

type CronWorkflowTriggerCreate400JSONResponse APIErrors

func (CronWorkflowTriggerCreate400JSONResponse) VisitCronWorkflowTriggerCreateResponse

func (response CronWorkflowTriggerCreate400JSONResponse) VisitCronWorkflowTriggerCreateResponse(w http.ResponseWriter) error

type CronWorkflowTriggerCreate403JSONResponse

type CronWorkflowTriggerCreate403JSONResponse APIErrors

func (CronWorkflowTriggerCreate403JSONResponse) VisitCronWorkflowTriggerCreateResponse

func (response CronWorkflowTriggerCreate403JSONResponse) VisitCronWorkflowTriggerCreateResponse(w http.ResponseWriter) error

type CronWorkflowTriggerCreate404JSONResponse

type CronWorkflowTriggerCreate404JSONResponse APIErrors

func (CronWorkflowTriggerCreate404JSONResponse) VisitCronWorkflowTriggerCreateResponse

func (response CronWorkflowTriggerCreate404JSONResponse) VisitCronWorkflowTriggerCreateResponse(w http.ResponseWriter) error

type CronWorkflowTriggerCreate429JSONResponse

type CronWorkflowTriggerCreate429JSONResponse APIErrors

func (CronWorkflowTriggerCreate429JSONResponse) VisitCronWorkflowTriggerCreateResponse

func (response CronWorkflowTriggerCreate429JSONResponse) VisitCronWorkflowTriggerCreateResponse(w http.ResponseWriter) error

type CronWorkflowTriggerCreateJSONRequestBody

type CronWorkflowTriggerCreateJSONRequestBody = CreateCronWorkflowTriggerRequest

CronWorkflowTriggerCreateJSONRequestBody defines body for CronWorkflowTriggerCreate for application/json ContentType.

type CronWorkflowTriggerCreateRequestObject

type CronWorkflowTriggerCreateRequestObject struct {
	Tenant   openapi_types.UUID `json:"tenant"`
	Workflow string             `json:"workflow"`
	Body     *CronWorkflowTriggerCreateJSONRequestBody
}

type CronWorkflowTriggerCreateResponseObject

type CronWorkflowTriggerCreateResponseObject interface {
	VisitCronWorkflowTriggerCreateResponse(w http.ResponseWriter) error
}

type CronWorkflows

type CronWorkflows struct {
	AdditionalMetadata *map[string]interface{} `json:"additionalMetadata,omitempty"`
	Cron               string                  `json:"cron"`
	Enabled            bool                    `json:"enabled"`
	Input              *map[string]interface{} `json:"input,omitempty"`
	Metadata           APIResourceMeta         `json:"metadata"`
	Method             CronWorkflowsMethod     `json:"method"`
	Name               *string                 `json:"name,omitempty"`
	TenantId           string                  `json:"tenantId"`
	WorkflowId         string                  `json:"workflowId"`
	WorkflowName       string                  `json:"workflowName"`
	WorkflowVersionId  string                  `json:"workflowVersionId"`
}

CronWorkflows defines model for CronWorkflows.

type CronWorkflowsList

type CronWorkflowsList struct {
	Pagination *PaginationResponse `json:"pagination,omitempty"`
	Rows       *[]CronWorkflows    `json:"rows,omitempty"`
}

CronWorkflowsList defines model for CronWorkflowsList.

type CronWorkflowsMethod

type CronWorkflowsMethod string

CronWorkflowsMethod defines model for CronWorkflowsMethod.

const (
	CronWorkflowsMethodAPI     CronWorkflowsMethod = "API"
	CronWorkflowsMethodDEFAULT CronWorkflowsMethod = "DEFAULT"
)

Defines values for CronWorkflowsMethod.

type CronWorkflowsOrderByField

type CronWorkflowsOrderByField string

CronWorkflowsOrderByField defines model for CronWorkflowsOrderByField.

const (
	CronWorkflowsOrderByFieldCreatedAt CronWorkflowsOrderByField = "createdAt"
	CronWorkflowsOrderByFieldName      CronWorkflowsOrderByField = "name"
)

Defines values for CronWorkflowsOrderByField.

type EchoRouter

type EchoRouter interface {
	CONNECT(path string, h echo.HandlerFunc, m ...echo.MiddlewareFunc) *echo.Route
	DELETE(path string, h echo.HandlerFunc, m ...echo.MiddlewareFunc) *echo.Route
	GET(path string, h echo.HandlerFunc, m ...echo.MiddlewareFunc) *echo.Route
	HEAD(path string, h echo.HandlerFunc, m ...echo.MiddlewareFunc) *echo.Route
	OPTIONS(path string, h echo.HandlerFunc, m ...echo.MiddlewareFunc) *echo.Route
	PATCH(path string, h echo.HandlerFunc, m ...echo.MiddlewareFunc) *echo.Route
	POST(path string, h echo.HandlerFunc, m ...echo.MiddlewareFunc) *echo.Route
	PUT(path string, h echo.HandlerFunc, m ...echo.MiddlewareFunc) *echo.Route
	TRACE(path string, h echo.HandlerFunc, m ...echo.MiddlewareFunc) *echo.Route
}

This is a simple interface which specifies echo.Route addition functions which are present on both echo.Echo and echo.Group, since we want to allow using either of them for path registration

type Event

type Event struct {
	// AdditionalMetadata Additional metadata for the event.
	AdditionalMetadata *map[string]interface{} `json:"additionalMetadata,omitempty"`

	// Key The key for the event.
	Key      string          `json:"key"`
	Metadata APIResourceMeta `json:"metadata"`
	Tenant   *Tenant         `json:"tenant,omitempty"`

	// TenantId The ID of the tenant associated with this event.
	TenantId           string                   `json:"tenantId"`
	WorkflowRunSummary *EventWorkflowRunSummary `json:"workflowRunSummary,omitempty"`
}

Event defines model for Event.

type EventCreate200JSONResponse

type EventCreate200JSONResponse Event

func (EventCreate200JSONResponse) VisitEventCreateResponse

func (response EventCreate200JSONResponse) VisitEventCreateResponse(w http.ResponseWriter) error

type EventCreate400JSONResponse

type EventCreate400JSONResponse APIErrors

func (EventCreate400JSONResponse) VisitEventCreateResponse

func (response EventCreate400JSONResponse) VisitEventCreateResponse(w http.ResponseWriter) error

type EventCreate403JSONResponse

type EventCreate403JSONResponse APIErrors

func (EventCreate403JSONResponse) VisitEventCreateResponse

func (response EventCreate403JSONResponse) VisitEventCreateResponse(w http.ResponseWriter) error

type EventCreate429JSONResponse

type EventCreate429JSONResponse APIErrors

func (EventCreate429JSONResponse) VisitEventCreateResponse

func (response EventCreate429JSONResponse) VisitEventCreateResponse(w http.ResponseWriter) error

type EventCreateBulk200JSONResponse

type EventCreateBulk200JSONResponse Events

func (EventCreateBulk200JSONResponse) VisitEventCreateBulkResponse

func (response EventCreateBulk200JSONResponse) VisitEventCreateBulkResponse(w http.ResponseWriter) error

type EventCreateBulk400JSONResponse

type EventCreateBulk400JSONResponse APIErrors

func (EventCreateBulk400JSONResponse) VisitEventCreateBulkResponse

func (response EventCreateBulk400JSONResponse) VisitEventCreateBulkResponse(w http.ResponseWriter) error

type EventCreateBulk403JSONResponse

type EventCreateBulk403JSONResponse APIErrors

func (EventCreateBulk403JSONResponse) VisitEventCreateBulkResponse

func (response EventCreateBulk403JSONResponse) VisitEventCreateBulkResponse(w http.ResponseWriter) error

type EventCreateBulk429JSONResponse

type EventCreateBulk429JSONResponse APIErrors

func (EventCreateBulk429JSONResponse) VisitEventCreateBulkResponse

func (response EventCreateBulk429JSONResponse) VisitEventCreateBulkResponse(w http.ResponseWriter) error

type EventCreateBulkJSONRequestBody

type EventCreateBulkJSONRequestBody = BulkCreateEventRequest

EventCreateBulkJSONRequestBody defines body for EventCreateBulk for application/json ContentType.

type EventCreateBulkRequestObject

type EventCreateBulkRequestObject struct {
	Tenant openapi_types.UUID `json:"tenant"`
	Body   *EventCreateBulkJSONRequestBody
}

type EventCreateBulkResponseObject

type EventCreateBulkResponseObject interface {
	VisitEventCreateBulkResponse(w http.ResponseWriter) error
}

type EventCreateJSONRequestBody

type EventCreateJSONRequestBody = CreateEventRequest

EventCreateJSONRequestBody defines body for EventCreate for application/json ContentType.

type EventCreateRequestObject

type EventCreateRequestObject struct {
	Tenant openapi_types.UUID `json:"tenant"`
	Body   *EventCreateJSONRequestBody
}

type EventCreateResponseObject

type EventCreateResponseObject interface {
	VisitEventCreateResponse(w http.ResponseWriter) error
}

type EventData

type EventData struct {
	// Data The data for the event (JSON bytes).
	Data string `json:"data"`
}

EventData defines model for EventData.

type EventDataGet200JSONResponse

type EventDataGet200JSONResponse EventData

func (EventDataGet200JSONResponse) VisitEventDataGetResponse

func (response EventDataGet200JSONResponse) VisitEventDataGetResponse(w http.ResponseWriter) error

type EventDataGet400JSONResponse

type EventDataGet400JSONResponse APIErrors

func (EventDataGet400JSONResponse) VisitEventDataGetResponse

func (response EventDataGet400JSONResponse) VisitEventDataGetResponse(w http.ResponseWriter) error

type EventDataGet403JSONResponse

type EventDataGet403JSONResponse APIErrors

func (EventDataGet403JSONResponse) VisitEventDataGetResponse

func (response EventDataGet403JSONResponse) VisitEventDataGetResponse(w http.ResponseWriter) error

type EventDataGetRequestObject

type EventDataGetRequestObject struct {
	Event openapi_types.UUID `json:"event"`
}

type EventDataGetResponseObject

type EventDataGetResponseObject interface {
	VisitEventDataGetResponse(w http.ResponseWriter) error
}

type EventGet200JSONResponse

type EventGet200JSONResponse Event

func (EventGet200JSONResponse) VisitEventGetResponse

func (response EventGet200JSONResponse) VisitEventGetResponse(w http.ResponseWriter) error

type EventGet400JSONResponse

type EventGet400JSONResponse APIErrors

func (EventGet400JSONResponse) VisitEventGetResponse

func (response EventGet400JSONResponse) VisitEventGetResponse(w http.ResponseWriter) error

type EventGet403JSONResponse

type EventGet403JSONResponse APIErrors

func (EventGet403JSONResponse) VisitEventGetResponse

func (response EventGet403JSONResponse) VisitEventGetResponse(w http.ResponseWriter) error

type EventGetRequestObject

type EventGetRequestObject struct {
	Event openapi_types.UUID `json:"event"`
}

type EventGetResponseObject

type EventGetResponseObject interface {
	VisitEventGetResponse(w http.ResponseWriter) error
}

type EventKey

type EventKey = string

EventKey The key for the event.

type EventKeyList

type EventKeyList struct {
	Pagination *PaginationResponse `json:"pagination,omitempty"`
	Rows       *[]EventKey         `json:"rows,omitempty"`
}

EventKeyList defines model for EventKeyList.

type EventKeyList200JSONResponse

type EventKeyList200JSONResponse EventKeyList

func (EventKeyList200JSONResponse) VisitEventKeyListResponse

func (response EventKeyList200JSONResponse) VisitEventKeyListResponse(w http.ResponseWriter) error

type EventKeyList400JSONResponse

type EventKeyList400JSONResponse APIErrors

func (EventKeyList400JSONResponse) VisitEventKeyListResponse

func (response EventKeyList400JSONResponse) VisitEventKeyListResponse(w http.ResponseWriter) error

type EventKeyList403JSONResponse

type EventKeyList403JSONResponse APIErrors

func (EventKeyList403JSONResponse) VisitEventKeyListResponse

func (response EventKeyList403JSONResponse) VisitEventKeyListResponse(w http.ResponseWriter) error

type EventKeyListRequestObject

type EventKeyListRequestObject struct {
	Tenant openapi_types.UUID `json:"tenant"`
}

type EventKeyListResponseObject

type EventKeyListResponseObject interface {
	VisitEventKeyListResponse(w http.ResponseWriter) error
}

type EventList

type EventList struct {
	Pagination *PaginationResponse `json:"pagination,omitempty"`
	Rows       *[]Event            `json:"rows,omitempty"`
}

EventList defines model for EventList.

type EventList200JSONResponse

type EventList200JSONResponse EventList

func (EventList200JSONResponse) VisitEventListResponse

func (response EventList200JSONResponse) VisitEventListResponse(w http.ResponseWriter) error

type EventList400JSONResponse

type EventList400JSONResponse APIErrors

func (EventList400JSONResponse) VisitEventListResponse

func (response EventList400JSONResponse) VisitEventListResponse(w http.ResponseWriter) error

type EventList403JSONResponse

type EventList403JSONResponse APIErrors

func (EventList403JSONResponse) VisitEventListResponse

func (response EventList403JSONResponse) VisitEventListResponse(w http.ResponseWriter) error

type EventListParams

type EventListParams struct {
	// Offset The number to skip
	Offset *int64 `form:"offset,omitempty" json:"offset,omitempty"`

	// Limit The number to limit by
	Limit *int64 `form:"limit,omitempty" json:"limit,omitempty"`

	// Keys A list of keys to filter by
	Keys *[]EventKey `form:"keys,omitempty" json:"keys,omitempty"`

	// Workflows A list of workflow IDs to filter by
	Workflows *[]WorkflowID `form:"workflows,omitempty" json:"workflows,omitempty"`

	// Statuses A list of workflow run statuses to filter by
	Statuses *WorkflowRunStatusList `form:"statuses,omitempty" json:"statuses,omitempty"`

	// Search The search query to filter for
	Search *EventSearch `form:"search,omitempty" json:"search,omitempty"`

	// OrderByField What to order by
	OrderByField *EventOrderByField `form:"orderByField,omitempty" json:"orderByField,omitempty"`

	// OrderByDirection The order direction
	OrderByDirection *EventOrderByDirection `form:"orderByDirection,omitempty" json:"orderByDirection,omitempty"`

	// AdditionalMetadata A list of metadata key value pairs to filter by
	AdditionalMetadata *[]string `form:"additionalMetadata,omitempty" json:"additionalMetadata,omitempty"`

	// EventIds A list of event ids to filter by
	EventIds *[]openapi_types.UUID `form:"eventIds,omitempty" json:"eventIds,omitempty"`
}

EventListParams defines parameters for EventList.

type EventListRequestObject

type EventListRequestObject struct {
	Tenant openapi_types.UUID `json:"tenant"`
	Params EventListParams
}

type EventListResponseObject

type EventListResponseObject interface {
	VisitEventListResponse(w http.ResponseWriter) error
}

type EventOrderByDirection

type EventOrderByDirection string

EventOrderByDirection defines model for EventOrderByDirection.

const (
	EventOrderByDirectionAsc  EventOrderByDirection = "asc"
	EventOrderByDirectionDesc EventOrderByDirection = "desc"
)

Defines values for EventOrderByDirection.

type EventOrderByField

type EventOrderByField string

EventOrderByField defines model for EventOrderByField.

const (
	EventOrderByFieldCreatedAt EventOrderByField = "createdAt"
)

Defines values for EventOrderByField.

type EventSearch

type EventSearch = string

EventSearch defines model for EventSearch.

type EventUpdateCancel200JSONResponse

type EventUpdateCancel200JSONResponse struct {
	WorkflowRunIds *[]openapi_types.UUID `json:"workflowRunIds,omitempty"`
}

func (EventUpdateCancel200JSONResponse) VisitEventUpdateCancelResponse

func (response EventUpdateCancel200JSONResponse) VisitEventUpdateCancelResponse(w http.ResponseWriter) error

type EventUpdateCancel400JSONResponse

type EventUpdateCancel400JSONResponse APIErrors

func (EventUpdateCancel400JSONResponse) VisitEventUpdateCancelResponse

func (response EventUpdateCancel400JSONResponse) VisitEventUpdateCancelResponse(w http.ResponseWriter) error

type EventUpdateCancel403JSONResponse

type EventUpdateCancel403JSONResponse APIErrors

func (EventUpdateCancel403JSONResponse) VisitEventUpdateCancelResponse

func (response EventUpdateCancel403JSONResponse) VisitEventUpdateCancelResponse(w http.ResponseWriter) error

type EventUpdateCancel429JSONResponse

type EventUpdateCancel429JSONResponse APIErrors

func (EventUpdateCancel429JSONResponse) VisitEventUpdateCancelResponse

func (response EventUpdateCancel429JSONResponse) VisitEventUpdateCancelResponse(w http.ResponseWriter) error

type EventUpdateCancelJSONRequestBody

type EventUpdateCancelJSONRequestBody = CancelEventRequest

EventUpdateCancelJSONRequestBody defines body for EventUpdateCancel for application/json ContentType.

type EventUpdateCancelRequestObject

type EventUpdateCancelRequestObject struct {
	Tenant openapi_types.UUID `json:"tenant"`
	Body   *EventUpdateCancelJSONRequestBody
}

type EventUpdateCancelResponseObject

type EventUpdateCancelResponseObject interface {
	VisitEventUpdateCancelResponse(w http.ResponseWriter) error
}

type EventUpdateReplay200JSONResponse

type EventUpdateReplay200JSONResponse EventList

func (EventUpdateReplay200JSONResponse) VisitEventUpdateReplayResponse

func (response EventUpdateReplay200JSONResponse) VisitEventUpdateReplayResponse(w http.ResponseWriter) error

type EventUpdateReplay400JSONResponse

type EventUpdateReplay400JSONResponse APIErrors

func (EventUpdateReplay400JSONResponse) VisitEventUpdateReplayResponse

func (response EventUpdateReplay400JSONResponse) VisitEventUpdateReplayResponse(w http.ResponseWriter) error

type EventUpdateReplay403JSONResponse

type EventUpdateReplay403JSONResponse APIErrors

func (EventUpdateReplay403JSONResponse) VisitEventUpdateReplayResponse

func (response EventUpdateReplay403JSONResponse) VisitEventUpdateReplayResponse(w http.ResponseWriter) error

type EventUpdateReplay429JSONResponse

type EventUpdateReplay429JSONResponse APIErrors

func (EventUpdateReplay429JSONResponse) VisitEventUpdateReplayResponse

func (response EventUpdateReplay429JSONResponse) VisitEventUpdateReplayResponse(w http.ResponseWriter) error

type EventUpdateReplayJSONRequestBody

type EventUpdateReplayJSONRequestBody = ReplayEventRequest

EventUpdateReplayJSONRequestBody defines body for EventUpdateReplay for application/json ContentType.

type EventUpdateReplayRequestObject

type EventUpdateReplayRequestObject struct {
	Tenant openapi_types.UUID `json:"tenant"`
	Body   *EventUpdateReplayJSONRequestBody
}

type EventUpdateReplayResponseObject

type EventUpdateReplayResponseObject interface {
	VisitEventUpdateReplayResponse(w http.ResponseWriter) error
}

type EventWorkflowRunSummary

type EventWorkflowRunSummary struct {
	// Cancelled The number of cancelled runs.
	Cancelled *int64 `json:"cancelled,omitempty"`

	// Failed The number of failed runs.
	Failed *int64 `json:"failed,omitempty"`

	// Pending The number of pending runs.
	Pending *int64 `json:"pending,omitempty"`

	// Queued The number of queued runs.
	Queued *int64 `json:"queued,omitempty"`

	// Running The number of running runs.
	Running *int64 `json:"running,omitempty"`

	// Succeeded The number of succeeded runs.
	Succeeded *int64 `json:"succeeded,omitempty"`
}

EventWorkflowRunSummary defines model for EventWorkflowRunSummary.

type Events

type Events struct {
	// Events The events.
	Events   []Event         `json:"events"`
	Metadata APIResourceMeta `json:"metadata"`
}

Events defines model for Events.

type InfoGetVersion200JSONResponse

type InfoGetVersion200JSONResponse struct {
	Version string `json:"version"`
}

func (InfoGetVersion200JSONResponse) VisitInfoGetVersionResponse

func (response InfoGetVersion200JSONResponse) VisitInfoGetVersionResponse(w http.ResponseWriter) error

type InfoGetVersionRequestObject

type InfoGetVersionRequestObject struct {
}

type InfoGetVersionResponseObject

type InfoGetVersionResponseObject interface {
	VisitInfoGetVersionResponse(w http.ResponseWriter) error
}

type Job

type Job struct {
	// Description The description of the job.
	Description *string         `json:"description,omitempty"`
	Metadata    APIResourceMeta `json:"metadata"`
	Name        string          `json:"name"`
	Steps       []Step          `json:"steps"`
	TenantId    string          `json:"tenantId"`

	// Timeout The timeout of the job.
	Timeout   *string `json:"timeout,omitempty"`
	VersionId string  `json:"versionId"`
}

Job defines model for Job.

type JobRun

type JobRun struct {
	CancelledAt     *time.Time              `json:"cancelledAt,omitempty"`
	CancelledError  *string                 `json:"cancelledError,omitempty"`
	CancelledReason *string                 `json:"cancelledReason,omitempty"`
	FinishedAt      *time.Time              `json:"finishedAt,omitempty"`
	Job             *Job                    `json:"job,omitempty"`
	JobId           string                  `json:"jobId"`
	Metadata        APIResourceMeta         `json:"metadata"`
	Result          *map[string]interface{} `json:"result,omitempty"`
	StartedAt       *time.Time              `json:"startedAt,omitempty"`
	Status          JobRunStatus            `json:"status"`
	StepRuns        *[]StepRun              `json:"stepRuns,omitempty"`
	TenantId        string                  `json:"tenantId"`
	TickerId        *string                 `json:"tickerId,omitempty"`
	TimeoutAt       *time.Time              `json:"timeoutAt,omitempty"`
	WorkflowRun     *WorkflowRun            `json:"workflowRun,omitempty"`
	WorkflowRunId   string                  `json:"workflowRunId"`
}

JobRun defines model for JobRun.

type JobRunStatus

type JobRunStatus string

JobRunStatus defines model for JobRunStatus.

const (
	JobRunStatusBACKOFF   JobRunStatus = "BACKOFF"
	JobRunStatusCANCELLED JobRunStatus = "CANCELLED"
	JobRunStatusFAILED    JobRunStatus = "FAILED"
	JobRunStatusPENDING   JobRunStatus = "PENDING"
	JobRunStatusRUNNING   JobRunStatus = "RUNNING"
	JobRunStatusSUCCEEDED JobRunStatus = "SUCCEEDED"
)

Defines values for JobRunStatus.

type ListAPIMetaIntegration

type ListAPIMetaIntegration = []APIMetaIntegration

ListAPIMetaIntegration defines model for ListAPIMetaIntegration.

type ListAPITokensResponse

type ListAPITokensResponse struct {
	Pagination *PaginationResponse `json:"pagination,omitempty"`
	Rows       *[]APIToken         `json:"rows,omitempty"`
}

ListAPITokensResponse defines model for ListAPITokensResponse.

type ListSNSIntegrations

type ListSNSIntegrations struct {
	Pagination PaginationResponse `json:"pagination"`
	Rows       []SNSIntegration   `json:"rows"`
}

ListSNSIntegrations defines model for ListSNSIntegrations.

type ListSlackWebhooks

type ListSlackWebhooks struct {
	Pagination PaginationResponse `json:"pagination"`
	Rows       []SlackWebhook     `json:"rows"`
}

ListSlackWebhooks defines model for ListSlackWebhooks.

type LivenessGet200Response

type LivenessGet200Response struct {
}

func (LivenessGet200Response) VisitLivenessGetResponse

func (response LivenessGet200Response) VisitLivenessGetResponse(w http.ResponseWriter) error

type LivenessGet500Response

type LivenessGet500Response struct {
}

func (LivenessGet500Response) VisitLivenessGetResponse

func (response LivenessGet500Response) VisitLivenessGetResponse(w http.ResponseWriter) error

type LivenessGetRequestObject

type LivenessGetRequestObject struct {
}

type LivenessGetResponseObject

type LivenessGetResponseObject interface {
	VisitLivenessGetResponse(w http.ResponseWriter) error
}

type LogLine

type LogLine struct {
	// CreatedAt The creation date of the log line.
	CreatedAt time.Time `json:"createdAt"`

	// Message The log message.
	Message string `json:"message"`

	// Metadata The log metadata.
	Metadata map[string]interface{} `json:"metadata"`
}

LogLine defines model for LogLine.

type LogLineLevel

type LogLineLevel string

LogLineLevel defines model for LogLineLevel.

const (
	LogLineLevelDEBUG LogLineLevel = "DEBUG"
	LogLineLevelERROR LogLineLevel = "ERROR"
	LogLineLevelINFO  LogLineLevel = "INFO"
	LogLineLevelWARN  LogLineLevel = "WARN"
)

Defines values for LogLineLevel.

type LogLineLevelField

type LogLineLevelField = []LogLineLevel

LogLineLevelField defines model for LogLineLevelField.

type LogLineList

type LogLineList struct {
	Pagination *PaginationResponse `json:"pagination,omitempty"`
	Rows       *[]LogLine          `json:"rows,omitempty"`
}

LogLineList defines model for LogLineList.

type LogLineList200JSONResponse

type LogLineList200JSONResponse LogLineList

func (LogLineList200JSONResponse) VisitLogLineListResponse

func (response LogLineList200JSONResponse) VisitLogLineListResponse(w http.ResponseWriter) error

type LogLineList400JSONResponse

type LogLineList400JSONResponse APIErrors

func (LogLineList400JSONResponse) VisitLogLineListResponse

func (response LogLineList400JSONResponse) VisitLogLineListResponse(w http.ResponseWriter) error

type LogLineList403JSONResponse

type LogLineList403JSONResponse APIErrors

func (LogLineList403JSONResponse) VisitLogLineListResponse

func (response LogLineList403JSONResponse) VisitLogLineListResponse(w http.ResponseWriter) error

type LogLineListParams

type LogLineListParams struct {
	// Offset The number to skip
	Offset *int64 `form:"offset,omitempty" json:"offset,omitempty"`

	// Limit The number to limit by
	Limit *int64 `form:"limit,omitempty" json:"limit,omitempty"`

	// Levels A list of levels to filter by
	Levels *LogLineLevelField `form:"levels,omitempty" json:"levels,omitempty"`

	// Search The search query to filter for
	Search *LogLineSearch `form:"search,omitempty" json:"search,omitempty"`

	// OrderByField What to order by
	OrderByField *LogLineOrderByField `form:"orderByField,omitempty" json:"orderByField,omitempty"`

	// OrderByDirection The order direction
	OrderByDirection *LogLineOrderByDirection `form:"orderByDirection,omitempty" json:"orderByDirection,omitempty"`
}

LogLineListParams defines parameters for LogLineList.

type LogLineListRequestObject

type LogLineListRequestObject struct {
	StepRun openapi_types.UUID `json:"step-run"`
	Params  LogLineListParams
}

type LogLineListResponseObject

type LogLineListResponseObject interface {
	VisitLogLineListResponse(w http.ResponseWriter) error
}

type LogLineOrderByDirection

type LogLineOrderByDirection string

LogLineOrderByDirection defines model for LogLineOrderByDirection.

const (
	LogLineOrderByDirectionAsc  LogLineOrderByDirection = "asc"
	LogLineOrderByDirectionDesc LogLineOrderByDirection = "desc"
)

Defines values for LogLineOrderByDirection.

type LogLineOrderByField

type LogLineOrderByField string

LogLineOrderByField defines model for LogLineOrderByField.

const (
	LogLineOrderByFieldCreatedAt LogLineOrderByField = "createdAt"
)

Defines values for LogLineOrderByField.

type LogLineSearch

type LogLineSearch = string

LogLineSearch defines model for LogLineSearch.

type MetadataGet200JSONResponse

type MetadataGet200JSONResponse APIMeta

func (MetadataGet200JSONResponse) VisitMetadataGetResponse

func (response MetadataGet200JSONResponse) VisitMetadataGetResponse(w http.ResponseWriter) error

type MetadataGet400JSONResponse

type MetadataGet400JSONResponse APIErrors

func (MetadataGet400JSONResponse) VisitMetadataGetResponse

func (response MetadataGet400JSONResponse) VisitMetadataGetResponse(w http.ResponseWriter) error

type MetadataGetRequestObject

type MetadataGetRequestObject struct {
}

type MetadataGetResponseObject

type MetadataGetResponseObject interface {
	VisitMetadataGetResponse(w http.ResponseWriter) error
}

type MetadataListIntegrations200JSONResponse

type MetadataListIntegrations200JSONResponse ListAPIMetaIntegration

func (MetadataListIntegrations200JSONResponse) VisitMetadataListIntegrationsResponse

func (response MetadataListIntegrations200JSONResponse) VisitMetadataListIntegrationsResponse(w http.ResponseWriter) error

type MetadataListIntegrations400JSONResponse

type MetadataListIntegrations400JSONResponse APIErrors

func (MetadataListIntegrations400JSONResponse) VisitMetadataListIntegrationsResponse

func (response MetadataListIntegrations400JSONResponse) VisitMetadataListIntegrationsResponse(w http.ResponseWriter) error

type MetadataListIntegrationsRequestObject

type MetadataListIntegrationsRequestObject struct {
}

type MetadataListIntegrationsResponseObject

type MetadataListIntegrationsResponseObject interface {
	VisitMetadataListIntegrationsResponse(w http.ResponseWriter) error
}

type MonitoringPostRunProbe200Response

type MonitoringPostRunProbe200Response struct {
}

func (MonitoringPostRunProbe200Response) VisitMonitoringPostRunProbeResponse

func (response MonitoringPostRunProbe200Response) VisitMonitoringPostRunProbeResponse(w http.ResponseWriter) error

type MonitoringPostRunProbe403JSONResponse

type MonitoringPostRunProbe403JSONResponse APIErrors

func (MonitoringPostRunProbe403JSONResponse) VisitMonitoringPostRunProbeResponse

func (response MonitoringPostRunProbe403JSONResponse) VisitMonitoringPostRunProbeResponse(w http.ResponseWriter) error

type MonitoringPostRunProbeRequestObject

type MonitoringPostRunProbeRequestObject struct {
	Tenant openapi_types.UUID `json:"tenant"`
}

type MonitoringPostRunProbeResponseObject

type MonitoringPostRunProbeResponseObject interface {
	VisitMonitoringPostRunProbeResponse(w http.ResponseWriter) error
}

type PaginationResponse

type PaginationResponse struct {
	// CurrentPage the current page
	CurrentPage *int64 `json:"current_page,omitempty"`

	// NextPage the next page
	NextPage *int64 `json:"next_page,omitempty"`

	// NumPages the total number of pages for listing
	NumPages *int64 `json:"num_pages,omitempty"`
}

PaginationResponse defines model for PaginationResponse.

type QueueMetrics

type QueueMetrics struct {
	// NumPending The number of items pending.
	NumPending int `json:"numPending"`

	// NumQueued The number of items in the queue.
	NumQueued int `json:"numQueued"`

	// NumRunning The number of items running.
	NumRunning int `json:"numRunning"`
}

QueueMetrics defines model for QueueMetrics.

type RateLimit

type RateLimit struct {
	// Key The key for the rate limit.
	Key string `json:"key"`

	// LastRefill The last time the rate limit was refilled.
	LastRefill time.Time `json:"lastRefill"`

	// LimitValue The maximum number of requests allowed within the window.
	LimitValue int `json:"limitValue"`

	// TenantId The ID of the tenant associated with this rate limit.
	TenantId string `json:"tenantId"`

	// Value The current number of requests made within the window.
	Value int `json:"value"`

	// Window The window of time in which the limitValue is enforced.
	Window string `json:"window"`
}

RateLimit defines model for RateLimit.

type RateLimitList

type RateLimitList struct {
	Pagination *PaginationResponse `json:"pagination,omitempty"`
	Rows       *[]RateLimit        `json:"rows,omitempty"`
}

RateLimitList defines model for RateLimitList.

type RateLimitList200JSONResponse

type RateLimitList200JSONResponse RateLimitList

func (RateLimitList200JSONResponse) VisitRateLimitListResponse

func (response RateLimitList200JSONResponse) VisitRateLimitListResponse(w http.ResponseWriter) error

type RateLimitList400JSONResponse

type RateLimitList400JSONResponse APIErrors

func (RateLimitList400JSONResponse) VisitRateLimitListResponse

func (response RateLimitList400JSONResponse) VisitRateLimitListResponse(w http.ResponseWriter) error

type RateLimitList403JSONResponse

type RateLimitList403JSONResponse APIErrors

func (RateLimitList403JSONResponse) VisitRateLimitListResponse

func (response RateLimitList403JSONResponse) VisitRateLimitListResponse(w http.ResponseWriter) error

type RateLimitListParams

type RateLimitListParams struct {
	// Offset The number to skip
	Offset *int64 `form:"offset,omitempty" json:"offset,omitempty"`

	// Limit The number to limit by
	Limit *int64 `form:"limit,omitempty" json:"limit,omitempty"`

	// Search The search query to filter for
	Search *string `form:"search,omitempty" json:"search,omitempty"`

	// OrderByField What to order by
	OrderByField *RateLimitOrderByField `form:"orderByField,omitempty" json:"orderByField,omitempty"`

	// OrderByDirection The order direction
	OrderByDirection *RateLimitOrderByDirection `form:"orderByDirection,omitempty" json:"orderByDirection,omitempty"`
}

RateLimitListParams defines parameters for RateLimitList.

type RateLimitListRequestObject

type RateLimitListRequestObject struct {
	Tenant openapi_types.UUID `json:"tenant"`
	Params RateLimitListParams
}

type RateLimitListResponseObject

type RateLimitListResponseObject interface {
	VisitRateLimitListResponse(w http.ResponseWriter) error
}

type RateLimitOrderByDirection

type RateLimitOrderByDirection string

RateLimitOrderByDirection defines model for RateLimitOrderByDirection.

const (
	Asc  RateLimitOrderByDirection = "asc"
	Desc RateLimitOrderByDirection = "desc"
)

Defines values for RateLimitOrderByDirection.

type RateLimitOrderByField

type RateLimitOrderByField string

RateLimitOrderByField defines model for RateLimitOrderByField.

const (
	Key        RateLimitOrderByField = "key"
	LimitValue RateLimitOrderByField = "limitValue"
	Value      RateLimitOrderByField = "value"
)

Defines values for RateLimitOrderByField.

type ReadinessGet200Response

type ReadinessGet200Response struct {
}

func (ReadinessGet200Response) VisitReadinessGetResponse

func (response ReadinessGet200Response) VisitReadinessGetResponse(w http.ResponseWriter) error

type ReadinessGet500Response

type ReadinessGet500Response struct {
}

func (ReadinessGet500Response) VisitReadinessGetResponse

func (response ReadinessGet500Response) VisitReadinessGetResponse(w http.ResponseWriter) error

type ReadinessGetRequestObject

type ReadinessGetRequestObject struct {
}

type ReadinessGetResponseObject

type ReadinessGetResponseObject interface {
	VisitReadinessGetResponse(w http.ResponseWriter) error
}

type RecentStepRuns

type RecentStepRuns struct {
	// ActionId The action id.
	ActionId      string             `json:"actionId"`
	CancelledAt   *time.Time         `json:"cancelledAt,omitempty"`
	FinishedAt    *time.Time         `json:"finishedAt,omitempty"`
	Metadata      APIResourceMeta    `json:"metadata"`
	StartedAt     *time.Time         `json:"startedAt,omitempty"`
	Status        StepRunStatus      `json:"status"`
	WorkflowRunId openapi_types.UUID `json:"workflowRunId"`
}

RecentStepRuns defines model for RecentStepRuns.

type RejectInviteRequest

type RejectInviteRequest struct {
	Invite string `json:"invite" validate:"required,uuid"`
}

RejectInviteRequest defines model for RejectInviteRequest.

type ReplayEventRequest

type ReplayEventRequest struct {
	EventIds []openapi_types.UUID `json:"eventIds"`
}

ReplayEventRequest defines model for ReplayEventRequest.

type ReplayWorkflowRunsRequest

type ReplayWorkflowRunsRequest struct {
	WorkflowRunIds []openapi_types.UUID `json:"workflowRunIds"`
}

ReplayWorkflowRunsRequest defines model for ReplayWorkflowRunsRequest.

type ReplayWorkflowRunsResponse

type ReplayWorkflowRunsResponse struct {
	WorkflowRuns []WorkflowRun `json:"workflowRuns"`
}

ReplayWorkflowRunsResponse defines model for ReplayWorkflowRunsResponse.

type RerunStepRunRequest

type RerunStepRunRequest struct {
	Input map[string]interface{} `json:"input"`
}

RerunStepRunRequest defines model for RerunStepRunRequest.

type SNSIntegration

type SNSIntegration struct {
	// IngestUrl The URL to send SNS messages to.
	IngestUrl *string         `json:"ingestUrl,omitempty"`
	Metadata  APIResourceMeta `json:"metadata"`

	// TenantId The unique identifier for the tenant that the SNS integration belongs to.
	TenantId openapi_types.UUID `json:"tenantId"`

	// TopicArn The Amazon Resource Name (ARN) of the SNS topic.
	TopicArn string `json:"topicArn"`
}

SNSIntegration defines model for SNSIntegration.

type ScheduleWorkflowRunRequest

type ScheduleWorkflowRunRequest struct {
	AdditionalMetadata map[string]interface{} `json:"additionalMetadata"`
	Input              map[string]interface{} `json:"input"`
	TriggerAt          time.Time              `json:"triggerAt"`
}

ScheduleWorkflowRunRequest defines model for ScheduleWorkflowRunRequest.

type ScheduledRunStatus

type ScheduledRunStatus string

ScheduledRunStatus defines model for ScheduledRunStatus.

const (
	ScheduledRunStatusCANCELLED ScheduledRunStatus = "CANCELLED"
	ScheduledRunStatusFAILED    ScheduledRunStatus = "FAILED"
	ScheduledRunStatusPENDING   ScheduledRunStatus = "PENDING"
	ScheduledRunStatusQUEUED    ScheduledRunStatus = "QUEUED"
	ScheduledRunStatusRUNNING   ScheduledRunStatus = "RUNNING"
	ScheduledRunStatusSCHEDULED ScheduledRunStatus = "SCHEDULED"
	ScheduledRunStatusSUCCEEDED ScheduledRunStatus = "SUCCEEDED"
)

Defines values for ScheduledRunStatus.

type ScheduledWorkflowRunCreate200JSONResponse

type ScheduledWorkflowRunCreate200JSONResponse ScheduledWorkflows

func (ScheduledWorkflowRunCreate200JSONResponse) VisitScheduledWorkflowRunCreateResponse

func (response ScheduledWorkflowRunCreate200JSONResponse) VisitScheduledWorkflowRunCreateResponse(w http.ResponseWriter) error

type ScheduledWorkflowRunCreate400JSONResponse

type ScheduledWorkflowRunCreate400JSONResponse APIErrors

func (ScheduledWorkflowRunCreate400JSONResponse) VisitScheduledWorkflowRunCreateResponse

func (response ScheduledWorkflowRunCreate400JSONResponse) VisitScheduledWorkflowRunCreateResponse(w http.ResponseWriter) error

type ScheduledWorkflowRunCreate403JSONResponse

type ScheduledWorkflowRunCreate403JSONResponse APIErrors

func (ScheduledWorkflowRunCreate403JSONResponse) VisitScheduledWorkflowRunCreateResponse

func (response ScheduledWorkflowRunCreate403JSONResponse) VisitScheduledWorkflowRunCreateResponse(w http.ResponseWriter) error

type ScheduledWorkflowRunCreate404JSONResponse

type ScheduledWorkflowRunCreate404JSONResponse APIErrors

func (ScheduledWorkflowRunCreate404JSONResponse) VisitScheduledWorkflowRunCreateResponse

func (response ScheduledWorkflowRunCreate404JSONResponse) VisitScheduledWorkflowRunCreateResponse(w http.ResponseWriter) error

type ScheduledWorkflowRunCreate429JSONResponse

type ScheduledWorkflowRunCreate429JSONResponse APIErrors

func (ScheduledWorkflowRunCreate429JSONResponse) VisitScheduledWorkflowRunCreateResponse

func (response ScheduledWorkflowRunCreate429JSONResponse) VisitScheduledWorkflowRunCreateResponse(w http.ResponseWriter) error

type ScheduledWorkflowRunCreateJSONRequestBody

type ScheduledWorkflowRunCreateJSONRequestBody = ScheduleWorkflowRunRequest

ScheduledWorkflowRunCreateJSONRequestBody defines body for ScheduledWorkflowRunCreate for application/json ContentType.

type ScheduledWorkflowRunCreateRequestObject

type ScheduledWorkflowRunCreateRequestObject struct {
	Tenant   openapi_types.UUID `json:"tenant"`
	Workflow string             `json:"workflow"`
	Body     *ScheduledWorkflowRunCreateJSONRequestBody
}

type ScheduledWorkflowRunCreateResponseObject

type ScheduledWorkflowRunCreateResponseObject interface {
	VisitScheduledWorkflowRunCreateResponse(w http.ResponseWriter) error
}

type ScheduledWorkflows

type ScheduledWorkflows struct {
	AdditionalMetadata   *map[string]interface{}  `json:"additionalMetadata,omitempty"`
	Input                *map[string]interface{}  `json:"input,omitempty"`
	Metadata             APIResourceMeta          `json:"metadata"`
	Method               ScheduledWorkflowsMethod `json:"method"`
	TenantId             string                   `json:"tenantId"`
	TriggerAt            time.Time                `json:"triggerAt"`
	WorkflowId           string                   `json:"workflowId"`
	WorkflowName         string                   `json:"workflowName"`
	WorkflowRunCreatedAt *time.Time               `json:"workflowRunCreatedAt,omitempty"`
	WorkflowRunId        *openapi_types.UUID      `json:"workflowRunId,omitempty"`
	WorkflowRunName      *string                  `json:"workflowRunName,omitempty"`
	WorkflowRunStatus    *WorkflowRunStatus       `json:"workflowRunStatus,omitempty"`
	WorkflowVersionId    string                   `json:"workflowVersionId"`
}

ScheduledWorkflows defines model for ScheduledWorkflows.

type ScheduledWorkflowsList

type ScheduledWorkflowsList struct {
	Pagination *PaginationResponse   `json:"pagination,omitempty"`
	Rows       *[]ScheduledWorkflows `json:"rows,omitempty"`
}

ScheduledWorkflowsList defines model for ScheduledWorkflowsList.

type ScheduledWorkflowsMethod

type ScheduledWorkflowsMethod string

ScheduledWorkflowsMethod defines model for ScheduledWorkflowsMethod.

const (
	ScheduledWorkflowsMethodAPI     ScheduledWorkflowsMethod = "API"
	ScheduledWorkflowsMethodDEFAULT ScheduledWorkflowsMethod = "DEFAULT"
)

Defines values for ScheduledWorkflowsMethod.

type ScheduledWorkflowsOrderByField

type ScheduledWorkflowsOrderByField string

ScheduledWorkflowsOrderByField defines model for ScheduledWorkflowsOrderByField.

const (
	ScheduledWorkflowsOrderByFieldCreatedAt ScheduledWorkflowsOrderByField = "createdAt"
	ScheduledWorkflowsOrderByFieldTriggerAt ScheduledWorkflowsOrderByField = "triggerAt"
)

Defines values for ScheduledWorkflowsOrderByField.

type SemaphoreSlots

type SemaphoreSlots struct {
	// ActionId The action id.
	ActionId string `json:"actionId"`

	// StartedAt The time this slot was started.
	StartedAt *time.Time    `json:"startedAt,omitempty"`
	Status    StepRunStatus `json:"status"`

	// StepRunId The step run id.
	StepRunId openapi_types.UUID `json:"stepRunId"`

	// TimeoutAt The time this slot will timeout.
	TimeoutAt *time.Time `json:"timeoutAt,omitempty"`

	// WorkflowRunId The workflow run id.
	WorkflowRunId openapi_types.UUID `json:"workflowRunId"`
}

SemaphoreSlots defines model for SemaphoreSlots.

type ServerInterface

type ServerInterface interface {
	// Get liveness
	// (GET /api/live)
	LivenessGet(ctx echo.Context) error
	// Get readiness
	// (GET /api/ready)
	ReadinessGet(ctx echo.Context) error
	// Delete tenant alert email group
	// (DELETE /api/v1/alerting-email-groups/{alert-email-group})
	AlertEmailGroupDelete(ctx echo.Context, alertEmailGroup openapi_types.UUID) error
	// Update tenant alert email group
	// (PATCH /api/v1/alerting-email-groups/{alert-email-group})
	AlertEmailGroupUpdate(ctx echo.Context, alertEmailGroup openapi_types.UUID) error
	// Revoke API Token
	// (POST /api/v1/api-tokens/{api-token})
	ApiTokenUpdateRevoke(ctx echo.Context, apiToken openapi_types.UUID) error
	// Get cloud metadata
	// (GET /api/v1/cloud/metadata)
	CloudMetadataGet(ctx echo.Context) error
	// Get event data
	// (GET /api/v1/events/{event})
	EventGet(ctx echo.Context, event openapi_types.UUID) error
	// Get event data
	// (GET /api/v1/events/{event}/data)
	EventDataGet(ctx echo.Context, event openapi_types.UUID) error
	// Get metadata
	// (GET /api/v1/meta)
	MetadataGet(ctx echo.Context) error
	// List integrations
	// (GET /api/v1/meta/integrations)
	MetadataListIntegrations(ctx echo.Context) error
	// Detailed Health Probe For the Instance
	// (POST /api/v1/monitoring/{tenant}/probe)
	MonitoringPostRunProbe(ctx echo.Context, tenant openapi_types.UUID) error
	// Delete Slack webhook
	// (DELETE /api/v1/slack/{slack})
	SlackWebhookDelete(ctx echo.Context, slack openapi_types.UUID) error
	// Delete SNS integration
	// (DELETE /api/v1/sns/{sns})
	SnsDelete(ctx echo.Context, sns openapi_types.UUID) error
	// Github app tenant webhook
	// (POST /api/v1/sns/{tenant}/{event})
	SnsUpdate(ctx echo.Context, tenant openapi_types.UUID, event string) error
	// List tasks
	// (GET /api/v1/stable/dags/tasks)
	V1DagListTasks(ctx echo.Context, params V1DagListTasksParams) error
	// Get a task
	// (GET /api/v1/stable/tasks/{task})
	V1TaskGet(ctx echo.Context, task openapi_types.UUID) error
	// List log lines
	// (GET /api/v1/stable/tasks/{task}/logs)
	V1LogLineList(ctx echo.Context, task openapi_types.UUID) error
	// List events for a task
	// (GET /api/v1/stable/tasks/{task}/task-events)
	V1TaskEventList(ctx echo.Context, task openapi_types.UUID, params V1TaskEventListParams) error
	// Get task metrics
	// (GET /api/v1/stable/tenants/{tenant}/task-metrics)
	V1TaskListStatusMetrics(ctx echo.Context, tenant openapi_types.UUID, params V1TaskListStatusMetricsParams) error
	// Get task point metrics
	// (GET /api/v1/stable/tenants/{tenant}/task-point-metrics)
	V1TaskGetPointMetrics(ctx echo.Context, tenant openapi_types.UUID, params V1TaskGetPointMetricsParams) error
	// Cancel tasks
	// (POST /api/v1/stable/tenants/{tenant}/tasks/cancel)
	V1TaskCancel(ctx echo.Context, tenant openapi_types.UUID) error
	// Replay tasks
	// (POST /api/v1/stable/tenants/{tenant}/tasks/replay)
	V1TaskReplay(ctx echo.Context, tenant openapi_types.UUID) error
	// List workflow runs
	// (GET /api/v1/stable/tenants/{tenant}/workflow-runs)
	V1WorkflowRunList(ctx echo.Context, tenant openapi_types.UUID, params V1WorkflowRunListParams) error
	// List workflow runs
	// (GET /api/v1/stable/tenants/{tenant}/workflow-runs/display-names)
	V1WorkflowRunDisplayNamesList(ctx echo.Context, tenant openapi_types.UUID, params V1WorkflowRunDisplayNamesListParams) error
	// Create workflow run
	// (POST /api/v1/stable/tenants/{tenant}/workflow-runs/trigger)
	V1WorkflowRunCreate(ctx echo.Context, tenant openapi_types.UUID) error
	// List tasks
	// (GET /api/v1/stable/workflow-runs/{v1-workflow-run})
	V1WorkflowRunGet(ctx echo.Context, v1WorkflowRun openapi_types.UUID) error
	// List tasks
	// (GET /api/v1/stable/workflow-runs/{v1-workflow-run}/task-events)
	V1WorkflowRunTaskEventsList(ctx echo.Context, v1WorkflowRun openapi_types.UUID, params V1WorkflowRunTaskEventsListParams) error
	// List archives for step run
	// (GET /api/v1/step-runs/{step-run}/archives)
	StepRunListArchives(ctx echo.Context, stepRun openapi_types.UUID, params StepRunListArchivesParams) error
	// List events for step run
	// (GET /api/v1/step-runs/{step-run}/events)
	StepRunListEvents(ctx echo.Context, stepRun openapi_types.UUID, params StepRunListEventsParams) error
	// List log lines
	// (GET /api/v1/step-runs/{step-run}/logs)
	LogLineList(ctx echo.Context, stepRun openapi_types.UUID, params LogLineListParams) error
	// Create tenant
	// (POST /api/v1/tenants)
	TenantCreate(ctx echo.Context) error
	// Update tenant
	// (PATCH /api/v1/tenants/{tenant})
	TenantUpdate(ctx echo.Context, tenant openapi_types.UUID) error
	// List tenant alert email groups
	// (GET /api/v1/tenants/{tenant}/alerting-email-groups)
	AlertEmailGroupList(ctx echo.Context, tenant openapi_types.UUID) error
	// Create tenant alert email group
	// (POST /api/v1/tenants/{tenant}/alerting-email-groups)
	AlertEmailGroupCreate(ctx echo.Context, tenant openapi_types.UUID) error
	// Get tenant alerting settings
	// (GET /api/v1/tenants/{tenant}/alerting/settings)
	TenantAlertingSettingsGet(ctx echo.Context, tenant openapi_types.UUID) error
	// List API Tokens
	// (GET /api/v1/tenants/{tenant}/api-tokens)
	ApiTokenList(ctx echo.Context, tenant openapi_types.UUID) error
	// Create API Token
	// (POST /api/v1/tenants/{tenant}/api-tokens)
	ApiTokenCreate(ctx echo.Context, tenant openapi_types.UUID) error
	// List events
	// (GET /api/v1/tenants/{tenant}/events)
	EventList(ctx echo.Context, tenant openapi_types.UUID, params EventListParams) error
	// Create event
	// (POST /api/v1/tenants/{tenant}/events)
	EventCreate(ctx echo.Context, tenant openapi_types.UUID) error
	// Bulk Create events
	// (POST /api/v1/tenants/{tenant}/events/bulk)
	EventCreateBulk(ctx echo.Context, tenant openapi_types.UUID) error
	// Replay events
	// (POST /api/v1/tenants/{tenant}/events/cancel)
	EventUpdateCancel(ctx echo.Context, tenant openapi_types.UUID) error
	// List event keys
	// (GET /api/v1/tenants/{tenant}/events/keys)
	EventKeyList(ctx echo.Context, tenant openapi_types.UUID) error
	// Replay events
	// (POST /api/v1/tenants/{tenant}/events/replay)
	EventUpdateReplay(ctx echo.Context, tenant openapi_types.UUID) error
	// List tenant invites
	// (GET /api/v1/tenants/{tenant}/invites)
	TenantInviteList(ctx echo.Context, tenant openapi_types.UUID) error
	// Create tenant invite
	// (POST /api/v1/tenants/{tenant}/invites)
	TenantInviteCreate(ctx echo.Context, tenant openapi_types.UUID) error
	// Delete invite
	// (DELETE /api/v1/tenants/{tenant}/invites/{tenant-invite})
	TenantInviteDelete(ctx echo.Context, tenant openapi_types.UUID, tenantInvite openapi_types.UUID) error
	// Update invite
	// (PATCH /api/v1/tenants/{tenant}/invites/{tenant-invite})
	TenantInviteUpdate(ctx echo.Context, tenant openapi_types.UUID, tenantInvite openapi_types.UUID) error
	// List tenant members
	// (GET /api/v1/tenants/{tenant}/members)
	TenantMemberList(ctx echo.Context, tenant openapi_types.UUID) error
	// Delete a tenant member
	// (DELETE /api/v1/tenants/{tenant}/members/{member})
	TenantMemberDelete(ctx echo.Context, tenant openapi_types.UUID, member openapi_types.UUID) error
	// Get workflow metrics
	// (GET /api/v1/tenants/{tenant}/queue-metrics)
	TenantGetQueueMetrics(ctx echo.Context, tenant openapi_types.UUID, params TenantGetQueueMetricsParams) error
	// List rate limits
	// (GET /api/v1/tenants/{tenant}/rate-limits)
	RateLimitList(ctx echo.Context, tenant openapi_types.UUID, params RateLimitListParams) error
	// Create tenant alert email group
	// (GET /api/v1/tenants/{tenant}/resource-policy)
	TenantResourcePolicyGet(ctx echo.Context, tenant openapi_types.UUID) error
	// List Slack integrations
	// (GET /api/v1/tenants/{tenant}/slack)
	SlackWebhookList(ctx echo.Context, tenant openapi_types.UUID) error
	// Start OAuth flow
	// (GET /api/v1/tenants/{tenant}/slack/start)
	UserUpdateSlackOauthStart(ctx echo.Context, tenant openapi_types.UUID) error
	// List SNS integrations
	// (GET /api/v1/tenants/{tenant}/sns)
	SnsList(ctx echo.Context, tenant openapi_types.UUID) error
	// Create SNS integration
	// (POST /api/v1/tenants/{tenant}/sns)
	SnsCreate(ctx echo.Context, tenant openapi_types.UUID) error
	// Get step run metrics
	// (GET /api/v1/tenants/{tenant}/step-run-queue-metrics)
	TenantGetStepRunQueueMetrics(ctx echo.Context, tenant openapi_types.UUID) error
	// Get step run
	// (GET /api/v1/tenants/{tenant}/step-runs/{step-run})
	StepRunGet(ctx echo.Context, tenant openapi_types.UUID, stepRun openapi_types.UUID) error
	// Attempts to cancel a step run
	// (POST /api/v1/tenants/{tenant}/step-runs/{step-run}/cancel)
	StepRunUpdateCancel(ctx echo.Context, tenant openapi_types.UUID, stepRun openapi_types.UUID) error
	// Rerun step run
	// (POST /api/v1/tenants/{tenant}/step-runs/{step-run}/rerun)
	StepRunUpdateRerun(ctx echo.Context, tenant openapi_types.UUID, stepRun openapi_types.UUID) error
	// Get step run schema
	// (GET /api/v1/tenants/{tenant}/step-runs/{step-run}/schema)
	StepRunGetSchema(ctx echo.Context, tenant openapi_types.UUID, stepRun openapi_types.UUID) error
	// List webhooks
	// (GET /api/v1/tenants/{tenant}/webhook-workers)
	WebhookList(ctx echo.Context, tenant openapi_types.UUID) error
	// Create a webhook
	// (POST /api/v1/tenants/{tenant}/webhook-workers)
	WebhookCreate(ctx echo.Context, tenant openapi_types.UUID) error
	// Get workers
	// (GET /api/v1/tenants/{tenant}/worker)
	WorkerList(ctx echo.Context, tenant openapi_types.UUID) error
	// Replay workflow runs
	// (POST /api/v1/tenants/{tenant}/workflow-runs/replay)
	WorkflowRunUpdateReplay(ctx echo.Context, tenant openapi_types.UUID) error
	// Get workflow run
	// (GET /api/v1/tenants/{tenant}/workflow-runs/{workflow-run})
	WorkflowRunGet(ctx echo.Context, tenant openapi_types.UUID, workflowRun openapi_types.UUID) error
	// Get workflow run input
	// (GET /api/v1/tenants/{tenant}/workflow-runs/{workflow-run}/input)
	WorkflowRunGetInput(ctx echo.Context, tenant openapi_types.UUID, workflowRun openapi_types.UUID) error
	// Get workflow run
	// (GET /api/v1/tenants/{tenant}/workflow-runs/{workflow-run}/shape)
	WorkflowRunGetShape(ctx echo.Context, tenant openapi_types.UUID, workflowRun openapi_types.UUID) error
	// List events for all step runs for a workflow run
	// (GET /api/v1/tenants/{tenant}/workflow-runs/{workflow-run}/step-run-events)
	WorkflowRunListStepRunEvents(ctx echo.Context, tenant openapi_types.UUID, workflowRun openapi_types.UUID, params WorkflowRunListStepRunEventsParams) error
	// Get workflows
	// (GET /api/v1/tenants/{tenant}/workflows)
	WorkflowList(ctx echo.Context, tenant openapi_types.UUID, params WorkflowListParams) error
	// Cancel workflow runs
	// (POST /api/v1/tenants/{tenant}/workflows/cancel)
	WorkflowRunCancel(ctx echo.Context, tenant openapi_types.UUID) error
	// Get cron job workflows
	// (GET /api/v1/tenants/{tenant}/workflows/crons)
	CronWorkflowList(ctx echo.Context, tenant openapi_types.UUID, params CronWorkflowListParams) error
	// Delete cron job workflow run
	// (DELETE /api/v1/tenants/{tenant}/workflows/crons/{cron-workflow})
	WorkflowCronDelete(ctx echo.Context, tenant openapi_types.UUID, cronWorkflow openapi_types.UUID) error
	// Get cron job workflow run
	// (GET /api/v1/tenants/{tenant}/workflows/crons/{cron-workflow})
	WorkflowCronGet(ctx echo.Context, tenant openapi_types.UUID, cronWorkflow openapi_types.UUID) error
	// Get workflow runs
	// (GET /api/v1/tenants/{tenant}/workflows/runs)
	WorkflowRunList(ctx echo.Context, tenant openapi_types.UUID, params WorkflowRunListParams) error
	// Get workflow runs metrics
	// (GET /api/v1/tenants/{tenant}/workflows/runs/metrics)
	WorkflowRunGetMetrics(ctx echo.Context, tenant openapi_types.UUID, params WorkflowRunGetMetricsParams) error
	// Get scheduled workflow runs
	// (GET /api/v1/tenants/{tenant}/workflows/scheduled)
	WorkflowScheduledList(ctx echo.Context, tenant openapi_types.UUID, params WorkflowScheduledListParams) error
	// Delete scheduled workflow run
	// (DELETE /api/v1/tenants/{tenant}/workflows/scheduled/{scheduled-workflow-run})
	WorkflowScheduledDelete(ctx echo.Context, tenant openapi_types.UUID, scheduledWorkflowRun openapi_types.UUID) error
	// Get scheduled workflow run
	// (GET /api/v1/tenants/{tenant}/workflows/scheduled/{scheduled-workflow-run})
	WorkflowScheduledGet(ctx echo.Context, tenant openapi_types.UUID, scheduledWorkflowRun openapi_types.UUID) error
	// Create cron job workflow trigger
	// (POST /api/v1/tenants/{tenant}/workflows/{workflow}/crons)
	CronWorkflowTriggerCreate(ctx echo.Context, tenant openapi_types.UUID, workflow string) error
	// Trigger workflow run
	// (POST /api/v1/tenants/{tenant}/workflows/{workflow}/scheduled)
	ScheduledWorkflowRunCreate(ctx echo.Context, tenant openapi_types.UUID, workflow string) error
	// Get workflow worker count
	// (GET /api/v1/tenants/{tenant}/workflows/{workflow}/worker-count)
	WorkflowGetWorkersCount(ctx echo.Context, tenant openapi_types.UUID, workflow openapi_types.UUID) error
	// Get current user
	// (GET /api/v1/users/current)
	UserGetCurrent(ctx echo.Context) error
	// Complete OAuth flow
	// (GET /api/v1/users/github/callback)
	UserUpdateGithubOauthCallback(ctx echo.Context) error
	// Start OAuth flow
	// (GET /api/v1/users/github/start)
	UserUpdateGithubOauthStart(ctx echo.Context) error
	// Complete OAuth flow
	// (GET /api/v1/users/google/callback)
	UserUpdateGoogleOauthCallback(ctx echo.Context) error
	// Start OAuth flow
	// (GET /api/v1/users/google/start)
	UserUpdateGoogleOauthStart(ctx echo.Context) error
	// List tenant invites
	// (GET /api/v1/users/invites)
	UserListTenantInvites(ctx echo.Context) error
	// Accept tenant invite
	// (POST /api/v1/users/invites/accept)
	TenantInviteAccept(ctx echo.Context) error
	// Reject tenant invite
	// (POST /api/v1/users/invites/reject)
	TenantInviteReject(ctx echo.Context) error
	// Login user
	// (POST /api/v1/users/login)
	UserUpdateLogin(ctx echo.Context) error
	// Logout user
	// (POST /api/v1/users/logout)
	UserUpdateLogout(ctx echo.Context) error
	// List tenant memberships
	// (GET /api/v1/users/memberships)
	TenantMembershipsList(ctx echo.Context) error
	// Change user password
	// (POST /api/v1/users/password)
	UserUpdatePassword(ctx echo.Context) error
	// Register user
	// (POST /api/v1/users/register)
	UserCreate(ctx echo.Context) error
	// Complete OAuth flow
	// (GET /api/v1/users/slack/callback)
	UserUpdateSlackOauthCallback(ctx echo.Context) error
	// We return the version for the currently running server
	// (GET /api/v1/version)
	InfoGetVersion(ctx echo.Context) error
	// Delete a webhook
	// (DELETE /api/v1/webhook-workers/{webhook})
	WebhookDelete(ctx echo.Context, webhook openapi_types.UUID) error
	// List webhook requests
	// (GET /api/v1/webhook-workers/{webhook}/requests)
	WebhookRequestsList(ctx echo.Context, webhook openapi_types.UUID) error
	// Get worker
	// (GET /api/v1/workers/{worker})
	WorkerGet(ctx echo.Context, worker openapi_types.UUID) error
	// Update worker
	// (PATCH /api/v1/workers/{worker})
	WorkerUpdate(ctx echo.Context, worker openapi_types.UUID) error
	// Delete workflow
	// (DELETE /api/v1/workflows/{workflow})
	WorkflowDelete(ctx echo.Context, workflow openapi_types.UUID) error
	// Get workflow
	// (GET /api/v1/workflows/{workflow})
	WorkflowGet(ctx echo.Context, workflow openapi_types.UUID) error
	// Update workflow
	// (PATCH /api/v1/workflows/{workflow})
	WorkflowUpdate(ctx echo.Context, workflow openapi_types.UUID) error
	// Get workflow metrics
	// (GET /api/v1/workflows/{workflow}/metrics)
	WorkflowGetMetrics(ctx echo.Context, workflow openapi_types.UUID, params WorkflowGetMetricsParams) error
	// Trigger workflow run
	// (POST /api/v1/workflows/{workflow}/trigger)
	WorkflowRunCreate(ctx echo.Context, workflow openapi_types.UUID, params WorkflowRunCreateParams) error
	// Get workflow version
	// (GET /api/v1/workflows/{workflow}/versions)
	WorkflowVersionGet(ctx echo.Context, workflow openapi_types.UUID, params WorkflowVersionGetParams) error
}

ServerInterface represents all server handlers.

func NewStrictHandler

func NewStrictHandler(ssi StrictServerInterface, middlewares []StrictMiddlewareFunc) ServerInterface

type ServerInterfaceWrapper

type ServerInterfaceWrapper struct {
	Handler ServerInterface
}

ServerInterfaceWrapper converts echo contexts to parameters.

func (*ServerInterfaceWrapper) AlertEmailGroupCreate

func (w *ServerInterfaceWrapper) AlertEmailGroupCreate(ctx echo.Context) error

AlertEmailGroupCreate converts echo context to params.

func (*ServerInterfaceWrapper) AlertEmailGroupDelete

func (w *ServerInterfaceWrapper) AlertEmailGroupDelete(ctx echo.Context) error

AlertEmailGroupDelete converts echo context to params.

func (*ServerInterfaceWrapper) AlertEmailGroupList

func (w *ServerInterfaceWrapper) AlertEmailGroupList(ctx echo.Context) error

AlertEmailGroupList converts echo context to params.

func (*ServerInterfaceWrapper) AlertEmailGroupUpdate

func (w *ServerInterfaceWrapper) AlertEmailGroupUpdate(ctx echo.Context) error

AlertEmailGroupUpdate converts echo context to params.

func (*ServerInterfaceWrapper) ApiTokenCreate

func (w *ServerInterfaceWrapper) ApiTokenCreate(ctx echo.Context) error

ApiTokenCreate converts echo context to params.

func (*ServerInterfaceWrapper) ApiTokenList

func (w *ServerInterfaceWrapper) ApiTokenList(ctx echo.Context) error

ApiTokenList converts echo context to params.

func (*ServerInterfaceWrapper) ApiTokenUpdateRevoke

func (w *ServerInterfaceWrapper) ApiTokenUpdateRevoke(ctx echo.Context) error

ApiTokenUpdateRevoke converts echo context to params.

func (*ServerInterfaceWrapper) CloudMetadataGet

func (w *ServerInterfaceWrapper) CloudMetadataGet(ctx echo.Context) error

CloudMetadataGet converts echo context to params.

func (*ServerInterfaceWrapper) CronWorkflowList

func (w *ServerInterfaceWrapper) CronWorkflowList(ctx echo.Context) error

CronWorkflowList converts echo context to params.

func (*ServerInterfaceWrapper) CronWorkflowTriggerCreate

func (w *ServerInterfaceWrapper) CronWorkflowTriggerCreate(ctx echo.Context) error

CronWorkflowTriggerCreate converts echo context to params.

func (*ServerInterfaceWrapper) EventCreate

func (w *ServerInterfaceWrapper) EventCreate(ctx echo.Context) error

EventCreate converts echo context to params.

func (*ServerInterfaceWrapper) EventCreateBulk

func (w *ServerInterfaceWrapper) EventCreateBulk(ctx echo.Context) error

EventCreateBulk converts echo context to params.

func (*ServerInterfaceWrapper) EventDataGet

func (w *ServerInterfaceWrapper) EventDataGet(ctx echo.Context) error

EventDataGet converts echo context to params.

func (*ServerInterfaceWrapper) EventGet

func (w *ServerInterfaceWrapper) EventGet(ctx echo.Context) error

EventGet converts echo context to params.

func (*ServerInterfaceWrapper) EventKeyList

func (w *ServerInterfaceWrapper) EventKeyList(ctx echo.Context) error

EventKeyList converts echo context to params.

func (*ServerInterfaceWrapper) EventList

func (w *ServerInterfaceWrapper) EventList(ctx echo.Context) error

EventList converts echo context to params.

func (*ServerInterfaceWrapper) EventUpdateCancel

func (w *ServerInterfaceWrapper) EventUpdateCancel(ctx echo.Context) error

EventUpdateCancel converts echo context to params.

func (*ServerInterfaceWrapper) EventUpdateReplay

func (w *ServerInterfaceWrapper) EventUpdateReplay(ctx echo.Context) error

EventUpdateReplay converts echo context to params.

func (*ServerInterfaceWrapper) InfoGetVersion

func (w *ServerInterfaceWrapper) InfoGetVersion(ctx echo.Context) error

InfoGetVersion converts echo context to params.

func (*ServerInterfaceWrapper) LivenessGet

func (w *ServerInterfaceWrapper) LivenessGet(ctx echo.Context) error

LivenessGet converts echo context to params.

func (*ServerInterfaceWrapper) LogLineList

func (w *ServerInterfaceWrapper) LogLineList(ctx echo.Context) error

LogLineList converts echo context to params.

func (*ServerInterfaceWrapper) MetadataGet

func (w *ServerInterfaceWrapper) MetadataGet(ctx echo.Context) error

MetadataGet converts echo context to params.

func (*ServerInterfaceWrapper) MetadataListIntegrations

func (w *ServerInterfaceWrapper) MetadataListIntegrations(ctx echo.Context) error

MetadataListIntegrations converts echo context to params.

func (*ServerInterfaceWrapper) MonitoringPostRunProbe

func (w *ServerInterfaceWrapper) MonitoringPostRunProbe(ctx echo.Context) error

MonitoringPostRunProbe converts echo context to params.

func (*ServerInterfaceWrapper) RateLimitList

func (w *ServerInterfaceWrapper) RateLimitList(ctx echo.Context) error

RateLimitList converts echo context to params.

func (*ServerInterfaceWrapper) ReadinessGet

func (w *ServerInterfaceWrapper) ReadinessGet(ctx echo.Context) error

ReadinessGet converts echo context to params.

func (*ServerInterfaceWrapper) ScheduledWorkflowRunCreate

func (w *ServerInterfaceWrapper) ScheduledWorkflowRunCreate(ctx echo.Context) error

ScheduledWorkflowRunCreate converts echo context to params.

func (*ServerInterfaceWrapper) SlackWebhookDelete

func (w *ServerInterfaceWrapper) SlackWebhookDelete(ctx echo.Context) error

SlackWebhookDelete converts echo context to params.

func (*ServerInterfaceWrapper) SlackWebhookList

func (w *ServerInterfaceWrapper) SlackWebhookList(ctx echo.Context) error

SlackWebhookList converts echo context to params.

func (*ServerInterfaceWrapper) SnsCreate

func (w *ServerInterfaceWrapper) SnsCreate(ctx echo.Context) error

SnsCreate converts echo context to params.

func (*ServerInterfaceWrapper) SnsDelete

func (w *ServerInterfaceWrapper) SnsDelete(ctx echo.Context) error

SnsDelete converts echo context to params.

func (*ServerInterfaceWrapper) SnsList

func (w *ServerInterfaceWrapper) SnsList(ctx echo.Context) error

SnsList converts echo context to params.

func (*ServerInterfaceWrapper) SnsUpdate

func (w *ServerInterfaceWrapper) SnsUpdate(ctx echo.Context) error

SnsUpdate converts echo context to params.

func (*ServerInterfaceWrapper) StepRunGet

func (w *ServerInterfaceWrapper) StepRunGet(ctx echo.Context) error

StepRunGet converts echo context to params.

func (*ServerInterfaceWrapper) StepRunGetSchema

func (w *ServerInterfaceWrapper) StepRunGetSchema(ctx echo.Context) error

StepRunGetSchema converts echo context to params.

func (*ServerInterfaceWrapper) StepRunListArchives

func (w *ServerInterfaceWrapper) StepRunListArchives(ctx echo.Context) error

StepRunListArchives converts echo context to params.

func (*ServerInterfaceWrapper) StepRunListEvents

func (w *ServerInterfaceWrapper) StepRunListEvents(ctx echo.Context) error

StepRunListEvents converts echo context to params.

func (*ServerInterfaceWrapper) StepRunUpdateCancel

func (w *ServerInterfaceWrapper) StepRunUpdateCancel(ctx echo.Context) error

StepRunUpdateCancel converts echo context to params.

func (*ServerInterfaceWrapper) StepRunUpdateRerun

func (w *ServerInterfaceWrapper) StepRunUpdateRerun(ctx echo.Context) error

StepRunUpdateRerun converts echo context to params.

func (*ServerInterfaceWrapper) TenantAlertingSettingsGet

func (w *ServerInterfaceWrapper) TenantAlertingSettingsGet(ctx echo.Context) error

TenantAlertingSettingsGet converts echo context to params.

func (*ServerInterfaceWrapper) TenantCreate

func (w *ServerInterfaceWrapper) TenantCreate(ctx echo.Context) error

TenantCreate converts echo context to params.

func (*ServerInterfaceWrapper) TenantGetQueueMetrics

func (w *ServerInterfaceWrapper) TenantGetQueueMetrics(ctx echo.Context) error

TenantGetQueueMetrics converts echo context to params.

func (*ServerInterfaceWrapper) TenantGetStepRunQueueMetrics

func (w *ServerInterfaceWrapper) TenantGetStepRunQueueMetrics(ctx echo.Context) error

TenantGetStepRunQueueMetrics converts echo context to params.

func (*ServerInterfaceWrapper) TenantInviteAccept

func (w *ServerInterfaceWrapper) TenantInviteAccept(ctx echo.Context) error

TenantInviteAccept converts echo context to params.

func (*ServerInterfaceWrapper) TenantInviteCreate

func (w *ServerInterfaceWrapper) TenantInviteCreate(ctx echo.Context) error

TenantInviteCreate converts echo context to params.

func (*ServerInterfaceWrapper) TenantInviteDelete

func (w *ServerInterfaceWrapper) TenantInviteDelete(ctx echo.Context) error

TenantInviteDelete converts echo context to params.

func (*ServerInterfaceWrapper) TenantInviteList

func (w *ServerInterfaceWrapper) TenantInviteList(ctx echo.Context) error

TenantInviteList converts echo context to params.

func (*ServerInterfaceWrapper) TenantInviteReject

func (w *ServerInterfaceWrapper) TenantInviteReject(ctx echo.Context) error

TenantInviteReject converts echo context to params.

func (*ServerInterfaceWrapper) TenantInviteUpdate

func (w *ServerInterfaceWrapper) TenantInviteUpdate(ctx echo.Context) error

TenantInviteUpdate converts echo context to params.

func (*ServerInterfaceWrapper) TenantMemberDelete

func (w *ServerInterfaceWrapper) TenantMemberDelete(ctx echo.Context) error

TenantMemberDelete converts echo context to params.

func (*ServerInterfaceWrapper) TenantMemberList

func (w *ServerInterfaceWrapper) TenantMemberList(ctx echo.Context) error

TenantMemberList converts echo context to params.

func (*ServerInterfaceWrapper) TenantMembershipsList

func (w *ServerInterfaceWrapper) TenantMembershipsList(ctx echo.Context) error

TenantMembershipsList converts echo context to params.

func (*ServerInterfaceWrapper) TenantResourcePolicyGet

func (w *ServerInterfaceWrapper) TenantResourcePolicyGet(ctx echo.Context) error

TenantResourcePolicyGet converts echo context to params.

func (*ServerInterfaceWrapper) TenantUpdate

func (w *ServerInterfaceWrapper) TenantUpdate(ctx echo.Context) error

TenantUpdate converts echo context to params.

func (*ServerInterfaceWrapper) UserCreate

func (w *ServerInterfaceWrapper) UserCreate(ctx echo.Context) error

UserCreate converts echo context to params.

func (*ServerInterfaceWrapper) UserGetCurrent

func (w *ServerInterfaceWrapper) UserGetCurrent(ctx echo.Context) error

UserGetCurrent converts echo context to params.

func (*ServerInterfaceWrapper) UserListTenantInvites

func (w *ServerInterfaceWrapper) UserListTenantInvites(ctx echo.Context) error

UserListTenantInvites converts echo context to params.

func (*ServerInterfaceWrapper) UserUpdateGithubOauthCallback

func (w *ServerInterfaceWrapper) UserUpdateGithubOauthCallback(ctx echo.Context) error

UserUpdateGithubOauthCallback converts echo context to params.

func (*ServerInterfaceWrapper) UserUpdateGithubOauthStart

func (w *ServerInterfaceWrapper) UserUpdateGithubOauthStart(ctx echo.Context) error

UserUpdateGithubOauthStart converts echo context to params.

func (*ServerInterfaceWrapper) UserUpdateGoogleOauthCallback

func (w *ServerInterfaceWrapper) UserUpdateGoogleOauthCallback(ctx echo.Context) error

UserUpdateGoogleOauthCallback converts echo context to params.

func (*ServerInterfaceWrapper) UserUpdateGoogleOauthStart

func (w *ServerInterfaceWrapper) UserUpdateGoogleOauthStart(ctx echo.Context) error

UserUpdateGoogleOauthStart converts echo context to params.

func (*ServerInterfaceWrapper) UserUpdateLogin

func (w *ServerInterfaceWrapper) UserUpdateLogin(ctx echo.Context) error

UserUpdateLogin converts echo context to params.

func (*ServerInterfaceWrapper) UserUpdateLogout

func (w *ServerInterfaceWrapper) UserUpdateLogout(ctx echo.Context) error

UserUpdateLogout converts echo context to params.

func (*ServerInterfaceWrapper) UserUpdatePassword

func (w *ServerInterfaceWrapper) UserUpdatePassword(ctx echo.Context) error

UserUpdatePassword converts echo context to params.

func (*ServerInterfaceWrapper) UserUpdateSlackOauthCallback

func (w *ServerInterfaceWrapper) UserUpdateSlackOauthCallback(ctx echo.Context) error

UserUpdateSlackOauthCallback converts echo context to params.

func (*ServerInterfaceWrapper) UserUpdateSlackOauthStart

func (w *ServerInterfaceWrapper) UserUpdateSlackOauthStart(ctx echo.Context) error

UserUpdateSlackOauthStart converts echo context to params.

func (*ServerInterfaceWrapper) V1DagListTasks

func (w *ServerInterfaceWrapper) V1DagListTasks(ctx echo.Context) error

V1DagListTasks converts echo context to params.

func (*ServerInterfaceWrapper) V1LogLineList

func (w *ServerInterfaceWrapper) V1LogLineList(ctx echo.Context) error

V1LogLineList converts echo context to params.

func (*ServerInterfaceWrapper) V1TaskCancel

func (w *ServerInterfaceWrapper) V1TaskCancel(ctx echo.Context) error

V1TaskCancel converts echo context to params.

func (*ServerInterfaceWrapper) V1TaskEventList

func (w *ServerInterfaceWrapper) V1TaskEventList(ctx echo.Context) error

V1TaskEventList converts echo context to params.

func (*ServerInterfaceWrapper) V1TaskGet

func (w *ServerInterfaceWrapper) V1TaskGet(ctx echo.Context) error

V1TaskGet converts echo context to params.

func (*ServerInterfaceWrapper) V1TaskGetPointMetrics

func (w *ServerInterfaceWrapper) V1TaskGetPointMetrics(ctx echo.Context) error

V1TaskGetPointMetrics converts echo context to params.

func (*ServerInterfaceWrapper) V1TaskListStatusMetrics

func (w *ServerInterfaceWrapper) V1TaskListStatusMetrics(ctx echo.Context) error

V1TaskListStatusMetrics converts echo context to params.

func (*ServerInterfaceWrapper) V1TaskReplay

func (w *ServerInterfaceWrapper) V1TaskReplay(ctx echo.Context) error

V1TaskReplay converts echo context to params.

func (*ServerInterfaceWrapper) V1WorkflowRunCreate

func (w *ServerInterfaceWrapper) V1WorkflowRunCreate(ctx echo.Context) error

V1WorkflowRunCreate converts echo context to params.

func (*ServerInterfaceWrapper) V1WorkflowRunDisplayNamesList

func (w *ServerInterfaceWrapper) V1WorkflowRunDisplayNamesList(ctx echo.Context) error

V1WorkflowRunDisplayNamesList converts echo context to params.

func (*ServerInterfaceWrapper) V1WorkflowRunGet

func (w *ServerInterfaceWrapper) V1WorkflowRunGet(ctx echo.Context) error

V1WorkflowRunGet converts echo context to params.

func (*ServerInterfaceWrapper) V1WorkflowRunList

func (w *ServerInterfaceWrapper) V1WorkflowRunList(ctx echo.Context) error

V1WorkflowRunList converts echo context to params.

func (*ServerInterfaceWrapper) V1WorkflowRunTaskEventsList

func (w *ServerInterfaceWrapper) V1WorkflowRunTaskEventsList(ctx echo.Context) error

V1WorkflowRunTaskEventsList converts echo context to params.

func (*ServerInterfaceWrapper) WebhookCreate

func (w *ServerInterfaceWrapper) WebhookCreate(ctx echo.Context) error

WebhookCreate converts echo context to params.

func (*ServerInterfaceWrapper) WebhookDelete

func (w *ServerInterfaceWrapper) WebhookDelete(ctx echo.Context) error

WebhookDelete converts echo context to params.

func (*ServerInterfaceWrapper) WebhookList

func (w *ServerInterfaceWrapper) WebhookList(ctx echo.Context) error

WebhookList converts echo context to params.

func (*ServerInterfaceWrapper) WebhookRequestsList

func (w *ServerInterfaceWrapper) WebhookRequestsList(ctx echo.Context) error

WebhookRequestsList converts echo context to params.

func (*ServerInterfaceWrapper) WorkerGet

func (w *ServerInterfaceWrapper) WorkerGet(ctx echo.Context) error

WorkerGet converts echo context to params.

func (*ServerInterfaceWrapper) WorkerList

func (w *ServerInterfaceWrapper) WorkerList(ctx echo.Context) error

WorkerList converts echo context to params.

func (*ServerInterfaceWrapper) WorkerUpdate

func (w *ServerInterfaceWrapper) WorkerUpdate(ctx echo.Context) error

WorkerUpdate converts echo context to params.

func (*ServerInterfaceWrapper) WorkflowCronDelete

func (w *ServerInterfaceWrapper) WorkflowCronDelete(ctx echo.Context) error

WorkflowCronDelete converts echo context to params.

func (*ServerInterfaceWrapper) WorkflowCronGet

func (w *ServerInterfaceWrapper) WorkflowCronGet(ctx echo.Context) error

WorkflowCronGet converts echo context to params.

func (*ServerInterfaceWrapper) WorkflowDelete

func (w *ServerInterfaceWrapper) WorkflowDelete(ctx echo.Context) error

WorkflowDelete converts echo context to params.

func (*ServerInterfaceWrapper) WorkflowGet

func (w *ServerInterfaceWrapper) WorkflowGet(ctx echo.Context) error

WorkflowGet converts echo context to params.

func (*ServerInterfaceWrapper) WorkflowGetMetrics

func (w *ServerInterfaceWrapper) WorkflowGetMetrics(ctx echo.Context) error

WorkflowGetMetrics converts echo context to params.

func (*ServerInterfaceWrapper) WorkflowGetWorkersCount

func (w *ServerInterfaceWrapper) WorkflowGetWorkersCount(ctx echo.Context) error

WorkflowGetWorkersCount converts echo context to params.

func (*ServerInterfaceWrapper) WorkflowList

func (w *ServerInterfaceWrapper) WorkflowList(ctx echo.Context) error

WorkflowList converts echo context to params.

func (*ServerInterfaceWrapper) WorkflowRunCancel

func (w *ServerInterfaceWrapper) WorkflowRunCancel(ctx echo.Context) error

WorkflowRunCancel converts echo context to params.

func (*ServerInterfaceWrapper) WorkflowRunCreate

func (w *ServerInterfaceWrapper) WorkflowRunCreate(ctx echo.Context) error

WorkflowRunCreate converts echo context to params.

func (*ServerInterfaceWrapper) WorkflowRunGet

func (w *ServerInterfaceWrapper) WorkflowRunGet(ctx echo.Context) error

WorkflowRunGet converts echo context to params.

func (*ServerInterfaceWrapper) WorkflowRunGetInput

func (w *ServerInterfaceWrapper) WorkflowRunGetInput(ctx echo.Context) error

WorkflowRunGetInput converts echo context to params.

func (*ServerInterfaceWrapper) WorkflowRunGetMetrics

func (w *ServerInterfaceWrapper) WorkflowRunGetMetrics(ctx echo.Context) error

WorkflowRunGetMetrics converts echo context to params.

func (*ServerInterfaceWrapper) WorkflowRunGetShape

func (w *ServerInterfaceWrapper) WorkflowRunGetShape(ctx echo.Context) error

WorkflowRunGetShape converts echo context to params.

func (*ServerInterfaceWrapper) WorkflowRunList

func (w *ServerInterfaceWrapper) WorkflowRunList(ctx echo.Context) error

WorkflowRunList converts echo context to params.

func (*ServerInterfaceWrapper) WorkflowRunListStepRunEvents

func (w *ServerInterfaceWrapper) WorkflowRunListStepRunEvents(ctx echo.Context) error

WorkflowRunListStepRunEvents converts echo context to params.

func (*ServerInterfaceWrapper) WorkflowRunUpdateReplay

func (w *ServerInterfaceWrapper) WorkflowRunUpdateReplay(ctx echo.Context) error

WorkflowRunUpdateReplay converts echo context to params.

func (*ServerInterfaceWrapper) WorkflowScheduledDelete

func (w *ServerInterfaceWrapper) WorkflowScheduledDelete(ctx echo.Context) error

WorkflowScheduledDelete converts echo context to params.

func (*ServerInterfaceWrapper) WorkflowScheduledGet

func (w *ServerInterfaceWrapper) WorkflowScheduledGet(ctx echo.Context) error

WorkflowScheduledGet converts echo context to params.

func (*ServerInterfaceWrapper) WorkflowScheduledList

func (w *ServerInterfaceWrapper) WorkflowScheduledList(ctx echo.Context) error

WorkflowScheduledList converts echo context to params.

func (*ServerInterfaceWrapper) WorkflowUpdate

func (w *ServerInterfaceWrapper) WorkflowUpdate(ctx echo.Context) error

WorkflowUpdate converts echo context to params.

func (*ServerInterfaceWrapper) WorkflowVersionGet

func (w *ServerInterfaceWrapper) WorkflowVersionGet(ctx echo.Context) error

WorkflowVersionGet converts echo context to params.

type SlackWebhook

type SlackWebhook struct {
	// ChannelId The channel id associated with this slack webhook.
	ChannelId string `json:"channelId"`

	// ChannelName The channel name associated with this slack webhook.
	ChannelName string          `json:"channelName"`
	Metadata    APIResourceMeta `json:"metadata"`

	// TeamId The team id associated with this slack webhook.
	TeamId string `json:"teamId"`

	// TeamName The team name associated with this slack webhook.
	TeamName string `json:"teamName"`

	// TenantId The unique identifier for the tenant that the SNS integration belongs to.
	TenantId openapi_types.UUID `json:"tenantId"`
}

SlackWebhook defines model for SlackWebhook.

type SlackWebhookDelete204Response

type SlackWebhookDelete204Response struct {
}

func (SlackWebhookDelete204Response) VisitSlackWebhookDeleteResponse

func (response SlackWebhookDelete204Response) VisitSlackWebhookDeleteResponse(w http.ResponseWriter) error

type SlackWebhookDelete400JSONResponse

type SlackWebhookDelete400JSONResponse APIErrors

func (SlackWebhookDelete400JSONResponse) VisitSlackWebhookDeleteResponse

func (response SlackWebhookDelete400JSONResponse) VisitSlackWebhookDeleteResponse(w http.ResponseWriter) error

type SlackWebhookDelete401JSONResponse

type SlackWebhookDelete401JSONResponse APIErrors

func (SlackWebhookDelete401JSONResponse) VisitSlackWebhookDeleteResponse

func (response SlackWebhookDelete401JSONResponse) VisitSlackWebhookDeleteResponse(w http.ResponseWriter) error

type SlackWebhookDelete405JSONResponse

type SlackWebhookDelete405JSONResponse APIErrors

func (SlackWebhookDelete405JSONResponse) VisitSlackWebhookDeleteResponse

func (response SlackWebhookDelete405JSONResponse) VisitSlackWebhookDeleteResponse(w http.ResponseWriter) error

type SlackWebhookDeleteRequestObject

type SlackWebhookDeleteRequestObject struct {
	Slack openapi_types.UUID `json:"slack"`
}

type SlackWebhookDeleteResponseObject

type SlackWebhookDeleteResponseObject interface {
	VisitSlackWebhookDeleteResponse(w http.ResponseWriter) error
}

type SlackWebhookList200JSONResponse

type SlackWebhookList200JSONResponse ListSlackWebhooks

func (SlackWebhookList200JSONResponse) VisitSlackWebhookListResponse

func (response SlackWebhookList200JSONResponse) VisitSlackWebhookListResponse(w http.ResponseWriter) error

type SlackWebhookList400JSONResponse

type SlackWebhookList400JSONResponse APIErrors

func (SlackWebhookList400JSONResponse) VisitSlackWebhookListResponse

func (response SlackWebhookList400JSONResponse) VisitSlackWebhookListResponse(w http.ResponseWriter) error

type SlackWebhookList401JSONResponse

type SlackWebhookList401JSONResponse APIErrors

func (SlackWebhookList401JSONResponse) VisitSlackWebhookListResponse

func (response SlackWebhookList401JSONResponse) VisitSlackWebhookListResponse(w http.ResponseWriter) error

type SlackWebhookList405JSONResponse

type SlackWebhookList405JSONResponse APIErrors

func (SlackWebhookList405JSONResponse) VisitSlackWebhookListResponse

func (response SlackWebhookList405JSONResponse) VisitSlackWebhookListResponse(w http.ResponseWriter) error

type SlackWebhookListRequestObject

type SlackWebhookListRequestObject struct {
	Tenant openapi_types.UUID `json:"tenant"`
}

type SlackWebhookListResponseObject

type SlackWebhookListResponseObject interface {
	VisitSlackWebhookListResponse(w http.ResponseWriter) error
}

type SnsCreate201JSONResponse

type SnsCreate201JSONResponse SNSIntegration

func (SnsCreate201JSONResponse) VisitSnsCreateResponse

func (response SnsCreate201JSONResponse) VisitSnsCreateResponse(w http.ResponseWriter) error

type SnsCreate400JSONResponse

type SnsCreate400JSONResponse APIErrors

func (SnsCreate400JSONResponse) VisitSnsCreateResponse

func (response SnsCreate400JSONResponse) VisitSnsCreateResponse(w http.ResponseWriter) error

type SnsCreate401JSONResponse

type SnsCreate401JSONResponse APIErrors

func (SnsCreate401JSONResponse) VisitSnsCreateResponse

func (response SnsCreate401JSONResponse) VisitSnsCreateResponse(w http.ResponseWriter) error

type SnsCreate405JSONResponse

type SnsCreate405JSONResponse APIErrors

func (SnsCreate405JSONResponse) VisitSnsCreateResponse

func (response SnsCreate405JSONResponse) VisitSnsCreateResponse(w http.ResponseWriter) error

type SnsCreateJSONRequestBody

type SnsCreateJSONRequestBody = CreateSNSIntegrationRequest

SnsCreateJSONRequestBody defines body for SnsCreate for application/json ContentType.

type SnsCreateRequestObject

type SnsCreateRequestObject struct {
	Tenant openapi_types.UUID `json:"tenant"`
	Body   *SnsCreateJSONRequestBody
}

type SnsCreateResponseObject

type SnsCreateResponseObject interface {
	VisitSnsCreateResponse(w http.ResponseWriter) error
}

type SnsDelete204Response

type SnsDelete204Response struct {
}

func (SnsDelete204Response) VisitSnsDeleteResponse

func (response SnsDelete204Response) VisitSnsDeleteResponse(w http.ResponseWriter) error

type SnsDelete400JSONResponse

type SnsDelete400JSONResponse APIErrors

func (SnsDelete400JSONResponse) VisitSnsDeleteResponse

func (response SnsDelete400JSONResponse) VisitSnsDeleteResponse(w http.ResponseWriter) error

type SnsDelete401JSONResponse

type SnsDelete401JSONResponse APIErrors

func (SnsDelete401JSONResponse) VisitSnsDeleteResponse

func (response SnsDelete401JSONResponse) VisitSnsDeleteResponse(w http.ResponseWriter) error

type SnsDelete405JSONResponse

type SnsDelete405JSONResponse APIErrors

func (SnsDelete405JSONResponse) VisitSnsDeleteResponse

func (response SnsDelete405JSONResponse) VisitSnsDeleteResponse(w http.ResponseWriter) error

type SnsDeleteRequestObject

type SnsDeleteRequestObject struct {
	Sns openapi_types.UUID `json:"sns"`
}

type SnsDeleteResponseObject

type SnsDeleteResponseObject interface {
	VisitSnsDeleteResponse(w http.ResponseWriter) error
}

type SnsList200JSONResponse

type SnsList200JSONResponse ListSNSIntegrations

func (SnsList200JSONResponse) VisitSnsListResponse

func (response SnsList200JSONResponse) VisitSnsListResponse(w http.ResponseWriter) error

type SnsList400JSONResponse

type SnsList400JSONResponse APIErrors

func (SnsList400JSONResponse) VisitSnsListResponse

func (response SnsList400JSONResponse) VisitSnsListResponse(w http.ResponseWriter) error

type SnsList401JSONResponse

type SnsList401JSONResponse APIErrors

func (SnsList401JSONResponse) VisitSnsListResponse

func (response SnsList401JSONResponse) VisitSnsListResponse(w http.ResponseWriter) error

type SnsList405JSONResponse

type SnsList405JSONResponse APIErrors

func (SnsList405JSONResponse) VisitSnsListResponse

func (response SnsList405JSONResponse) VisitSnsListResponse(w http.ResponseWriter) error

type SnsListRequestObject

type SnsListRequestObject struct {
	Tenant openapi_types.UUID `json:"tenant"`
}

type SnsListResponseObject

type SnsListResponseObject interface {
	VisitSnsListResponse(w http.ResponseWriter) error
}

type SnsUpdate200Response

type SnsUpdate200Response struct {
}

func (SnsUpdate200Response) VisitSnsUpdateResponse

func (response SnsUpdate200Response) VisitSnsUpdateResponse(w http.ResponseWriter) error

type SnsUpdate400JSONResponse

type SnsUpdate400JSONResponse APIErrors

func (SnsUpdate400JSONResponse) VisitSnsUpdateResponse

func (response SnsUpdate400JSONResponse) VisitSnsUpdateResponse(w http.ResponseWriter) error

type SnsUpdate401JSONResponse

type SnsUpdate401JSONResponse APIErrors

func (SnsUpdate401JSONResponse) VisitSnsUpdateResponse

func (response SnsUpdate401JSONResponse) VisitSnsUpdateResponse(w http.ResponseWriter) error

type SnsUpdate405JSONResponse

type SnsUpdate405JSONResponse APIErrors

func (SnsUpdate405JSONResponse) VisitSnsUpdateResponse

func (response SnsUpdate405JSONResponse) VisitSnsUpdateResponse(w http.ResponseWriter) error

type SnsUpdateRequestObject

type SnsUpdateRequestObject struct {
	Tenant openapi_types.UUID `json:"tenant"`
	Event  string             `json:"event"`
}

type SnsUpdateResponseObject

type SnsUpdateResponseObject interface {
	VisitSnsUpdateResponse(w http.ResponseWriter) error
}

type Step

type Step struct {
	Action   string          `json:"action"`
	Children *[]string       `json:"children,omitempty"`
	JobId    string          `json:"jobId"`
	Metadata APIResourceMeta `json:"metadata"`
	Parents  *[]string       `json:"parents,omitempty"`

	// ReadableId The readable id of the step.
	ReadableId string `json:"readableId"`
	TenantId   string `json:"tenantId"`

	// Timeout The timeout of the step.
	Timeout *string `json:"timeout,omitempty"`
}

Step defines model for Step.

type StepRun

type StepRun struct {
	CancelledAt         *time.Time              `json:"cancelledAt,omitempty"`
	CancelledAtEpoch    *int                    `json:"cancelledAtEpoch,omitempty"`
	CancelledError      *string                 `json:"cancelledError,omitempty"`
	CancelledReason     *string                 `json:"cancelledReason,omitempty"`
	ChildWorkflowRuns   *[]string               `json:"childWorkflowRuns,omitempty"`
	ChildWorkflowsCount *int                    `json:"childWorkflowsCount,omitempty"`
	Error               *string                 `json:"error,omitempty"`
	FinishedAt          *time.Time              `json:"finishedAt,omitempty"`
	FinishedAtEpoch     *int                    `json:"finishedAtEpoch,omitempty"`
	Input               *string                 `json:"input,omitempty"`
	JobRun              *JobRun                 `json:"jobRun,omitempty"`
	JobRunId            string                  `json:"jobRunId"`
	Metadata            APIResourceMeta         `json:"metadata"`
	Output              *string                 `json:"output,omitempty"`
	Parents             *[]string               `json:"parents,omitempty"`
	RequeueAfter        *time.Time              `json:"requeueAfter,omitempty"`
	Result              *map[string]interface{} `json:"result,omitempty"`
	StartedAt           *time.Time              `json:"startedAt,omitempty"`
	StartedAtEpoch      *int                    `json:"startedAtEpoch,omitempty"`
	Status              StepRunStatus           `json:"status"`
	Step                *Step                   `json:"step,omitempty"`
	StepId              string                  `json:"stepId"`
	TenantId            string                  `json:"tenantId"`
	TimeoutAt           *time.Time              `json:"timeoutAt,omitempty"`
	TimeoutAtEpoch      *int                    `json:"timeoutAtEpoch,omitempty"`
	WorkerId            *string                 `json:"workerId,omitempty"`
}

StepRun defines model for StepRun.

type StepRunArchive

type StepRunArchive struct {
	CancelledAt      *time.Time `json:"cancelledAt,omitempty"`
	CancelledAtEpoch *int       `json:"cancelledAtEpoch,omitempty"`
	CancelledError   *string    `json:"cancelledError,omitempty"`
	CancelledReason  *string    `json:"cancelledReason,omitempty"`
	CreatedAt        time.Time  `json:"createdAt"`
	Error            *string    `json:"error,omitempty"`
	FinishedAt       *time.Time `json:"finishedAt,omitempty"`
	FinishedAtEpoch  *int       `json:"finishedAtEpoch,omitempty"`
	Input            *string    `json:"input,omitempty"`
	Order            int        `json:"order"`
	Output           *string    `json:"output,omitempty"`
	RetryCount       int        `json:"retryCount"`
	StartedAt        *time.Time `json:"startedAt,omitempty"`
	StartedAtEpoch   *int       `json:"startedAtEpoch,omitempty"`
	StepRunId        string     `json:"stepRunId"`
	TimeoutAt        *time.Time `json:"timeoutAt,omitempty"`
	TimeoutAtEpoch   *int       `json:"timeoutAtEpoch,omitempty"`
}

StepRunArchive defines model for StepRunArchive.

type StepRunArchiveList

type StepRunArchiveList struct {
	Pagination *PaginationResponse `json:"pagination,omitempty"`
	Rows       *[]StepRunArchive   `json:"rows,omitempty"`
}

StepRunArchiveList defines model for StepRunArchiveList.

type StepRunEvent

type StepRunEvent struct {
	Count         int                     `json:"count"`
	Data          *map[string]interface{} `json:"data,omitempty"`
	Id            int                     `json:"id"`
	Message       string                  `json:"message"`
	Reason        StepRunEventReason      `json:"reason"`
	Severity      StepRunEventSeverity    `json:"severity"`
	StepRunId     *string                 `json:"stepRunId,omitempty"`
	TimeFirstSeen time.Time               `json:"timeFirstSeen"`
	TimeLastSeen  time.Time               `json:"timeLastSeen"`
	WorkflowRunId *string                 `json:"workflowRunId,omitempty"`
}

StepRunEvent defines model for StepRunEvent.

type StepRunEventList

type StepRunEventList struct {
	Pagination *PaginationResponse `json:"pagination,omitempty"`
	Rows       *[]StepRunEvent     `json:"rows,omitempty"`
}

StepRunEventList defines model for StepRunEventList.

type StepRunEventReason

type StepRunEventReason string

StepRunEventReason defines model for StepRunEventReason.

const (
	StepRunEventReasonACKNOWLEDGED                 StepRunEventReason = "ACKNOWLEDGED"
	StepRunEventReasonASSIGNED                     StepRunEventReason = "ASSIGNED"
	StepRunEventReasonCANCELLED                    StepRunEventReason = "CANCELLED"
	StepRunEventReasonFAILED                       StepRunEventReason = "FAILED"
	StepRunEventReasonFINISHED                     StepRunEventReason = "FINISHED"
	StepRunEventReasonREASSIGNED                   StepRunEventReason = "REASSIGNED"
	StepRunEventReasonREQUEUEDNOWORKER             StepRunEventReason = "REQUEUED_NO_WORKER"
	StepRunEventReasonREQUEUEDRATELIMIT            StepRunEventReason = "REQUEUED_RATE_LIMIT"
	StepRunEventReasonRETRIEDBYUSER                StepRunEventReason = "RETRIED_BY_USER"
	StepRunEventReasonRETRYING                     StepRunEventReason = "RETRYING"
	StepRunEventReasonSCHEDULINGTIMEDOUT           StepRunEventReason = "SCHEDULING_TIMED_OUT"
	StepRunEventReasonSLOTRELEASED                 StepRunEventReason = "SLOT_RELEASED"
	StepRunEventReasonSTARTED                      StepRunEventReason = "STARTED"
	StepRunEventReasonTIMEDOUT                     StepRunEventReason = "TIMED_OUT"
	StepRunEventReasonTIMEOUTREFRESHED             StepRunEventReason = "TIMEOUT_REFRESHED"
	StepRunEventReasonWORKFLOWRUNGROUPKEYFAILED    StepRunEventReason = "WORKFLOW_RUN_GROUP_KEY_FAILED"
	StepRunEventReasonWORKFLOWRUNGROUPKEYSUCCEEDED StepRunEventReason = "WORKFLOW_RUN_GROUP_KEY_SUCCEEDED"
)

Defines values for StepRunEventReason.

type StepRunEventSeverity

type StepRunEventSeverity string

StepRunEventSeverity defines model for StepRunEventSeverity.

const (
	StepRunEventSeverityCRITICAL StepRunEventSeverity = "CRITICAL"
	StepRunEventSeverityINFO     StepRunEventSeverity = "INFO"
	StepRunEventSeverityWARNING  StepRunEventSeverity = "WARNING"
)

Defines values for StepRunEventSeverity.

type StepRunGet200JSONResponse

type StepRunGet200JSONResponse StepRun

func (StepRunGet200JSONResponse) VisitStepRunGetResponse

func (response StepRunGet200JSONResponse) VisitStepRunGetResponse(w http.ResponseWriter) error

type StepRunGet400JSONResponse

type StepRunGet400JSONResponse APIErrors

func (StepRunGet400JSONResponse) VisitStepRunGetResponse

func (response StepRunGet400JSONResponse) VisitStepRunGetResponse(w http.ResponseWriter) error

type StepRunGet403JSONResponse

type StepRunGet403JSONResponse APIErrors

func (StepRunGet403JSONResponse) VisitStepRunGetResponse

func (response StepRunGet403JSONResponse) VisitStepRunGetResponse(w http.ResponseWriter) error

type StepRunGet404JSONResponse

type StepRunGet404JSONResponse APIErrors

func (StepRunGet404JSONResponse) VisitStepRunGetResponse

func (response StepRunGet404JSONResponse) VisitStepRunGetResponse(w http.ResponseWriter) error

type StepRunGetRequestObject

type StepRunGetRequestObject struct {
	Tenant  openapi_types.UUID `json:"tenant"`
	StepRun openapi_types.UUID `json:"step-run"`
}

type StepRunGetResponseObject

type StepRunGetResponseObject interface {
	VisitStepRunGetResponse(w http.ResponseWriter) error
}

type StepRunGetSchema200JSONResponse

type StepRunGetSchema200JSONResponse map[string]interface{}

func (StepRunGetSchema200JSONResponse) VisitStepRunGetSchemaResponse

func (response StepRunGetSchema200JSONResponse) VisitStepRunGetSchemaResponse(w http.ResponseWriter) error

type StepRunGetSchema400JSONResponse

type StepRunGetSchema400JSONResponse APIErrors

func (StepRunGetSchema400JSONResponse) VisitStepRunGetSchemaResponse

func (response StepRunGetSchema400JSONResponse) VisitStepRunGetSchemaResponse(w http.ResponseWriter) error

type StepRunGetSchema403JSONResponse

type StepRunGetSchema403JSONResponse APIErrors

func (StepRunGetSchema403JSONResponse) VisitStepRunGetSchemaResponse

func (response StepRunGetSchema403JSONResponse) VisitStepRunGetSchemaResponse(w http.ResponseWriter) error

type StepRunGetSchema404JSONResponse

type StepRunGetSchema404JSONResponse APIErrors

func (StepRunGetSchema404JSONResponse) VisitStepRunGetSchemaResponse

func (response StepRunGetSchema404JSONResponse) VisitStepRunGetSchemaResponse(w http.ResponseWriter) error

type StepRunGetSchemaRequestObject

type StepRunGetSchemaRequestObject struct {
	Tenant  openapi_types.UUID `json:"tenant"`
	StepRun openapi_types.UUID `json:"step-run"`
}

type StepRunGetSchemaResponseObject

type StepRunGetSchemaResponseObject interface {
	VisitStepRunGetSchemaResponse(w http.ResponseWriter) error
}

type StepRunListArchives200JSONResponse

type StepRunListArchives200JSONResponse StepRunArchiveList

func (StepRunListArchives200JSONResponse) VisitStepRunListArchivesResponse

func (response StepRunListArchives200JSONResponse) VisitStepRunListArchivesResponse(w http.ResponseWriter) error

type StepRunListArchives400JSONResponse

type StepRunListArchives400JSONResponse APIErrors

func (StepRunListArchives400JSONResponse) VisitStepRunListArchivesResponse

func (response StepRunListArchives400JSONResponse) VisitStepRunListArchivesResponse(w http.ResponseWriter) error

type StepRunListArchives403JSONResponse

type StepRunListArchives403JSONResponse APIErrors

func (StepRunListArchives403JSONResponse) VisitStepRunListArchivesResponse

func (response StepRunListArchives403JSONResponse) VisitStepRunListArchivesResponse(w http.ResponseWriter) error

type StepRunListArchives404JSONResponse

type StepRunListArchives404JSONResponse APIErrors

func (StepRunListArchives404JSONResponse) VisitStepRunListArchivesResponse

func (response StepRunListArchives404JSONResponse) VisitStepRunListArchivesResponse(w http.ResponseWriter) error

type StepRunListArchivesParams

type StepRunListArchivesParams struct {
	// Offset The number to skip
	Offset *int64 `form:"offset,omitempty" json:"offset,omitempty"`

	// Limit The number to limit by
	Limit *int64 `form:"limit,omitempty" json:"limit,omitempty"`
}

StepRunListArchivesParams defines parameters for StepRunListArchives.

type StepRunListArchivesRequestObject

type StepRunListArchivesRequestObject struct {
	StepRun openapi_types.UUID `json:"step-run"`
	Params  StepRunListArchivesParams
}

type StepRunListArchivesResponseObject

type StepRunListArchivesResponseObject interface {
	VisitStepRunListArchivesResponse(w http.ResponseWriter) error
}

type StepRunListEvents200JSONResponse

type StepRunListEvents200JSONResponse StepRunEventList

func (StepRunListEvents200JSONResponse) VisitStepRunListEventsResponse

func (response StepRunListEvents200JSONResponse) VisitStepRunListEventsResponse(w http.ResponseWriter) error

type StepRunListEvents400JSONResponse

type StepRunListEvents400JSONResponse APIErrors

func (StepRunListEvents400JSONResponse) VisitStepRunListEventsResponse

func (response StepRunListEvents400JSONResponse) VisitStepRunListEventsResponse(w http.ResponseWriter) error

type StepRunListEvents403JSONResponse

type StepRunListEvents403JSONResponse APIErrors

func (StepRunListEvents403JSONResponse) VisitStepRunListEventsResponse

func (response StepRunListEvents403JSONResponse) VisitStepRunListEventsResponse(w http.ResponseWriter) error

type StepRunListEvents404JSONResponse

type StepRunListEvents404JSONResponse APIErrors

func (StepRunListEvents404JSONResponse) VisitStepRunListEventsResponse

func (response StepRunListEvents404JSONResponse) VisitStepRunListEventsResponse(w http.ResponseWriter) error

type StepRunListEventsParams

type StepRunListEventsParams struct {
	// Offset The number to skip
	Offset *int64 `form:"offset,omitempty" json:"offset,omitempty"`

	// Limit The number to limit by
	Limit *int64 `form:"limit,omitempty" json:"limit,omitempty"`
}

StepRunListEventsParams defines parameters for StepRunListEvents.

type StepRunListEventsRequestObject

type StepRunListEventsRequestObject struct {
	StepRun openapi_types.UUID `json:"step-run"`
	Params  StepRunListEventsParams
}

type StepRunListEventsResponseObject

type StepRunListEventsResponseObject interface {
	VisitStepRunListEventsResponse(w http.ResponseWriter) error
}

type StepRunStatus

type StepRunStatus string

StepRunStatus defines model for StepRunStatus.

const (
	StepRunStatusASSIGNED          StepRunStatus = "ASSIGNED"
	StepRunStatusBACKOFF           StepRunStatus = "BACKOFF"
	StepRunStatusCANCELLED         StepRunStatus = "CANCELLED"
	StepRunStatusCANCELLING        StepRunStatus = "CANCELLING"
	StepRunStatusFAILED            StepRunStatus = "FAILED"
	StepRunStatusPENDING           StepRunStatus = "PENDING"
	StepRunStatusPENDINGASSIGNMENT StepRunStatus = "PENDING_ASSIGNMENT"
	StepRunStatusRUNNING           StepRunStatus = "RUNNING"
	StepRunStatusSUCCEEDED         StepRunStatus = "SUCCEEDED"
)

Defines values for StepRunStatus.

type StepRunUpdateCancel200JSONResponse

type StepRunUpdateCancel200JSONResponse StepRun

func (StepRunUpdateCancel200JSONResponse) VisitStepRunUpdateCancelResponse

func (response StepRunUpdateCancel200JSONResponse) VisitStepRunUpdateCancelResponse(w http.ResponseWriter) error

type StepRunUpdateCancel400JSONResponse

type StepRunUpdateCancel400JSONResponse APIErrors

func (StepRunUpdateCancel400JSONResponse) VisitStepRunUpdateCancelResponse

func (response StepRunUpdateCancel400JSONResponse) VisitStepRunUpdateCancelResponse(w http.ResponseWriter) error

type StepRunUpdateCancel403JSONResponse

type StepRunUpdateCancel403JSONResponse APIErrors

func (StepRunUpdateCancel403JSONResponse) VisitStepRunUpdateCancelResponse

func (response StepRunUpdateCancel403JSONResponse) VisitStepRunUpdateCancelResponse(w http.ResponseWriter) error

type StepRunUpdateCancelRequestObject

type StepRunUpdateCancelRequestObject struct {
	Tenant  openapi_types.UUID `json:"tenant"`
	StepRun openapi_types.UUID `json:"step-run"`
}

type StepRunUpdateCancelResponseObject

type StepRunUpdateCancelResponseObject interface {
	VisitStepRunUpdateCancelResponse(w http.ResponseWriter) error
}

type StepRunUpdateRerun200JSONResponse

type StepRunUpdateRerun200JSONResponse StepRun

func (StepRunUpdateRerun200JSONResponse) VisitStepRunUpdateRerunResponse

func (response StepRunUpdateRerun200JSONResponse) VisitStepRunUpdateRerunResponse(w http.ResponseWriter) error

type StepRunUpdateRerun400JSONResponse

type StepRunUpdateRerun400JSONResponse APIErrors

func (StepRunUpdateRerun400JSONResponse) VisitStepRunUpdateRerunResponse

func (response StepRunUpdateRerun400JSONResponse) VisitStepRunUpdateRerunResponse(w http.ResponseWriter) error

type StepRunUpdateRerun403JSONResponse

type StepRunUpdateRerun403JSONResponse APIErrors

func (StepRunUpdateRerun403JSONResponse) VisitStepRunUpdateRerunResponse

func (response StepRunUpdateRerun403JSONResponse) VisitStepRunUpdateRerunResponse(w http.ResponseWriter) error

type StepRunUpdateRerunJSONRequestBody

type StepRunUpdateRerunJSONRequestBody = RerunStepRunRequest

StepRunUpdateRerunJSONRequestBody defines body for StepRunUpdateRerun for application/json ContentType.

type StepRunUpdateRerunRequestObject

type StepRunUpdateRerunRequestObject struct {
	Tenant  openapi_types.UUID `json:"tenant"`
	StepRun openapi_types.UUID `json:"step-run"`
	Body    *StepRunUpdateRerunJSONRequestBody
}

type StepRunUpdateRerunResponseObject

type StepRunUpdateRerunResponseObject interface {
	VisitStepRunUpdateRerunResponse(w http.ResponseWriter) error
}

type StrictHandlerFunc

type StrictHandlerFunc func(ctx echo.Context, args interface{}) (interface{}, error)

type StrictMiddlewareFunc added in v0.6.0

type StrictMiddlewareFunc func(f StrictHandlerFunc, operationID string) StrictHandlerFunc

type StrictServerInterface

type StrictServerInterface interface {
	LivenessGet(ctx echo.Context, request LivenessGetRequestObject) (LivenessGetResponseObject, error)

	ReadinessGet(ctx echo.Context, request ReadinessGetRequestObject) (ReadinessGetResponseObject, error)

	AlertEmailGroupDelete(ctx echo.Context, request AlertEmailGroupDeleteRequestObject) (AlertEmailGroupDeleteResponseObject, error)

	AlertEmailGroupUpdate(ctx echo.Context, request AlertEmailGroupUpdateRequestObject) (AlertEmailGroupUpdateResponseObject, error)

	ApiTokenUpdateRevoke(ctx echo.Context, request ApiTokenUpdateRevokeRequestObject) (ApiTokenUpdateRevokeResponseObject, error)

	CloudMetadataGet(ctx echo.Context, request CloudMetadataGetRequestObject) (CloudMetadataGetResponseObject, error)

	EventGet(ctx echo.Context, request EventGetRequestObject) (EventGetResponseObject, error)

	EventDataGet(ctx echo.Context, request EventDataGetRequestObject) (EventDataGetResponseObject, error)

	MetadataGet(ctx echo.Context, request MetadataGetRequestObject) (MetadataGetResponseObject, error)

	MetadataListIntegrations(ctx echo.Context, request MetadataListIntegrationsRequestObject) (MetadataListIntegrationsResponseObject, error)

	MonitoringPostRunProbe(ctx echo.Context, request MonitoringPostRunProbeRequestObject) (MonitoringPostRunProbeResponseObject, error)

	SlackWebhookDelete(ctx echo.Context, request SlackWebhookDeleteRequestObject) (SlackWebhookDeleteResponseObject, error)

	SnsDelete(ctx echo.Context, request SnsDeleteRequestObject) (SnsDeleteResponseObject, error)

	SnsUpdate(ctx echo.Context, request SnsUpdateRequestObject) (SnsUpdateResponseObject, error)

	V1DagListTasks(ctx echo.Context, request V1DagListTasksRequestObject) (V1DagListTasksResponseObject, error)

	V1TaskGet(ctx echo.Context, request V1TaskGetRequestObject) (V1TaskGetResponseObject, error)

	V1LogLineList(ctx echo.Context, request V1LogLineListRequestObject) (V1LogLineListResponseObject, error)

	V1TaskEventList(ctx echo.Context, request V1TaskEventListRequestObject) (V1TaskEventListResponseObject, error)

	V1TaskListStatusMetrics(ctx echo.Context, request V1TaskListStatusMetricsRequestObject) (V1TaskListStatusMetricsResponseObject, error)

	V1TaskGetPointMetrics(ctx echo.Context, request V1TaskGetPointMetricsRequestObject) (V1TaskGetPointMetricsResponseObject, error)

	V1TaskCancel(ctx echo.Context, request V1TaskCancelRequestObject) (V1TaskCancelResponseObject, error)

	V1TaskReplay(ctx echo.Context, request V1TaskReplayRequestObject) (V1TaskReplayResponseObject, error)

	V1WorkflowRunList(ctx echo.Context, request V1WorkflowRunListRequestObject) (V1WorkflowRunListResponseObject, error)

	V1WorkflowRunDisplayNamesList(ctx echo.Context, request V1WorkflowRunDisplayNamesListRequestObject) (V1WorkflowRunDisplayNamesListResponseObject, error)

	V1WorkflowRunCreate(ctx echo.Context, request V1WorkflowRunCreateRequestObject) (V1WorkflowRunCreateResponseObject, error)

	V1WorkflowRunGet(ctx echo.Context, request V1WorkflowRunGetRequestObject) (V1WorkflowRunGetResponseObject, error)

	V1WorkflowRunTaskEventsList(ctx echo.Context, request V1WorkflowRunTaskEventsListRequestObject) (V1WorkflowRunTaskEventsListResponseObject, error)

	StepRunListArchives(ctx echo.Context, request StepRunListArchivesRequestObject) (StepRunListArchivesResponseObject, error)

	StepRunListEvents(ctx echo.Context, request StepRunListEventsRequestObject) (StepRunListEventsResponseObject, error)

	LogLineList(ctx echo.Context, request LogLineListRequestObject) (LogLineListResponseObject, error)

	TenantCreate(ctx echo.Context, request TenantCreateRequestObject) (TenantCreateResponseObject, error)

	TenantUpdate(ctx echo.Context, request TenantUpdateRequestObject) (TenantUpdateResponseObject, error)

	AlertEmailGroupList(ctx echo.Context, request AlertEmailGroupListRequestObject) (AlertEmailGroupListResponseObject, error)

	AlertEmailGroupCreate(ctx echo.Context, request AlertEmailGroupCreateRequestObject) (AlertEmailGroupCreateResponseObject, error)

	TenantAlertingSettingsGet(ctx echo.Context, request TenantAlertingSettingsGetRequestObject) (TenantAlertingSettingsGetResponseObject, error)

	ApiTokenList(ctx echo.Context, request ApiTokenListRequestObject) (ApiTokenListResponseObject, error)

	ApiTokenCreate(ctx echo.Context, request ApiTokenCreateRequestObject) (ApiTokenCreateResponseObject, error)

	EventList(ctx echo.Context, request EventListRequestObject) (EventListResponseObject, error)

	EventCreate(ctx echo.Context, request EventCreateRequestObject) (EventCreateResponseObject, error)

	EventCreateBulk(ctx echo.Context, request EventCreateBulkRequestObject) (EventCreateBulkResponseObject, error)

	EventUpdateCancel(ctx echo.Context, request EventUpdateCancelRequestObject) (EventUpdateCancelResponseObject, error)

	EventKeyList(ctx echo.Context, request EventKeyListRequestObject) (EventKeyListResponseObject, error)

	EventUpdateReplay(ctx echo.Context, request EventUpdateReplayRequestObject) (EventUpdateReplayResponseObject, error)

	TenantInviteList(ctx echo.Context, request TenantInviteListRequestObject) (TenantInviteListResponseObject, error)

	TenantInviteCreate(ctx echo.Context, request TenantInviteCreateRequestObject) (TenantInviteCreateResponseObject, error)

	TenantInviteDelete(ctx echo.Context, request TenantInviteDeleteRequestObject) (TenantInviteDeleteResponseObject, error)

	TenantInviteUpdate(ctx echo.Context, request TenantInviteUpdateRequestObject) (TenantInviteUpdateResponseObject, error)

	TenantMemberList(ctx echo.Context, request TenantMemberListRequestObject) (TenantMemberListResponseObject, error)

	TenantMemberDelete(ctx echo.Context, request TenantMemberDeleteRequestObject) (TenantMemberDeleteResponseObject, error)

	TenantGetQueueMetrics(ctx echo.Context, request TenantGetQueueMetricsRequestObject) (TenantGetQueueMetricsResponseObject, error)

	RateLimitList(ctx echo.Context, request RateLimitListRequestObject) (RateLimitListResponseObject, error)

	TenantResourcePolicyGet(ctx echo.Context, request TenantResourcePolicyGetRequestObject) (TenantResourcePolicyGetResponseObject, error)

	SlackWebhookList(ctx echo.Context, request SlackWebhookListRequestObject) (SlackWebhookListResponseObject, error)

	UserUpdateSlackOauthStart(ctx echo.Context, request UserUpdateSlackOauthStartRequestObject) (UserUpdateSlackOauthStartResponseObject, error)

	SnsList(ctx echo.Context, request SnsListRequestObject) (SnsListResponseObject, error)

	SnsCreate(ctx echo.Context, request SnsCreateRequestObject) (SnsCreateResponseObject, error)

	TenantGetStepRunQueueMetrics(ctx echo.Context, request TenantGetStepRunQueueMetricsRequestObject) (TenantGetStepRunQueueMetricsResponseObject, error)

	StepRunGet(ctx echo.Context, request StepRunGetRequestObject) (StepRunGetResponseObject, error)

	StepRunUpdateCancel(ctx echo.Context, request StepRunUpdateCancelRequestObject) (StepRunUpdateCancelResponseObject, error)

	StepRunUpdateRerun(ctx echo.Context, request StepRunUpdateRerunRequestObject) (StepRunUpdateRerunResponseObject, error)

	StepRunGetSchema(ctx echo.Context, request StepRunGetSchemaRequestObject) (StepRunGetSchemaResponseObject, error)

	WebhookList(ctx echo.Context, request WebhookListRequestObject) (WebhookListResponseObject, error)

	WebhookCreate(ctx echo.Context, request WebhookCreateRequestObject) (WebhookCreateResponseObject, error)

	WorkerList(ctx echo.Context, request WorkerListRequestObject) (WorkerListResponseObject, error)

	WorkflowRunUpdateReplay(ctx echo.Context, request WorkflowRunUpdateReplayRequestObject) (WorkflowRunUpdateReplayResponseObject, error)

	WorkflowRunGet(ctx echo.Context, request WorkflowRunGetRequestObject) (WorkflowRunGetResponseObject, error)

	WorkflowRunGetInput(ctx echo.Context, request WorkflowRunGetInputRequestObject) (WorkflowRunGetInputResponseObject, error)

	WorkflowRunGetShape(ctx echo.Context, request WorkflowRunGetShapeRequestObject) (WorkflowRunGetShapeResponseObject, error)

	WorkflowRunListStepRunEvents(ctx echo.Context, request WorkflowRunListStepRunEventsRequestObject) (WorkflowRunListStepRunEventsResponseObject, error)

	WorkflowList(ctx echo.Context, request WorkflowListRequestObject) (WorkflowListResponseObject, error)

	WorkflowRunCancel(ctx echo.Context, request WorkflowRunCancelRequestObject) (WorkflowRunCancelResponseObject, error)

	CronWorkflowList(ctx echo.Context, request CronWorkflowListRequestObject) (CronWorkflowListResponseObject, error)

	WorkflowCronDelete(ctx echo.Context, request WorkflowCronDeleteRequestObject) (WorkflowCronDeleteResponseObject, error)

	WorkflowCronGet(ctx echo.Context, request WorkflowCronGetRequestObject) (WorkflowCronGetResponseObject, error)

	WorkflowRunList(ctx echo.Context, request WorkflowRunListRequestObject) (WorkflowRunListResponseObject, error)

	WorkflowRunGetMetrics(ctx echo.Context, request WorkflowRunGetMetricsRequestObject) (WorkflowRunGetMetricsResponseObject, error)

	WorkflowScheduledList(ctx echo.Context, request WorkflowScheduledListRequestObject) (WorkflowScheduledListResponseObject, error)

	WorkflowScheduledDelete(ctx echo.Context, request WorkflowScheduledDeleteRequestObject) (WorkflowScheduledDeleteResponseObject, error)

	WorkflowScheduledGet(ctx echo.Context, request WorkflowScheduledGetRequestObject) (WorkflowScheduledGetResponseObject, error)

	CronWorkflowTriggerCreate(ctx echo.Context, request CronWorkflowTriggerCreateRequestObject) (CronWorkflowTriggerCreateResponseObject, error)

	ScheduledWorkflowRunCreate(ctx echo.Context, request ScheduledWorkflowRunCreateRequestObject) (ScheduledWorkflowRunCreateResponseObject, error)

	WorkflowGetWorkersCount(ctx echo.Context, request WorkflowGetWorkersCountRequestObject) (WorkflowGetWorkersCountResponseObject, error)

	UserGetCurrent(ctx echo.Context, request UserGetCurrentRequestObject) (UserGetCurrentResponseObject, error)

	UserUpdateGithubOauthCallback(ctx echo.Context, request UserUpdateGithubOauthCallbackRequestObject) (UserUpdateGithubOauthCallbackResponseObject, error)

	UserUpdateGithubOauthStart(ctx echo.Context, request UserUpdateGithubOauthStartRequestObject) (UserUpdateGithubOauthStartResponseObject, error)

	UserUpdateGoogleOauthCallback(ctx echo.Context, request UserUpdateGoogleOauthCallbackRequestObject) (UserUpdateGoogleOauthCallbackResponseObject, error)

	UserUpdateGoogleOauthStart(ctx echo.Context, request UserUpdateGoogleOauthStartRequestObject) (UserUpdateGoogleOauthStartResponseObject, error)

	UserListTenantInvites(ctx echo.Context, request UserListTenantInvitesRequestObject) (UserListTenantInvitesResponseObject, error)

	TenantInviteAccept(ctx echo.Context, request TenantInviteAcceptRequestObject) (TenantInviteAcceptResponseObject, error)

	TenantInviteReject(ctx echo.Context, request TenantInviteRejectRequestObject) (TenantInviteRejectResponseObject, error)

	UserUpdateLogin(ctx echo.Context, request UserUpdateLoginRequestObject) (UserUpdateLoginResponseObject, error)

	UserUpdateLogout(ctx echo.Context, request UserUpdateLogoutRequestObject) (UserUpdateLogoutResponseObject, error)

	TenantMembershipsList(ctx echo.Context, request TenantMembershipsListRequestObject) (TenantMembershipsListResponseObject, error)

	UserUpdatePassword(ctx echo.Context, request UserUpdatePasswordRequestObject) (UserUpdatePasswordResponseObject, error)

	UserCreate(ctx echo.Context, request UserCreateRequestObject) (UserCreateResponseObject, error)

	UserUpdateSlackOauthCallback(ctx echo.Context, request UserUpdateSlackOauthCallbackRequestObject) (UserUpdateSlackOauthCallbackResponseObject, error)

	InfoGetVersion(ctx echo.Context, request InfoGetVersionRequestObject) (InfoGetVersionResponseObject, error)

	WebhookDelete(ctx echo.Context, request WebhookDeleteRequestObject) (WebhookDeleteResponseObject, error)

	WebhookRequestsList(ctx echo.Context, request WebhookRequestsListRequestObject) (WebhookRequestsListResponseObject, error)

	WorkerGet(ctx echo.Context, request WorkerGetRequestObject) (WorkerGetResponseObject, error)

	WorkerUpdate(ctx echo.Context, request WorkerUpdateRequestObject) (WorkerUpdateResponseObject, error)

	WorkflowDelete(ctx echo.Context, request WorkflowDeleteRequestObject) (WorkflowDeleteResponseObject, error)

	WorkflowGet(ctx echo.Context, request WorkflowGetRequestObject) (WorkflowGetResponseObject, error)

	WorkflowUpdate(ctx echo.Context, request WorkflowUpdateRequestObject) (WorkflowUpdateResponseObject, error)

	WorkflowGetMetrics(ctx echo.Context, request WorkflowGetMetricsRequestObject) (WorkflowGetMetricsResponseObject, error)

	WorkflowRunCreate(ctx echo.Context, request WorkflowRunCreateRequestObject) (WorkflowRunCreateResponseObject, error)

	WorkflowVersionGet(ctx echo.Context, request WorkflowVersionGetRequestObject) (WorkflowVersionGetResponseObject, error)
}

type Tenant

type Tenant struct {
	// AlertMemberEmails Whether to alert tenant members.
	AlertMemberEmails *bool `json:"alertMemberEmails,omitempty"`

	// AnalyticsOptOut Whether the tenant has opted out of analytics.
	AnalyticsOptOut *bool           `json:"analyticsOptOut,omitempty"`
	Metadata        APIResourceMeta `json:"metadata"`

	// Name The name of the tenant.
	Name string `json:"name"`

	// Slug The slug of the tenant.
	Slug    string        `json:"slug"`
	Version TenantVersion `json:"version"`
}

Tenant defines model for Tenant.

type TenantAlertEmailGroup

type TenantAlertEmailGroup struct {
	// Emails A list of emails for users
	Emails   []string        `json:"emails"`
	Metadata APIResourceMeta `json:"metadata"`
}

TenantAlertEmailGroup defines model for TenantAlertEmailGroup.

type TenantAlertEmailGroupList

type TenantAlertEmailGroupList struct {
	Pagination *PaginationResponse      `json:"pagination,omitempty"`
	Rows       *[]TenantAlertEmailGroup `json:"rows,omitempty"`
}

TenantAlertEmailGroupList defines model for TenantAlertEmailGroupList.

type TenantAlertingSettings

type TenantAlertingSettings struct {
	// AlertMemberEmails Whether to alert tenant members.
	AlertMemberEmails *bool `json:"alertMemberEmails,omitempty"`

	// EnableExpiringTokenAlerts Whether to enable alerts when tokens are approaching expiration.
	EnableExpiringTokenAlerts *bool `json:"enableExpiringTokenAlerts,omitempty"`

	// EnableTenantResourceLimitAlerts Whether to enable alerts when tenant resources are approaching limits.
	EnableTenantResourceLimitAlerts *bool `json:"enableTenantResourceLimitAlerts,omitempty"`

	// EnableWorkflowRunFailureAlerts Whether to send alerts when workflow runs fail.
	EnableWorkflowRunFailureAlerts *bool `json:"enableWorkflowRunFailureAlerts,omitempty"`

	// LastAlertedAt The last time an alert was sent.
	LastAlertedAt *time.Time `json:"lastAlertedAt,omitempty"`

	// MaxAlertingFrequency The max frequency at which to alert.
	MaxAlertingFrequency string          `json:"maxAlertingFrequency"`
	Metadata             APIResourceMeta `json:"metadata"`
}

TenantAlertingSettings defines model for TenantAlertingSettings.

type TenantAlertingSettingsGet200JSONResponse

type TenantAlertingSettingsGet200JSONResponse TenantAlertingSettings

func (TenantAlertingSettingsGet200JSONResponse) VisitTenantAlertingSettingsGetResponse

func (response TenantAlertingSettingsGet200JSONResponse) VisitTenantAlertingSettingsGetResponse(w http.ResponseWriter) error

type TenantAlertingSettingsGet400JSONResponse

type TenantAlertingSettingsGet400JSONResponse APIErrors

func (TenantAlertingSettingsGet400JSONResponse) VisitTenantAlertingSettingsGetResponse

func (response TenantAlertingSettingsGet400JSONResponse) VisitTenantAlertingSettingsGetResponse(w http.ResponseWriter) error

type TenantAlertingSettingsGet403JSONResponse

type TenantAlertingSettingsGet403JSONResponse APIError

func (TenantAlertingSettingsGet403JSONResponse) VisitTenantAlertingSettingsGetResponse

func (response TenantAlertingSettingsGet403JSONResponse) VisitTenantAlertingSettingsGetResponse(w http.ResponseWriter) error

type TenantAlertingSettingsGetRequestObject

type TenantAlertingSettingsGetRequestObject struct {
	Tenant openapi_types.UUID `json:"tenant"`
}

type TenantAlertingSettingsGetResponseObject

type TenantAlertingSettingsGetResponseObject interface {
	VisitTenantAlertingSettingsGetResponse(w http.ResponseWriter) error
}

type TenantCreate200JSONResponse

type TenantCreate200JSONResponse Tenant

func (TenantCreate200JSONResponse) VisitTenantCreateResponse

func (response TenantCreate200JSONResponse) VisitTenantCreateResponse(w http.ResponseWriter) error

type TenantCreate400JSONResponse

type TenantCreate400JSONResponse APIErrors

func (TenantCreate400JSONResponse) VisitTenantCreateResponse

func (response TenantCreate400JSONResponse) VisitTenantCreateResponse(w http.ResponseWriter) error

type TenantCreate403JSONResponse

type TenantCreate403JSONResponse APIError

func (TenantCreate403JSONResponse) VisitTenantCreateResponse

func (response TenantCreate403JSONResponse) VisitTenantCreateResponse(w http.ResponseWriter) error

type TenantCreateJSONRequestBody

type TenantCreateJSONRequestBody = CreateTenantRequest

TenantCreateJSONRequestBody defines body for TenantCreate for application/json ContentType.

type TenantCreateRequestObject

type TenantCreateRequestObject struct {
	Body *TenantCreateJSONRequestBody
}

type TenantCreateResponseObject

type TenantCreateResponseObject interface {
	VisitTenantCreateResponse(w http.ResponseWriter) error
}

type TenantGetQueueMetrics200JSONResponse

type TenantGetQueueMetrics200JSONResponse TenantQueueMetrics

func (TenantGetQueueMetrics200JSONResponse) VisitTenantGetQueueMetricsResponse

func (response TenantGetQueueMetrics200JSONResponse) VisitTenantGetQueueMetricsResponse(w http.ResponseWriter) error

type TenantGetQueueMetrics400JSONResponse

type TenantGetQueueMetrics400JSONResponse APIErrors

func (TenantGetQueueMetrics400JSONResponse) VisitTenantGetQueueMetricsResponse

func (response TenantGetQueueMetrics400JSONResponse) VisitTenantGetQueueMetricsResponse(w http.ResponseWriter) error

type TenantGetQueueMetrics403JSONResponse

type TenantGetQueueMetrics403JSONResponse APIErrors

func (TenantGetQueueMetrics403JSONResponse) VisitTenantGetQueueMetricsResponse

func (response TenantGetQueueMetrics403JSONResponse) VisitTenantGetQueueMetricsResponse(w http.ResponseWriter) error

type TenantGetQueueMetrics404JSONResponse

type TenantGetQueueMetrics404JSONResponse APIErrors

func (TenantGetQueueMetrics404JSONResponse) VisitTenantGetQueueMetricsResponse

func (response TenantGetQueueMetrics404JSONResponse) VisitTenantGetQueueMetricsResponse(w http.ResponseWriter) error

type TenantGetQueueMetricsParams

type TenantGetQueueMetricsParams struct {
	// Workflows A list of workflow IDs to filter by
	Workflows *[]WorkflowID `form:"workflows,omitempty" json:"workflows,omitempty"`

	// AdditionalMetadata A list of metadata key value pairs to filter by
	AdditionalMetadata *[]string `form:"additionalMetadata,omitempty" json:"additionalMetadata,omitempty"`
}

TenantGetQueueMetricsParams defines parameters for TenantGetQueueMetrics.

type TenantGetQueueMetricsRequestObject

type TenantGetQueueMetricsRequestObject struct {
	Tenant openapi_types.UUID `json:"tenant"`
	Params TenantGetQueueMetricsParams
}

type TenantGetQueueMetricsResponseObject

type TenantGetQueueMetricsResponseObject interface {
	VisitTenantGetQueueMetricsResponse(w http.ResponseWriter) error
}

type TenantGetStepRunQueueMetrics200JSONResponse

type TenantGetStepRunQueueMetrics200JSONResponse TenantStepRunQueueMetrics

func (TenantGetStepRunQueueMetrics200JSONResponse) VisitTenantGetStepRunQueueMetricsResponse

func (response TenantGetStepRunQueueMetrics200JSONResponse) VisitTenantGetStepRunQueueMetricsResponse(w http.ResponseWriter) error

type TenantGetStepRunQueueMetrics400JSONResponse

type TenantGetStepRunQueueMetrics400JSONResponse APIErrors

func (TenantGetStepRunQueueMetrics400JSONResponse) VisitTenantGetStepRunQueueMetricsResponse

func (response TenantGetStepRunQueueMetrics400JSONResponse) VisitTenantGetStepRunQueueMetricsResponse(w http.ResponseWriter) error

type TenantGetStepRunQueueMetrics403JSONResponse

type TenantGetStepRunQueueMetrics403JSONResponse APIErrors

func (TenantGetStepRunQueueMetrics403JSONResponse) VisitTenantGetStepRunQueueMetricsResponse

func (response TenantGetStepRunQueueMetrics403JSONResponse) VisitTenantGetStepRunQueueMetricsResponse(w http.ResponseWriter) error

type TenantGetStepRunQueueMetrics404JSONResponse

type TenantGetStepRunQueueMetrics404JSONResponse APIErrors

func (TenantGetStepRunQueueMetrics404JSONResponse) VisitTenantGetStepRunQueueMetricsResponse

func (response TenantGetStepRunQueueMetrics404JSONResponse) VisitTenantGetStepRunQueueMetricsResponse(w http.ResponseWriter) error

type TenantGetStepRunQueueMetricsRequestObject

type TenantGetStepRunQueueMetricsRequestObject struct {
	Tenant openapi_types.UUID `json:"tenant"`
}

type TenantGetStepRunQueueMetricsResponseObject

type TenantGetStepRunQueueMetricsResponseObject interface {
	VisitTenantGetStepRunQueueMetricsResponse(w http.ResponseWriter) error
}

type TenantInvite

type TenantInvite struct {
	// Email The email of the user to invite.
	Email string `json:"email"`

	// Expires The time that this invite expires.
	Expires  time.Time        `json:"expires"`
	Metadata APIResourceMeta  `json:"metadata"`
	Role     TenantMemberRole `json:"role"`

	// TenantId The tenant id associated with this tenant invite.
	TenantId string `json:"tenantId"`

	// TenantName The tenant name for the tenant.
	TenantName *string `json:"tenantName,omitempty"`
}

TenantInvite defines model for TenantInvite.

type TenantInviteAccept200Response

type TenantInviteAccept200Response struct {
}

func (TenantInviteAccept200Response) VisitTenantInviteAcceptResponse

func (response TenantInviteAccept200Response) VisitTenantInviteAcceptResponse(w http.ResponseWriter) error

type TenantInviteAccept400JSONResponse

type TenantInviteAccept400JSONResponse APIErrors

func (TenantInviteAccept400JSONResponse) VisitTenantInviteAcceptResponse

func (response TenantInviteAccept400JSONResponse) VisitTenantInviteAcceptResponse(w http.ResponseWriter) error

type TenantInviteAccept403JSONResponse

type TenantInviteAccept403JSONResponse APIError

func (TenantInviteAccept403JSONResponse) VisitTenantInviteAcceptResponse

func (response TenantInviteAccept403JSONResponse) VisitTenantInviteAcceptResponse(w http.ResponseWriter) error

type TenantInviteAcceptJSONRequestBody

type TenantInviteAcceptJSONRequestBody = AcceptInviteRequest

TenantInviteAcceptJSONRequestBody defines body for TenantInviteAccept for application/json ContentType.

type TenantInviteAcceptRequestObject

type TenantInviteAcceptRequestObject struct {
	Body *TenantInviteAcceptJSONRequestBody
}

type TenantInviteAcceptResponseObject

type TenantInviteAcceptResponseObject interface {
	VisitTenantInviteAcceptResponse(w http.ResponseWriter) error
}

type TenantInviteCreate201JSONResponse

type TenantInviteCreate201JSONResponse TenantInvite

func (TenantInviteCreate201JSONResponse) VisitTenantInviteCreateResponse

func (response TenantInviteCreate201JSONResponse) VisitTenantInviteCreateResponse(w http.ResponseWriter) error

type TenantInviteCreate400JSONResponse

type TenantInviteCreate400JSONResponse APIErrors

func (TenantInviteCreate400JSONResponse) VisitTenantInviteCreateResponse

func (response TenantInviteCreate400JSONResponse) VisitTenantInviteCreateResponse(w http.ResponseWriter) error

type TenantInviteCreate403JSONResponse

type TenantInviteCreate403JSONResponse APIError

func (TenantInviteCreate403JSONResponse) VisitTenantInviteCreateResponse

func (response TenantInviteCreate403JSONResponse) VisitTenantInviteCreateResponse(w http.ResponseWriter) error

type TenantInviteCreateJSONRequestBody

type TenantInviteCreateJSONRequestBody = CreateTenantInviteRequest

TenantInviteCreateJSONRequestBody defines body for TenantInviteCreate for application/json ContentType.

type TenantInviteCreateRequestObject

type TenantInviteCreateRequestObject struct {
	Tenant openapi_types.UUID `json:"tenant"`
	Body   *TenantInviteCreateJSONRequestBody
}

type TenantInviteCreateResponseObject

type TenantInviteCreateResponseObject interface {
	VisitTenantInviteCreateResponse(w http.ResponseWriter) error
}

type TenantInviteDelete200JSONResponse

type TenantInviteDelete200JSONResponse TenantInvite

func (TenantInviteDelete200JSONResponse) VisitTenantInviteDeleteResponse

func (response TenantInviteDelete200JSONResponse) VisitTenantInviteDeleteResponse(w http.ResponseWriter) error

type TenantInviteDelete400JSONResponse

type TenantInviteDelete400JSONResponse APIErrors

func (TenantInviteDelete400JSONResponse) VisitTenantInviteDeleteResponse

func (response TenantInviteDelete400JSONResponse) VisitTenantInviteDeleteResponse(w http.ResponseWriter) error

type TenantInviteDeleteRequestObject

type TenantInviteDeleteRequestObject struct {
	Tenant       openapi_types.UUID `json:"tenant"`
	TenantInvite openapi_types.UUID `json:"tenant-invite"`
}

type TenantInviteDeleteResponseObject

type TenantInviteDeleteResponseObject interface {
	VisitTenantInviteDeleteResponse(w http.ResponseWriter) error
}

type TenantInviteList

type TenantInviteList struct {
	Pagination *PaginationResponse `json:"pagination,omitempty"`
	Rows       *[]TenantInvite     `json:"rows,omitempty"`
}

TenantInviteList defines model for TenantInviteList.

type TenantInviteList200JSONResponse

type TenantInviteList200JSONResponse TenantInviteList

func (TenantInviteList200JSONResponse) VisitTenantInviteListResponse

func (response TenantInviteList200JSONResponse) VisitTenantInviteListResponse(w http.ResponseWriter) error

type TenantInviteList400JSONResponse

type TenantInviteList400JSONResponse APIErrors

func (TenantInviteList400JSONResponse) VisitTenantInviteListResponse

func (response TenantInviteList400JSONResponse) VisitTenantInviteListResponse(w http.ResponseWriter) error

type TenantInviteList403JSONResponse

type TenantInviteList403JSONResponse APIError

func (TenantInviteList403JSONResponse) VisitTenantInviteListResponse

func (response TenantInviteList403JSONResponse) VisitTenantInviteListResponse(w http.ResponseWriter) error

type TenantInviteListRequestObject

type TenantInviteListRequestObject struct {
	Tenant openapi_types.UUID `json:"tenant"`
}

type TenantInviteListResponseObject

type TenantInviteListResponseObject interface {
	VisitTenantInviteListResponse(w http.ResponseWriter) error
}

type TenantInviteReject200Response

type TenantInviteReject200Response struct {
}

func (TenantInviteReject200Response) VisitTenantInviteRejectResponse

func (response TenantInviteReject200Response) VisitTenantInviteRejectResponse(w http.ResponseWriter) error

type TenantInviteReject400JSONResponse

type TenantInviteReject400JSONResponse APIErrors

func (TenantInviteReject400JSONResponse) VisitTenantInviteRejectResponse

func (response TenantInviteReject400JSONResponse) VisitTenantInviteRejectResponse(w http.ResponseWriter) error

type TenantInviteReject403JSONResponse

type TenantInviteReject403JSONResponse APIError

func (TenantInviteReject403JSONResponse) VisitTenantInviteRejectResponse

func (response TenantInviteReject403JSONResponse) VisitTenantInviteRejectResponse(w http.ResponseWriter) error

type TenantInviteRejectJSONRequestBody

type TenantInviteRejectJSONRequestBody = RejectInviteRequest

TenantInviteRejectJSONRequestBody defines body for TenantInviteReject for application/json ContentType.

type TenantInviteRejectRequestObject

type TenantInviteRejectRequestObject struct {
	Body *TenantInviteRejectJSONRequestBody
}

type TenantInviteRejectResponseObject

type TenantInviteRejectResponseObject interface {
	VisitTenantInviteRejectResponse(w http.ResponseWriter) error
}

type TenantInviteUpdate200JSONResponse

type TenantInviteUpdate200JSONResponse TenantInvite

func (TenantInviteUpdate200JSONResponse) VisitTenantInviteUpdateResponse

func (response TenantInviteUpdate200JSONResponse) VisitTenantInviteUpdateResponse(w http.ResponseWriter) error

type TenantInviteUpdate400JSONResponse

type TenantInviteUpdate400JSONResponse APIErrors

func (TenantInviteUpdate400JSONResponse) VisitTenantInviteUpdateResponse

func (response TenantInviteUpdate400JSONResponse) VisitTenantInviteUpdateResponse(w http.ResponseWriter) error

type TenantInviteUpdateJSONRequestBody

type TenantInviteUpdateJSONRequestBody = UpdateTenantInviteRequest

TenantInviteUpdateJSONRequestBody defines body for TenantInviteUpdate for application/json ContentType.

type TenantInviteUpdateRequestObject

type TenantInviteUpdateRequestObject struct {
	Tenant       openapi_types.UUID `json:"tenant"`
	TenantInvite openapi_types.UUID `json:"tenant-invite"`
	Body         *TenantInviteUpdateJSONRequestBody
}

type TenantInviteUpdateResponseObject

type TenantInviteUpdateResponseObject interface {
	VisitTenantInviteUpdateResponse(w http.ResponseWriter) error
}

type TenantMember

type TenantMember struct {
	Metadata APIResourceMeta  `json:"metadata"`
	Role     TenantMemberRole `json:"role"`
	Tenant   *Tenant          `json:"tenant,omitempty"`
	User     UserTenantPublic `json:"user"`
}

TenantMember defines model for TenantMember.

type TenantMemberDelete204JSONResponse

type TenantMemberDelete204JSONResponse TenantMember

func (TenantMemberDelete204JSONResponse) VisitTenantMemberDeleteResponse

func (response TenantMemberDelete204JSONResponse) VisitTenantMemberDeleteResponse(w http.ResponseWriter) error

type TenantMemberDelete400JSONResponse

type TenantMemberDelete400JSONResponse APIErrors

func (TenantMemberDelete400JSONResponse) VisitTenantMemberDeleteResponse

func (response TenantMemberDelete400JSONResponse) VisitTenantMemberDeleteResponse(w http.ResponseWriter) error

type TenantMemberDelete403JSONResponse

type TenantMemberDelete403JSONResponse APIErrors

func (TenantMemberDelete403JSONResponse) VisitTenantMemberDeleteResponse

func (response TenantMemberDelete403JSONResponse) VisitTenantMemberDeleteResponse(w http.ResponseWriter) error

type TenantMemberDelete404JSONResponse

type TenantMemberDelete404JSONResponse APIErrors

func (TenantMemberDelete404JSONResponse) VisitTenantMemberDeleteResponse

func (response TenantMemberDelete404JSONResponse) VisitTenantMemberDeleteResponse(w http.ResponseWriter) error

type TenantMemberDeleteRequestObject

type TenantMemberDeleteRequestObject struct {
	Tenant openapi_types.UUID `json:"tenant"`
	Member openapi_types.UUID `json:"member"`
}

type TenantMemberDeleteResponseObject

type TenantMemberDeleteResponseObject interface {
	VisitTenantMemberDeleteResponse(w http.ResponseWriter) error
}

type TenantMemberList

type TenantMemberList struct {
	Pagination *PaginationResponse `json:"pagination,omitempty"`
	Rows       *[]TenantMember     `json:"rows,omitempty"`
}

TenantMemberList defines model for TenantMemberList.

type TenantMemberList200JSONResponse

type TenantMemberList200JSONResponse TenantMemberList

func (TenantMemberList200JSONResponse) VisitTenantMemberListResponse

func (response TenantMemberList200JSONResponse) VisitTenantMemberListResponse(w http.ResponseWriter) error

type TenantMemberList400JSONResponse

type TenantMemberList400JSONResponse APIErrors

func (TenantMemberList400JSONResponse) VisitTenantMemberListResponse

func (response TenantMemberList400JSONResponse) VisitTenantMemberListResponse(w http.ResponseWriter) error

type TenantMemberList403JSONResponse

type TenantMemberList403JSONResponse APIError

func (TenantMemberList403JSONResponse) VisitTenantMemberListResponse

func (response TenantMemberList403JSONResponse) VisitTenantMemberListResponse(w http.ResponseWriter) error

type TenantMemberListRequestObject

type TenantMemberListRequestObject struct {
	Tenant openapi_types.UUID `json:"tenant"`
}

type TenantMemberListResponseObject

type TenantMemberListResponseObject interface {
	VisitTenantMemberListResponse(w http.ResponseWriter) error
}

type TenantMemberRole

type TenantMemberRole string

TenantMemberRole defines model for TenantMemberRole.

const (
	ADMIN  TenantMemberRole = "ADMIN"
	MEMBER TenantMemberRole = "MEMBER"
	OWNER  TenantMemberRole = "OWNER"
)

Defines values for TenantMemberRole.

type TenantMembershipsList200JSONResponse

type TenantMembershipsList200JSONResponse UserTenantMembershipsList

func (TenantMembershipsList200JSONResponse) VisitTenantMembershipsListResponse

func (response TenantMembershipsList200JSONResponse) VisitTenantMembershipsListResponse(w http.ResponseWriter) error

type TenantMembershipsList400JSONResponse

type TenantMembershipsList400JSONResponse APIErrors

func (TenantMembershipsList400JSONResponse) VisitTenantMembershipsListResponse

func (response TenantMembershipsList400JSONResponse) VisitTenantMembershipsListResponse(w http.ResponseWriter) error

type TenantMembershipsList403JSONResponse

type TenantMembershipsList403JSONResponse APIErrors

func (TenantMembershipsList403JSONResponse) VisitTenantMembershipsListResponse

func (response TenantMembershipsList403JSONResponse) VisitTenantMembershipsListResponse(w http.ResponseWriter) error

type TenantMembershipsListRequestObject

type TenantMembershipsListRequestObject struct {
}

type TenantMembershipsListResponseObject

type TenantMembershipsListResponseObject interface {
	VisitTenantMembershipsListResponse(w http.ResponseWriter) error
}

type TenantQueueMetrics

type TenantQueueMetrics struct {
	Queues   *map[string]int          `json:"queues,omitempty"`
	Total    *QueueMetrics            `json:"total,omitempty"`
	Workflow *map[string]QueueMetrics `json:"workflow,omitempty"`
}

TenantQueueMetrics defines model for TenantQueueMetrics.

type TenantResource

type TenantResource string

TenantResource defines model for TenantResource.

const (
	CRON        TenantResource = "CRON"
	EVENT       TenantResource = "EVENT"
	SCHEDULE    TenantResource = "SCHEDULE"
	WORKER      TenantResource = "WORKER"
	WORKFLOWRUN TenantResource = "WORKFLOW_RUN"
)

Defines values for TenantResource.

type TenantResourceLimit

type TenantResourceLimit struct {
	// AlarmValue The alarm value associated with this limit to warn of approaching limit value.
	AlarmValue *int `json:"alarmValue,omitempty"`

	// LastRefill The last time the limit was refilled.
	LastRefill *time.Time `json:"lastRefill,omitempty"`

	// LimitValue The limit associated with this limit.
	LimitValue int             `json:"limitValue"`
	Metadata   APIResourceMeta `json:"metadata"`
	Resource   TenantResource  `json:"resource"`

	// Value The current value associated with this limit.
	Value int `json:"value"`

	// Window The meter window for the limit. (i.e. 1 day, 1 week, 1 month)
	Window *string `json:"window,omitempty"`
}

TenantResourceLimit defines model for TenantResourceLimit.

type TenantResourcePolicy

type TenantResourcePolicy struct {
	// Limits A list of resource limits for the tenant.
	Limits []TenantResourceLimit `json:"limits"`
}

TenantResourcePolicy defines model for TenantResourcePolicy.

type TenantResourcePolicyGet200JSONResponse

type TenantResourcePolicyGet200JSONResponse TenantResourcePolicy

func (TenantResourcePolicyGet200JSONResponse) VisitTenantResourcePolicyGetResponse

func (response TenantResourcePolicyGet200JSONResponse) VisitTenantResourcePolicyGetResponse(w http.ResponseWriter) error

type TenantResourcePolicyGet400JSONResponse

type TenantResourcePolicyGet400JSONResponse APIErrors

func (TenantResourcePolicyGet400JSONResponse) VisitTenantResourcePolicyGetResponse

func (response TenantResourcePolicyGet400JSONResponse) VisitTenantResourcePolicyGetResponse(w http.ResponseWriter) error

type TenantResourcePolicyGet403JSONResponse

type TenantResourcePolicyGet403JSONResponse APIError

func (TenantResourcePolicyGet403JSONResponse) VisitTenantResourcePolicyGetResponse

func (response TenantResourcePolicyGet403JSONResponse) VisitTenantResourcePolicyGetResponse(w http.ResponseWriter) error

type TenantResourcePolicyGetRequestObject

type TenantResourcePolicyGetRequestObject struct {
	Tenant openapi_types.UUID `json:"tenant"`
}

type TenantResourcePolicyGetResponseObject

type TenantResourcePolicyGetResponseObject interface {
	VisitTenantResourcePolicyGetResponse(w http.ResponseWriter) error
}

type TenantStepRunQueueMetrics

type TenantStepRunQueueMetrics struct {
	Queues *map[string]int `json:"queues,omitempty"`
}

TenantStepRunQueueMetrics defines model for TenantStepRunQueueMetrics.

type TenantUpdate200JSONResponse

type TenantUpdate200JSONResponse Tenant

func (TenantUpdate200JSONResponse) VisitTenantUpdateResponse

func (response TenantUpdate200JSONResponse) VisitTenantUpdateResponse(w http.ResponseWriter) error

type TenantUpdate400JSONResponse

type TenantUpdate400JSONResponse APIErrors

func (TenantUpdate400JSONResponse) VisitTenantUpdateResponse

func (response TenantUpdate400JSONResponse) VisitTenantUpdateResponse(w http.ResponseWriter) error

type TenantUpdate403JSONResponse

type TenantUpdate403JSONResponse APIError

func (TenantUpdate403JSONResponse) VisitTenantUpdateResponse

func (response TenantUpdate403JSONResponse) VisitTenantUpdateResponse(w http.ResponseWriter) error

type TenantUpdateJSONRequestBody

type TenantUpdateJSONRequestBody = UpdateTenantRequest

TenantUpdateJSONRequestBody defines body for TenantUpdate for application/json ContentType.

type TenantUpdateRequestObject

type TenantUpdateRequestObject struct {
	Tenant openapi_types.UUID `json:"tenant"`
	Body   *TenantUpdateJSONRequestBody
}

type TenantUpdateResponseObject

type TenantUpdateResponseObject interface {
	VisitTenantUpdateResponse(w http.ResponseWriter) error
}

type TenantVersion

type TenantVersion string

TenantVersion defines model for TenantVersion.

const (
	V0 TenantVersion = "V0"
	V1 TenantVersion = "V1"
)

Defines values for TenantVersion.

type TriggerWorkflowRunRequest

type TriggerWorkflowRunRequest struct {
	AdditionalMetadata *map[string]interface{} `json:"additionalMetadata,omitempty"`
	Input              map[string]interface{}  `json:"input"`
}

TriggerWorkflowRunRequest defines model for TriggerWorkflowRunRequest.

type UpdateTenantAlertEmailGroupRequest

type UpdateTenantAlertEmailGroupRequest struct {
	// Emails A list of emails for users
	Emails []string `json:"emails" validate:"required,dive,email"`
}

UpdateTenantAlertEmailGroupRequest defines model for UpdateTenantAlertEmailGroupRequest.

type UpdateTenantInviteRequest

type UpdateTenantInviteRequest struct {
	Role TenantMemberRole `json:"role"`
}

UpdateTenantInviteRequest defines model for UpdateTenantInviteRequest.

type UpdateTenantRequest

type UpdateTenantRequest struct {
	// AlertMemberEmails Whether to alert tenant members.
	AlertMemberEmails *bool `json:"alertMemberEmails,omitempty"`

	// AnalyticsOptOut Whether the tenant has opted out of analytics.
	AnalyticsOptOut *bool `json:"analyticsOptOut,omitempty"`

	// EnableExpiringTokenAlerts Whether to enable alerts when tokens are approaching expiration.
	EnableExpiringTokenAlerts *bool `json:"enableExpiringTokenAlerts,omitempty"`

	// EnableTenantResourceLimitAlerts Whether to enable alerts when tenant resources are approaching limits.
	EnableTenantResourceLimitAlerts *bool `json:"enableTenantResourceLimitAlerts,omitempty"`

	// EnableWorkflowRunFailureAlerts Whether to send alerts when workflow runs fail.
	EnableWorkflowRunFailureAlerts *bool `json:"enableWorkflowRunFailureAlerts,omitempty"`

	// MaxAlertingFrequency The max frequency at which to alert.
	MaxAlertingFrequency *string `json:"maxAlertingFrequency,omitempty" validate:"omitnil,duration"`

	// Name The name of the tenant.
	Name    *string        `json:"name,omitempty"`
	Version *TenantVersion `json:"version,omitempty"`
}

UpdateTenantRequest defines model for UpdateTenantRequest.

type UpdateWorkerRequest

type UpdateWorkerRequest struct {
	// IsPaused Whether the worker is paused and cannot accept new runs.
	IsPaused *bool `json:"isPaused,omitempty"`
}

UpdateWorkerRequest defines model for UpdateWorkerRequest.

type User

type User struct {
	// Email The email address of the user.
	Email openapi_types.Email `json:"email"`

	// EmailHash A hash of the user's email address for use with Pylon Support Chat
	EmailHash *string `json:"emailHash,omitempty"`

	// EmailVerified Whether the user has verified their email address.
	EmailVerified bool `json:"emailVerified"`

	// HasPassword Whether the user has a password set.
	HasPassword *bool           `json:"hasPassword,omitempty"`
	Metadata    APIResourceMeta `json:"metadata"`

	// Name The display name of the user.
	Name *string `json:"name,omitempty"`
}

User defines model for User.

type UserChangePasswordRequest

type UserChangePasswordRequest struct {
	// NewPassword The new password for the user.
	NewPassword string `json:"newPassword" validate:"required,password"`

	// Password The password of the user.
	Password string `json:"password" validate:"required,password"`
}

UserChangePasswordRequest defines model for UserChangePasswordRequest.

type UserCreate200JSONResponse

type UserCreate200JSONResponse User

func (UserCreate200JSONResponse) VisitUserCreateResponse

func (response UserCreate200JSONResponse) VisitUserCreateResponse(w http.ResponseWriter) error

type UserCreate400JSONResponse

type UserCreate400JSONResponse APIErrors

func (UserCreate400JSONResponse) VisitUserCreateResponse

func (response UserCreate400JSONResponse) VisitUserCreateResponse(w http.ResponseWriter) error

type UserCreate401JSONResponse

type UserCreate401JSONResponse APIErrors

func (UserCreate401JSONResponse) VisitUserCreateResponse

func (response UserCreate401JSONResponse) VisitUserCreateResponse(w http.ResponseWriter) error

type UserCreate405JSONResponse

type UserCreate405JSONResponse APIErrors

func (UserCreate405JSONResponse) VisitUserCreateResponse

func (response UserCreate405JSONResponse) VisitUserCreateResponse(w http.ResponseWriter) error

type UserCreateJSONRequestBody

type UserCreateJSONRequestBody = UserRegisterRequest

UserCreateJSONRequestBody defines body for UserCreate for application/json ContentType.

type UserCreateRequestObject

type UserCreateRequestObject struct {
	Body *UserCreateJSONRequestBody
}

type UserCreateResponseObject

type UserCreateResponseObject interface {
	VisitUserCreateResponse(w http.ResponseWriter) error
}

type UserGetCurrent200JSONResponse

type UserGetCurrent200JSONResponse User

func (UserGetCurrent200JSONResponse) VisitUserGetCurrentResponse

func (response UserGetCurrent200JSONResponse) VisitUserGetCurrentResponse(w http.ResponseWriter) error

type UserGetCurrent400JSONResponse

type UserGetCurrent400JSONResponse APIErrors

func (UserGetCurrent400JSONResponse) VisitUserGetCurrentResponse

func (response UserGetCurrent400JSONResponse) VisitUserGetCurrentResponse(w http.ResponseWriter) error

type UserGetCurrent401JSONResponse

type UserGetCurrent401JSONResponse APIErrors

func (UserGetCurrent401JSONResponse) VisitUserGetCurrentResponse

func (response UserGetCurrent401JSONResponse) VisitUserGetCurrentResponse(w http.ResponseWriter) error

type UserGetCurrent405JSONResponse

type UserGetCurrent405JSONResponse APIErrors

func (UserGetCurrent405JSONResponse) VisitUserGetCurrentResponse

func (response UserGetCurrent405JSONResponse) VisitUserGetCurrentResponse(w http.ResponseWriter) error

type UserGetCurrentRequestObject

type UserGetCurrentRequestObject struct {
}

type UserGetCurrentResponseObject

type UserGetCurrentResponseObject interface {
	VisitUserGetCurrentResponse(w http.ResponseWriter) error
}

type UserListTenantInvites200JSONResponse

type UserListTenantInvites200JSONResponse TenantInviteList

func (UserListTenantInvites200JSONResponse) VisitUserListTenantInvitesResponse

func (response UserListTenantInvites200JSONResponse) VisitUserListTenantInvitesResponse(w http.ResponseWriter) error

type UserListTenantInvites400JSONResponse

type UserListTenantInvites400JSONResponse APIErrors

func (UserListTenantInvites400JSONResponse) VisitUserListTenantInvitesResponse

func (response UserListTenantInvites400JSONResponse) VisitUserListTenantInvitesResponse(w http.ResponseWriter) error

type UserListTenantInvites403JSONResponse

type UserListTenantInvites403JSONResponse APIErrors

func (UserListTenantInvites403JSONResponse) VisitUserListTenantInvitesResponse

func (response UserListTenantInvites403JSONResponse) VisitUserListTenantInvitesResponse(w http.ResponseWriter) error

type UserListTenantInvitesRequestObject

type UserListTenantInvitesRequestObject struct {
}

type UserListTenantInvitesResponseObject

type UserListTenantInvitesResponseObject interface {
	VisitUserListTenantInvitesResponse(w http.ResponseWriter) error
}

type UserLoginRequest

type UserLoginRequest struct {
	// Email The email address of the user.
	Email openapi_types.Email `json:"email" validate:"required,email"`

	// Password The password of the user.
	Password string `json:"password" validate:"required,password"`
}

UserLoginRequest defines model for UserLoginRequest.

type UserRegisterRequest

type UserRegisterRequest struct {
	// Email The email address of the user.
	Email openapi_types.Email `json:"email" validate:"required,email"`

	// Name The name of the user.
	Name string `json:"name"`

	// Password The password of the user.
	Password string `json:"password" validate:"required,password"`
}

UserRegisterRequest defines model for UserRegisterRequest.

type UserTenantMembershipsList

type UserTenantMembershipsList struct {
	Pagination *PaginationResponse `json:"pagination,omitempty"`
	Rows       *[]TenantMember     `json:"rows,omitempty"`
}

UserTenantMembershipsList defines model for UserTenantMembershipsList.

type UserTenantPublic

type UserTenantPublic struct {
	// Email The email address of the user.
	Email openapi_types.Email `json:"email"`

	// Name The display name of the user.
	Name *string `json:"name,omitempty"`
}

UserTenantPublic defines model for UserTenantPublic.

type UserUpdateGithubOauthCallback302Response

type UserUpdateGithubOauthCallback302Response struct {
	Headers UserUpdateGithubOauthCallback302ResponseHeaders
}

func (UserUpdateGithubOauthCallback302Response) VisitUserUpdateGithubOauthCallbackResponse

func (response UserUpdateGithubOauthCallback302Response) VisitUserUpdateGithubOauthCallbackResponse(w http.ResponseWriter) error

type UserUpdateGithubOauthCallback302ResponseHeaders

type UserUpdateGithubOauthCallback302ResponseHeaders struct {
	Location string
}

type UserUpdateGithubOauthCallbackRequestObject

type UserUpdateGithubOauthCallbackRequestObject struct {
}

type UserUpdateGithubOauthCallbackResponseObject

type UserUpdateGithubOauthCallbackResponseObject interface {
	VisitUserUpdateGithubOauthCallbackResponse(w http.ResponseWriter) error
}

type UserUpdateGithubOauthStart302Response

type UserUpdateGithubOauthStart302Response struct {
	Headers UserUpdateGithubOauthStart302ResponseHeaders
}

func (UserUpdateGithubOauthStart302Response) VisitUserUpdateGithubOauthStartResponse

func (response UserUpdateGithubOauthStart302Response) VisitUserUpdateGithubOauthStartResponse(w http.ResponseWriter) error

type UserUpdateGithubOauthStart302ResponseHeaders

type UserUpdateGithubOauthStart302ResponseHeaders struct {
	Location string
}

type UserUpdateGithubOauthStartRequestObject

type UserUpdateGithubOauthStartRequestObject struct {
}

type UserUpdateGithubOauthStartResponseObject

type UserUpdateGithubOauthStartResponseObject interface {
	VisitUserUpdateGithubOauthStartResponse(w http.ResponseWriter) error
}

type UserUpdateGoogleOauthCallback302Response

type UserUpdateGoogleOauthCallback302Response struct {
	Headers UserUpdateGoogleOauthCallback302ResponseHeaders
}

func (UserUpdateGoogleOauthCallback302Response) VisitUserUpdateGoogleOauthCallbackResponse

func (response UserUpdateGoogleOauthCallback302Response) VisitUserUpdateGoogleOauthCallbackResponse(w http.ResponseWriter) error

type UserUpdateGoogleOauthCallback302ResponseHeaders

type UserUpdateGoogleOauthCallback302ResponseHeaders struct {
	Location string
}

type UserUpdateGoogleOauthCallbackRequestObject

type UserUpdateGoogleOauthCallbackRequestObject struct {
}

type UserUpdateGoogleOauthCallbackResponseObject

type UserUpdateGoogleOauthCallbackResponseObject interface {
	VisitUserUpdateGoogleOauthCallbackResponse(w http.ResponseWriter) error
}

type UserUpdateGoogleOauthStart302Response

type UserUpdateGoogleOauthStart302Response struct {
	Headers UserUpdateGoogleOauthStart302ResponseHeaders
}

func (UserUpdateGoogleOauthStart302Response) VisitUserUpdateGoogleOauthStartResponse

func (response UserUpdateGoogleOauthStart302Response) VisitUserUpdateGoogleOauthStartResponse(w http.ResponseWriter) error

type UserUpdateGoogleOauthStart302ResponseHeaders

type UserUpdateGoogleOauthStart302ResponseHeaders struct {
	Location string
}

type UserUpdateGoogleOauthStartRequestObject

type UserUpdateGoogleOauthStartRequestObject struct {
}

type UserUpdateGoogleOauthStartResponseObject

type UserUpdateGoogleOauthStartResponseObject interface {
	VisitUserUpdateGoogleOauthStartResponse(w http.ResponseWriter) error
}

type UserUpdateLogin200JSONResponse

type UserUpdateLogin200JSONResponse User

func (UserUpdateLogin200JSONResponse) VisitUserUpdateLoginResponse

func (response UserUpdateLogin200JSONResponse) VisitUserUpdateLoginResponse(w http.ResponseWriter) error

type UserUpdateLogin400JSONResponse

type UserUpdateLogin400JSONResponse APIErrors

func (UserUpdateLogin400JSONResponse) VisitUserUpdateLoginResponse

func (response UserUpdateLogin400JSONResponse) VisitUserUpdateLoginResponse(w http.ResponseWriter) error

type UserUpdateLogin401JSONResponse

type UserUpdateLogin401JSONResponse APIErrors

func (UserUpdateLogin401JSONResponse) VisitUserUpdateLoginResponse

func (response UserUpdateLogin401JSONResponse) VisitUserUpdateLoginResponse(w http.ResponseWriter) error

type UserUpdateLogin405JSONResponse

type UserUpdateLogin405JSONResponse APIErrors

func (UserUpdateLogin405JSONResponse) VisitUserUpdateLoginResponse

func (response UserUpdateLogin405JSONResponse) VisitUserUpdateLoginResponse(w http.ResponseWriter) error

type UserUpdateLoginJSONRequestBody

type UserUpdateLoginJSONRequestBody = UserLoginRequest

UserUpdateLoginJSONRequestBody defines body for UserUpdateLogin for application/json ContentType.

type UserUpdateLoginRequestObject

type UserUpdateLoginRequestObject struct {
	Body *UserUpdateLoginJSONRequestBody
}

type UserUpdateLoginResponseObject

type UserUpdateLoginResponseObject interface {
	VisitUserUpdateLoginResponse(w http.ResponseWriter) error
}

type UserUpdateLogout200JSONResponse

type UserUpdateLogout200JSONResponse User

func (UserUpdateLogout200JSONResponse) VisitUserUpdateLogoutResponse

func (response UserUpdateLogout200JSONResponse) VisitUserUpdateLogoutResponse(w http.ResponseWriter) error

type UserUpdateLogout400JSONResponse

type UserUpdateLogout400JSONResponse APIErrors

func (UserUpdateLogout400JSONResponse) VisitUserUpdateLogoutResponse

func (response UserUpdateLogout400JSONResponse) VisitUserUpdateLogoutResponse(w http.ResponseWriter) error

type UserUpdateLogout401JSONResponse

type UserUpdateLogout401JSONResponse APIErrors

func (UserUpdateLogout401JSONResponse) VisitUserUpdateLogoutResponse

func (response UserUpdateLogout401JSONResponse) VisitUserUpdateLogoutResponse(w http.ResponseWriter) error

type UserUpdateLogout405JSONResponse

type UserUpdateLogout405JSONResponse APIErrors

func (UserUpdateLogout405JSONResponse) VisitUserUpdateLogoutResponse

func (response UserUpdateLogout405JSONResponse) VisitUserUpdateLogoutResponse(w http.ResponseWriter) error

type UserUpdateLogoutRequestObject

type UserUpdateLogoutRequestObject struct {
}

type UserUpdateLogoutResponseObject

type UserUpdateLogoutResponseObject interface {
	VisitUserUpdateLogoutResponse(w http.ResponseWriter) error
}

type UserUpdatePassword200JSONResponse

type UserUpdatePassword200JSONResponse User

func (UserUpdatePassword200JSONResponse) VisitUserUpdatePasswordResponse

func (response UserUpdatePassword200JSONResponse) VisitUserUpdatePasswordResponse(w http.ResponseWriter) error

type UserUpdatePassword400JSONResponse

type UserUpdatePassword400JSONResponse APIErrors

func (UserUpdatePassword400JSONResponse) VisitUserUpdatePasswordResponse

func (response UserUpdatePassword400JSONResponse) VisitUserUpdatePasswordResponse(w http.ResponseWriter) error

type UserUpdatePassword401JSONResponse

type UserUpdatePassword401JSONResponse APIErrors

func (UserUpdatePassword401JSONResponse) VisitUserUpdatePasswordResponse

func (response UserUpdatePassword401JSONResponse) VisitUserUpdatePasswordResponse(w http.ResponseWriter) error

type UserUpdatePassword405JSONResponse

type UserUpdatePassword405JSONResponse APIErrors

func (UserUpdatePassword405JSONResponse) VisitUserUpdatePasswordResponse

func (response UserUpdatePassword405JSONResponse) VisitUserUpdatePasswordResponse(w http.ResponseWriter) error

type UserUpdatePasswordJSONRequestBody

type UserUpdatePasswordJSONRequestBody = UserChangePasswordRequest

UserUpdatePasswordJSONRequestBody defines body for UserUpdatePassword for application/json ContentType.

type UserUpdatePasswordRequestObject

type UserUpdatePasswordRequestObject struct {
	Body *UserUpdatePasswordJSONRequestBody
}

type UserUpdatePasswordResponseObject

type UserUpdatePasswordResponseObject interface {
	VisitUserUpdatePasswordResponse(w http.ResponseWriter) error
}

type UserUpdateSlackOauthCallback302Response

type UserUpdateSlackOauthCallback302Response struct {
	Headers UserUpdateSlackOauthCallback302ResponseHeaders
}

func (UserUpdateSlackOauthCallback302Response) VisitUserUpdateSlackOauthCallbackResponse

func (response UserUpdateSlackOauthCallback302Response) VisitUserUpdateSlackOauthCallbackResponse(w http.ResponseWriter) error

type UserUpdateSlackOauthCallback302ResponseHeaders

type UserUpdateSlackOauthCallback302ResponseHeaders struct {
	Location string
}

type UserUpdateSlackOauthCallbackRequestObject

type UserUpdateSlackOauthCallbackRequestObject struct {
}

type UserUpdateSlackOauthCallbackResponseObject

type UserUpdateSlackOauthCallbackResponseObject interface {
	VisitUserUpdateSlackOauthCallbackResponse(w http.ResponseWriter) error
}

type UserUpdateSlackOauthStart302Response

type UserUpdateSlackOauthStart302Response struct {
	Headers UserUpdateSlackOauthStart302ResponseHeaders
}

func (UserUpdateSlackOauthStart302Response) VisitUserUpdateSlackOauthStartResponse

func (response UserUpdateSlackOauthStart302Response) VisitUserUpdateSlackOauthStartResponse(w http.ResponseWriter) error

type UserUpdateSlackOauthStart302ResponseHeaders

type UserUpdateSlackOauthStart302ResponseHeaders struct {
	Location string
}

type UserUpdateSlackOauthStartRequestObject

type UserUpdateSlackOauthStartRequestObject struct {
	Tenant openapi_types.UUID `json:"tenant"`
}

type UserUpdateSlackOauthStartResponseObject

type UserUpdateSlackOauthStartResponseObject interface {
	VisitUserUpdateSlackOauthStartResponse(w http.ResponseWriter) error
}

type V1CancelTaskRequest

type V1CancelTaskRequest struct {
	// ExternalIds A list of external IDs, which can refer to either task or workflow run external IDs
	ExternalIds *[]openapi_types.UUID `json:"externalIds,omitempty"`
	Filter      *V1TaskFilter         `json:"filter,omitempty"`
}

V1CancelTaskRequest defines model for V1CancelTaskRequest.

type V1DagChildren

type V1DagChildren struct {
	Children *[]V1TaskSummary    `json:"children,omitempty"`
	DagId    *openapi_types.UUID `json:"dagId,omitempty"`
}

V1DagChildren defines model for V1DagChildren.

type V1DagListTasks200JSONResponse

type V1DagListTasks200JSONResponse []V1DagChildren

func (V1DagListTasks200JSONResponse) VisitV1DagListTasksResponse

func (response V1DagListTasks200JSONResponse) VisitV1DagListTasksResponse(w http.ResponseWriter) error

type V1DagListTasks400JSONResponse

type V1DagListTasks400JSONResponse APIErrors

func (V1DagListTasks400JSONResponse) VisitV1DagListTasksResponse

func (response V1DagListTasks400JSONResponse) VisitV1DagListTasksResponse(w http.ResponseWriter) error

type V1DagListTasks403JSONResponse

type V1DagListTasks403JSONResponse APIErrors

func (V1DagListTasks403JSONResponse) VisitV1DagListTasksResponse

func (response V1DagListTasks403JSONResponse) VisitV1DagListTasksResponse(w http.ResponseWriter) error

type V1DagListTasks501JSONResponse

type V1DagListTasks501JSONResponse APIErrors

func (V1DagListTasks501JSONResponse) VisitV1DagListTasksResponse

func (response V1DagListTasks501JSONResponse) VisitV1DagListTasksResponse(w http.ResponseWriter) error

type V1DagListTasksParams

type V1DagListTasksParams struct {
	// DagIds The external id of the DAG
	DagIds []openapi_types.UUID `form:"dag_ids" json:"dag_ids"`

	// Tenant The tenant id
	Tenant openapi_types.UUID `form:"tenant" json:"tenant"`
}

V1DagListTasksParams defines parameters for V1DagListTasks.

type V1DagListTasksRequestObject

type V1DagListTasksRequestObject struct {
	Params V1DagListTasksParams
}

type V1DagListTasksResponseObject

type V1DagListTasksResponseObject interface {
	VisitV1DagListTasksResponse(w http.ResponseWriter) error
}

type V1LogLine

type V1LogLine struct {
	// CreatedAt The creation date of the log line.
	CreatedAt time.Time `json:"createdAt"`

	// Message The log message.
	Message string `json:"message"`

	// Metadata The log metadata.
	Metadata map[string]interface{} `json:"metadata"`
}

V1LogLine defines model for V1LogLine.

type V1LogLineList

type V1LogLineList struct {
	Pagination *PaginationResponse `json:"pagination,omitempty"`
	Rows       *[]V1LogLine        `json:"rows,omitempty"`
}

V1LogLineList defines model for V1LogLineList.

type V1LogLineList200JSONResponse

type V1LogLineList200JSONResponse V1LogLineList

func (V1LogLineList200JSONResponse) VisitV1LogLineListResponse

func (response V1LogLineList200JSONResponse) VisitV1LogLineListResponse(w http.ResponseWriter) error

type V1LogLineList400JSONResponse

type V1LogLineList400JSONResponse APIErrors

func (V1LogLineList400JSONResponse) VisitV1LogLineListResponse

func (response V1LogLineList400JSONResponse) VisitV1LogLineListResponse(w http.ResponseWriter) error

type V1LogLineList403JSONResponse

type V1LogLineList403JSONResponse APIErrors

func (V1LogLineList403JSONResponse) VisitV1LogLineListResponse

func (response V1LogLineList403JSONResponse) VisitV1LogLineListResponse(w http.ResponseWriter) error

type V1LogLineListRequestObject

type V1LogLineListRequestObject struct {
	Task openapi_types.UUID `json:"task"`
}

type V1LogLineListResponseObject

type V1LogLineListResponseObject interface {
	VisitV1LogLineListResponse(w http.ResponseWriter) error
}

type V1ReplayTaskRequest

type V1ReplayTaskRequest struct {
	// ExternalIds A list of external IDs, which can refer to either task or workflow run external IDs
	ExternalIds *[]openapi_types.UUID `json:"externalIds,omitempty"`
	Filter      *V1TaskFilter         `json:"filter,omitempty"`
}

V1ReplayTaskRequest defines model for V1ReplayTaskRequest.

type V1TaskCancel200Response added in v0.55.0

type V1TaskCancel200Response struct {
}

func (V1TaskCancel200Response) VisitV1TaskCancelResponse added in v0.55.0

func (response V1TaskCancel200Response) VisitV1TaskCancelResponse(w http.ResponseWriter) error

type V1TaskCancel400JSONResponse

type V1TaskCancel400JSONResponse APIErrors

func (V1TaskCancel400JSONResponse) VisitV1TaskCancelResponse

func (response V1TaskCancel400JSONResponse) VisitV1TaskCancelResponse(w http.ResponseWriter) error

type V1TaskCancel403JSONResponse

type V1TaskCancel403JSONResponse APIErrors

func (V1TaskCancel403JSONResponse) VisitV1TaskCancelResponse

func (response V1TaskCancel403JSONResponse) VisitV1TaskCancelResponse(w http.ResponseWriter) error

type V1TaskCancel404JSONResponse

type V1TaskCancel404JSONResponse APIErrors

func (V1TaskCancel404JSONResponse) VisitV1TaskCancelResponse

func (response V1TaskCancel404JSONResponse) VisitV1TaskCancelResponse(w http.ResponseWriter) error

type V1TaskCancel501JSONResponse

type V1TaskCancel501JSONResponse APIErrors

func (V1TaskCancel501JSONResponse) VisitV1TaskCancelResponse

func (response V1TaskCancel501JSONResponse) VisitV1TaskCancelResponse(w http.ResponseWriter) error

type V1TaskCancelJSONRequestBody

type V1TaskCancelJSONRequestBody = V1CancelTaskRequest

V1TaskCancelJSONRequestBody defines body for V1TaskCancel for application/json ContentType.

type V1TaskCancelRequestObject

type V1TaskCancelRequestObject struct {
	Tenant openapi_types.UUID `json:"tenant"`
	Body   *V1TaskCancelJSONRequestBody
}

type V1TaskCancelResponseObject

type V1TaskCancelResponseObject interface {
	VisitV1TaskCancelResponse(w http.ResponseWriter) error
}

type V1TaskEvent

type V1TaskEvent struct {
	ErrorMessage    *string             `json:"errorMessage,omitempty"`
	EventType       V1TaskEventType     `json:"eventType"`
	Id              int                 `json:"id"`
	Message         string              `json:"message"`
	Output          *string             `json:"output,omitempty"`
	TaskDisplayName *string             `json:"taskDisplayName,omitempty"`
	TaskId          openapi_types.UUID  `json:"taskId"`
	Timestamp       time.Time           `json:"timestamp"`
	WorkerId        *openapi_types.UUID `json:"workerId,omitempty"`
}

V1TaskEvent defines model for V1TaskEvent.

type V1TaskEventList

type V1TaskEventList struct {
	Pagination *PaginationResponse `json:"pagination,omitempty"`
	Rows       *[]V1TaskEvent      `json:"rows,omitempty"`
}

V1TaskEventList defines model for V1TaskEventList.

type V1TaskEventList200JSONResponse

type V1TaskEventList200JSONResponse V1TaskEventList

func (V1TaskEventList200JSONResponse) VisitV1TaskEventListResponse

func (response V1TaskEventList200JSONResponse) VisitV1TaskEventListResponse(w http.ResponseWriter) error

type V1TaskEventList400JSONResponse

type V1TaskEventList400JSONResponse APIErrors

func (V1TaskEventList400JSONResponse) VisitV1TaskEventListResponse

func (response V1TaskEventList400JSONResponse) VisitV1TaskEventListResponse(w http.ResponseWriter) error

type V1TaskEventList403JSONResponse

type V1TaskEventList403JSONResponse APIErrors

func (V1TaskEventList403JSONResponse) VisitV1TaskEventListResponse

func (response V1TaskEventList403JSONResponse) VisitV1TaskEventListResponse(w http.ResponseWriter) error

type V1TaskEventList404JSONResponse

type V1TaskEventList404JSONResponse APIErrors

func (V1TaskEventList404JSONResponse) VisitV1TaskEventListResponse

func (response V1TaskEventList404JSONResponse) VisitV1TaskEventListResponse(w http.ResponseWriter) error

type V1TaskEventList501JSONResponse

type V1TaskEventList501JSONResponse APIErrors

func (V1TaskEventList501JSONResponse) VisitV1TaskEventListResponse

func (response V1TaskEventList501JSONResponse) VisitV1TaskEventListResponse(w http.ResponseWriter) error

type V1TaskEventListParams

type V1TaskEventListParams struct {
	// Offset The number to skip
	Offset *int64 `form:"offset,omitempty" json:"offset,omitempty"`

	// Limit The number to limit by
	Limit *int64 `form:"limit,omitempty" json:"limit,omitempty"`
}

V1TaskEventListParams defines parameters for V1TaskEventList.

type V1TaskEventListRequestObject

type V1TaskEventListRequestObject struct {
	Task   openapi_types.UUID `json:"task"`
	Params V1TaskEventListParams
}

type V1TaskEventListResponseObject

type V1TaskEventListResponseObject interface {
	VisitV1TaskEventListResponse(w http.ResponseWriter) error
}

type V1TaskEventType

type V1TaskEventType string

V1TaskEventType defines model for V1TaskEventType.

const (
	V1TaskEventTypeACKNOWLEDGED       V1TaskEventType = "ACKNOWLEDGED"
	V1TaskEventTypeASSIGNED           V1TaskEventType = "ASSIGNED"
	V1TaskEventTypeCANCELLED          V1TaskEventType = "CANCELLED"
	V1TaskEventTypeCREATED            V1TaskEventType = "CREATED"
	V1TaskEventTypeFAILED             V1TaskEventType = "FAILED"
	V1TaskEventTypeFINISHED           V1TaskEventType = "FINISHED"
	V1TaskEventTypeQUEUED             V1TaskEventType = "QUEUED"
	V1TaskEventTypeRATELIMITERROR     V1TaskEventType = "RATE_LIMIT_ERROR"
	V1TaskEventTypeREASSIGNED         V1TaskEventType = "REASSIGNED"
	V1TaskEventTypeREQUEUEDNOWORKER   V1TaskEventType = "REQUEUED_NO_WORKER"
	V1TaskEventTypeREQUEUEDRATELIMIT  V1TaskEventType = "REQUEUED_RATE_LIMIT"
	V1TaskEventTypeRETRIEDBYUSER      V1TaskEventType = "RETRIED_BY_USER"
	V1TaskEventTypeRETRYING           V1TaskEventType = "RETRYING"
	V1TaskEventTypeSCHEDULINGTIMEDOUT V1TaskEventType = "SCHEDULING_TIMED_OUT"
	V1TaskEventTypeSENTTOWORKER       V1TaskEventType = "SENT_TO_WORKER"
	V1TaskEventTypeSKIPPED            V1TaskEventType = "SKIPPED"
	V1TaskEventTypeSLOTRELEASED       V1TaskEventType = "SLOT_RELEASED"
	V1TaskEventTypeSTARTED            V1TaskEventType = "STARTED"
	V1TaskEventTypeTIMEDOUT           V1TaskEventType = "TIMED_OUT"
	V1TaskEventTypeTIMEOUTREFRESHED   V1TaskEventType = "TIMEOUT_REFRESHED"
)

Defines values for V1TaskEventType.

type V1TaskFilter

type V1TaskFilter struct {
	AdditionalMetadata *[]string             `json:"additionalMetadata,omitempty"`
	Since              time.Time             `json:"since"`
	Statuses           *[]V1TaskStatus       `json:"statuses,omitempty"`
	Until              *time.Time            `json:"until,omitempty"`
	WorkflowIds        *[]openapi_types.UUID `json:"workflowIds,omitempty"`
}

V1TaskFilter defines model for V1TaskFilter.

type V1TaskGet200JSONResponse

type V1TaskGet200JSONResponse V1TaskSummary

func (V1TaskGet200JSONResponse) VisitV1TaskGetResponse

func (response V1TaskGet200JSONResponse) VisitV1TaskGetResponse(w http.ResponseWriter) error

type V1TaskGet400JSONResponse

type V1TaskGet400JSONResponse APIErrors

func (V1TaskGet400JSONResponse) VisitV1TaskGetResponse

func (response V1TaskGet400JSONResponse) VisitV1TaskGetResponse(w http.ResponseWriter) error

type V1TaskGet403JSONResponse

type V1TaskGet403JSONResponse APIErrors

func (V1TaskGet403JSONResponse) VisitV1TaskGetResponse

func (response V1TaskGet403JSONResponse) VisitV1TaskGetResponse(w http.ResponseWriter) error

type V1TaskGet404JSONResponse

type V1TaskGet404JSONResponse APIErrors

func (V1TaskGet404JSONResponse) VisitV1TaskGetResponse

func (response V1TaskGet404JSONResponse) VisitV1TaskGetResponse(w http.ResponseWriter) error

type V1TaskGet501JSONResponse

type V1TaskGet501JSONResponse APIErrors

func (V1TaskGet501JSONResponse) VisitV1TaskGetResponse

func (response V1TaskGet501JSONResponse) VisitV1TaskGetResponse(w http.ResponseWriter) error

type V1TaskGetPointMetrics200JSONResponse

type V1TaskGetPointMetrics200JSONResponse V1TaskPointMetrics

func (V1TaskGetPointMetrics200JSONResponse) VisitV1TaskGetPointMetricsResponse

func (response V1TaskGetPointMetrics200JSONResponse) VisitV1TaskGetPointMetricsResponse(w http.ResponseWriter) error

type V1TaskGetPointMetrics400JSONResponse

type V1TaskGetPointMetrics400JSONResponse APIErrors

func (V1TaskGetPointMetrics400JSONResponse) VisitV1TaskGetPointMetricsResponse

func (response V1TaskGetPointMetrics400JSONResponse) VisitV1TaskGetPointMetricsResponse(w http.ResponseWriter) error

type V1TaskGetPointMetrics403JSONResponse

type V1TaskGetPointMetrics403JSONResponse APIErrors

func (V1TaskGetPointMetrics403JSONResponse) VisitV1TaskGetPointMetricsResponse

func (response V1TaskGetPointMetrics403JSONResponse) VisitV1TaskGetPointMetricsResponse(w http.ResponseWriter) error

type V1TaskGetPointMetrics501JSONResponse

type V1TaskGetPointMetrics501JSONResponse APIErrors

func (V1TaskGetPointMetrics501JSONResponse) VisitV1TaskGetPointMetricsResponse

func (response V1TaskGetPointMetrics501JSONResponse) VisitV1TaskGetPointMetricsResponse(w http.ResponseWriter) error

type V1TaskGetPointMetricsParams

type V1TaskGetPointMetricsParams struct {
	// CreatedAfter The time after the task was created
	CreatedAfter *time.Time `form:"createdAfter,omitempty" json:"createdAfter,omitempty"`

	// FinishedBefore The time before the task was completed
	FinishedBefore *time.Time `form:"finishedBefore,omitempty" json:"finishedBefore,omitempty"`
}

V1TaskGetPointMetricsParams defines parameters for V1TaskGetPointMetrics.

type V1TaskGetPointMetricsRequestObject

type V1TaskGetPointMetricsRequestObject struct {
	Tenant openapi_types.UUID `json:"tenant"`
	Params V1TaskGetPointMetricsParams
}

type V1TaskGetPointMetricsResponseObject

type V1TaskGetPointMetricsResponseObject interface {
	VisitV1TaskGetPointMetricsResponse(w http.ResponseWriter) error
}

type V1TaskGetRequestObject

type V1TaskGetRequestObject struct {
	Task openapi_types.UUID `json:"task"`
}

type V1TaskGetResponseObject

type V1TaskGetResponseObject interface {
	VisitV1TaskGetResponse(w http.ResponseWriter) error
}

type V1TaskListStatusMetrics200JSONResponse

type V1TaskListStatusMetrics200JSONResponse V1TaskRunMetrics

func (V1TaskListStatusMetrics200JSONResponse) VisitV1TaskListStatusMetricsResponse

func (response V1TaskListStatusMetrics200JSONResponse) VisitV1TaskListStatusMetricsResponse(w http.ResponseWriter) error

type V1TaskListStatusMetrics400JSONResponse

type V1TaskListStatusMetrics400JSONResponse APIErrors

func (V1TaskListStatusMetrics400JSONResponse) VisitV1TaskListStatusMetricsResponse

func (response V1TaskListStatusMetrics400JSONResponse) VisitV1TaskListStatusMetricsResponse(w http.ResponseWriter) error

type V1TaskListStatusMetrics403JSONResponse

type V1TaskListStatusMetrics403JSONResponse APIErrors

func (V1TaskListStatusMetrics403JSONResponse) VisitV1TaskListStatusMetricsResponse

func (response V1TaskListStatusMetrics403JSONResponse) VisitV1TaskListStatusMetricsResponse(w http.ResponseWriter) error

type V1TaskListStatusMetrics501JSONResponse

type V1TaskListStatusMetrics501JSONResponse APIErrors

func (V1TaskListStatusMetrics501JSONResponse) VisitV1TaskListStatusMetricsResponse

func (response V1TaskListStatusMetrics501JSONResponse) VisitV1TaskListStatusMetricsResponse(w http.ResponseWriter) error

type V1TaskListStatusMetricsParams

type V1TaskListStatusMetricsParams struct {
	// Since The start time to get metrics for
	Since time.Time `form:"since" json:"since"`

	// WorkflowIds The workflow id to find runs for
	WorkflowIds *[]openapi_types.UUID `form:"workflow_ids,omitempty" json:"workflow_ids,omitempty"`

	// ParentTaskExternalId The parent task's external id
	ParentTaskExternalId *openapi_types.UUID `form:"parent_task_external_id,omitempty" json:"parent_task_external_id,omitempty"`
}

V1TaskListStatusMetricsParams defines parameters for V1TaskListStatusMetrics.

type V1TaskListStatusMetricsRequestObject

type V1TaskListStatusMetricsRequestObject struct {
	Tenant openapi_types.UUID `json:"tenant"`
	Params V1TaskListStatusMetricsParams
}

type V1TaskListStatusMetricsResponseObject

type V1TaskListStatusMetricsResponseObject interface {
	VisitV1TaskListStatusMetricsResponse(w http.ResponseWriter) error
}

type V1TaskPointMetric

type V1TaskPointMetric struct {
	FAILED    int       `json:"FAILED"`
	SUCCEEDED int       `json:"SUCCEEDED"`
	Time      time.Time `json:"time"`
}

V1TaskPointMetric defines model for V1TaskPointMetric.

type V1TaskPointMetrics

type V1TaskPointMetrics struct {
	Results *[]V1TaskPointMetric `json:"results,omitempty"`
}

V1TaskPointMetrics defines model for V1TaskPointMetrics.

type V1TaskReplay200Response added in v0.55.0

type V1TaskReplay200Response struct {
}

func (V1TaskReplay200Response) VisitV1TaskReplayResponse added in v0.55.0

func (response V1TaskReplay200Response) VisitV1TaskReplayResponse(w http.ResponseWriter) error

type V1TaskReplay400JSONResponse

type V1TaskReplay400JSONResponse APIErrors

func (V1TaskReplay400JSONResponse) VisitV1TaskReplayResponse

func (response V1TaskReplay400JSONResponse) VisitV1TaskReplayResponse(w http.ResponseWriter) error

type V1TaskReplay403JSONResponse

type V1TaskReplay403JSONResponse APIErrors

func (V1TaskReplay403JSONResponse) VisitV1TaskReplayResponse

func (response V1TaskReplay403JSONResponse) VisitV1TaskReplayResponse(w http.ResponseWriter) error

type V1TaskReplay404JSONResponse

type V1TaskReplay404JSONResponse APIErrors

func (V1TaskReplay404JSONResponse) VisitV1TaskReplayResponse

func (response V1TaskReplay404JSONResponse) VisitV1TaskReplayResponse(w http.ResponseWriter) error

type V1TaskReplay501JSONResponse

type V1TaskReplay501JSONResponse APIErrors

func (V1TaskReplay501JSONResponse) VisitV1TaskReplayResponse

func (response V1TaskReplay501JSONResponse) VisitV1TaskReplayResponse(w http.ResponseWriter) error

type V1TaskReplayJSONRequestBody

type V1TaskReplayJSONRequestBody = V1ReplayTaskRequest

V1TaskReplayJSONRequestBody defines body for V1TaskReplay for application/json ContentType.

type V1TaskReplayRequestObject

type V1TaskReplayRequestObject struct {
	Tenant openapi_types.UUID `json:"tenant"`
	Body   *V1TaskReplayJSONRequestBody
}

type V1TaskReplayResponseObject

type V1TaskReplayResponseObject interface {
	VisitV1TaskReplayResponse(w http.ResponseWriter) error
}

type V1TaskRunMetric

type V1TaskRunMetric struct {
	Count  int          `json:"count"`
	Status V1TaskStatus `json:"status"`
}

V1TaskRunMetric defines model for V1TaskRunMetric.

type V1TaskRunMetrics

type V1TaskRunMetrics = []V1TaskRunMetric

V1TaskRunMetrics defines model for V1TaskRunMetrics.

type V1TaskStatus

type V1TaskStatus string

V1TaskStatus defines model for V1TaskStatus.

const (
	V1TaskStatusCANCELLED V1TaskStatus = "CANCELLED"
	V1TaskStatusCOMPLETED V1TaskStatus = "COMPLETED"
	V1TaskStatusFAILED    V1TaskStatus = "FAILED"
	V1TaskStatusQUEUED    V1TaskStatus = "QUEUED"
	V1TaskStatusRUNNING   V1TaskStatus = "RUNNING"
)

Defines values for V1TaskStatus.

type V1TaskSummary

type V1TaskSummary struct {
	// AdditionalMetadata Additional metadata for the task run.
	AdditionalMetadata *map[string]interface{} `json:"additionalMetadata,omitempty"`

	// Children The list of children tasks
	Children *[]V1TaskSummary `json:"children,omitempty"`

	// CreatedAt The timestamp the task was created.
	CreatedAt time.Time `json:"createdAt"`

	// DisplayName The display name of the task run.
	DisplayName string `json:"displayName"`

	// Duration The duration of the task run, in milliseconds.
	Duration *int `json:"duration,omitempty"`

	// ErrorMessage The error message of the task run (for the latest run)
	ErrorMessage *string `json:"errorMessage,omitempty"`

	// FinishedAt The timestamp the task run finished.
	FinishedAt *time.Time `json:"finishedAt,omitempty"`

	// Input The input of the task run.
	Input    map[string]interface{} `json:"input"`
	Metadata APIResourceMeta        `json:"metadata"`

	// NumSpawnedChildren The number of spawned children tasks
	NumSpawnedChildren int `json:"numSpawnedChildren"`

	// Output The output of the task run (for the latest run)
	Output map[string]interface{} `json:"output"`

	// StartedAt The timestamp the task run started.
	StartedAt *time.Time   `json:"startedAt,omitempty"`
	Status    V1TaskStatus `json:"status"`

	// StepId The step ID of the task.
	StepId *openapi_types.UUID `json:"stepId,omitempty"`

	// TaskExternalId The external ID of the task.
	TaskExternalId openapi_types.UUID `json:"taskExternalId"`

	// TaskId The ID of the task.
	TaskId int `json:"taskId"`

	// TaskInsertedAt The timestamp the task was inserted.
	TaskInsertedAt time.Time `json:"taskInsertedAt"`

	// TenantId The ID of the tenant.
	TenantId     openapi_types.UUID `json:"tenantId"`
	Type         V1WorkflowType     `json:"type"`
	WorkflowId   openapi_types.UUID `json:"workflowId"`
	WorkflowName *string            `json:"workflowName,omitempty"`

	// WorkflowRunExternalId The external ID of the workflow run
	WorkflowRunExternalId *openapi_types.UUID `json:"workflowRunExternalId,omitempty"`

	// WorkflowVersionId The version ID of the workflow
	WorkflowVersionId *openapi_types.UUID `json:"workflowVersionId,omitempty"`
}

V1TaskSummary defines model for V1TaskSummary.

type V1TaskSummaryList

type V1TaskSummaryList struct {
	Pagination PaginationResponse `json:"pagination"`

	// Rows The list of tasks
	Rows []V1TaskSummary `json:"rows"`
}

V1TaskSummaryList defines model for V1TaskSummaryList.

type V1TriggerWorkflowRunRequest

type V1TriggerWorkflowRunRequest struct {
	AdditionalMetadata *map[string]interface{} `json:"additionalMetadata,omitempty"`
	Input              map[string]interface{}  `json:"input"`

	// WorkflowName The name of the workflow.
	WorkflowName string `json:"workflowName"`
}

V1TriggerWorkflowRunRequest defines model for V1TriggerWorkflowRunRequest.

type V1WorkflowRun

type V1WorkflowRun struct {
	// AdditionalMetadata Additional metadata for the task run.
	AdditionalMetadata *map[string]interface{} `json:"additionalMetadata,omitempty"`

	// CreatedAt The timestamp the task run was created.
	CreatedAt *time.Time `json:"createdAt,omitempty"`

	// DisplayName The display name of the task run.
	DisplayName string `json:"displayName"`

	// Duration The duration of the task run, in milliseconds.
	Duration *int `json:"duration,omitempty"`

	// ErrorMessage The error message of the task run (for the latest run)
	ErrorMessage *string `json:"errorMessage,omitempty"`

	// FinishedAt The timestamp the task run finished.
	FinishedAt *time.Time `json:"finishedAt,omitempty"`

	// Input The input of the task run.
	Input    map[string]interface{} `json:"input"`
	Metadata APIResourceMeta        `json:"metadata"`

	// Output The output of the task run (for the latest run)
	Output map[string]interface{} `json:"output"`

	// StartedAt The timestamp the task run started.
	StartedAt *time.Time   `json:"startedAt,omitempty"`
	Status    V1TaskStatus `json:"status"`

	// TenantId The ID of the tenant.
	TenantId   openapi_types.UUID `json:"tenantId"`
	WorkflowId openapi_types.UUID `json:"workflowId"`

	// WorkflowVersionId The ID of the workflow version.
	WorkflowVersionId *openapi_types.UUID `json:"workflowVersionId,omitempty"`
}

V1WorkflowRun defines model for V1WorkflowRun.

type V1WorkflowRunCreate200JSONResponse

type V1WorkflowRunCreate200JSONResponse V1WorkflowRunDetails

func (V1WorkflowRunCreate200JSONResponse) VisitV1WorkflowRunCreateResponse

func (response V1WorkflowRunCreate200JSONResponse) VisitV1WorkflowRunCreateResponse(w http.ResponseWriter) error

type V1WorkflowRunCreate400JSONResponse

type V1WorkflowRunCreate400JSONResponse APIErrors

func (V1WorkflowRunCreate400JSONResponse) VisitV1WorkflowRunCreateResponse

func (response V1WorkflowRunCreate400JSONResponse) VisitV1WorkflowRunCreateResponse(w http.ResponseWriter) error

type V1WorkflowRunCreate403JSONResponse

type V1WorkflowRunCreate403JSONResponse APIErrors

func (V1WorkflowRunCreate403JSONResponse) VisitV1WorkflowRunCreateResponse

func (response V1WorkflowRunCreate403JSONResponse) VisitV1WorkflowRunCreateResponse(w http.ResponseWriter) error

type V1WorkflowRunCreateJSONRequestBody

type V1WorkflowRunCreateJSONRequestBody = V1TriggerWorkflowRunRequest

V1WorkflowRunCreateJSONRequestBody defines body for V1WorkflowRunCreate for application/json ContentType.

type V1WorkflowRunCreateRequestObject

type V1WorkflowRunCreateRequestObject struct {
	Tenant openapi_types.UUID `json:"tenant"`
	Body   *V1WorkflowRunCreateJSONRequestBody
}

type V1WorkflowRunCreateResponseObject

type V1WorkflowRunCreateResponseObject interface {
	VisitV1WorkflowRunCreateResponse(w http.ResponseWriter) error
}

type V1WorkflowRunDetails

type V1WorkflowRunDetails struct {
	Run   V1WorkflowRun                         `json:"run"`
	Shape WorkflowRunShapeForWorkflowRunDetails `json:"shape"`

	// TaskEvents The list of task events for the workflow run
	TaskEvents []V1TaskEvent   `json:"taskEvents"`
	Tasks      []V1TaskSummary `json:"tasks"`
}

V1WorkflowRunDetails defines model for V1WorkflowRunDetails.

type V1WorkflowRunDisplayName

type V1WorkflowRunDisplayName struct {
	DisplayName string          `json:"displayName"`
	Metadata    APIResourceMeta `json:"metadata"`
}

V1WorkflowRunDisplayName defines model for V1WorkflowRunDisplayName.

type V1WorkflowRunDisplayNameList

type V1WorkflowRunDisplayNameList struct {
	Pagination PaginationResponse `json:"pagination"`

	// Rows The list of display names
	Rows []V1WorkflowRunDisplayName `json:"rows"`
}

V1WorkflowRunDisplayNameList defines model for V1WorkflowRunDisplayNameList.

type V1WorkflowRunDisplayNamesList200JSONResponse

type V1WorkflowRunDisplayNamesList200JSONResponse V1WorkflowRunDisplayNameList

func (V1WorkflowRunDisplayNamesList200JSONResponse) VisitV1WorkflowRunDisplayNamesListResponse

func (response V1WorkflowRunDisplayNamesList200JSONResponse) VisitV1WorkflowRunDisplayNamesListResponse(w http.ResponseWriter) error

type V1WorkflowRunDisplayNamesList400JSONResponse

type V1WorkflowRunDisplayNamesList400JSONResponse APIErrors

func (V1WorkflowRunDisplayNamesList400JSONResponse) VisitV1WorkflowRunDisplayNamesListResponse

func (response V1WorkflowRunDisplayNamesList400JSONResponse) VisitV1WorkflowRunDisplayNamesListResponse(w http.ResponseWriter) error

type V1WorkflowRunDisplayNamesList403JSONResponse

type V1WorkflowRunDisplayNamesList403JSONResponse APIErrors

func (V1WorkflowRunDisplayNamesList403JSONResponse) VisitV1WorkflowRunDisplayNamesListResponse

func (response V1WorkflowRunDisplayNamesList403JSONResponse) VisitV1WorkflowRunDisplayNamesListResponse(w http.ResponseWriter) error

type V1WorkflowRunDisplayNamesList501JSONResponse

type V1WorkflowRunDisplayNamesList501JSONResponse APIErrors

func (V1WorkflowRunDisplayNamesList501JSONResponse) VisitV1WorkflowRunDisplayNamesListResponse

func (response V1WorkflowRunDisplayNamesList501JSONResponse) VisitV1WorkflowRunDisplayNamesListResponse(w http.ResponseWriter) error

type V1WorkflowRunDisplayNamesListParams

type V1WorkflowRunDisplayNamesListParams struct {
	// ExternalIds The external ids of the workflow runs to get display names for
	ExternalIds []openapi_types.UUID `form:"external_ids" json:"external_ids"`
}

V1WorkflowRunDisplayNamesListParams defines parameters for V1WorkflowRunDisplayNamesList.

type V1WorkflowRunDisplayNamesListRequestObject

type V1WorkflowRunDisplayNamesListRequestObject struct {
	Tenant openapi_types.UUID `json:"tenant"`
	Params V1WorkflowRunDisplayNamesListParams
}

type V1WorkflowRunDisplayNamesListResponseObject

type V1WorkflowRunDisplayNamesListResponseObject interface {
	VisitV1WorkflowRunDisplayNamesListResponse(w http.ResponseWriter) error
}

type V1WorkflowRunGet200JSONResponse

type V1WorkflowRunGet200JSONResponse V1WorkflowRunDetails

func (V1WorkflowRunGet200JSONResponse) VisitV1WorkflowRunGetResponse

func (response V1WorkflowRunGet200JSONResponse) VisitV1WorkflowRunGetResponse(w http.ResponseWriter) error

type V1WorkflowRunGet400JSONResponse

type V1WorkflowRunGet400JSONResponse APIErrors

func (V1WorkflowRunGet400JSONResponse) VisitV1WorkflowRunGetResponse

func (response V1WorkflowRunGet400JSONResponse) VisitV1WorkflowRunGetResponse(w http.ResponseWriter) error

type V1WorkflowRunGet403JSONResponse

type V1WorkflowRunGet403JSONResponse APIErrors

func (V1WorkflowRunGet403JSONResponse) VisitV1WorkflowRunGetResponse

func (response V1WorkflowRunGet403JSONResponse) VisitV1WorkflowRunGetResponse(w http.ResponseWriter) error

type V1WorkflowRunGet501JSONResponse

type V1WorkflowRunGet501JSONResponse APIErrors

func (V1WorkflowRunGet501JSONResponse) VisitV1WorkflowRunGetResponse

func (response V1WorkflowRunGet501JSONResponse) VisitV1WorkflowRunGetResponse(w http.ResponseWriter) error

type V1WorkflowRunGetRequestObject

type V1WorkflowRunGetRequestObject struct {
	V1WorkflowRun openapi_types.UUID `json:"v1-workflow-run"`
}

type V1WorkflowRunGetResponseObject

type V1WorkflowRunGetResponseObject interface {
	VisitV1WorkflowRunGetResponse(w http.ResponseWriter) error
}

type V1WorkflowRunList200JSONResponse

type V1WorkflowRunList200JSONResponse V1TaskSummaryList

func (V1WorkflowRunList200JSONResponse) VisitV1WorkflowRunListResponse

func (response V1WorkflowRunList200JSONResponse) VisitV1WorkflowRunListResponse(w http.ResponseWriter) error

type V1WorkflowRunList400JSONResponse

type V1WorkflowRunList400JSONResponse APIErrors

func (V1WorkflowRunList400JSONResponse) VisitV1WorkflowRunListResponse

func (response V1WorkflowRunList400JSONResponse) VisitV1WorkflowRunListResponse(w http.ResponseWriter) error

type V1WorkflowRunList403JSONResponse

type V1WorkflowRunList403JSONResponse APIErrors

func (V1WorkflowRunList403JSONResponse) VisitV1WorkflowRunListResponse

func (response V1WorkflowRunList403JSONResponse) VisitV1WorkflowRunListResponse(w http.ResponseWriter) error

type V1WorkflowRunList501JSONResponse

type V1WorkflowRunList501JSONResponse APIErrors

func (V1WorkflowRunList501JSONResponse) VisitV1WorkflowRunListResponse

func (response V1WorkflowRunList501JSONResponse) VisitV1WorkflowRunListResponse(w http.ResponseWriter) error

type V1WorkflowRunListParams

type V1WorkflowRunListParams struct {
	// Offset The number to skip
	Offset *int64 `form:"offset,omitempty" json:"offset,omitempty"`

	// Limit The number to limit by
	Limit *int64 `form:"limit,omitempty" json:"limit,omitempty"`

	// Statuses A list of statuses to filter by
	Statuses *[]V1TaskStatus `form:"statuses,omitempty" json:"statuses,omitempty"`

	// Since The earliest date to filter by
	Since time.Time `form:"since" json:"since"`

	// Until The latest date to filter by
	Until *time.Time `form:"until,omitempty" json:"until,omitempty"`

	// AdditionalMetadata Additional metadata k-v pairs to filter by
	AdditionalMetadata *[]string `form:"additional_metadata,omitempty" json:"additional_metadata,omitempty"`

	// WorkflowIds The workflow ids to find runs for
	WorkflowIds *[]openapi_types.UUID `form:"workflow_ids,omitempty" json:"workflow_ids,omitempty"`

	// WorkerId The worker id to filter by
	WorkerId *openapi_types.UUID `form:"worker_id,omitempty" json:"worker_id,omitempty"`

	// OnlyTasks Whether to include DAGs or only to include tasks
	OnlyTasks bool `form:"only_tasks" json:"only_tasks"`

	// ParentTaskExternalId The parent task external id to filter by
	ParentTaskExternalId *openapi_types.UUID `form:"parent_task_external_id,omitempty" json:"parent_task_external_id,omitempty"`
}

V1WorkflowRunListParams defines parameters for V1WorkflowRunList.

type V1WorkflowRunListRequestObject

type V1WorkflowRunListRequestObject struct {
	Tenant openapi_types.UUID `json:"tenant"`
	Params V1WorkflowRunListParams
}

type V1WorkflowRunListResponseObject

type V1WorkflowRunListResponseObject interface {
	VisitV1WorkflowRunListResponse(w http.ResponseWriter) error
}

type V1WorkflowRunTaskEventsList200JSONResponse

type V1WorkflowRunTaskEventsList200JSONResponse V1TaskEventList

func (V1WorkflowRunTaskEventsList200JSONResponse) VisitV1WorkflowRunTaskEventsListResponse

func (response V1WorkflowRunTaskEventsList200JSONResponse) VisitV1WorkflowRunTaskEventsListResponse(w http.ResponseWriter) error

type V1WorkflowRunTaskEventsList400JSONResponse

type V1WorkflowRunTaskEventsList400JSONResponse APIErrors

func (V1WorkflowRunTaskEventsList400JSONResponse) VisitV1WorkflowRunTaskEventsListResponse

func (response V1WorkflowRunTaskEventsList400JSONResponse) VisitV1WorkflowRunTaskEventsListResponse(w http.ResponseWriter) error

type V1WorkflowRunTaskEventsList403JSONResponse

type V1WorkflowRunTaskEventsList403JSONResponse APIErrors

func (V1WorkflowRunTaskEventsList403JSONResponse) VisitV1WorkflowRunTaskEventsListResponse

func (response V1WorkflowRunTaskEventsList403JSONResponse) VisitV1WorkflowRunTaskEventsListResponse(w http.ResponseWriter) error

type V1WorkflowRunTaskEventsList501JSONResponse

type V1WorkflowRunTaskEventsList501JSONResponse APIErrors

func (V1WorkflowRunTaskEventsList501JSONResponse) VisitV1WorkflowRunTaskEventsListResponse

func (response V1WorkflowRunTaskEventsList501JSONResponse) VisitV1WorkflowRunTaskEventsListResponse(w http.ResponseWriter) error

type V1WorkflowRunTaskEventsListParams

type V1WorkflowRunTaskEventsListParams struct {
	// Offset The number to skip
	Offset *int64 `form:"offset,omitempty" json:"offset,omitempty"`

	// Limit The number to limit by
	Limit *int64 `form:"limit,omitempty" json:"limit,omitempty"`
}

V1WorkflowRunTaskEventsListParams defines parameters for V1WorkflowRunTaskEventsList.

type V1WorkflowRunTaskEventsListRequestObject

type V1WorkflowRunTaskEventsListRequestObject struct {
	V1WorkflowRun openapi_types.UUID `json:"v1-workflow-run"`
	Params        V1WorkflowRunTaskEventsListParams
}

type V1WorkflowRunTaskEventsListResponseObject

type V1WorkflowRunTaskEventsListResponseObject interface {
	VisitV1WorkflowRunTaskEventsListResponse(w http.ResponseWriter) error
}

type V1WorkflowType

type V1WorkflowType string

V1WorkflowType defines model for V1WorkflowType.

const (
	V1WorkflowTypeDAG  V1WorkflowType = "DAG"
	V1WorkflowTypeTASK V1WorkflowType = "TASK"
)

Defines values for V1WorkflowType.

type WebhookCreate200JSONResponse

type WebhookCreate200JSONResponse WebhookWorkerCreated

func (WebhookCreate200JSONResponse) VisitWebhookCreateResponse

func (response WebhookCreate200JSONResponse) VisitWebhookCreateResponse(w http.ResponseWriter) error

type WebhookCreate400JSONResponse

type WebhookCreate400JSONResponse APIErrors

func (WebhookCreate400JSONResponse) VisitWebhookCreateResponse

func (response WebhookCreate400JSONResponse) VisitWebhookCreateResponse(w http.ResponseWriter) error

type WebhookCreate401JSONResponse

type WebhookCreate401JSONResponse APIErrors

func (WebhookCreate401JSONResponse) VisitWebhookCreateResponse

func (response WebhookCreate401JSONResponse) VisitWebhookCreateResponse(w http.ResponseWriter) error

type WebhookCreate405JSONResponse

type WebhookCreate405JSONResponse APIErrors

func (WebhookCreate405JSONResponse) VisitWebhookCreateResponse

func (response WebhookCreate405JSONResponse) VisitWebhookCreateResponse(w http.ResponseWriter) error

type WebhookCreateJSONRequestBody

type WebhookCreateJSONRequestBody = WebhookWorkerCreateRequest

WebhookCreateJSONRequestBody defines body for WebhookCreate for application/json ContentType.

type WebhookCreateRequestObject

type WebhookCreateRequestObject struct {
	Tenant openapi_types.UUID `json:"tenant"`
	Body   *WebhookCreateJSONRequestBody
}

type WebhookCreateResponseObject

type WebhookCreateResponseObject interface {
	VisitWebhookCreateResponse(w http.ResponseWriter) error
}

type WebhookDelete200Response

type WebhookDelete200Response struct {
}

func (WebhookDelete200Response) VisitWebhookDeleteResponse

func (response WebhookDelete200Response) VisitWebhookDeleteResponse(w http.ResponseWriter) error

type WebhookDelete400JSONResponse

type WebhookDelete400JSONResponse APIErrors

func (WebhookDelete400JSONResponse) VisitWebhookDeleteResponse

func (response WebhookDelete400JSONResponse) VisitWebhookDeleteResponse(w http.ResponseWriter) error

type WebhookDelete401JSONResponse

type WebhookDelete401JSONResponse APIErrors

func (WebhookDelete401JSONResponse) VisitWebhookDeleteResponse

func (response WebhookDelete401JSONResponse) VisitWebhookDeleteResponse(w http.ResponseWriter) error

type WebhookDelete405JSONResponse

type WebhookDelete405JSONResponse APIErrors

func (WebhookDelete405JSONResponse) VisitWebhookDeleteResponse

func (response WebhookDelete405JSONResponse) VisitWebhookDeleteResponse(w http.ResponseWriter) error

type WebhookDeleteRequestObject

type WebhookDeleteRequestObject struct {
	Webhook openapi_types.UUID `json:"webhook"`
}

type WebhookDeleteResponseObject

type WebhookDeleteResponseObject interface {
	VisitWebhookDeleteResponse(w http.ResponseWriter) error
}

type WebhookList200JSONResponse

type WebhookList200JSONResponse WebhookWorkerListResponse

func (WebhookList200JSONResponse) VisitWebhookListResponse

func (response WebhookList200JSONResponse) VisitWebhookListResponse(w http.ResponseWriter) error

type WebhookList400JSONResponse

type WebhookList400JSONResponse APIErrors

func (WebhookList400JSONResponse) VisitWebhookListResponse

func (response WebhookList400JSONResponse) VisitWebhookListResponse(w http.ResponseWriter) error

type WebhookList401JSONResponse

type WebhookList401JSONResponse APIErrors

func (WebhookList401JSONResponse) VisitWebhookListResponse

func (response WebhookList401JSONResponse) VisitWebhookListResponse(w http.ResponseWriter) error

type WebhookList405JSONResponse

type WebhookList405JSONResponse APIErrors

func (WebhookList405JSONResponse) VisitWebhookListResponse

func (response WebhookList405JSONResponse) VisitWebhookListResponse(w http.ResponseWriter) error

type WebhookListRequestObject

type WebhookListRequestObject struct {
	Tenant openapi_types.UUID `json:"tenant"`
}

type WebhookListResponseObject

type WebhookListResponseObject interface {
	VisitWebhookListResponse(w http.ResponseWriter) error
}

type WebhookRequestsList200JSONResponse

type WebhookRequestsList200JSONResponse WebhookWorkerRequestListResponse

func (WebhookRequestsList200JSONResponse) VisitWebhookRequestsListResponse

func (response WebhookRequestsList200JSONResponse) VisitWebhookRequestsListResponse(w http.ResponseWriter) error

type WebhookRequestsList400JSONResponse

type WebhookRequestsList400JSONResponse APIErrors

func (WebhookRequestsList400JSONResponse) VisitWebhookRequestsListResponse

func (response WebhookRequestsList400JSONResponse) VisitWebhookRequestsListResponse(w http.ResponseWriter) error

type WebhookRequestsList401JSONResponse

type WebhookRequestsList401JSONResponse APIErrors

func (WebhookRequestsList401JSONResponse) VisitWebhookRequestsListResponse

func (response WebhookRequestsList401JSONResponse) VisitWebhookRequestsListResponse(w http.ResponseWriter) error

type WebhookRequestsList405JSONResponse

type WebhookRequestsList405JSONResponse APIErrors

func (WebhookRequestsList405JSONResponse) VisitWebhookRequestsListResponse

func (response WebhookRequestsList405JSONResponse) VisitWebhookRequestsListResponse(w http.ResponseWriter) error

type WebhookRequestsListRequestObject

type WebhookRequestsListRequestObject struct {
	Webhook openapi_types.UUID `json:"webhook"`
}

type WebhookRequestsListResponseObject

type WebhookRequestsListResponseObject interface {
	VisitWebhookRequestsListResponse(w http.ResponseWriter) error
}

type WebhookWorker

type WebhookWorker struct {
	Metadata APIResourceMeta `json:"metadata"`

	// Name The name of the webhook worker.
	Name string `json:"name"`

	// Url The webhook url.
	Url string `json:"url"`
}

WebhookWorker defines model for WebhookWorker.

type WebhookWorkerCreateRequest

type WebhookWorkerCreateRequest struct {
	// Name The name of the webhook worker.
	Name string `json:"name"`

	// Secret The secret key for validation. If not provided, a random secret will be generated.
	Secret *string `json:"secret,omitempty"`

	// Url The webhook url.
	Url string `json:"url"`
}

WebhookWorkerCreateRequest defines model for WebhookWorkerCreateRequest.

type WebhookWorkerCreated

type WebhookWorkerCreated struct {
	Metadata APIResourceMeta `json:"metadata"`

	// Name The name of the webhook worker.
	Name string `json:"name"`

	// Secret The secret key for validation.
	Secret string `json:"secret"`

	// Url The webhook url.
	Url string `json:"url"`
}

WebhookWorkerCreated defines model for WebhookWorkerCreated.

type WebhookWorkerListResponse

type WebhookWorkerListResponse struct {
	Pagination *PaginationResponse `json:"pagination,omitempty"`
	Rows       *[]WebhookWorker    `json:"rows,omitempty"`
}

WebhookWorkerListResponse defines model for WebhookWorkerListResponse.

type WebhookWorkerRequest

type WebhookWorkerRequest struct {
	// CreatedAt The date and time the request was created.
	CreatedAt time.Time                  `json:"created_at"`
	Method    WebhookWorkerRequestMethod `json:"method"`

	// StatusCode The HTTP status code of the response.
	StatusCode int `json:"statusCode"`
}

WebhookWorkerRequest defines model for WebhookWorkerRequest.

type WebhookWorkerRequestListResponse

type WebhookWorkerRequestListResponse struct {
	// Requests The list of webhook requests.
	Requests *[]WebhookWorkerRequest `json:"requests,omitempty"`
}

WebhookWorkerRequestListResponse defines model for WebhookWorkerRequestListResponse.

type WebhookWorkerRequestMethod

type WebhookWorkerRequestMethod = interface{}

WebhookWorkerRequestMethod defines model for WebhookWorkerRequestMethod.

type Worker

type Worker struct {
	// Actions The actions this worker can perform.
	Actions *[]string `json:"actions,omitempty"`

	// AvailableRuns The number of runs this worker can execute concurrently.
	AvailableRuns *int `json:"availableRuns,omitempty"`

	// DispatcherId the id of the assigned dispatcher, in UUID format
	DispatcherId *openapi_types.UUID `json:"dispatcherId,omitempty"`

	// Labels The current label state of the worker.
	Labels *[]WorkerLabel `json:"labels,omitempty"`

	// LastHeartbeatAt The time this worker last sent a heartbeat.
	LastHeartbeatAt *time.Time `json:"lastHeartbeatAt,omitempty"`

	// LastListenerEstablished The time this worker last sent a heartbeat.
	LastListenerEstablished *time.Time `json:"lastListenerEstablished,omitempty"`

	// MaxRuns The maximum number of runs this worker can execute concurrently.
	MaxRuns  *int            `json:"maxRuns,omitempty"`
	Metadata APIResourceMeta `json:"metadata"`

	// Name The name of the worker.
	Name string `json:"name"`

	// RecentStepRuns The recent step runs for the worker.
	RecentStepRuns *[]RecentStepRuns  `json:"recentStepRuns,omitempty"`
	RuntimeInfo    *WorkerRuntimeInfo `json:"runtimeInfo,omitempty"`

	// Slots The semaphore slot state for the worker.
	Slots *[]SemaphoreSlots `json:"slots,omitempty"`

	// Status The status of the worker.
	Status *WorkerStatus `json:"status,omitempty"`
	Type   WorkerType    `json:"type"`

	// WebhookId The webhook ID for the worker.
	WebhookId *openapi_types.UUID `json:"webhookId,omitempty"`

	// WebhookUrl The webhook URL for the worker.
	WebhookUrl *string `json:"webhookUrl,omitempty"`
}

Worker defines model for Worker.

type WorkerGet200JSONResponse

type WorkerGet200JSONResponse Worker

func (WorkerGet200JSONResponse) VisitWorkerGetResponse

func (response WorkerGet200JSONResponse) VisitWorkerGetResponse(w http.ResponseWriter) error

type WorkerGet400JSONResponse

type WorkerGet400JSONResponse APIErrors

func (WorkerGet400JSONResponse) VisitWorkerGetResponse

func (response WorkerGet400JSONResponse) VisitWorkerGetResponse(w http.ResponseWriter) error

type WorkerGet403JSONResponse

type WorkerGet403JSONResponse APIErrors

func (WorkerGet403JSONResponse) VisitWorkerGetResponse

func (response WorkerGet403JSONResponse) VisitWorkerGetResponse(w http.ResponseWriter) error

type WorkerGetRequestObject

type WorkerGetRequestObject struct {
	Worker openapi_types.UUID `json:"worker"`
}

type WorkerGetResponseObject

type WorkerGetResponseObject interface {
	VisitWorkerGetResponse(w http.ResponseWriter) error
}

type WorkerLabel

type WorkerLabel struct {
	// Key The key of the label.
	Key      string          `json:"key"`
	Metadata APIResourceMeta `json:"metadata"`

	// Value The value of the label.
	Value *string `json:"value,omitempty"`
}

WorkerLabel defines model for WorkerLabel.

type WorkerList

type WorkerList struct {
	Pagination *PaginationResponse `json:"pagination,omitempty"`
	Rows       *[]Worker           `json:"rows,omitempty"`
}

WorkerList defines model for WorkerList.

type WorkerList200JSONResponse

type WorkerList200JSONResponse WorkerList

func (WorkerList200JSONResponse) VisitWorkerListResponse

func (response WorkerList200JSONResponse) VisitWorkerListResponse(w http.ResponseWriter) error

type WorkerList400JSONResponse

type WorkerList400JSONResponse APIErrors

func (WorkerList400JSONResponse) VisitWorkerListResponse

func (response WorkerList400JSONResponse) VisitWorkerListResponse(w http.ResponseWriter) error

type WorkerList403JSONResponse

type WorkerList403JSONResponse APIErrors

func (WorkerList403JSONResponse) VisitWorkerListResponse

func (response WorkerList403JSONResponse) VisitWorkerListResponse(w http.ResponseWriter) error

type WorkerListRequestObject

type WorkerListRequestObject struct {
	Tenant openapi_types.UUID `json:"tenant"`
}

type WorkerListResponseObject

type WorkerListResponseObject interface {
	VisitWorkerListResponse(w http.ResponseWriter) error
}

type WorkerRuntimeInfo

type WorkerRuntimeInfo struct {
	Language        *WorkerRuntimeSDKs `json:"language,omitempty"`
	LanguageVersion *string            `json:"languageVersion,omitempty"`
	Os              *string            `json:"os,omitempty"`
	RuntimeExtra    *string            `json:"runtimeExtra,omitempty"`
	SdkVersion      *string            `json:"sdkVersion,omitempty"`
}

WorkerRuntimeInfo defines model for WorkerRuntimeInfo.

type WorkerRuntimeSDKs

type WorkerRuntimeSDKs string

WorkerRuntimeSDKs defines model for WorkerRuntimeSDKs.

const (
	GOLANG     WorkerRuntimeSDKs = "GOLANG"
	PYTHON     WorkerRuntimeSDKs = "PYTHON"
	TYPESCRIPT WorkerRuntimeSDKs = "TYPESCRIPT"
)

Defines values for WorkerRuntimeSDKs.

type WorkerStatus

type WorkerStatus string

WorkerStatus The status of the worker.

const (
	ACTIVE   WorkerStatus = "ACTIVE"
	INACTIVE WorkerStatus = "INACTIVE"
	PAUSED   WorkerStatus = "PAUSED"
)

Defines values for WorkerStatus.

type WorkerType

type WorkerType string

WorkerType defines model for WorkerType.

const (
	MANAGED    WorkerType = "MANAGED"
	SELFHOSTED WorkerType = "SELFHOSTED"
	WEBHOOK    WorkerType = "WEBHOOK"
)

Defines values for WorkerType.

type WorkerUpdate200JSONResponse

type WorkerUpdate200JSONResponse Worker

func (WorkerUpdate200JSONResponse) VisitWorkerUpdateResponse

func (response WorkerUpdate200JSONResponse) VisitWorkerUpdateResponse(w http.ResponseWriter) error

type WorkerUpdate400JSONResponse

type WorkerUpdate400JSONResponse APIErrors

func (WorkerUpdate400JSONResponse) VisitWorkerUpdateResponse

func (response WorkerUpdate400JSONResponse) VisitWorkerUpdateResponse(w http.ResponseWriter) error

type WorkerUpdate403JSONResponse

type WorkerUpdate403JSONResponse APIErrors

func (WorkerUpdate403JSONResponse) VisitWorkerUpdateResponse

func (response WorkerUpdate403JSONResponse) VisitWorkerUpdateResponse(w http.ResponseWriter) error

type WorkerUpdateJSONRequestBody

type WorkerUpdateJSONRequestBody = UpdateWorkerRequest

WorkerUpdateJSONRequestBody defines body for WorkerUpdate for application/json ContentType.

type WorkerUpdateRequestObject

type WorkerUpdateRequestObject struct {
	Worker openapi_types.UUID `json:"worker"`
	Body   *WorkerUpdateJSONRequestBody
}

type WorkerUpdateResponseObject

type WorkerUpdateResponseObject interface {
	VisitWorkerUpdateResponse(w http.ResponseWriter) error
}

type Workflow

type Workflow struct {
	// Description The description of the workflow.
	Description *string `json:"description,omitempty"`

	// IsPaused Whether the workflow is paused.
	IsPaused *bool `json:"isPaused,omitempty"`

	// Jobs The jobs of the workflow.
	Jobs     *[]Job          `json:"jobs,omitempty"`
	Metadata APIResourceMeta `json:"metadata"`

	// Name The name of the workflow.
	Name string `json:"name"`

	// Tags The tags of the workflow.
	Tags     *[]WorkflowTag         `json:"tags,omitempty"`
	Versions *[]WorkflowVersionMeta `json:"versions,omitempty"`
}

Workflow defines model for Workflow.

type WorkflowConcurrency

type WorkflowConcurrency struct {
	// GetConcurrencyGroup An action which gets the concurrency group for the WorkflowRun.
	GetConcurrencyGroup string                   `json:"getConcurrencyGroup"`
	LimitStrategy       ConcurrencyLimitStrategy `json:"limitStrategy"`

	// MaxRuns The maximum number of concurrent workflow runs.
	MaxRuns int32 `json:"maxRuns"`
}

WorkflowConcurrency defines model for WorkflowConcurrency.

type WorkflowCronDelete204Response

type WorkflowCronDelete204Response struct {
}

func (WorkflowCronDelete204Response) VisitWorkflowCronDeleteResponse

func (response WorkflowCronDelete204Response) VisitWorkflowCronDeleteResponse(w http.ResponseWriter) error

type WorkflowCronDelete400JSONResponse

type WorkflowCronDelete400JSONResponse APIErrors

func (WorkflowCronDelete400JSONResponse) VisitWorkflowCronDeleteResponse

func (response WorkflowCronDelete400JSONResponse) VisitWorkflowCronDeleteResponse(w http.ResponseWriter) error

type WorkflowCronDelete403JSONResponse

type WorkflowCronDelete403JSONResponse APIError

func (WorkflowCronDelete403JSONResponse) VisitWorkflowCronDeleteResponse

func (response WorkflowCronDelete403JSONResponse) VisitWorkflowCronDeleteResponse(w http.ResponseWriter) error

type WorkflowCronDeleteRequestObject

type WorkflowCronDeleteRequestObject struct {
	Tenant       openapi_types.UUID `json:"tenant"`
	CronWorkflow openapi_types.UUID `json:"cron-workflow"`
}

type WorkflowCronDeleteResponseObject

type WorkflowCronDeleteResponseObject interface {
	VisitWorkflowCronDeleteResponse(w http.ResponseWriter) error
}

type WorkflowCronGet200JSONResponse

type WorkflowCronGet200JSONResponse CronWorkflows

func (WorkflowCronGet200JSONResponse) VisitWorkflowCronGetResponse

func (response WorkflowCronGet200JSONResponse) VisitWorkflowCronGetResponse(w http.ResponseWriter) error

type WorkflowCronGet400JSONResponse

type WorkflowCronGet400JSONResponse APIErrors

func (WorkflowCronGet400JSONResponse) VisitWorkflowCronGetResponse

func (response WorkflowCronGet400JSONResponse) VisitWorkflowCronGetResponse(w http.ResponseWriter) error

type WorkflowCronGet403JSONResponse

type WorkflowCronGet403JSONResponse APIErrors

func (WorkflowCronGet403JSONResponse) VisitWorkflowCronGetResponse

func (response WorkflowCronGet403JSONResponse) VisitWorkflowCronGetResponse(w http.ResponseWriter) error

type WorkflowCronGet404JSONResponse

type WorkflowCronGet404JSONResponse APIErrors

func (WorkflowCronGet404JSONResponse) VisitWorkflowCronGetResponse

func (response WorkflowCronGet404JSONResponse) VisitWorkflowCronGetResponse(w http.ResponseWriter) error

type WorkflowCronGetRequestObject

type WorkflowCronGetRequestObject struct {
	Tenant       openapi_types.UUID `json:"tenant"`
	CronWorkflow openapi_types.UUID `json:"cron-workflow"`
}

type WorkflowCronGetResponseObject

type WorkflowCronGetResponseObject interface {
	VisitWorkflowCronGetResponse(w http.ResponseWriter) error
}

type WorkflowDelete204Response

type WorkflowDelete204Response struct {
}

func (WorkflowDelete204Response) VisitWorkflowDeleteResponse

func (response WorkflowDelete204Response) VisitWorkflowDeleteResponse(w http.ResponseWriter) error

type WorkflowDelete400JSONResponse

type WorkflowDelete400JSONResponse APIErrors

func (WorkflowDelete400JSONResponse) VisitWorkflowDeleteResponse

func (response WorkflowDelete400JSONResponse) VisitWorkflowDeleteResponse(w http.ResponseWriter) error

type WorkflowDelete403JSONResponse

type WorkflowDelete403JSONResponse APIErrors

func (WorkflowDelete403JSONResponse) VisitWorkflowDeleteResponse

func (response WorkflowDelete403JSONResponse) VisitWorkflowDeleteResponse(w http.ResponseWriter) error

type WorkflowDelete404JSONResponse

type WorkflowDelete404JSONResponse APIErrors

func (WorkflowDelete404JSONResponse) VisitWorkflowDeleteResponse

func (response WorkflowDelete404JSONResponse) VisitWorkflowDeleteResponse(w http.ResponseWriter) error

type WorkflowDeleteRequestObject

type WorkflowDeleteRequestObject struct {
	Workflow openapi_types.UUID `json:"workflow"`
}

type WorkflowDeleteResponseObject

type WorkflowDeleteResponseObject interface {
	VisitWorkflowDeleteResponse(w http.ResponseWriter) error
}

type WorkflowGet200JSONResponse

type WorkflowGet200JSONResponse Workflow

func (WorkflowGet200JSONResponse) VisitWorkflowGetResponse

func (response WorkflowGet200JSONResponse) VisitWorkflowGetResponse(w http.ResponseWriter) error

type WorkflowGet400JSONResponse

type WorkflowGet400JSONResponse APIErrors

func (WorkflowGet400JSONResponse) VisitWorkflowGetResponse

func (response WorkflowGet400JSONResponse) VisitWorkflowGetResponse(w http.ResponseWriter) error

type WorkflowGet403JSONResponse

type WorkflowGet403JSONResponse APIErrors

func (WorkflowGet403JSONResponse) VisitWorkflowGetResponse

func (response WorkflowGet403JSONResponse) VisitWorkflowGetResponse(w http.ResponseWriter) error

type WorkflowGet404JSONResponse

type WorkflowGet404JSONResponse APIErrors

func (WorkflowGet404JSONResponse) VisitWorkflowGetResponse

func (response WorkflowGet404JSONResponse) VisitWorkflowGetResponse(w http.ResponseWriter) error

type WorkflowGetMetrics200JSONResponse

type WorkflowGetMetrics200JSONResponse WorkflowMetrics

func (WorkflowGetMetrics200JSONResponse) VisitWorkflowGetMetricsResponse

func (response WorkflowGetMetrics200JSONResponse) VisitWorkflowGetMetricsResponse(w http.ResponseWriter) error

type WorkflowGetMetrics400JSONResponse

type WorkflowGetMetrics400JSONResponse APIErrors

func (WorkflowGetMetrics400JSONResponse) VisitWorkflowGetMetricsResponse

func (response WorkflowGetMetrics400JSONResponse) VisitWorkflowGetMetricsResponse(w http.ResponseWriter) error

type WorkflowGetMetrics403JSONResponse

type WorkflowGetMetrics403JSONResponse APIErrors

func (WorkflowGetMetrics403JSONResponse) VisitWorkflowGetMetricsResponse

func (response WorkflowGetMetrics403JSONResponse) VisitWorkflowGetMetricsResponse(w http.ResponseWriter) error

type WorkflowGetMetrics404JSONResponse

type WorkflowGetMetrics404JSONResponse APIErrors

func (WorkflowGetMetrics404JSONResponse) VisitWorkflowGetMetricsResponse

func (response WorkflowGetMetrics404JSONResponse) VisitWorkflowGetMetricsResponse(w http.ResponseWriter) error

type WorkflowGetMetricsParams

type WorkflowGetMetricsParams struct {
	// Status A status of workflow run statuses to filter by
	Status *WorkflowRunStatus `form:"status,omitempty" json:"status,omitempty"`

	// GroupKey A group key to filter metrics by
	GroupKey *string `form:"groupKey,omitempty" json:"groupKey,omitempty"`
}

WorkflowGetMetricsParams defines parameters for WorkflowGetMetrics.

type WorkflowGetMetricsRequestObject

type WorkflowGetMetricsRequestObject struct {
	Workflow openapi_types.UUID `json:"workflow"`
	Params   WorkflowGetMetricsParams
}

type WorkflowGetMetricsResponseObject

type WorkflowGetMetricsResponseObject interface {
	VisitWorkflowGetMetricsResponse(w http.ResponseWriter) error
}

type WorkflowGetRequestObject

type WorkflowGetRequestObject struct {
	Workflow openapi_types.UUID `json:"workflow"`
}

type WorkflowGetResponseObject

type WorkflowGetResponseObject interface {
	VisitWorkflowGetResponse(w http.ResponseWriter) error
}

type WorkflowGetWorkersCount200JSONResponse

type WorkflowGetWorkersCount200JSONResponse WorkflowWorkersCount

func (WorkflowGetWorkersCount200JSONResponse) VisitWorkflowGetWorkersCountResponse

func (response WorkflowGetWorkersCount200JSONResponse) VisitWorkflowGetWorkersCountResponse(w http.ResponseWriter) error

type WorkflowGetWorkersCount400JSONResponse

type WorkflowGetWorkersCount400JSONResponse APIErrors

func (WorkflowGetWorkersCount400JSONResponse) VisitWorkflowGetWorkersCountResponse

func (response WorkflowGetWorkersCount400JSONResponse) VisitWorkflowGetWorkersCountResponse(w http.ResponseWriter) error

type WorkflowGetWorkersCount403JSONResponse

type WorkflowGetWorkersCount403JSONResponse APIErrors

func (WorkflowGetWorkersCount403JSONResponse) VisitWorkflowGetWorkersCountResponse

func (response WorkflowGetWorkersCount403JSONResponse) VisitWorkflowGetWorkersCountResponse(w http.ResponseWriter) error

type WorkflowGetWorkersCountRequestObject

type WorkflowGetWorkersCountRequestObject struct {
	Tenant   openapi_types.UUID `json:"tenant"`
	Workflow openapi_types.UUID `json:"workflow"`
}

type WorkflowGetWorkersCountResponseObject

type WorkflowGetWorkersCountResponseObject interface {
	VisitWorkflowGetWorkersCountResponse(w http.ResponseWriter) error
}

type WorkflowID

type WorkflowID = string

WorkflowID A workflow ID.

type WorkflowKind

type WorkflowKind string

WorkflowKind defines model for WorkflowKind.

const (
	WorkflowKindDAG      WorkflowKind = "DAG"
	WorkflowKindDURABLE  WorkflowKind = "DURABLE"
	WorkflowKindFUNCTION WorkflowKind = "FUNCTION"
)

Defines values for WorkflowKind.

type WorkflowKindList

type WorkflowKindList = []WorkflowKind

WorkflowKindList defines model for WorkflowKindList.

type WorkflowList

type WorkflowList struct {
	Metadata   *APIResourceMeta    `json:"metadata,omitempty"`
	Pagination *PaginationResponse `json:"pagination,omitempty"`
	Rows       *[]Workflow         `json:"rows,omitempty"`
}

WorkflowList defines model for WorkflowList.

type WorkflowList200JSONResponse

type WorkflowList200JSONResponse WorkflowList

func (WorkflowList200JSONResponse) VisitWorkflowListResponse

func (response WorkflowList200JSONResponse) VisitWorkflowListResponse(w http.ResponseWriter) error

type WorkflowList400JSONResponse

type WorkflowList400JSONResponse APIErrors

func (WorkflowList400JSONResponse) VisitWorkflowListResponse

func (response WorkflowList400JSONResponse) VisitWorkflowListResponse(w http.ResponseWriter) error

type WorkflowList403JSONResponse

type WorkflowList403JSONResponse APIErrors

func (WorkflowList403JSONResponse) VisitWorkflowListResponse

func (response WorkflowList403JSONResponse) VisitWorkflowListResponse(w http.ResponseWriter) error

type WorkflowListParams

type WorkflowListParams struct {
	// Offset The number to skip
	Offset *int `form:"offset,omitempty" json:"offset,omitempty"`

	// Limit The number to limit by
	Limit *int `form:"limit,omitempty" json:"limit,omitempty"`

	// Name Search by name
	Name *string `form:"name,omitempty" json:"name,omitempty"`
}

WorkflowListParams defines parameters for WorkflowList.

type WorkflowListRequestObject

type WorkflowListRequestObject struct {
	Tenant openapi_types.UUID `json:"tenant"`
	Params WorkflowListParams
}

type WorkflowListResponseObject

type WorkflowListResponseObject interface {
	VisitWorkflowListResponse(w http.ResponseWriter) error
}

type WorkflowMetrics

type WorkflowMetrics struct {
	// GroupKeyCount The total number of concurrency group keys.
	GroupKeyCount *int `json:"groupKeyCount,omitempty"`

	// GroupKeyRunsCount The number of runs for a specific group key (passed via filter)
	GroupKeyRunsCount *int `json:"groupKeyRunsCount,omitempty"`
}

WorkflowMetrics defines model for WorkflowMetrics.

type WorkflowRun

type WorkflowRun struct {
	AdditionalMetadata *map[string]interface{} `json:"additionalMetadata,omitempty"`
	DisplayName        *string                 `json:"displayName,omitempty"`
	Duration           *int                    `json:"duration,omitempty"`
	Error              *string                 `json:"error,omitempty"`
	FinishedAt         *time.Time              `json:"finishedAt,omitempty"`
	Input              *map[string]interface{} `json:"input,omitempty"`
	JobRuns            *[]JobRun               `json:"jobRuns,omitempty"`
	Metadata           APIResourceMeta         `json:"metadata"`
	ParentId           *openapi_types.UUID     `json:"parentId,omitempty"`
	ParentStepRunId    *openapi_types.UUID     `json:"parentStepRunId,omitempty"`
	StartedAt          *time.Time              `json:"startedAt,omitempty"`
	Status             WorkflowRunStatus       `json:"status"`
	TenantId           string                  `json:"tenantId"`
	TriggeredBy        WorkflowRunTriggeredBy  `json:"triggeredBy"`
	WorkflowVersion    *WorkflowVersion        `json:"workflowVersion,omitempty"`
	WorkflowVersionId  string                  `json:"workflowVersionId"`
}

WorkflowRun defines model for WorkflowRun.

type WorkflowRunCancel200JSONResponse

type WorkflowRunCancel200JSONResponse struct {
	WorkflowRunIds *[]openapi_types.UUID `json:"workflowRunIds,omitempty"`
}

func (WorkflowRunCancel200JSONResponse) VisitWorkflowRunCancelResponse

func (response WorkflowRunCancel200JSONResponse) VisitWorkflowRunCancelResponse(w http.ResponseWriter) error

type WorkflowRunCancel400JSONResponse

type WorkflowRunCancel400JSONResponse APIErrors

func (WorkflowRunCancel400JSONResponse) VisitWorkflowRunCancelResponse

func (response WorkflowRunCancel400JSONResponse) VisitWorkflowRunCancelResponse(w http.ResponseWriter) error

type WorkflowRunCancel403JSONResponse

type WorkflowRunCancel403JSONResponse APIErrors

func (WorkflowRunCancel403JSONResponse) VisitWorkflowRunCancelResponse

func (response WorkflowRunCancel403JSONResponse) VisitWorkflowRunCancelResponse(w http.ResponseWriter) error

type WorkflowRunCancelJSONRequestBody

type WorkflowRunCancelJSONRequestBody = WorkflowRunsCancelRequest

WorkflowRunCancelJSONRequestBody defines body for WorkflowRunCancel for application/json ContentType.

type WorkflowRunCancelRequestObject

type WorkflowRunCancelRequestObject struct {
	Tenant openapi_types.UUID `json:"tenant"`
	Body   *WorkflowRunCancelJSONRequestBody
}

type WorkflowRunCancelResponseObject

type WorkflowRunCancelResponseObject interface {
	VisitWorkflowRunCancelResponse(w http.ResponseWriter) error
}

type WorkflowRunCreate200JSONResponse

type WorkflowRunCreate200JSONResponse WorkflowRun

func (WorkflowRunCreate200JSONResponse) VisitWorkflowRunCreateResponse

func (response WorkflowRunCreate200JSONResponse) VisitWorkflowRunCreateResponse(w http.ResponseWriter) error

type WorkflowRunCreate400JSONResponse

type WorkflowRunCreate400JSONResponse APIErrors

func (WorkflowRunCreate400JSONResponse) VisitWorkflowRunCreateResponse

func (response WorkflowRunCreate400JSONResponse) VisitWorkflowRunCreateResponse(w http.ResponseWriter) error

type WorkflowRunCreate403JSONResponse

type WorkflowRunCreate403JSONResponse APIErrors

func (WorkflowRunCreate403JSONResponse) VisitWorkflowRunCreateResponse

func (response WorkflowRunCreate403JSONResponse) VisitWorkflowRunCreateResponse(w http.ResponseWriter) error

type WorkflowRunCreate404JSONResponse

type WorkflowRunCreate404JSONResponse APIErrors

func (WorkflowRunCreate404JSONResponse) VisitWorkflowRunCreateResponse

func (response WorkflowRunCreate404JSONResponse) VisitWorkflowRunCreateResponse(w http.ResponseWriter) error

type WorkflowRunCreate429JSONResponse

type WorkflowRunCreate429JSONResponse APIErrors

func (WorkflowRunCreate429JSONResponse) VisitWorkflowRunCreateResponse

func (response WorkflowRunCreate429JSONResponse) VisitWorkflowRunCreateResponse(w http.ResponseWriter) error

type WorkflowRunCreateJSONRequestBody

type WorkflowRunCreateJSONRequestBody = TriggerWorkflowRunRequest

WorkflowRunCreateJSONRequestBody defines body for WorkflowRunCreate for application/json ContentType.

type WorkflowRunCreateParams

type WorkflowRunCreateParams struct {
	// Version The workflow version. If not supplied, the latest version is fetched.
	Version *openapi_types.UUID `form:"version,omitempty" json:"version,omitempty"`
}

WorkflowRunCreateParams defines parameters for WorkflowRunCreate.

type WorkflowRunCreateRequestObject

type WorkflowRunCreateRequestObject struct {
	Workflow openapi_types.UUID `json:"workflow"`
	Params   WorkflowRunCreateParams
	Body     *WorkflowRunCreateJSONRequestBody
}

type WorkflowRunCreateResponseObject

type WorkflowRunCreateResponseObject interface {
	VisitWorkflowRunCreateResponse(w http.ResponseWriter) error
}

type WorkflowRunGet200JSONResponse

type WorkflowRunGet200JSONResponse WorkflowRun

func (WorkflowRunGet200JSONResponse) VisitWorkflowRunGetResponse

func (response WorkflowRunGet200JSONResponse) VisitWorkflowRunGetResponse(w http.ResponseWriter) error

type WorkflowRunGet400JSONResponse

type WorkflowRunGet400JSONResponse APIErrors

func (WorkflowRunGet400JSONResponse) VisitWorkflowRunGetResponse

func (response WorkflowRunGet400JSONResponse) VisitWorkflowRunGetResponse(w http.ResponseWriter) error

type WorkflowRunGet403JSONResponse

type WorkflowRunGet403JSONResponse APIErrors

func (WorkflowRunGet403JSONResponse) VisitWorkflowRunGetResponse

func (response WorkflowRunGet403JSONResponse) VisitWorkflowRunGetResponse(w http.ResponseWriter) error

type WorkflowRunGetInput200JSONResponse

type WorkflowRunGetInput200JSONResponse map[string]interface{}

func (WorkflowRunGetInput200JSONResponse) VisitWorkflowRunGetInputResponse

func (response WorkflowRunGetInput200JSONResponse) VisitWorkflowRunGetInputResponse(w http.ResponseWriter) error

type WorkflowRunGetInput400JSONResponse

type WorkflowRunGetInput400JSONResponse APIErrors

func (WorkflowRunGetInput400JSONResponse) VisitWorkflowRunGetInputResponse

func (response WorkflowRunGetInput400JSONResponse) VisitWorkflowRunGetInputResponse(w http.ResponseWriter) error

type WorkflowRunGetInput403JSONResponse

type WorkflowRunGetInput403JSONResponse APIErrors

func (WorkflowRunGetInput403JSONResponse) VisitWorkflowRunGetInputResponse

func (response WorkflowRunGetInput403JSONResponse) VisitWorkflowRunGetInputResponse(w http.ResponseWriter) error

type WorkflowRunGetInput404JSONResponse

type WorkflowRunGetInput404JSONResponse APIErrors

func (WorkflowRunGetInput404JSONResponse) VisitWorkflowRunGetInputResponse

func (response WorkflowRunGetInput404JSONResponse) VisitWorkflowRunGetInputResponse(w http.ResponseWriter) error

type WorkflowRunGetInputRequestObject

type WorkflowRunGetInputRequestObject struct {
	Tenant      openapi_types.UUID `json:"tenant"`
	WorkflowRun openapi_types.UUID `json:"workflow-run"`
}

type WorkflowRunGetInputResponseObject

type WorkflowRunGetInputResponseObject interface {
	VisitWorkflowRunGetInputResponse(w http.ResponseWriter) error
}

type WorkflowRunGetMetrics200JSONResponse

type WorkflowRunGetMetrics200JSONResponse WorkflowRunsMetrics

func (WorkflowRunGetMetrics200JSONResponse) VisitWorkflowRunGetMetricsResponse

func (response WorkflowRunGetMetrics200JSONResponse) VisitWorkflowRunGetMetricsResponse(w http.ResponseWriter) error

type WorkflowRunGetMetrics400JSONResponse

type WorkflowRunGetMetrics400JSONResponse APIErrors

func (WorkflowRunGetMetrics400JSONResponse) VisitWorkflowRunGetMetricsResponse

func (response WorkflowRunGetMetrics400JSONResponse) VisitWorkflowRunGetMetricsResponse(w http.ResponseWriter) error

type WorkflowRunGetMetrics403JSONResponse

type WorkflowRunGetMetrics403JSONResponse APIErrors

func (WorkflowRunGetMetrics403JSONResponse) VisitWorkflowRunGetMetricsResponse

func (response WorkflowRunGetMetrics403JSONResponse) VisitWorkflowRunGetMetricsResponse(w http.ResponseWriter) error

type WorkflowRunGetMetricsParams

type WorkflowRunGetMetricsParams struct {
	// EventId The event id to get runs for.
	EventId *openapi_types.UUID `form:"eventId,omitempty" json:"eventId,omitempty"`

	// WorkflowId The workflow id to get runs for.
	WorkflowId *openapi_types.UUID `form:"workflowId,omitempty" json:"workflowId,omitempty"`

	// ParentWorkflowRunId The parent workflow run id
	ParentWorkflowRunId *openapi_types.UUID `form:"parentWorkflowRunId,omitempty" json:"parentWorkflowRunId,omitempty"`

	// ParentStepRunId The parent step run id
	ParentStepRunId *openapi_types.UUID `form:"parentStepRunId,omitempty" json:"parentStepRunId,omitempty"`

	// AdditionalMetadata A list of metadata key value pairs to filter by
	AdditionalMetadata *[]string `form:"additionalMetadata,omitempty" json:"additionalMetadata,omitempty"`

	// CreatedAfter The time after the workflow run was created
	CreatedAfter *time.Time `form:"createdAfter,omitempty" json:"createdAfter,omitempty"`

	// CreatedBefore The time before the workflow run was created
	CreatedBefore *time.Time `form:"createdBefore,omitempty" json:"createdBefore,omitempty"`
}

WorkflowRunGetMetricsParams defines parameters for WorkflowRunGetMetrics.

type WorkflowRunGetMetricsRequestObject

type WorkflowRunGetMetricsRequestObject struct {
	Tenant openapi_types.UUID `json:"tenant"`
	Params WorkflowRunGetMetricsParams
}

type WorkflowRunGetMetricsResponseObject

type WorkflowRunGetMetricsResponseObject interface {
	VisitWorkflowRunGetMetricsResponse(w http.ResponseWriter) error
}

type WorkflowRunGetRequestObject

type WorkflowRunGetRequestObject struct {
	Tenant      openapi_types.UUID `json:"tenant"`
	WorkflowRun openapi_types.UUID `json:"workflow-run"`
}

type WorkflowRunGetResponseObject

type WorkflowRunGetResponseObject interface {
	VisitWorkflowRunGetResponse(w http.ResponseWriter) error
}

type WorkflowRunGetShape200JSONResponse

type WorkflowRunGetShape200JSONResponse WorkflowRunShape

func (WorkflowRunGetShape200JSONResponse) VisitWorkflowRunGetShapeResponse

func (response WorkflowRunGetShape200JSONResponse) VisitWorkflowRunGetShapeResponse(w http.ResponseWriter) error

type WorkflowRunGetShape400JSONResponse

type WorkflowRunGetShape400JSONResponse APIErrors

func (WorkflowRunGetShape400JSONResponse) VisitWorkflowRunGetShapeResponse

func (response WorkflowRunGetShape400JSONResponse) VisitWorkflowRunGetShapeResponse(w http.ResponseWriter) error

type WorkflowRunGetShape403JSONResponse

type WorkflowRunGetShape403JSONResponse APIErrors

func (WorkflowRunGetShape403JSONResponse) VisitWorkflowRunGetShapeResponse

func (response WorkflowRunGetShape403JSONResponse) VisitWorkflowRunGetShapeResponse(w http.ResponseWriter) error

type WorkflowRunGetShapeRequestObject

type WorkflowRunGetShapeRequestObject struct {
	Tenant      openapi_types.UUID `json:"tenant"`
	WorkflowRun openapi_types.UUID `json:"workflow-run"`
}

type WorkflowRunGetShapeResponseObject

type WorkflowRunGetShapeResponseObject interface {
	VisitWorkflowRunGetShapeResponse(w http.ResponseWriter) error
}

type WorkflowRunList

type WorkflowRunList struct {
	Pagination *PaginationResponse `json:"pagination,omitempty"`
	Rows       *[]WorkflowRun      `json:"rows,omitempty"`
}

WorkflowRunList defines model for WorkflowRunList.

type WorkflowRunList200JSONResponse

type WorkflowRunList200JSONResponse WorkflowRunList

func (WorkflowRunList200JSONResponse) VisitWorkflowRunListResponse

func (response WorkflowRunList200JSONResponse) VisitWorkflowRunListResponse(w http.ResponseWriter) error

type WorkflowRunList400JSONResponse

type WorkflowRunList400JSONResponse APIErrors

func (WorkflowRunList400JSONResponse) VisitWorkflowRunListResponse

func (response WorkflowRunList400JSONResponse) VisitWorkflowRunListResponse(w http.ResponseWriter) error

type WorkflowRunList403JSONResponse

type WorkflowRunList403JSONResponse APIErrors

func (WorkflowRunList403JSONResponse) VisitWorkflowRunListResponse

func (response WorkflowRunList403JSONResponse) VisitWorkflowRunListResponse(w http.ResponseWriter) error

type WorkflowRunListParams

type WorkflowRunListParams struct {
	// Offset The number to skip
	Offset *int64 `form:"offset,omitempty" json:"offset,omitempty"`

	// Limit The number to limit by
	Limit *int64 `form:"limit,omitempty" json:"limit,omitempty"`

	// EventId The event id to get runs for.
	EventId *openapi_types.UUID `form:"eventId,omitempty" json:"eventId,omitempty"`

	// WorkflowId The workflow id to get runs for.
	WorkflowId *openapi_types.UUID `form:"workflowId,omitempty" json:"workflowId,omitempty"`

	// ParentWorkflowRunId The parent workflow run id
	ParentWorkflowRunId *openapi_types.UUID `form:"parentWorkflowRunId,omitempty" json:"parentWorkflowRunId,omitempty"`

	// ParentStepRunId The parent step run id
	ParentStepRunId *openapi_types.UUID `form:"parentStepRunId,omitempty" json:"parentStepRunId,omitempty"`

	// Statuses A list of workflow run statuses to filter by
	Statuses *WorkflowRunStatusList `form:"statuses,omitempty" json:"statuses,omitempty"`

	// Kinds A list of workflow kinds to filter by
	Kinds *WorkflowKindList `form:"kinds,omitempty" json:"kinds,omitempty"`

	// AdditionalMetadata A list of metadata key value pairs to filter by
	AdditionalMetadata *[]string `form:"additionalMetadata,omitempty" json:"additionalMetadata,omitempty"`

	// CreatedAfter The time after the workflow run was created
	CreatedAfter *time.Time `form:"createdAfter,omitempty" json:"createdAfter,omitempty"`

	// CreatedBefore The time before the workflow run was created
	CreatedBefore *time.Time `form:"createdBefore,omitempty" json:"createdBefore,omitempty"`

	// FinishedAfter The time after the workflow run was finished
	FinishedAfter *time.Time `form:"finishedAfter,omitempty" json:"finishedAfter,omitempty"`

	// FinishedBefore The time before the workflow run was finished
	FinishedBefore *time.Time `form:"finishedBefore,omitempty" json:"finishedBefore,omitempty"`

	// OrderByField The order by field
	OrderByField *WorkflowRunOrderByField `form:"orderByField,omitempty" json:"orderByField,omitempty"`

	// OrderByDirection The order by direction
	OrderByDirection *WorkflowRunOrderByDirection `form:"orderByDirection,omitempty" json:"orderByDirection,omitempty"`
}

WorkflowRunListParams defines parameters for WorkflowRunList.

type WorkflowRunListRequestObject

type WorkflowRunListRequestObject struct {
	Tenant openapi_types.UUID `json:"tenant"`
	Params WorkflowRunListParams
}

type WorkflowRunListResponseObject

type WorkflowRunListResponseObject interface {
	VisitWorkflowRunListResponse(w http.ResponseWriter) error
}

type WorkflowRunListStepRunEvents200JSONResponse

type WorkflowRunListStepRunEvents200JSONResponse StepRunEventList

func (WorkflowRunListStepRunEvents200JSONResponse) VisitWorkflowRunListStepRunEventsResponse

func (response WorkflowRunListStepRunEvents200JSONResponse) VisitWorkflowRunListStepRunEventsResponse(w http.ResponseWriter) error

type WorkflowRunListStepRunEvents400JSONResponse

type WorkflowRunListStepRunEvents400JSONResponse APIErrors

func (WorkflowRunListStepRunEvents400JSONResponse) VisitWorkflowRunListStepRunEventsResponse

func (response WorkflowRunListStepRunEvents400JSONResponse) VisitWorkflowRunListStepRunEventsResponse(w http.ResponseWriter) error

type WorkflowRunListStepRunEvents403JSONResponse

type WorkflowRunListStepRunEvents403JSONResponse APIErrors

func (WorkflowRunListStepRunEvents403JSONResponse) VisitWorkflowRunListStepRunEventsResponse

func (response WorkflowRunListStepRunEvents403JSONResponse) VisitWorkflowRunListStepRunEventsResponse(w http.ResponseWriter) error

type WorkflowRunListStepRunEvents404JSONResponse

type WorkflowRunListStepRunEvents404JSONResponse APIErrors

func (WorkflowRunListStepRunEvents404JSONResponse) VisitWorkflowRunListStepRunEventsResponse

func (response WorkflowRunListStepRunEvents404JSONResponse) VisitWorkflowRunListStepRunEventsResponse(w http.ResponseWriter) error

type WorkflowRunListStepRunEventsParams

type WorkflowRunListStepRunEventsParams struct {
	// LastId Last ID of the last event
	LastId *int32 `form:"lastId,omitempty" json:"lastId,omitempty"`
}

WorkflowRunListStepRunEventsParams defines parameters for WorkflowRunListStepRunEvents.

type WorkflowRunListStepRunEventsRequestObject

type WorkflowRunListStepRunEventsRequestObject struct {
	Tenant      openapi_types.UUID `json:"tenant"`
	WorkflowRun openapi_types.UUID `json:"workflow-run"`
	Params      WorkflowRunListStepRunEventsParams
}

type WorkflowRunListStepRunEventsResponseObject

type WorkflowRunListStepRunEventsResponseObject interface {
	VisitWorkflowRunListStepRunEventsResponse(w http.ResponseWriter) error
}

type WorkflowRunOrderByDirection

type WorkflowRunOrderByDirection string

WorkflowRunOrderByDirection defines model for WorkflowRunOrderByDirection.

const (
	ASC  WorkflowRunOrderByDirection = "ASC"
	DESC WorkflowRunOrderByDirection = "DESC"
)

Defines values for WorkflowRunOrderByDirection.

type WorkflowRunOrderByField

type WorkflowRunOrderByField string

WorkflowRunOrderByField defines model for WorkflowRunOrderByField.

const (
	CreatedAt  WorkflowRunOrderByField = "createdAt"
	Duration   WorkflowRunOrderByField = "duration"
	FinishedAt WorkflowRunOrderByField = "finishedAt"
	StartedAt  WorkflowRunOrderByField = "startedAt"
)

Defines values for WorkflowRunOrderByField.

type WorkflowRunShape

type WorkflowRunShape struct {
	AdditionalMetadata *map[string]interface{} `json:"additionalMetadata,omitempty"`
	DisplayName        *string                 `json:"displayName,omitempty"`
	Duration           *int                    `json:"duration,omitempty"`
	Error              *string                 `json:"error,omitempty"`
	FinishedAt         *time.Time              `json:"finishedAt,omitempty"`
	Input              *map[string]interface{} `json:"input,omitempty"`
	JobRuns            *[]JobRun               `json:"jobRuns,omitempty"`
	Metadata           APIResourceMeta         `json:"metadata"`
	ParentId           *openapi_types.UUID     `json:"parentId,omitempty"`
	ParentStepRunId    *openapi_types.UUID     `json:"parentStepRunId,omitempty"`
	StartedAt          *time.Time              `json:"startedAt,omitempty"`
	Status             WorkflowRunStatus       `json:"status"`
	TenantId           string                  `json:"tenantId"`
	TriggeredBy        WorkflowRunTriggeredBy  `json:"triggeredBy"`
	WorkflowId         *string                 `json:"workflowId,omitempty"`
	WorkflowVersion    *WorkflowVersion        `json:"workflowVersion,omitempty"`
	WorkflowVersionId  string                  `json:"workflowVersionId"`
}

WorkflowRunShape defines model for WorkflowRunShape.

type WorkflowRunShapeForWorkflowRunDetails

type WorkflowRunShapeForWorkflowRunDetails = []WorkflowRunShapeItemForWorkflowRunDetails

WorkflowRunShapeForWorkflowRunDetails defines model for WorkflowRunShapeForWorkflowRunDetails.

type WorkflowRunShapeItemForWorkflowRunDetails

type WorkflowRunShapeItemForWorkflowRunDetails struct {
	ChildrenStepIds []openapi_types.UUID `json:"childrenStepIds"`
	StepId          openapi_types.UUID   `json:"stepId"`
	TaskExternalId  openapi_types.UUID   `json:"taskExternalId"`
	TaskName        string               `json:"taskName"`
}

WorkflowRunShapeItemForWorkflowRunDetails defines model for WorkflowRunShapeItemForWorkflowRunDetails.

type WorkflowRunStatus

type WorkflowRunStatus string

WorkflowRunStatus defines model for WorkflowRunStatus.

const (
	BACKOFF   WorkflowRunStatus = "BACKOFF"
	CANCELLED WorkflowRunStatus = "CANCELLED"
	FAILED    WorkflowRunStatus = "FAILED"
	PENDING   WorkflowRunStatus = "PENDING"
	QUEUED    WorkflowRunStatus = "QUEUED"
	RUNNING   WorkflowRunStatus = "RUNNING"
	SUCCEEDED WorkflowRunStatus = "SUCCEEDED"
)

Defines values for WorkflowRunStatus.

type WorkflowRunStatusList

type WorkflowRunStatusList = []WorkflowRunStatus

WorkflowRunStatusList defines model for WorkflowRunStatusList.

type WorkflowRunTriggeredBy

type WorkflowRunTriggeredBy struct {
	CronParentId        *string         `json:"cronParentId,omitempty"`
	CronSchedule        *string         `json:"cronSchedule,omitempty"`
	EventId             *string         `json:"eventId,omitempty"`
	Metadata            APIResourceMeta `json:"metadata"`
	ParentWorkflowRunId *string         `json:"parentWorkflowRunId,omitempty"`
}

WorkflowRunTriggeredBy defines model for WorkflowRunTriggeredBy.

type WorkflowRunUpdateReplay200JSONResponse

type WorkflowRunUpdateReplay200JSONResponse ReplayWorkflowRunsResponse

func (WorkflowRunUpdateReplay200JSONResponse) VisitWorkflowRunUpdateReplayResponse

func (response WorkflowRunUpdateReplay200JSONResponse) VisitWorkflowRunUpdateReplayResponse(w http.ResponseWriter) error

type WorkflowRunUpdateReplay400JSONResponse

type WorkflowRunUpdateReplay400JSONResponse APIErrors

func (WorkflowRunUpdateReplay400JSONResponse) VisitWorkflowRunUpdateReplayResponse

func (response WorkflowRunUpdateReplay400JSONResponse) VisitWorkflowRunUpdateReplayResponse(w http.ResponseWriter) error

type WorkflowRunUpdateReplay403JSONResponse

type WorkflowRunUpdateReplay403JSONResponse APIErrors

func (WorkflowRunUpdateReplay403JSONResponse) VisitWorkflowRunUpdateReplayResponse

func (response WorkflowRunUpdateReplay403JSONResponse) VisitWorkflowRunUpdateReplayResponse(w http.ResponseWriter) error

type WorkflowRunUpdateReplay429JSONResponse

type WorkflowRunUpdateReplay429JSONResponse APIErrors

func (WorkflowRunUpdateReplay429JSONResponse) VisitWorkflowRunUpdateReplayResponse

func (response WorkflowRunUpdateReplay429JSONResponse) VisitWorkflowRunUpdateReplayResponse(w http.ResponseWriter) error

type WorkflowRunUpdateReplayJSONRequestBody

type WorkflowRunUpdateReplayJSONRequestBody = ReplayWorkflowRunsRequest

WorkflowRunUpdateReplayJSONRequestBody defines body for WorkflowRunUpdateReplay for application/json ContentType.

type WorkflowRunUpdateReplayRequestObject

type WorkflowRunUpdateReplayRequestObject struct {
	Tenant openapi_types.UUID `json:"tenant"`
	Body   *WorkflowRunUpdateReplayJSONRequestBody
}

type WorkflowRunUpdateReplayResponseObject

type WorkflowRunUpdateReplayResponseObject interface {
	VisitWorkflowRunUpdateReplayResponse(w http.ResponseWriter) error
}

type WorkflowRunsCancelRequest

type WorkflowRunsCancelRequest struct {
	WorkflowRunIds []openapi_types.UUID `json:"workflowRunIds"`
}

WorkflowRunsCancelRequest defines model for WorkflowRunsCancelRequest.

type WorkflowRunsMetrics

type WorkflowRunsMetrics struct {
	Counts *WorkflowRunsMetricsCounts `json:"counts,omitempty"`
}

WorkflowRunsMetrics defines model for WorkflowRunsMetrics.

type WorkflowRunsMetricsCounts

type WorkflowRunsMetricsCounts struct {
	CANCELLED *int `json:"CANCELLED,omitempty"`
	FAILED    *int `json:"FAILED,omitempty"`
	PENDING   *int `json:"PENDING,omitempty"`
	QUEUED    *int `json:"QUEUED,omitempty"`
	RUNNING   *int `json:"RUNNING,omitempty"`
	SUCCEEDED *int `json:"SUCCEEDED,omitempty"`
}

WorkflowRunsMetricsCounts defines model for WorkflowRunsMetricsCounts.

type WorkflowScheduledDelete204Response

type WorkflowScheduledDelete204Response struct {
}

func (WorkflowScheduledDelete204Response) VisitWorkflowScheduledDeleteResponse

func (response WorkflowScheduledDelete204Response) VisitWorkflowScheduledDeleteResponse(w http.ResponseWriter) error

type WorkflowScheduledDelete400JSONResponse

type WorkflowScheduledDelete400JSONResponse APIErrors

func (WorkflowScheduledDelete400JSONResponse) VisitWorkflowScheduledDeleteResponse

func (response WorkflowScheduledDelete400JSONResponse) VisitWorkflowScheduledDeleteResponse(w http.ResponseWriter) error

type WorkflowScheduledDelete403JSONResponse

type WorkflowScheduledDelete403JSONResponse APIError

func (WorkflowScheduledDelete403JSONResponse) VisitWorkflowScheduledDeleteResponse

func (response WorkflowScheduledDelete403JSONResponse) VisitWorkflowScheduledDeleteResponse(w http.ResponseWriter) error

type WorkflowScheduledDeleteRequestObject

type WorkflowScheduledDeleteRequestObject struct {
	Tenant               openapi_types.UUID `json:"tenant"`
	ScheduledWorkflowRun openapi_types.UUID `json:"scheduled-workflow-run"`
}

type WorkflowScheduledDeleteResponseObject

type WorkflowScheduledDeleteResponseObject interface {
	VisitWorkflowScheduledDeleteResponse(w http.ResponseWriter) error
}

type WorkflowScheduledGet200JSONResponse

type WorkflowScheduledGet200JSONResponse ScheduledWorkflows

func (WorkflowScheduledGet200JSONResponse) VisitWorkflowScheduledGetResponse

func (response WorkflowScheduledGet200JSONResponse) VisitWorkflowScheduledGetResponse(w http.ResponseWriter) error

type WorkflowScheduledGet400JSONResponse

type WorkflowScheduledGet400JSONResponse APIErrors

func (WorkflowScheduledGet400JSONResponse) VisitWorkflowScheduledGetResponse

func (response WorkflowScheduledGet400JSONResponse) VisitWorkflowScheduledGetResponse(w http.ResponseWriter) error

type WorkflowScheduledGet403JSONResponse

type WorkflowScheduledGet403JSONResponse APIErrors

func (WorkflowScheduledGet403JSONResponse) VisitWorkflowScheduledGetResponse

func (response WorkflowScheduledGet403JSONResponse) VisitWorkflowScheduledGetResponse(w http.ResponseWriter) error

type WorkflowScheduledGet404JSONResponse

type WorkflowScheduledGet404JSONResponse APIErrors

func (WorkflowScheduledGet404JSONResponse) VisitWorkflowScheduledGetResponse

func (response WorkflowScheduledGet404JSONResponse) VisitWorkflowScheduledGetResponse(w http.ResponseWriter) error

type WorkflowScheduledGetRequestObject

type WorkflowScheduledGetRequestObject struct {
	Tenant               openapi_types.UUID `json:"tenant"`
	ScheduledWorkflowRun openapi_types.UUID `json:"scheduled-workflow-run"`
}

type WorkflowScheduledGetResponseObject

type WorkflowScheduledGetResponseObject interface {
	VisitWorkflowScheduledGetResponse(w http.ResponseWriter) error
}

type WorkflowScheduledList200JSONResponse

type WorkflowScheduledList200JSONResponse ScheduledWorkflowsList

func (WorkflowScheduledList200JSONResponse) VisitWorkflowScheduledListResponse

func (response WorkflowScheduledList200JSONResponse) VisitWorkflowScheduledListResponse(w http.ResponseWriter) error

type WorkflowScheduledList400JSONResponse

type WorkflowScheduledList400JSONResponse APIErrors

func (WorkflowScheduledList400JSONResponse) VisitWorkflowScheduledListResponse

func (response WorkflowScheduledList400JSONResponse) VisitWorkflowScheduledListResponse(w http.ResponseWriter) error

type WorkflowScheduledList403JSONResponse

type WorkflowScheduledList403JSONResponse APIErrors

func (WorkflowScheduledList403JSONResponse) VisitWorkflowScheduledListResponse

func (response WorkflowScheduledList403JSONResponse) VisitWorkflowScheduledListResponse(w http.ResponseWriter) error

type WorkflowScheduledListParams

type WorkflowScheduledListParams struct {
	// Offset The number to skip
	Offset *int64 `form:"offset,omitempty" json:"offset,omitempty"`

	// Limit The number to limit by
	Limit *int64 `form:"limit,omitempty" json:"limit,omitempty"`

	// OrderByField The order by field
	OrderByField *ScheduledWorkflowsOrderByField `form:"orderByField,omitempty" json:"orderByField,omitempty"`

	// OrderByDirection The order by direction
	OrderByDirection *WorkflowRunOrderByDirection `form:"orderByDirection,omitempty" json:"orderByDirection,omitempty"`

	// WorkflowId The workflow id to get runs for.
	WorkflowId *openapi_types.UUID `form:"workflowId,omitempty" json:"workflowId,omitempty"`

	// ParentWorkflowRunId The parent workflow run id
	ParentWorkflowRunId *openapi_types.UUID `form:"parentWorkflowRunId,omitempty" json:"parentWorkflowRunId,omitempty"`

	// ParentStepRunId The parent step run id
	ParentStepRunId *openapi_types.UUID `form:"parentStepRunId,omitempty" json:"parentStepRunId,omitempty"`

	// AdditionalMetadata A list of metadata key value pairs to filter by
	AdditionalMetadata *[]string `form:"additionalMetadata,omitempty" json:"additionalMetadata,omitempty"`

	// Statuses A list of scheduled run statuses to filter by
	Statuses *[]ScheduledRunStatus `form:"statuses,omitempty" json:"statuses,omitempty"`
}

WorkflowScheduledListParams defines parameters for WorkflowScheduledList.

type WorkflowScheduledListRequestObject

type WorkflowScheduledListRequestObject struct {
	Tenant openapi_types.UUID `json:"tenant"`
	Params WorkflowScheduledListParams
}

type WorkflowScheduledListResponseObject

type WorkflowScheduledListResponseObject interface {
	VisitWorkflowScheduledListResponse(w http.ResponseWriter) error
}

type WorkflowTag

type WorkflowTag struct {
	// Color The description of the workflow.
	Color string `json:"color"`

	// Name The name of the workflow.
	Name string `json:"name"`
}

WorkflowTag defines model for WorkflowTag.

type WorkflowTriggerCronRef

type WorkflowTriggerCronRef struct {
	Cron     *string `json:"cron,omitempty"`
	ParentId *string `json:"parent_id,omitempty"`
}

WorkflowTriggerCronRef defines model for WorkflowTriggerCronRef.

type WorkflowTriggerEventRef

type WorkflowTriggerEventRef struct {
	EventKey *string `json:"event_key,omitempty"`
	ParentId *string `json:"parent_id,omitempty"`
}

WorkflowTriggerEventRef defines model for WorkflowTriggerEventRef.

type WorkflowTriggers

type WorkflowTriggers struct {
	Crons             *[]WorkflowTriggerCronRef  `json:"crons,omitempty"`
	Events            *[]WorkflowTriggerEventRef `json:"events,omitempty"`
	Metadata          *APIResourceMeta           `json:"metadata,omitempty"`
	TenantId          *string                    `json:"tenant_id,omitempty"`
	WorkflowVersionId *string                    `json:"workflow_version_id,omitempty"`
}

WorkflowTriggers defines model for WorkflowTriggers.

type WorkflowUpdate200JSONResponse

type WorkflowUpdate200JSONResponse Workflow

func (WorkflowUpdate200JSONResponse) VisitWorkflowUpdateResponse

func (response WorkflowUpdate200JSONResponse) VisitWorkflowUpdateResponse(w http.ResponseWriter) error

type WorkflowUpdate400JSONResponse

type WorkflowUpdate400JSONResponse APIErrors

func (WorkflowUpdate400JSONResponse) VisitWorkflowUpdateResponse

func (response WorkflowUpdate400JSONResponse) VisitWorkflowUpdateResponse(w http.ResponseWriter) error

type WorkflowUpdate403JSONResponse

type WorkflowUpdate403JSONResponse APIErrors

func (WorkflowUpdate403JSONResponse) VisitWorkflowUpdateResponse

func (response WorkflowUpdate403JSONResponse) VisitWorkflowUpdateResponse(w http.ResponseWriter) error

type WorkflowUpdateJSONRequestBody

type WorkflowUpdateJSONRequestBody = WorkflowUpdateRequest

WorkflowUpdateJSONRequestBody defines body for WorkflowUpdate for application/json ContentType.

type WorkflowUpdateRequest

type WorkflowUpdateRequest struct {
	// IsPaused Whether the workflow is paused.
	IsPaused *bool `json:"isPaused,omitempty"`
}

WorkflowUpdateRequest defines model for WorkflowUpdateRequest.

type WorkflowUpdateRequestObject

type WorkflowUpdateRequestObject struct {
	Workflow openapi_types.UUID `json:"workflow"`
	Body     *WorkflowUpdateJSONRequestBody
}

type WorkflowUpdateResponseObject

type WorkflowUpdateResponseObject interface {
	VisitWorkflowUpdateResponse(w http.ResponseWriter) error
}

type WorkflowVersion

type WorkflowVersion struct {
	Concurrency *WorkflowConcurrency `json:"concurrency,omitempty"`

	// DefaultPriority The default priority of the workflow.
	DefaultPriority *int32          `json:"defaultPriority,omitempty"`
	Jobs            *[]Job          `json:"jobs,omitempty"`
	Metadata        APIResourceMeta `json:"metadata"`
	Order           int32           `json:"order"`
	ScheduleTimeout *string         `json:"scheduleTimeout,omitempty"`

	// Sticky The sticky strategy of the workflow.
	Sticky   *string           `json:"sticky,omitempty"`
	Triggers *WorkflowTriggers `json:"triggers,omitempty"`

	// Version The version of the workflow.
	Version    string    `json:"version"`
	Workflow   *Workflow `json:"workflow,omitempty"`
	WorkflowId string    `json:"workflowId"`
}

WorkflowVersion defines model for WorkflowVersion.

type WorkflowVersionGet200JSONResponse

type WorkflowVersionGet200JSONResponse WorkflowVersion

func (WorkflowVersionGet200JSONResponse) VisitWorkflowVersionGetResponse

func (response WorkflowVersionGet200JSONResponse) VisitWorkflowVersionGetResponse(w http.ResponseWriter) error

type WorkflowVersionGet400JSONResponse

type WorkflowVersionGet400JSONResponse APIErrors

func (WorkflowVersionGet400JSONResponse) VisitWorkflowVersionGetResponse

func (response WorkflowVersionGet400JSONResponse) VisitWorkflowVersionGetResponse(w http.ResponseWriter) error

type WorkflowVersionGet403JSONResponse

type WorkflowVersionGet403JSONResponse APIErrors

func (WorkflowVersionGet403JSONResponse) VisitWorkflowVersionGetResponse

func (response WorkflowVersionGet403JSONResponse) VisitWorkflowVersionGetResponse(w http.ResponseWriter) error

type WorkflowVersionGet404JSONResponse

type WorkflowVersionGet404JSONResponse APIErrors

func (WorkflowVersionGet404JSONResponse) VisitWorkflowVersionGetResponse

func (response WorkflowVersionGet404JSONResponse) VisitWorkflowVersionGetResponse(w http.ResponseWriter) error

type WorkflowVersionGetParams

type WorkflowVersionGetParams struct {
	// Version The workflow version. If not supplied, the latest version is fetched.
	Version *openapi_types.UUID `form:"version,omitempty" json:"version,omitempty"`
}

WorkflowVersionGetParams defines parameters for WorkflowVersionGet.

type WorkflowVersionGetRequestObject

type WorkflowVersionGetRequestObject struct {
	Workflow openapi_types.UUID `json:"workflow"`
	Params   WorkflowVersionGetParams
}

type WorkflowVersionGetResponseObject

type WorkflowVersionGetResponseObject interface {
	VisitWorkflowVersionGetResponse(w http.ResponseWriter) error
}

type WorkflowVersionMeta

type WorkflowVersionMeta struct {
	Metadata APIResourceMeta `json:"metadata"`
	Order    int32           `json:"order"`

	// Version The version of the workflow.
	Version    string    `json:"version"`
	Workflow   *Workflow `json:"workflow,omitempty"`
	WorkflowId string    `json:"workflowId"`
}

WorkflowVersionMeta defines model for WorkflowVersionMeta.

type WorkflowWorkersCount

type WorkflowWorkersCount struct {
	FreeSlotCount *int    `json:"freeSlotCount,omitempty"`
	MaxSlotCount  *int    `json:"maxSlotCount,omitempty"`
	WorkflowRunId *string `json:"workflowRunId,omitempty"`
}

WorkflowWorkersCount defines model for WorkflowWorkersCount.

Jump to

Keyboard shortcuts

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