biz

Jun 6, 2024

Changes in this version

+ func IsErrNotImplemented(err error) bool

+ type ErrNotImplemented struct

+ func NewErrNotImplemented(msg string) ErrNotImplemented

+ func (e ErrNotImplemented) Error() string

Jun 4, 2024

Changes in this version

+ type SigningUseCase struct

+ CA ca.CertificateAuthority

+ func NewChainloopSigningUseCase(ca ca.CertificateAuthority) *SigningUseCase

+ func (s *SigningUseCase) CreateSigningCert(ctx context.Context, orgID string, csrRaw []byte) ([]string, error)

May 20, 2024

Changes in this version

type WorkflowRunUseCase

+ func (uc *WorkflowRunUseCase) GetByIDInOrg(ctx context.Context, orgID, runID string) (*WorkflowRun, error)

May 8, 2024

Changes in this version

type WorkflowRepo

+ GetOrgScopedByName func(ctx context.Context, orgID uuid.UUID, workflowName string) (*Workflow, error)

type WorkflowUseCase

+ func (uc *WorkflowUseCase) FindByNameInOrg(ctx context.Context, orgID, workflowName string) (*Workflow, error)

May 3, 2024

Changes in this version

type ReferrerRepo

+ Exist func(ctx context.Context, digest string, filters ...GetFromRootFilter) (bool, error)

Apr 16, 2024

Changes in this version

type APIToken

+ Name string

type CASBackend

+ Name string

type CASBackendOpts

+ Name string

Apr 2, 2024

Changes in this version

type Integration

+ Name string

type IntegrationCreateOpts

+ Name string

type WorkflowUpdateOpts

+ ContractID *string

Mar 13, 2024

Changes in this version

+ const RandomNameMaxTries

+ func ValidateIsDNS1123(name string) error

+ type ByStatusCount struct

+ Count int32

+ Status string

type ContractCreateOpts

+ Description *string

type ContractUpdateOpts

+ Description *string

+ type DayRunsCount struct

+ Date time.Time

+ Totals []*ByStatusCount

type OrgMetricsRepo

+ DailyRunsCount func(ctx context.Context, orgID, workflowID uuid.UUID, timeWindow time.Duration) ([]*DayRunsCount, error)

type OrgMetricsUseCase

+ func (uc *OrgMetricsUseCase) DailyRunsCount(ctx context.Context, orgID string, workflowID *string, ...) ([]*DayRunsCount, error)

type WorkflowContract

+ Description string

+ type WorkflowContractCreateOpts struct

+ AddUniquePrefix bool

+ Description *string

+ Name string

+ OrgID string

+ Schema *schemav1.CraftingSchema

+ type WorkflowContractUpdateOpts struct

+ Description *string

+ Name string

+ Schema *schemav1.CraftingSchema

Mar 4, 2024

Changes in this version

+ type InvitationCreateOpt func(*invitationCreateOpts)

+ func WithInvitationRole(r authz.Role) InvitationCreateOpt

type Membership

+ Role authz.Role

+ User *User

+ type MembershipCreateOpt func(*membershipCreateOpts)

+ func WithCurrentMembership() MembershipCreateOpt

+ func WithMembershipRole(r authz.Role) MembershipCreateOpt

type MembershipRepo

+ FindByIDInOrg func(ctx context.Context, orgID, ID uuid.UUID) (*Membership, error)

+ SetRole func(ctx context.Context, ID uuid.UUID, role authz.Role) (*Membership, error)

type MembershipUseCase

+ func (uc *MembershipUseCase) DeleteOther(ctx context.Context, orgID, userID, membershipID string) error

+ func (uc *MembershipUseCase) LeaveAndDeleteOrg(ctx context.Context, userID, membershipID string) error

+ func (uc *MembershipUseCase) UpdateRole(ctx context.Context, orgID, userID, membershipID string, role authz.Role) (*Membership, error)

type OrgInvitation

+ Role authz.Role

type OrgInvitationRepo

+ ListByOrg func(ctx context.Context, org uuid.UUID) ([]*OrgInvitation, error)

type OrgInvitationUseCase

+ func (uc *OrgInvitationUseCase) ListByOrg(ctx context.Context, orgID string) ([]*OrgInvitation, error)

type UserOrgFinder

+ CurrentMembership func(ctx context.Context, userID string) (*Membership, error)

type UserUseCase

+ func (uc *UserUseCase) CurrentMembership(ctx context.Context, userID string) (*Membership, error)

Feb 29, 2024

Changes in this version

+ type CreateOpt func(*createOptions)

+ func WithCreateInlineBackend() CreateOpt

type MembershipUseCase

+ func (uc *MembershipUseCase) FindByOrgAndUser(ctx context.Context, orgID, userID string) (*Membership, error)

+ type RunListFilters struct

+ Status WorkflowRunStatus

+ WorkflowID uuid.UUID

type Workflow

+ ContractRevisionLatest int

+ Description string

type WorkflowCreateOpts

+ Description string

type WorkflowRun

+ ContractRevisionLatest int

+ ContractRevisionUsed int

type WorkflowRunCreateOpts

+ ContractRevision *WorkflowContractWithVersion

+ type WorkflowRunRepoCreateOpts struct

+ Backends []uuid.UUID

+ LatestRevision int

+ RobotaccountID uuid.UUID

+ RunURL string

+ RunnerType string

+ SchemaVersionID uuid.UUID

+ UsedRevision int

+ WorkflowID uuid.UUID

type WorkflowUpdateOpts

+ Description *string

Feb 19, 2024

Changes in this version

+ const OrganizationRandomNameMaxTries

+ var ErrAlreadyExists = errors.New("duplicate")

+ func ValidateOrgName(name string) error

type OrganizationUseCase

+ func (uc *OrganizationUseCase) CreateWithRandomName(ctx context.Context) (*Organization, error)

Feb 12, 2024

Changes in this version

+ type AttestationState struct

+ State *v1.CraftingState

