Versions in this module Expand all Collapse all v1 v1.0.5 Mar 29, 2024 v1.0.4 Mar 20, 2024 v1.0.3 Mar 20, 2024 v1.0.2 Mar 13, 2024 v1.0.1 Feb 27, 2024 v1.0.0 Feb 26, 2024 Changes in this version + const CreateDagOKCode + const DeleteDagOKCode + const GetDagDetailsOKCode + const ListDagsOKCode + const PostDagActionBodyActionMarkDashFailed + const PostDagActionBodyActionMarkDashSuccess + const PostDagActionBodyActionRename + const PostDagActionBodyActionRetry + const PostDagActionBodyActionSave + const PostDagActionBodyActionStart + const PostDagActionBodyActionStop + const PostDagActionBodyActionSuspend + const PostDagActionOKCode + const SearchDagsOKCode + type BlackdaggerAPI struct + APIKeyAuthenticator func(string, string, security.TokenAuthentication) runtime.Authenticator + BasicAuthenticator func(security.UserPassAuthentication) runtime.Authenticator + BearerAuthenticator func(string, security.ScopedTokenAuthentication) runtime.Authenticator + CommandLineOptionsGroups []swag.CommandLineOptionsGroup + CreateDagHandler CreateDagHandler + DeleteDagHandler DeleteDagHandler + GetDagDetailsHandler GetDagDetailsHandler + JSONConsumer runtime.Consumer + JSONProducer runtime.Producer + ListDagsHandler ListDagsHandler + Logger func(string, ...interface{}) + Middleware func(middleware.Builder) http.Handler + PostDagActionHandler PostDagActionHandler + PreServerShutdown func() + SearchDagsHandler SearchDagsHandler + ServeError func(http.ResponseWriter, *http.Request, error) + ServerShutdown func() + func NewBlackdaggerAPI(spec *loads.Document) *BlackdaggerAPI + func (o *BlackdaggerAPI) AddMiddlewareFor(method, path string, builder middleware.Builder) + func (o *BlackdaggerAPI) AuthenticatorsFor(schemes map[string]spec.SecurityScheme) map[string]runtime.Authenticator + func (o *BlackdaggerAPI) Authorizer() runtime.Authorizer + func (o *BlackdaggerAPI) ConsumersFor(mediaTypes []string) map[string]runtime.Consumer + func (o *BlackdaggerAPI) Context() *middleware.Context + func (o *BlackdaggerAPI) DefaultConsumes() string + func (o *BlackdaggerAPI) DefaultProduces() string + func (o *BlackdaggerAPI) Formats() strfmt.Registry + func (o *BlackdaggerAPI) HandlerFor(method, path string) (http.Handler, bool) + func (o *BlackdaggerAPI) Init() + func (o *BlackdaggerAPI) ProducersFor(mediaTypes []string) map[string]runtime.Producer + func (o *BlackdaggerAPI) RegisterConsumer(mediaType string, consumer runtime.Consumer) + func (o *BlackdaggerAPI) RegisterFormat(name string, format strfmt.Format, validator strfmt.Validator) + func (o *BlackdaggerAPI) RegisterProducer(mediaType string, producer runtime.Producer) + func (o *BlackdaggerAPI) Serve(builder middleware.Builder) http.Handler + func (o *BlackdaggerAPI) ServeErrorFor(operationID string) func(http.ResponseWriter, *http.Request, error) + func (o *BlackdaggerAPI) SetDefaultConsumes(mediaType string) + func (o *BlackdaggerAPI) SetDefaultProduces(mediaType string) + func (o *BlackdaggerAPI) SetSpec(spec *loads.Document) + func (o *BlackdaggerAPI) UseRedoc() + func (o *BlackdaggerAPI) UseSwaggerUI() + func (o *BlackdaggerAPI) Validate() error + type CreateDag struct + Context *middleware.Context + Handler CreateDagHandler + func NewCreateDag(ctx *middleware.Context, handler CreateDagHandler) *CreateDag + func (o *CreateDag) ServeHTTP(rw http.ResponseWriter, r *http.Request) + type CreateDagBody struct + Action *string + Value *string + func (o *CreateDagBody) ContextValidate(ctx context.Context, formats strfmt.Registry) error + func (o *CreateDagBody) MarshalBinary() ([]byte, error) + func (o *CreateDagBody) UnmarshalBinary(b []byte) error + func (o *CreateDagBody) Validate(formats strfmt.Registry) error + type CreateDagDefault struct + Payload *models.APIError + func NewCreateDagDefault(code int) *CreateDagDefault + func (o *CreateDagDefault) SetPayload(payload *models.APIError) + func (o *CreateDagDefault) SetStatusCode(code int) + func (o *CreateDagDefault) WithPayload(payload *models.APIError) *CreateDagDefault + func (o *CreateDagDefault) WithStatusCode(code int) *CreateDagDefault + func (o *CreateDagDefault) WriteResponse(rw http.ResponseWriter, producer runtime.Producer) + type CreateDagHandler interface + Handle func(CreateDagParams) middleware.Responder + type CreateDagHandlerFunc func(CreateDagParams) middleware.Responder + func (fn CreateDagHandlerFunc) Handle(params CreateDagParams) middleware.Responder + type CreateDagOK struct + Payload *models.CreateDagResponse + func NewCreateDagOK() *CreateDagOK + func (o *CreateDagOK) SetPayload(payload *models.CreateDagResponse) + func (o *CreateDagOK) WithPayload(payload *models.CreateDagResponse) *CreateDagOK + func (o *CreateDagOK) WriteResponse(rw http.ResponseWriter, producer runtime.Producer) + type CreateDagParams struct + Body CreateDagBody + HTTPRequest *http.Request + func NewCreateDagParams() CreateDagParams + func (o *CreateDagParams) BindRequest(r *http.Request, route *middleware.MatchedRoute) error + type CreateDagURL struct + func (o *CreateDagURL) Build() (*url.URL, error) + func (o *CreateDagURL) BuildFull(scheme, host string) (*url.URL, error) + func (o *CreateDagURL) Must(u *url.URL, err error) *url.URL + func (o *CreateDagURL) SetBasePath(bp string) + func (o *CreateDagURL) String() string + func (o *CreateDagURL) StringFull(scheme, host string) string + func (o *CreateDagURL) WithBasePath(bp string) *CreateDagURL + type DeleteDag struct + Context *middleware.Context + Handler DeleteDagHandler + func NewDeleteDag(ctx *middleware.Context, handler DeleteDagHandler) *DeleteDag + func (o *DeleteDag) ServeHTTP(rw http.ResponseWriter, r *http.Request) + type DeleteDagDefault struct + Payload *models.APIError + func NewDeleteDagDefault(code int) *DeleteDagDefault + func (o *DeleteDagDefault) SetPayload(payload *models.APIError) + func (o *DeleteDagDefault) SetStatusCode(code int) + func (o *DeleteDagDefault) WithPayload(payload *models.APIError) *DeleteDagDefault + func (o *DeleteDagDefault) WithStatusCode(code int) *DeleteDagDefault + func (o *DeleteDagDefault) WriteResponse(rw http.ResponseWriter, producer runtime.Producer) + type DeleteDagHandler interface + Handle func(DeleteDagParams) middleware.Responder + type DeleteDagHandlerFunc func(DeleteDagParams) middleware.Responder + func (fn DeleteDagHandlerFunc) Handle(params DeleteDagParams) middleware.Responder + type DeleteDagOK struct + func NewDeleteDagOK() *DeleteDagOK + func (o *DeleteDagOK) WriteResponse(rw http.ResponseWriter, producer runtime.Producer) + type DeleteDagParams struct + DagID string + HTTPRequest *http.Request + func NewDeleteDagParams() DeleteDagParams + func (o *DeleteDagParams) BindRequest(r *http.Request, route *middleware.MatchedRoute) error + type DeleteDagURL struct + DagID string + func (o *DeleteDagURL) Build() (*url.URL, error) + func (o *DeleteDagURL) BuildFull(scheme, host string) (*url.URL, error) + func (o *DeleteDagURL) Must(u *url.URL, err error) *url.URL + func (o *DeleteDagURL) SetBasePath(bp string) + func (o *DeleteDagURL) String() string + func (o *DeleteDagURL) StringFull(scheme, host string) string + func (o *DeleteDagURL) WithBasePath(bp string) *DeleteDagURL + type GetDagDetails struct + Context *middleware.Context + Handler GetDagDetailsHandler + func NewGetDagDetails(ctx *middleware.Context, handler GetDagDetailsHandler) *GetDagDetails + func (o *GetDagDetails) ServeHTTP(rw http.ResponseWriter, r *http.Request) + type GetDagDetailsDefault struct + Payload *models.APIError + func NewGetDagDetailsDefault(code int) *GetDagDetailsDefault + func (o *GetDagDetailsDefault) SetPayload(payload *models.APIError) + func (o *GetDagDetailsDefault) SetStatusCode(code int) + func (o *GetDagDetailsDefault) WithPayload(payload *models.APIError) *GetDagDetailsDefault + func (o *GetDagDetailsDefault) WithStatusCode(code int) *GetDagDetailsDefault + func (o *GetDagDetailsDefault) WriteResponse(rw http.ResponseWriter, producer runtime.Producer) + type GetDagDetailsHandler interface + Handle func(GetDagDetailsParams) middleware.Responder + type GetDagDetailsHandlerFunc func(GetDagDetailsParams) middleware.Responder + func (fn GetDagDetailsHandlerFunc) Handle(params GetDagDetailsParams) middleware.Responder + type GetDagDetailsOK struct + Payload *models.GetDagDetailsResponse + func NewGetDagDetailsOK() *GetDagDetailsOK + func (o *GetDagDetailsOK) SetPayload(payload *models.GetDagDetailsResponse) + func (o *GetDagDetailsOK) WithPayload(payload *models.GetDagDetailsResponse) *GetDagDetailsOK + func (o *GetDagDetailsOK) WriteResponse(rw http.ResponseWriter, producer runtime.Producer) + type GetDagDetailsParams struct + DagID string + File *string + HTTPRequest *http.Request + Step *string + Tab *string + func NewGetDagDetailsParams() GetDagDetailsParams + func (o *GetDagDetailsParams) BindRequest(r *http.Request, route *middleware.MatchedRoute) error + type GetDagDetailsURL struct + DagID string + File *string + Step *string + Tab *string + func (o *GetDagDetailsURL) Build() (*url.URL, error) + func (o *GetDagDetailsURL) BuildFull(scheme, host string) (*url.URL, error) + func (o *GetDagDetailsURL) Must(u *url.URL, err error) *url.URL + func (o *GetDagDetailsURL) SetBasePath(bp string) + func (o *GetDagDetailsURL) String() string + func (o *GetDagDetailsURL) StringFull(scheme, host string) string + func (o *GetDagDetailsURL) WithBasePath(bp string) *GetDagDetailsURL + type ListDags struct + Context *middleware.Context + Handler ListDagsHandler + func NewListDags(ctx *middleware.Context, handler ListDagsHandler) *ListDags + func (o *ListDags) ServeHTTP(rw http.ResponseWriter, r *http.Request) + type ListDagsDefault struct + Payload *models.APIError + func NewListDagsDefault(code int) *ListDagsDefault + func (o *ListDagsDefault) SetPayload(payload *models.APIError) + func (o *ListDagsDefault) SetStatusCode(code int) + func (o *ListDagsDefault) WithPayload(payload *models.APIError) *ListDagsDefault + func (o *ListDagsDefault) WithStatusCode(code int) *ListDagsDefault + func (o *ListDagsDefault) WriteResponse(rw http.ResponseWriter, producer runtime.Producer) + type ListDagsHandler interface + Handle func(ListDagsParams) middleware.Responder + type ListDagsHandlerFunc func(ListDagsParams) middleware.Responder + func (fn ListDagsHandlerFunc) Handle(params ListDagsParams) middleware.Responder + type ListDagsOK struct + Payload *models.ListDagsResponse + func NewListDagsOK() *ListDagsOK + func (o *ListDagsOK) SetPayload(payload *models.ListDagsResponse) + func (o *ListDagsOK) WithPayload(payload *models.ListDagsResponse) *ListDagsOK + func (o *ListDagsOK) WriteResponse(rw http.ResponseWriter, producer runtime.Producer) + type ListDagsParams struct + HTTPRequest *http.Request + func NewListDagsParams() ListDagsParams + func (o *ListDagsParams) BindRequest(r *http.Request, route *middleware.MatchedRoute) error + type ListDagsURL struct + func (o *ListDagsURL) Build() (*url.URL, error) + func (o *ListDagsURL) BuildFull(scheme, host string) (*url.URL, error) + func (o *ListDagsURL) Must(u *url.URL, err error) *url.URL + func (o *ListDagsURL) SetBasePath(bp string) + func (o *ListDagsURL) String() string + func (o *ListDagsURL) StringFull(scheme, host string) string + func (o *ListDagsURL) WithBasePath(bp string) *ListDagsURL + type PostDagAction struct + Context *middleware.Context + Handler PostDagActionHandler + func NewPostDagAction(ctx *middleware.Context, handler PostDagActionHandler) *PostDagAction + func (o *PostDagAction) ServeHTTP(rw http.ResponseWriter, r *http.Request) + type PostDagActionBody struct + Action *string + Params string + RequestID string + Step string + Value string + func (o *PostDagActionBody) ContextValidate(ctx context.Context, formats strfmt.Registry) error + func (o *PostDagActionBody) MarshalBinary() ([]byte, error) + func (o *PostDagActionBody) UnmarshalBinary(b []byte) error + func (o *PostDagActionBody) Validate(formats strfmt.Registry) error + type PostDagActionDefault struct + Payload *models.APIError + func NewPostDagActionDefault(code int) *PostDagActionDefault + func (o *PostDagActionDefault) SetPayload(payload *models.APIError) + func (o *PostDagActionDefault) SetStatusCode(code int) + func (o *PostDagActionDefault) WithPayload(payload *models.APIError) *PostDagActionDefault + func (o *PostDagActionDefault) WithStatusCode(code int) *PostDagActionDefault + func (o *PostDagActionDefault) WriteResponse(rw http.ResponseWriter, producer runtime.Producer) + type PostDagActionHandler interface + Handle func(PostDagActionParams) middleware.Responder + type PostDagActionHandlerFunc func(PostDagActionParams) middleware.Responder + func (fn PostDagActionHandlerFunc) Handle(params PostDagActionParams) middleware.Responder + type PostDagActionOK struct + Payload *models.PostDagActionResponse + func NewPostDagActionOK() *PostDagActionOK + func (o *PostDagActionOK) SetPayload(payload *models.PostDagActionResponse) + func (o *PostDagActionOK) WithPayload(payload *models.PostDagActionResponse) *PostDagActionOK + func (o *PostDagActionOK) WriteResponse(rw http.ResponseWriter, producer runtime.Producer) + type PostDagActionParams struct + Body PostDagActionBody + DagID string + HTTPRequest *http.Request + func NewPostDagActionParams() PostDagActionParams + func (o *PostDagActionParams) BindRequest(r *http.Request, route *middleware.MatchedRoute) error + type PostDagActionURL struct + DagID string + func (o *PostDagActionURL) Build() (*url.URL, error) + func (o *PostDagActionURL) BuildFull(scheme, host string) (*url.URL, error) + func (o *PostDagActionURL) Must(u *url.URL, err error) *url.URL + func (o *PostDagActionURL) SetBasePath(bp string) + func (o *PostDagActionURL) String() string + func (o *PostDagActionURL) StringFull(scheme, host string) string + func (o *PostDagActionURL) WithBasePath(bp string) *PostDagActionURL + type SearchDags struct + Context *middleware.Context + Handler SearchDagsHandler + func NewSearchDags(ctx *middleware.Context, handler SearchDagsHandler) *SearchDags + func (o *SearchDags) ServeHTTP(rw http.ResponseWriter, r *http.Request) + type SearchDagsDefault struct + Payload *models.APIError + func NewSearchDagsDefault(code int) *SearchDagsDefault + func (o *SearchDagsDefault) SetPayload(payload *models.APIError) + func (o *SearchDagsDefault) SetStatusCode(code int) + func (o *SearchDagsDefault) WithPayload(payload *models.APIError) *SearchDagsDefault + func (o *SearchDagsDefault) WithStatusCode(code int) *SearchDagsDefault + func (o *SearchDagsDefault) WriteResponse(rw http.ResponseWriter, producer runtime.Producer) + type SearchDagsHandler interface + Handle func(SearchDagsParams) middleware.Responder + type SearchDagsHandlerFunc func(SearchDagsParams) middleware.Responder + func (fn SearchDagsHandlerFunc) Handle(params SearchDagsParams) middleware.Responder + type SearchDagsOK struct + Payload *models.SearchDagsResponse + func NewSearchDagsOK() *SearchDagsOK + func (o *SearchDagsOK) SetPayload(payload *models.SearchDagsResponse) + func (o *SearchDagsOK) WithPayload(payload *models.SearchDagsResponse) *SearchDagsOK + func (o *SearchDagsOK) WriteResponse(rw http.ResponseWriter, producer runtime.Producer) + type SearchDagsParams struct + HTTPRequest *http.Request + Q string + func NewSearchDagsParams() SearchDagsParams + func (o *SearchDagsParams) BindRequest(r *http.Request, route *middleware.MatchedRoute) error + type SearchDagsURL struct + Q string + func (o *SearchDagsURL) Build() (*url.URL, error) + func (o *SearchDagsURL) BuildFull(scheme, host string) (*url.URL, error) + func (o *SearchDagsURL) Must(u *url.URL, err error) *url.URL + func (o *SearchDagsURL) SetBasePath(bp string) + func (o *SearchDagsURL) String() string + func (o *SearchDagsURL) StringFull(scheme, host string) string + func (o *SearchDagsURL) WithBasePath(bp string) *SearchDagsURL