+ type AttestationStateRepo interface

+ Initialized func(ctx context.Context, workflowRunID uuid.UUID) (bool, error)

+ Read func(ctx context.Context, workflowRunID uuid.UUID) ([]byte, error)

+ Reset func(ctx context.Context, workflowRunID uuid.UUID) error

+ Save func(ctx context.Context, workflowRunID uuid.UUID, state []byte) error

+ type AttestationStateUseCase struct

+ func NewAttestationStateUseCase(repo AttestationStateRepo, wfRunRepo WorkflowRunRepo) (*AttestationStateUseCase, error)

+ func (uc *AttestationStateUseCase) Initialized(ctx context.Context, workflowID, runID string) (bool, error)

+ func (uc *AttestationStateUseCase) Read(ctx context.Context, workflowID, runID, passphrase string) (*AttestationState, error)

+ func (uc *AttestationStateUseCase) Reset(ctx context.Context, workflowID, runID string) error

+ func (uc *AttestationStateUseCase) Save(ctx context.Context, workflowID, runID string, state *v1.CraftingState, ...) error

Jan 29, 2024

Changes in this version

+ type APITokenSyncerUseCase struct

+ func NewAPITokenSyncerUseCase(tokenUC *APITokenUseCase) *APITokenSyncerUseCase

+ func (suc *APITokenSyncerUseCase) SyncPolicies() error

type APITokenUseCase

+ DefaultAuthzPolicies []*authz.Policy

Dec 18, 2023

Changes in this version

+ type APIToken struct

+ CreatedAt *time.Time

+ Description string

+ ExpiresAt *time.Time

+ ID uuid.UUID

+ JWT string

+ OrganizationID uuid.UUID

+ RevokedAt *time.Time

+ type APITokenRepo interface

+ Create func(ctx context.Context, description *string, expiresAt *time.Time, ...) (*APIToken, error)

+ FindByID func(ctx context.Context, ID uuid.UUID) (*APIToken, error)

+ List func(ctx context.Context, orgID uuid.UUID, includeRevoked bool) ([]*APIToken, error)

+ Revoke func(ctx context.Context, orgID, ID uuid.UUID) error

+ type APITokenUseCase struct

+ func NewAPITokenUseCase(apiTokenRepo APITokenRepo, conf *conf.Auth, logger log.Logger) (*APITokenUseCase, error)

+ func (uc *APITokenUseCase) Create(ctx context.Context, description *string, expiresIn *time.Duration, ...) (*APIToken, error)

+ func (uc *APITokenUseCase) FindByID(ctx context.Context, id string) (*APIToken, error)

+ func (uc *APITokenUseCase) List(ctx context.Context, orgID string, includeRevoked bool) ([]*APIToken, error)

+ func (uc *APITokenUseCase) Revoke(ctx context.Context, orgID, id string) error

type CASMappingUseCase

+ func (uc *CASMappingUseCase) FindCASMappingForDownloadByOrg(ctx context.Context, digest string, orgs []string) (*CASMapping, error)

+ func (uc *CASMappingUseCase) FindCASMappingForDownloadByUser(ctx context.Context, digest string, userID string) (*CASMapping, error)

type MembershipRepo

+ FindByOrgAndUser func(ctx context.Context, orgID, userID uuid.UUID) (*Membership, error)

type Referrer

+ Annotations map[string]string

+ Metadata map[string]string

type ReferrerUseCase

+ func (s *ReferrerUseCase) GetFromRootUser(ctx context.Context, digest, rootKind, userID string) (*StoredReferrer, error)

Dec 4, 2023

Changes in this version

type MembershipUseCase

+ func (uc *MembershipUseCase) DeleteWithOrg(ctx context.Context, userID, membershipID string) error

type OrganizationRepo

+ Update func(ctx context.Context, id uuid.UUID, name *string) (*Organization, error)

type OrganizationUseCase

+ func (uc *OrganizationUseCase) Update(ctx context.Context, userID, orgID string, name *string) (*Organization, error)

Nov 17, 2023

Changes in this version

+ func NewErrReferrerAmbiguous(digest string, kinds []string) error

+ func WithKind(kind string) func(*GetFromRootFilters)

+ func WithPublicVisibility(public bool) func(*GetFromRootFilters)

+ type ErrAmbiguousReferrer struct

+ func (e ErrAmbiguousReferrer) Error() string

+ type GetFromRootFilter func(*GetFromRootFilters)

+ type GetFromRootFilters struct

+ Public *bool

+ RootKind *string

type Referrer

+ InPublicWorkflow bool

+ func (r *Referrer) MapID() string

type ReferrerUseCase

+ func (s *ReferrerUseCase) GetFromRootInPublicSharedIndex(ctx context.Context, digest, rootKind string) (*StoredReferrer, error)

type StoredReferrer

+ WorkflowIDs []uuid.UUID

+ type WorkflowCreateOpts struct

+ ContractID string

+ Name string

+ OrgID string

+ Project string

+ Public bool

+ Team string

type WorkflowRepo

+ Update func(ctx context.Context, id uuid.UUID, opts *WorkflowUpdateOpts) (*Workflow, error)

+ type WorkflowUpdateOpts struct

+ Name *string

+ Project *string

+ Public *bool

+ Team *string

type WorkflowUseCase

+ func (uc *WorkflowUseCase) Update(ctx context.Context, orgID, workflowID string, opts *WorkflowUpdateOpts) (*Workflow, error)

Nov 9, 2023

Changes in this version

+ type Referrer struct

+ Digest string

+ Downloadable bool

+ Kind string

+ References []string

+ type ReferrerMap map[string]*Referrer

+ type ReferrerRepo interface

+ GetFromRoot func(ctx context.Context, digest string, orgIDS []uuid.UUID) (*StoredReferrer, error)

+ Save func(ctx context.Context, input ReferrerMap, orgID uuid.UUID) error

+ type ReferrerUseCase struct

+ func NewReferrerUseCase(repo ReferrerRepo, orgRepo OrganizationRepo, mRepo MembershipRepo, ...) *ReferrerUseCase

+ func (s *ReferrerUseCase) ExtractAndPersist(ctx context.Context, att *dsse.Envelope, orgID string) error

+ func (s *ReferrerUseCase) GetFromRoot(ctx context.Context, digest string, userID string) (*StoredReferrer, error)

+ type StoredReferrer struct

+ CreatedAt *time.Time

+ Digest string

+ Downloadable bool

+ ID uuid.UUID

+ Kind string

+ OrgIDs []uuid.UUID

+ References []*StoredReferrer

Oct 31, 2023

Changes in this version

type ErrUnauthorized

+ func NewErrUnauthorizedStr(errMsg string) ErrUnauthorized

type ErrValidation

+ func NewErrValidationStr(errMsg string) ErrValidation

type Membership

+ UserEmail string

+ type OrgInvitation struct

+ CreatedAt *time.Time

+ ID uuid.UUID

+ Org *Organization

+ ReceiverEmail string

+ Sender *User

+ Status OrgInvitationStatus

+ type OrgInvitationRepo interface

+ ChangeStatus func(ctx context.Context, ID uuid.UUID, status OrgInvitationStatus) error

+ Create func(ctx context.Context, orgID, senderID uuid.UUID, receiverEmail string) (*OrgInvitation, error)

+ FindByID func(ctx context.Context, ID uuid.UUID) (*OrgInvitation, error)

+ ListBySender func(ctx context.Context, sender uuid.UUID) ([]*OrgInvitation, error)

+ PendingInvitation func(ctx context.Context, orgID uuid.UUID, receiverEmail string) (*OrgInvitation, error)

+ PendingInvitations func(ctx context.Context, receiverEmail string) ([]*OrgInvitation, error)

+ SoftDelete func(ctx context.Context, id uuid.UUID) error

+ type OrgInvitationStatus string

+ var OrgInvitationStatusAccepted OrgInvitationStatus = "accepted"

+ var OrgInvitationStatusPending OrgInvitationStatus = "pending"

+ func (OrgInvitationStatus) Values() (kinds []string)

+ type OrgInvitationUseCase struct

+ func NewOrgInvitationUseCase(r OrgInvitationRepo, mRepo MembershipRepo, uRepo UserRepo, l log.Logger) (*OrgInvitationUseCase, error)

+ func (uc *OrgInvitationUseCase) AcceptInvitation(ctx context.Context, invitationID string) error

+ func (uc *OrgInvitationUseCase) AcceptPendingInvitations(ctx context.Context, receiverEmail string) error

+ func (uc *OrgInvitationUseCase) Create(ctx context.Context, orgID, senderID, receiverEmail string) (*OrgInvitation, error)

+ func (uc *OrgInvitationUseCase) FindByID(ctx context.Context, invitationID string) (*OrgInvitation, error)

+ func (uc *OrgInvitationUseCase) ListBySender(ctx context.Context, senderID string) ([]*OrgInvitation, error)

+ func (uc *OrgInvitationUseCase) Revoke(ctx context.Context, senderID, invitationID string) error

Sep 27, 2023

Changes in this version

+ type CASCredsOpts struct

+ BackendType string

+ Role robotaccount.Role

+ SecretPath string

Sep 15, 2023

Changes in this version

type CreateOpts

+ Public bool

type WorkflowRunRepo

+ FindByAttestationDigest func(ctx context.Context, digest string) (*WorkflowRun, error)

type WorkflowRunUseCase

+ func (uc *WorkflowRunUseCase) GetByDigestInOrgOrPublic(ctx context.Context, orgID, digest string) (*WorkflowRun, error)

+ func (uc *WorkflowRunUseCase) GetByIDInOrgOrPublic(ctx context.Context, orgID, runID string) (*WorkflowRun, error)

Sep 5, 2023

Changes in this version

+ func IsErrUnauthorized(err error) bool

type Attestation

+ Digest string

+ type CASMapping struct

+ CASBackend *CASBackend

+ CreatedAt *time.Time

+ Digest string

+ ID uuid.UUID

+ OrgID uuid.UUID

+ Public bool

+ WorkflowRunID uuid.UUID

+ type CASMappingLookupRef struct

+ Digest string

+ Name string

+ type CASMappingRepo interface

+ Create func(ctx context.Context, digest string, casBackendID, workflowRunID uuid.UUID) (*CASMapping, error)

+ FindByDigest func(ctx context.Context, digest string) ([]*CASMapping, error)

+ type CASMappingUseCase struct

+ func NewCASMappingUseCase(repo CASMappingRepo, mRepo MembershipRepo, logger log.Logger) *CASMappingUseCase

+ func (uc *CASMappingUseCase) Create(ctx context.Context, digest string, casBackendID, workflowRunID string) (*CASMapping, error)

+ func (uc *CASMappingUseCase) FindByDigest(ctx context.Context, digest string) ([]*CASMapping, error)

+ func (uc *CASMappingUseCase) FindCASMappingForDownload(ctx context.Context, digest string, userID string) (*CASMapping, error)

+ func (uc *CASMappingUseCase) LookupDigestsInAttestation(att *dsse.Envelope) ([]*CASMappingLookupRef, error)

+ type ErrUnauthorized struct

+ func NewErrUnauthorized(err error) ErrUnauthorized

+ func (e ErrUnauthorized) Error() string

type Workflow

+ Public bool

type WorkflowRepo

+ ChangeVisibility func(ctx context.Context, workflowID uuid.UUID, public bool) (*Workflow, error)

type WorkflowUseCase

+ func (uc *WorkflowUseCase) ChangeVisibility(ctx context.Context, orgID, workflowID string, public bool) (*Workflow, error)

Jul 20, 2023

Changes in this version

+ const CASBackendDefaultMaxBytes

+ const CASBackendInline

+ const CASBackendInlineDefaultMaxBytes

+ const CASBackendOCI

+ type CASBackend struct

+ CreatedAt *time.Time

+ Default bool

+ Description string

+ Fallback bool

+ ID uuid.UUID

+ Inline bool

+ Limits *CASBackendLimits

+ Location string

+ OrganizationID uuid.UUID

+ Provider CASBackendProvider

+ SecretName string

+ ValidatedAt *time.Time

+ ValidationStatus CASBackendValidationStatus

+ type CASBackendCreateOpts struct

+ Fallback bool

+ type CASBackendLimits struct

+ MaxBytes int64

+ type CASBackendOpts struct

+ Default bool

+ Description string

+ Location string

+ OrgID uuid.UUID

+ Provider CASBackendProvider

+ SecretName string

+ type CASBackendProvider string

+ func (CASBackendProvider) Values() (kinds []string)

+ type CASBackendReader interface

+ FindByIDInOrg func(ctx context.Context, OrgID, ID string) (*CASBackend, error)

+ FindDefaultBackend func(ctx context.Context, orgID string) (*CASBackend, error)

+ PerformValidation func(ctx context.Context, ID string) error

+ type CASBackendRepo interface

+ Create func(context.Context, *CASBackendCreateOpts) (*CASBackend, error)

+ Delete func(ctx context.Context, ID uuid.UUID) error

+ FindByID func(ctx context.Context, ID uuid.UUID) (*CASBackend, error)

+ FindByIDInOrg func(ctx context.Context, OrgID, ID uuid.UUID) (*CASBackend, error)

+ FindDefaultBackend func(ctx context.Context, orgID uuid.UUID) (*CASBackend, error)

+ FindFallbackBackend func(ctx context.Context, orgID uuid.UUID) (*CASBackend, error)

+ List func(ctx context.Context, orgID uuid.UUID) ([]*CASBackend, error)

+ SoftDelete func(ctx context.Context, ID uuid.UUID) error

+ Update func(context.Context, *CASBackendUpdateOpts) (*CASBackend, error)

+ UpdateValidationStatus func(ctx context.Context, ID uuid.UUID, status CASBackendValidationStatus) error

+ type CASBackendUpdateOpts struct

+ ID uuid.UUID

+ type CASBackendUseCase struct

+ func NewCASBackendUseCase(repo CASBackendRepo, credsRW credentials.ReaderWriter, ...) *CASBackendUseCase

+ func (uc *CASBackendUseCase) Create(ctx context.Context, orgID, location, description string, ...) (*CASBackend, error)

+ func (uc *CASBackendUseCase) CreateInlineFallbackBackend(ctx context.Context, orgID string) (*CASBackend, error)

+ func (uc *CASBackendUseCase) CreateOrUpdate(ctx context.Context, orgID, name, username, password string, ...) (*CASBackend, error)

+ func (uc *CASBackendUseCase) Delete(ctx context.Context, id string) error

+ func (uc *CASBackendUseCase) FindByIDInOrg(ctx context.Context, orgID, id string) (*CASBackend, error)

+ func (uc *CASBackendUseCase) FindDefaultBackend(ctx context.Context, orgID string) (*CASBackend, error)

+ func (uc *CASBackendUseCase) FindFallbackBackend(ctx context.Context, orgID string) (*CASBackend, error)

+ func (uc *CASBackendUseCase) List(ctx context.Context, orgID string) ([]*CASBackend, error)

+ func (uc *CASBackendUseCase) PerformValidation(ctx context.Context, id string) (err error)

+ func (uc *CASBackendUseCase) SoftDelete(ctx context.Context, orgID, id string) error

+ func (uc *CASBackendUseCase) Update(ctx context.Context, orgID, id, description string, creds any, defaultB bool) (*CASBackend, error)

+ type CASBackendValidationStatus string

+ var CASBackendValidationFailed CASBackendValidationStatus = "Invalid"

+ var CASBackendValidationOK CASBackendValidationStatus = "OK"

+ func (CASBackendValidationStatus) Values() (kinds []string)

type WorkflowRun

+ CASBackends []*CASBackend

type WorkflowRunCreateOpts

+ CASBackendID uuid.UUID

Jun 19, 2023

Changes in this version

type AttachOpts

+ AttachmentConfig *structpb.Struct

+ FanOutIntegration sdk.FanOut

type Integration

+ Description string

+ type IntegrationCreateOpts struct

+ Config []byte

+ Description string

+ Kind string

+ OrgID uuid.UUID

+ SecretName string

type IntegrationUseCase

+ func (uc *IntegrationUseCase) RegisterAndSave(ctx context.Context, orgID, description string, i sdk.FanOut, ...) (*Integration, error)

type WorkflowRun

+ Attestation *Attestation

type WorkflowRunRepo

+ SaveAttestation func(ctx context.Context, ID uuid.UUID, att *dsse.Envelope) error

type WorkflowRunUseCase

+ func (uc *WorkflowRunUseCase) SaveAttestation(ctx context.Context, id string, envelope *dsse.Envelope) error

Mar 31, 2023

Changes in this version

+ type CASClientFactory func(conf *conf.Bootstrap_CASServer, token string) (casclient.DownloaderUploader, error)

+ type CASClientOpts func(u *CASClientUseCase)

+ func WithClientFactory(f CASClientFactory) CASClientOpts

type CASClientUseCase

+ func (uc *CASClientUseCase) IsReady(ctx context.Context) (bool, error)

Mar 23, 2023

Changes in this version

type AttestationUseCase

+ func (uc *AttestationUseCase) UploadToCAS(ctx context.Context, envelope *dsse.Envelope, secretID, workflowRunID string) (*cr_v1.Hash, error)

+ type CASClient interface

+ Configured func() bool

+ type CASClientUseCase struct

+ func NewCASClientUseCase(credsProvider *CASCredentialsUseCase, config *conf.Bootstrap_CASServer, ...) *CASClientUseCase

+ func (uc *CASClientUseCase) Configured() bool

+ func (uc *CASClientUseCase) Download(ctx context.Context, secretID string, w io.Writer, digest string) error

+ func (uc *CASClientUseCase) Upload(ctx context.Context, secretID string, content io.Reader, ...) error

+ type CASDownloader interface

+ Download func(ctx context.Context, secretID string, w io.Writer, digest string) error

+ type CASUploader interface

+ Upload func(ctx context.Context, secretID string, content io.Reader, ...) error

+ type ErrValidation struct

+ func NewErrValidation(err error) ErrValidation

+ func (e ErrValidation) Error() string

type IntegrationUseCase

+ func NewIntegrationUseCase(opts *NewIntegrationUseCaseOpts) *IntegrationUseCase

+ func (uc *IntegrationUseCase) Create(ctx context.Context, orgID, kind string, secretID string, ...) (*Integration, error)

type MembershipUseCase

+ func NewMembershipUseCase(repo MembershipRepo, logger log.Logger) *MembershipUseCase

+ type NewIntegrationUseCaseOpts struct

+ CredsRW credentials.ReaderWriter

+ IRepo IntegrationRepo

+ IaRepo IntegrationAttachmentRepo

+ Logger log.Logger

+ WfRepo WorkflowRepo

type OCIRepositoryUseCase

+ func NewOCIRepositoryUseCase(repo OCIRepositoryRepo, credsRW credentials.ReaderWriter, p backend.Provider, ...) *OCIRepositoryUseCase

type OrganizationUseCase

+ func NewOrganizationUseCase(repo OrganizationRepo, repoUC *OCIRepositoryUseCase, iUC *IntegrationUseCase, ...) *OrganizationUseCase

type WorkflowContractUseCase

+ func NewWorkflowContractUseCase(repo WorkflowContractRepo, logger log.Logger) *WorkflowContractUseCase

type WorkflowRunUseCase

+ func NewWorkflowRunUseCase(wfrRepo WorkflowRunRepo, wfRepo WorkflowRepo, logger log.Logger) (*WorkflowRunUseCase, error)

Mar 7, 2023

Changes in this version

+ const DependencyTrackKind

+ var ErrAlreadyRepoInOrg = errors.New("there is already an OCI repository associated with this organization")

+ var ProviderSet = wire.NewSet(NewWorkflowUsecase, NewUserUseCase, NewRootAccountUseCase, ...)

+ func IsErrInvalidUUID(err error) bool

+ func IsErrValidation(err error) bool

+ func IsNotFound(err error) bool

+ type AttachOpts struct

+ Config *v1.IntegrationAttachmentConfig

+ IntegrationID string

+ OrgID string

+ WorkflowID string

+ type Attestation struct

+ Envelope *dsse.Envelope

+ type AttestationRef struct

+ SecretRef string

+ Sha256 string

+ type AttestationUseCase struct

+ func NewAttestationUseCase(logger log.Logger) *AttestationUseCase

+ func (uc *AttestationUseCase) FetchFromStore(ctx context.Context, downloader backend.Downloader, digest string) (*Attestation, error)

+ func (uc *AttestationUseCase) UploadAttestationToOCI(ctx context.Context, envelope *dsse.Envelope, uploader backend.Uploader, ...) (string, error)

+ type CASCredentialsUseCase struct

+ func NewCASCredentialsUseCase(c *conf.Auth, logger log.Logger) (*CASCredentialsUseCase, error)

+ func (uc *CASCredentialsUseCase) GenerateTemporaryCredentials(ctx context.Context, orgID, secretID string, role robotaccount.Role) (string, error)

+ type ContractCreateOpts struct

+ ContractBody []byte

+ Name string

+ OrgID uuid.UUID

+ type ContractUpdateOpts struct

+ ContractBody []byte

+ ContractID uuid.UUID

+ Name string

+ OrgID uuid.UUID

+ type CreateOpts struct

+ ContractID string

+ Name string

+ OrgID string

+ Project string

+ Team string

+ type ErrInvalidUUID struct

+ func NewErrInvalidUUID(err error) ErrInvalidUUID

+ func (e ErrInvalidUUID) Error() string

+ type ErrNotFound struct

+ func NewErrNotFound(entity string) ErrNotFound

+ func (e ErrNotFound) Error() string

+ type Integration struct

+ Config *v1.IntegrationConfig

+ CreatedAt *time.Time

+ ID uuid.UUID

+ Kind string

+ SecretName string

+ type IntegrationAndAttachment struct

+ type IntegrationAttachment struct

+ Config *v1.IntegrationAttachmentConfig

+ CreatedAt *time.Time

+ ID uuid.UUID

+ IntegrationID uuid.UUID

+ WorkflowID uuid.UUID

+ type IntegrationAttachmentRepo interface

+ Create func(ctx context.Context, integrationID, workflowID uuid.UUID, ...) (*IntegrationAttachment, error)

+ FindByIDInOrg func(ctx context.Context, orgID, ID uuid.UUID) (*IntegrationAttachment, error)

+ List func(ctx context.Context, orgID, workflowID uuid.UUID) ([]*IntegrationAttachment, error)

+ SoftDelete func(ctx context.Context, ID uuid.UUID) error

+ type IntegrationRepo interface

+ Create func(ctx context.Context, orgID uuid.UUID, kind string, secretID string, ...) (*Integration, error)

+ FindByIDInOrg func(ctx context.Context, orgID, ID uuid.UUID) (*Integration, error)

+ List func(ctx context.Context, orgID uuid.UUID) ([]*Integration, error)

+ SoftDelete func(ctx context.Context, ID uuid.UUID) error

+ type IntegrationUseCase struct

+ func NewIntegrationUsecase(opts *NewIntegrationUsecaseOpts) *IntegrationUseCase

+ func (uc *IntegrationUseCase) AddDependencyTrack(ctx context.Context, orgID, host, apiKey string, enableProjectCreation bool) (*Integration, error)

+ func (uc *IntegrationUseCase) AttachToWorkflow(ctx context.Context, opts *AttachOpts) (*IntegrationAttachment, error)

+ func (uc *IntegrationUseCase) Delete(ctx context.Context, orgID, integrationID string) error

+ func (uc *IntegrationUseCase) Detach(ctx context.Context, orgID, attachmentID string) error

+ func (uc *IntegrationUseCase) FindByIDInOrg(ctx context.Context, orgID, id string) (*Integration, error)

+ func (uc *IntegrationUseCase) List(ctx context.Context, orgID string) ([]*Integration, error)

+ func (uc *IntegrationUseCase) ListAttachments(ctx context.Context, orgID, workflowID string) ([]*IntegrationAttachment, error)

+ type Membership struct

+ CreatedAt *time.Time

+ Current bool

+ ID uuid.UUID

+ Org *Organization

+ OrganizationID uuid.UUID

+ UpdatedAt *time.Time

+ UserID uuid.UUID

+ type MembershipRepo interface

+ Create func(ctx context.Context, orgID, userID uuid.UUID, current bool) (*Membership, error)

+ Delete func(ctx context.Context, ID uuid.UUID) error

+ FindByIDInUser func(ctx context.Context, userID, ID uuid.UUID) (*Membership, error)

+ FindByOrg func(ctx context.Context, orgID uuid.UUID) ([]*Membership, error)

+ FindByUser func(ctx context.Context, userID uuid.UUID) ([]*Membership, error)

+ SetCurrent func(ctx context.Context, ID uuid.UUID) (*Membership, error)

+ type MembershipUseCase struct

+ func NewMembershipUsecase(repo MembershipRepo, logger log.Logger) *MembershipUseCase

+ func (uc *MembershipUseCase) ByOrg(ctx context.Context, orgID string) ([]*Membership, error)

+ func (uc *MembershipUseCase) ByUser(ctx context.Context, userID string) ([]*Membership, error)

+ func (uc *MembershipUseCase) Create(ctx context.Context, orgID, userID string, current bool) (*Membership, error)

+ func (uc *MembershipUseCase) Delete(ctx context.Context, id string) error

+ func (uc *MembershipUseCase) SetCurrent(ctx context.Context, userID, membershipID string) (*Membership, error)

+ type NewIntegrationUsecaseOpts struct

+ CredsRW credentials.ReaderWriter

+ IRepo IntegrationRepo

+ IaRepo IntegrationAttachmentRepo

+ Logger log.Logger

+ WfRepo WorkflowRepo

+ type NewUserUseCaseParams struct

+ Logger log.Logger

+ MembershipUseCase *MembershipUseCase

+ OrganizationUseCase *OrganizationUseCase

+ UserRepo UserRepo

+ type OCIRepoCreateOpts struct

+ OrgID uuid.UUID

+ type OCIRepoOpts struct

+ Password string

+ Repository string

+ SecretName string

+ Username string

+ type OCIRepoUpdateOpts struct

+ ID uuid.UUID

+ type OCIRepoValidationStatus string

+ var OCIRepoValidationFailed OCIRepoValidationStatus = "Invalid"

+ var OCIRepoValidationOK OCIRepoValidationStatus = "OK"

+ func (OCIRepoValidationStatus) Values() (kinds []string)

+ type OCIRepository struct

+ CreatedAt *time.Time

+ ID string

+ OrganizationID string

+ Repo string

+ SecretName string

+ ValidatedAt *time.Time

+ ValidationStatus OCIRepoValidationStatus

+ type OCIRepositoryReader interface

+ FindByID func(ctx context.Context, ID string) (*OCIRepository, error)

+ FindMainRepo func(ctx context.Context, orgID string) (*OCIRepository, error)

+ PerformValidation func(ctx context.Context, ID string) error

+ type OCIRepositoryRepo interface

+ Create func(context.Context, *OCIRepoCreateOpts) (*OCIRepository, error)

+ Delete func(ctx context.Context, ID uuid.UUID) error

+ FindByID func(ctx context.Context, ID uuid.UUID) (*OCIRepository, error)

+ FindMainRepo func(ctx context.Context, orgID uuid.UUID) (*OCIRepository, error)

+ Update func(context.Context, *OCIRepoUpdateOpts) (*OCIRepository, error)

+ UpdateValidationStatus func(ctx context.Context, ID uuid.UUID, status OCIRepoValidationStatus) error

+ type OCIRepositoryUseCase struct

+ func NewOCIRepositoryUsecase(repo OCIRepositoryRepo, credsRW credentials.ReaderWriter, p backend.Provider, ...) *OCIRepositoryUseCase

+ func (uc *OCIRepositoryUseCase) CreateOrUpdate(ctx context.Context, orgID, repoURL, username, password string) (*OCIRepository, error)

+ func (uc *OCIRepositoryUseCase) Delete(ctx context.Context, id string) error

+ func (uc *OCIRepositoryUseCase) FindByID(ctx context.Context, id string) (*OCIRepository, error)

+ func (uc *OCIRepositoryUseCase) FindMainRepo(ctx context.Context, orgID string) (*OCIRepository, error)

+ func (uc *OCIRepositoryUseCase) PerformValidation(ctx context.Context, id string) (err error)

+ type OrgMetricsRepo interface

+ RunsByRunnerTypeTotal func(ctx context.Context, orgID uuid.UUID, timeWindow time.Duration) (map[string]int32, error)

+ RunsByStatusTotal func(ctx context.Context, orgID uuid.UUID, timeWindow time.Duration) (map[string]int32, error)

+ RunsTotal func(ctx context.Context, orgID uuid.UUID, timeWindow time.Duration) (int32, error)

+ TopWorkflowsByRunsCount func(ctx context.Context, orgID uuid.UUID, numWorkflows int, ...) ([]*TopWorkflowsByRunsCountItem, error)

+ type OrgMetricsUseCase struct

+ func NewOrgMetricsUseCase(r OrgMetricsRepo, l log.Logger) (*OrgMetricsUseCase, error)

+ func (uc *OrgMetricsUseCase) RunsTotal(ctx context.Context, orgID string, timeWindow time.Duration) (int32, error)

+ func (uc *OrgMetricsUseCase) RunsTotalByRunnerType(ctx context.Context, orgID string, timeWindow time.Duration) (map[string]int32, error)

+ func (uc *OrgMetricsUseCase) RunsTotalByStatus(ctx context.Context, orgID string, timeWindow time.Duration) (map[string]int32, error)

+ func (uc *OrgMetricsUseCase) TopWorkflowsByRunsCount(ctx context.Context, orgID string, numWorkflows int, timeWindow time.Duration) ([]*TopWorkflowsByRunsCountItem, error)

+ type Organization struct

+ CreatedAt *time.Time

+ ID string

+ Name string

+ type OrganizationRepo interface

+ Create func(ctx context.Context, name string) (*Organization, error)

+ Delete func(ctx context.Context, ID uuid.UUID) error

+ FindByID func(ctx context.Context, orgID uuid.UUID) (*Organization, error)

+ type OrganizationUseCase struct

+ func NewOrganizationUsecase(repo OrganizationRepo, repoUC *OCIRepositoryUseCase, iUC *IntegrationUseCase, ...) *OrganizationUseCase

+ func (uc *OrganizationUseCase) Create(ctx context.Context, name string) (*Organization, error)

+ func (uc *OrganizationUseCase) Delete(ctx context.Context, id string) error

+ func (uc *OrganizationUseCase) FindByID(ctx context.Context, id string) (*Organization, error)

+ type RobotAccount struct

+ CreatedAt *time.Time

+ ID uuid.UUID

+ JWT string

+ Name string

+ RevokedAt *time.Time

+ WorkflowID uuid.UUID

+ type RobotAccountRepo interface

+ Create func(ctx context.Context, name string, workflowID uuid.UUID) (*RobotAccount, error)

+ FindByID func(ctx context.Context, ID uuid.UUID) (*RobotAccount, error)

+ List func(ctx context.Context, workflowID uuid.UUID, includeRevoked bool) ([]*RobotAccount, error)

+ Revoke func(ctx context.Context, orgID, ID uuid.UUID) error

+ type RobotAccountUseCase struct

+ func NewRootAccountUseCase(robotAccountRepo RobotAccountRepo, workflowRepo WorkflowRepo, conf *conf.Auth, ...) *RobotAccountUseCase

+ func (uc *RobotAccountUseCase) Create(ctx context.Context, name string, orgID, workflowID string) (*RobotAccount, error)

+ func (uc *RobotAccountUseCase) FindByID(ctx context.Context, id string) (*RobotAccount, error)

+ func (uc *RobotAccountUseCase) List(ctx context.Context, orgID, workflowID string, includeRevoked bool) ([]*RobotAccount, error)

+ func (uc *RobotAccountUseCase) Revoke(ctx context.Context, orgID, id string) error

+ type TopWorkflowsByRunsCountItem struct

+ ByStatus map[string]int32

+ Total int32

+ Workflow *Workflow

+ type User struct

+ CreatedAt *time.Time

+ Email string

+ ID string

+ type UserOrgFinder interface

+ CurrentOrg func(ctx context.Context, userID string) (*Organization, error)

+ FindByID func(ctx context.Context, userID string) (*User, error)

+ type UserRepo interface

+ CreateByEmail func(ctx context.Context, email string) (*User, error)

+ Delete func(ctx context.Context, userID uuid.UUID) error

+ FindByEmail func(ctx context.Context, email string) (*User, error)

+ FindByID func(ctx context.Context, userID uuid.UUID) (*User, error)

+ type UserUseCase struct

+ func NewUserUseCase(opts *NewUserUseCaseParams) *UserUseCase

+ func (uc *UserUseCase) CurrentOrg(ctx context.Context, userID string) (*Organization, error)

+ func (uc *UserUseCase) DeleteUser(ctx context.Context, userID string) error

+ func (uc *UserUseCase) FindByID(ctx context.Context, userID string) (*User, error)

+ func (uc *UserUseCase) FindOrCreateByEmail(ctx context.Context, email string) (*User, error)

+ type Workflow struct

+ ContractID uuid.UUID

+ CreatedAt *time.Time

+ ID uuid.UUID

+ LastRun *WorkflowRun

+ Name string

+ OrgID uuid.UUID

+ Project string

+ RunsCounter int

+ Team string

+ type WorkflowContract struct

+ CreatedAt *time.Time

+ ID uuid.UUID

+ LatestRevision int

+ Name string

+ WorkflowIDs []string

+ type WorkflowContractRepo interface

+ Create func(ctx context.Context, opts *ContractCreateOpts) (*WorkflowContract, error)

+ Describe func(ctx context.Context, orgID, contractID uuid.UUID, revision int) (*WorkflowContractWithVersion, error)

+ FindByIDInOrg func(ctx context.Context, orgID, ID uuid.UUID) (*WorkflowContract, error)

+ FindVersionByID func(ctx context.Context, versionID uuid.UUID) (*WorkflowContractVersion, error)

+ List func(ctx context.Context, orgID uuid.UUID) ([]*WorkflowContract, error)

+ SoftDelete func(ctx context.Context, contractID uuid.UUID) error

+ Update func(ctx context.Context, opts *ContractUpdateOpts) (*WorkflowContractWithVersion, error)

+ type WorkflowContractUseCase struct

+ func NewWorkflowContractUsecase(repo WorkflowContractRepo, logger log.Logger) *WorkflowContractUseCase

+ func (uc *WorkflowContractUseCase) Create(ctx context.Context, orgID, name string, schema *schemav1.CraftingSchema) (*WorkflowContract, error)

+ func (uc *WorkflowContractUseCase) Delete(ctx context.Context, orgID, contractID string) error

+ func (uc *WorkflowContractUseCase) Describe(ctx context.Context, orgID, contractID string, revision int) (*WorkflowContractWithVersion, error)

+ func (uc *WorkflowContractUseCase) FindByIDInOrg(ctx context.Context, orgID, contractID string) (*WorkflowContract, error)

+ func (uc *WorkflowContractUseCase) FindVersionByID(ctx context.Context, versionID string) (*WorkflowContractVersion, error)

+ func (uc *WorkflowContractUseCase) List(ctx context.Context, orgID string) ([]*WorkflowContract, error)

+ func (uc *WorkflowContractUseCase) Update(ctx context.Context, orgID, contractID, name string, ...) (*WorkflowContractWithVersion, error)

+ type WorkflowContractVersion struct

+ BodyV1 *schemav1.CraftingSchema

+ CreatedAt *time.Time

+ ID uuid.UUID

+ Revision int

+ type WorkflowContractWithVersion struct

+ Contract *WorkflowContract

+ Version *WorkflowContractVersion

+ type WorkflowRepo interface

+ Create func(context.Context, *CreateOpts) (*Workflow, error)

+ FindByID func(ctx context.Context, workflowID uuid.UUID) (*Workflow, error)

+ GetOrgScoped func(ctx context.Context, orgID, workflowID uuid.UUID) (*Workflow, error)

+ IncRunsCounter func(ctx context.Context, workflowID uuid.UUID) error

+ List func(ctx context.Context, orgID uuid.UUID) ([]*Workflow, error)

+ SoftDelete func(ctx context.Context, workflowID uuid.UUID) error

+ type WorkflowRun struct

+ AttestationID uuid.UUID

+ AttestationRef *AttestationRef

+ ContractVersionID uuid.UUID

+ CreatedAt *time.Time

+ FinishedAt *time.Time

+ ID uuid.UUID

+ Reason string

+ RunURL string

+ RunnerType string

+ State string

+ Workflow *Workflow

+ type WorkflowRunCreateOpts struct

+ ContractRevisionUUID uuid.UUID

+ RobotaccountID string

+ RunnerRunURL string

+ RunnerType string

+ WorkflowID string

+ type WorkflowRunExpirerOpts struct

+ CheckInterval time.Duration

+ ExpirationWindow time.Duration

+ type WorkflowRunExpirerUseCase struct

+ func NewWorkflowRunExpirerUseCase(wfrRepo WorkflowRunRepo, logger log.Logger) *WorkflowRunExpirerUseCase

+ func (uc *WorkflowRunExpirerUseCase) ExpirationSweep(ctx context.Context, olderThan time.Time) error

+ func (uc *WorkflowRunExpirerUseCase) Run(ctx context.Context, opts *WorkflowRunExpirerOpts)

+ type WorkflowRunRepo interface

+ Create func(ctx context.Context, workflowID, robotaccountID, contractVersion uuid.UUID, ...) (*WorkflowRun, error)

+ Expire func(ctx context.Context, id uuid.UUID) error

+ FindByID func(ctx context.Context, ID uuid.UUID) (*WorkflowRun, error)

+ FindByIDInOrg func(ctx context.Context, orgID, ID uuid.UUID) (*WorkflowRun, error)

+ List func(ctx context.Context, orgID, workflowID uuid.UUID, p *pagination.Options) ([]*WorkflowRun, string, error)

+ ListNotFinishedOlderThan func(ctx context.Context, olderThan time.Time) ([]*WorkflowRun, error)

+ MarkAsFinished func(ctx context.Context, ID uuid.UUID, status WorkflowRunStatus, reason string) error

+ SaveAttestationRef func(ctx context.Context, ID uuid.UUID, ref *AttestationRef) error

+ type WorkflowRunStatus string

+ const WorkflowRunCancelled

+ const WorkflowRunError

+ const WorkflowRunExpired

+ const WorkflowRunInitialized

+ const WorkflowRunSuccess

+ func (WorkflowRunStatus) Values() (kinds []string)

+ type WorkflowRunUseCase struct

+ func NewWorkflowRunUsecase(wfrRepo WorkflowRunRepo, wfRepo WorkflowRepo, logger log.Logger) (*WorkflowRunUseCase, error)

+ func (uc *WorkflowRunUseCase) AssociateAttestation(ctx context.Context, id string, ref *AttestationRef) error

+ func (uc *WorkflowRunUseCase) Create(ctx context.Context, opts *WorkflowRunCreateOpts) (*WorkflowRun, error)

+ func (uc *WorkflowRunUseCase) ExistsInWorkflow(ctx context.Context, workflowID, id string) (bool, error)

+ func (uc *WorkflowRunUseCase) List(ctx context.Context, orgID, workflowID string, p *pagination.Options) ([]*WorkflowRun, string, error)

+ func (uc *WorkflowRunUseCase) MarkAsFinished(ctx context.Context, id string, status WorkflowRunStatus, reason string) error

+ func (uc *WorkflowRunUseCase) View(ctx context.Context, orgID, runID string) (*WorkflowRun, error)

+ type WorkflowRunWithContract struct

+ type WorkflowUseCase struct

+ func NewWorkflowUsecase(wfr WorkflowRepo, schemaUC *WorkflowContractUseCase, logger log.Logger) *WorkflowUseCase

+ func (uc *WorkflowUseCase) Create(ctx context.Context, opts *CreateOpts) (*Workflow, error)

+ func (uc *WorkflowUseCase) Delete(ctx context.Context, orgID, workflowID string) error

+ func (uc *WorkflowUseCase) FindByID(ctx context.Context, workflowID string) (*Workflow, error)

+ func (uc *WorkflowUseCase) FindByIDInOrg(ctx context.Context, orgID, workflowID string) (*Workflow, error)

+ func (uc *WorkflowUseCase) IncRunsCounter(ctx context.Context, workflowID string) error

+ func (uc *WorkflowUseCase) List(ctx context.Context, orgID string) ([]*Workflow, error)