biz

Jan 3, 2025

Changes in this version

type Organization

+ BlockOnPolicyViolation bool

Dec 19, 2024

Changes in this version

+ type CASServerDefaultOpts struct

+ DefaultEntryMaxSize string

Dec 17, 2024

Changes in this version

type WorkflowContractUseCase

+ func (uc *WorkflowContractUseCase) ValidatePolicyAttachment(providerName string, att *schemav1.PolicyAttachment, token string) error

Dec 14, 2024

Changes in this version

type CASBackendUseCase

+ MaxBytesDefault int64

type UserOrgFinder

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

type UserUseCase

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

Dec 9, 2024

Changes in this version

+ type AuditorUseCase struct

+ func NewAuditorUseCase(p *auditor.AuditLogPublisher, logger log.Logger) *AuditorUseCase

+ func (uc *AuditorUseCase) Dispatch(ctx context.Context, entry auditor.LogEntry, orgID *uuid.UUID)

type NewUserUseCaseParams

+ AuditorUseCase *AuditorUseCase

Dec 5, 2024

Changes in this version

type ProjectVersion

+ TotalWorkflowRuns int

Nov 22, 2024

Changes in this version

+ type ContractQueryOpt func(opts *ContractQueryOpts)

+ func WithoutReferences() ContractQueryOpt

+ type ContractQueryOpts struct

+ SkipGetReferences bool

Nov 15, 2024

Changes in this version

type MembershipRepo

+ FindByOrgNameAndUser func(ctx context.Context, orgName string, userID uuid.UUID) (*Membership, error)

type MembershipUseCase

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

+ type WorkflowListOpts struct

+ WorkflowActiveWindow *TimeWindow

+ WorkflowDescription string

+ WorkflowName string

+ WorkflowProjectNames []string

+ WorkflowPublic *bool

+ WorkflowRunLastStatus WorkflowRunStatus

+ WorkflowRunRunnerType string

+ WorkflowTeam string

Nov 5, 2024

Changes in this version

type ProjectUseCase

+ func (uc *ProjectUseCase) Create(ctx context.Context, orgID, name string) (*Project, error)

type ProjectVersion

+ Prerelease bool

type ProjectVersionRepo

+ Create func(ctx context.Context, projectID uuid.UUID, version string, prerelease bool) (*ProjectVersion, error)

+ Update func(ctx context.Context, versionID uuid.UUID, updates *ProjectVersionUpdateOpts) (*ProjectVersion, error)

+ type ProjectVersionUpdateOpts struct

+ Prerelease *bool

type ProjectVersionUseCase

+ func (uc *ProjectVersionUseCase) Create(ctx context.Context, projectID, version string, prerelease bool) (*ProjectVersion, error)

+ func (uc *ProjectVersionUseCase) UpdateReleaseStatus(ctx context.Context, version string, isRelease bool) (*ProjectVersion, error)

type ProjectsRepo

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

Nov 4, 2024

Changes in this version

type RunListFilters

+ VersionID *uuid.UUID

Oct 29, 2024

Changes in this version

+ func ValidateVersion(version string) error

+ type EntityRef struct

+ ID string

+ Name string

+ type Project struct

+ CreatedAt *time.Time

+ ID uuid.UUID

+ Name string

+ OrgID uuid.UUID

+ UpdatedAt *time.Time

+ type ProjectUseCase struct

+ func NewProjectsUseCase(logger log.Logger, projectsRepository ProjectsRepo) *ProjectUseCase

+ func (uc *ProjectUseCase) FindProjectByReference(ctx context.Context, orgID string, reference *EntityRef) (*Project, error)

+ type ProjectVersion struct

+ CreatedAt *time.Time

+ ID uuid.UUID

+ Version string

+ type ProjectVersionRepo interface

+ FindByProjectAndVersion func(ctx context.Context, projectID uuid.UUID, version string) (*ProjectVersion, error)

+ type ProjectVersionUseCase struct

+ func NewProjectVersionUseCase(repo ProjectVersionRepo, l log.Logger) *ProjectVersionUseCase

+ func (uc *ProjectVersionUseCase) FindByProjectAndVersion(ctx context.Context, projectID string, version string) (*ProjectVersion, error)

+ type ProjectsRepo interface

+ FindProjectByOrgIDAndID func(ctx context.Context, orgID uuid.UUID, projectID uuid.UUID) (*Project, error)

+ FindProjectByOrgIDAndName func(ctx context.Context, orgID uuid.UUID, projectName string) (*Project, error)

type Workflow

+ ProjectID uuid.UUID

type WorkflowRun

+ ProjectVersion *ProjectVersion

type WorkflowRunCreateOpts

+ ProjectVersion string

type WorkflowRunRepoCreateOpts

+ ProjectVersion string

Oct 16, 2024

Changes in this version

type WorkflowContract

+ WorkflowRefs []*WorkflowRef

+ type WorkflowRef struct

+ ID uuid.UUID

+ Name string

+ ProjectName string

Oct 10, 2024

Changes in this version

type WorkflowRepo

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

Oct 8, 2024

Changes in this version

+ type RemotePolicyGroup struct

+ PolicyGroup *schemav1.PolicyGroup

+ ProviderRef *policies.PolicyReference

type WorkflowContractUseCase

+ func (uc *WorkflowContractUseCase) GetPolicyGroup(providerName, groupName, token string) (*RemotePolicyGroup, error)

Sep 2, 2024

Changes in this version

+ type RemotePolicy struct

+ Policy *schemav1.Policy

+ ProviderRef *policies.PolicyReference

Aug 20, 2024

Changes in this version

+ var EmptyDefaultContract = &Contract

+ type Contract struct

+ Format ContractRawFormat

+ Raw []byte

+ Schema *schemav1.CraftingSchema

+ func SchemaToRawContract(contract *schemav1.CraftingSchema) (*Contract, error)

+ func UnmarshalAndValidateRawContract(raw []byte, format ContractRawFormat) (*Contract, error)

type ContractCreateOpts

+ Contract *Contract

+ type ContractRawFormat string

+ const ContractRawFormatCUE

+ const ContractRawFormatJSON

+ const ContractRawFormatYAML

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

type ContractUpdateOpts

+ Contract *Contract

type WorkflowContractCreateOpts

+ RawSchema []byte

type WorkflowContractUpdateOpts

+ RawSchema []byte

type WorkflowContractUseCase

+ func (uc *WorkflowContractUseCase) ValidateContractPolicies(rawSchema []byte, token string) error

type WorkflowContractVersion

+ Schema *Contract

Aug 14, 2024

Changes in this version

type WorkflowContractUseCase

+ func (uc *WorkflowContractUseCase) GetPolicy(providerName, policyName, token string) (*schemav1.Policy, error)

Aug 13, 2024

Changes in this version

+ func IsErrAlreadyExists(err error) bool

type ErrAlreadyExists

+ func NewErrAlreadyExists(err error) ErrAlreadyExists

+ func NewErrAlreadyExistsStr(errMsg string) ErrAlreadyExists

+ func (e ErrAlreadyExists) Error() string

Jul 29, 2024

Changes in this version

+ type PromObservable interface

+ ObserveAttestationIfNeeded func(ctx context.Context, run *WorkflowRun, status WorkflowRunStatus) bool

type PrometheusUseCase

+ func (uc *PrometheusUseCase) ObserveAttestationIfNeeded(ctx context.Context, run *WorkflowRun, status WorkflowRunStatus) bool

type WorkflowRunExpirerUseCase

+ PromObservable PromObservable

Jul 25, 2024

Changes in this version

+ func IsErrAttestationStateConflict(err error) bool

+ func NewErrAttestationStateConflict(got, want string) error

type AttestationState

+ Digest string

+ type AttestationStateSaveOpts struct

+ BaseDigest string

+ type ErrAttestationStateConflict struct

+ func (e *ErrAttestationStateConflict) Error() string

+ type SaveOption func(*AttestationStateSaveOpts)

+ func WithAttStateBaseDigest(digest string) SaveOption

Jul 18, 2024

Changes in this version

type OrgMetricsUseCase

+ func (uc *OrgMetricsUseCase) GetLastWorkflowStatusByRun(ctx context.Context, orgName string) ([]*prometheuscollector.WorkflowLastStatusByRunReport, error)

+ type PrometheusUseCase struct

+ func NewPrometheusUseCase(conf []*conf.PrometheusIntegrationSpec, orgUseCase *OrganizationUseCase, ...) *PrometheusUseCase

+ func (uc *PrometheusUseCase) GetRegistryByOrganizationName(orgName string) *registry.PrometheusRegistry

+ func (uc *PrometheusUseCase) OrganizationHasRegistry(orgName string) bool

Jul 17, 2024

Changes in this version

type APIToken

+ OrganizationName string

Jul 1, 2024

Changes in this version

type APITokenRepo

+ FindByNameInOrg func(ctx context.Context, orgID uuid.UUID, name string) (*APIToken, error)

Jul 1, 2024

Changes in this version

+ func IsErrInvalidTimeWindow(err error) bool

type APITokenRepo

+ FindByName func(ctx context.Context, name string) (*APIToken, error)

type APITokenUseCase

+ func (uc *APITokenUseCase) FindByNameInOrg(ctx context.Context, orgID, name string) (*APIToken, error)

type CASBackendCreateOpts

+ Name string

type CASBackendRepo

+ FindByNameInOrg func(ctx context.Context, OrgID uuid.UUID, name string) (*CASBackend, error)

type CASBackendUseCase

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

+ type ErrInvalidTimeWindow struct

+ func NewErrInvalidTimeWindow(err error) ErrInvalidTimeWindow

+ func NewErrInvalidTimeWindowStr(errMsg string) ErrInvalidTimeWindow

+ func (e ErrInvalidTimeWindow) Error() string

type IntegrationRepo

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

type IntegrationUseCase

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

+ type TimeWindow struct

+ From time.Time

+ To time.Time

+ func (tw *TimeWindow) Validate() error

type Workflow

+ ContractName string

type WorkflowContract

+ WorkflowNames []string

type WorkflowContractRepo

+ FindByNameInOrg func(ctx context.Context, orgID uuid.UUID, name string) (*WorkflowContract, error)

type WorkflowContractUseCase

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

type WorkflowCreateOpts

+ ContractName string

Jun 20, 2024

Changes in this version

type CASBackendCreateOpts

+ MaxBytes int64

type CASCredsOpts

+ MaxBytes int64

Jun 17, 2024

Changes in this version

+ func PbRoleToBiz(r pb.MembershipRole) authz.Role

type NewUserUseCaseParams

+ OnboardingConfig []*conf.OnboardingSpec

type OrganizationRepo

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

type OrganizationUseCase

+ func (uc *OrganizationUseCase) AutoOnboardOrganizations(ctx context.Context, userID string) error

Jun 11, 2024

Changes in this version

+ const CASBackendDefaultMaxBytes

+ const CASBackendInline

+ const CASBackendInlineDefaultMaxBytes

+ const RandomNameMaxTries

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

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

+ func IsErrInvalidUUID(err error) bool

+ func IsErrNotImplemented(err error) bool

+ func IsErrUnauthorized(err error) bool

+ func IsErrValidation(err error) bool

+ func IsNotFound(err error) bool

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

+ func ValidateIsDNS1123(name string) error

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

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

+ type APIToken struct

+ CreatedAt *time.Time

+ Description string

+ ExpiresAt *time.Time

+ ID uuid.UUID

+ JWT string

+ Name string

+ OrganizationID uuid.UUID

+ RevokedAt *time.Time

+ type APITokenRepo interface

+ Create func(ctx context.Context, name string, 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 APITokenSyncerUseCase struct

+ func NewAPITokenSyncerUseCase(tokenUC *APITokenUseCase) *APITokenSyncerUseCase

+ func (suc *APITokenSyncerUseCase) SyncPolicies() error

+ type APITokenUseCase struct

+ DefaultAuthzPolicies []*authz.Policy

+ func NewAPITokenUseCase(apiTokenRepo APITokenRepo, conf *conf.Auth, authzE *authz.Enforcer, ...) (*APITokenUseCase, error)

+ func (uc *APITokenUseCase) Create(ctx context.Context, name string, description *string, ...) (*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 AttachOpts struct

+ AttachmentConfig *structpb.Struct

+ FanOutIntegration sdk.FanOut

+ IntegrationID string

+ OrgID string

+ WorkflowID string

+ type Attestation struct

+ Digest string

+ Envelope *dsse.Envelope

+ 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

+ type AttestationUseCase struct

+ func NewAttestationUseCase(client CASClient, logger log.Logger) *AttestationUseCase

+ func (uc *AttestationUseCase) UploadToCAS(ctx context.Context, envelope *dsse.Envelope, backend *CASBackend, ...) (*cr_v1.Hash, error)

+ type ByStatusCount struct

+ Count int32

+ Status string

+ type CASBackend struct

+ CreatedAt *time.Time

+ Default bool

+ Description string

+ Fallback bool

+ ID uuid.UUID

+ Inline bool

+ Limits *CASBackendLimits

+ Location string

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

+ Name 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, name, 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, name, description string, creds any, ...) (*CASBackend, error)

+ type CASBackendValidationStatus string

+ var CASBackendValidationFailed CASBackendValidationStatus = "Invalid"

+ var CASBackendValidationOK CASBackendValidationStatus = "OK"

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

+ type CASClient interface

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

+ type CASClientOpts func(u *CASClientUseCase)

+ func WithClientFactory(f CASClientFactory) CASClientOpts

+ type CASClientUseCase struct

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

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

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

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

+ type CASCredentialsUseCase struct

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

+ func (uc *CASCredentialsUseCase) GenerateTemporaryCredentials(backendRef *CASCredsOpts) (string, error)

+ type CASCredsOpts struct

+ BackendType string

+ Role robotaccount.Role

+ SecretPath string

+ type CASDownloader interface

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

+ 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) FindCASMappingForDownloadByOrg(ctx context.Context, digest string, orgs []string) (*CASMapping, error)

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

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

+ type CASUploader interface

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

+ type ContractCreateOpts struct

+ ContractBody []byte

+ Description *string

+ Name string

+ OrgID uuid.UUID

+ type ContractUpdateOpts struct

+ ContractBody []byte

+ Description *string

+ type CreateOpt func(*createOptions)

+ func WithCreateInlineBackend() CreateOpt

+ type DayRunsCount struct

+ Date time.Time

+ Totals []*ByStatusCount

+ type ErrAmbiguousReferrer struct

+ func (e ErrAmbiguousReferrer) Error() 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 ErrNotImplemented struct

+ func NewErrNotImplemented(msg string) ErrNotImplemented

+ func (e ErrNotImplemented) Error() string

+ type ErrUnauthorized struct

+ func NewErrUnauthorized(err error) ErrUnauthorized

+ func NewErrUnauthorizedStr(errMsg string) ErrUnauthorized

+ func (e ErrUnauthorized) Error() string

+ type ErrValidation struct

+ func NewErrValidation(err error) ErrValidation

+ func NewErrValidationStr(errMsg string) ErrValidation

+ func (e ErrValidation) Error() string

+ type GetFromRootFilter func(*GetFromRootFilters)

+ type GetFromRootFilters struct

+ Public *bool

+ RootKind *string

+ type Integration struct

+ Config []byte

+ CreatedAt *time.Time

+ Description string

+ ID uuid.UUID

+ Kind string

+ Name string

+ SecretName string

+ type IntegrationAndAttachment struct

+ type IntegrationAttachment struct

+ Config []byte

+ CreatedAt *time.Time

+ ID uuid.UUID

+ IntegrationID uuid.UUID

+ WorkflowID uuid.UUID

+ type IntegrationAttachmentRepo interface

+ Create func(ctx context.Context, integrationID, workflowID uuid.UUID, config []byte) (*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 IntegrationCreateOpts struct

+ Config []byte

+ Description string

+ Kind string

+ Name string

+ OrgID uuid.UUID

+ SecretName string

+ type IntegrationRepo interface

+ Create func(ctx context.Context, opts *IntegrationCreateOpts) (*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) 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)

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

+ type InvitationCreateOpt func(*invitationCreateOpts)

+ func WithInvitationRole(r authz.Role) InvitationCreateOpt

+ type Membership struct

+ CreatedAt *time.Time

+ Current bool

+ ID uuid.UUID

+ Org *Organization

+ OrganizationID uuid.UUID

+ Role authz.Role

+ UpdatedAt *time.Time

+ User *User

+ type MembershipCreateOpt func(*membershipCreateOpts)

+ func WithCurrentMembership() MembershipCreateOpt

+ func WithMembershipRole(r authz.Role) MembershipCreateOpt

+ type MembershipRepo interface

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

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

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

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

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

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

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

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

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

+ type MembershipUseCase struct

+ func NewMembershipUseCase(repo MembershipRepo, orgUC *OrganizationUseCase, 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, opts ...MembershipCreateOpt) (*Membership, error)

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

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

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

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

+ func (uc *MembershipUseCase) UpdateRole(ctx context.Context, orgID, userID, membershipID string, role authz.Role) (*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 OrgInvitation struct

+ CreatedAt *time.Time

+ ID uuid.UUID

+ Org *Organization

+ ReceiverEmail string

+ Role authz.Role

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

+ ListByOrg func(ctx context.Context, org 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) ListByOrg(ctx context.Context, orgID string) ([]*OrgInvitation, error)

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

+ type OrgMetricsRepo interface

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

+ 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) DailyRunsCount(ctx context.Context, orgID string, workflowID *string, ...) ([]*DayRunsCount, 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)

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

+ type OrganizationUseCase struct

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

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

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

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

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

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

+ type Referrer struct

+ Annotations map[string]string

+ Digest string

+ Downloadable bool

+ InPublicWorkflow bool

+ Kind string

+ Metadata map[string]string

+ References []*Referrer

+ func (r *Referrer) MapID() string

+ type ReferrerRepo interface

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

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

+ Save func(ctx context.Context, input []*Referrer, workflowID uuid.UUID) error

+ type ReferrerUseCase struct

+ func NewReferrerUseCase(repo ReferrerRepo, wfRepo WorkflowRepo, mRepo MembershipRepo, ...) (*ReferrerUseCase, error)

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

+ func (s *ReferrerUseCase) GetFromRoot(ctx context.Context, digest, rootKind string, orgIDs []uuid.UUID) (*StoredReferrer, error)

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

+ func (s *ReferrerUseCase) GetFromRootUser(ctx context.Context, digest, rootKind, userID string) (*StoredReferrer, 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 RunListFilters struct

+ Status WorkflowRunStatus

+ WorkflowID uuid.UUID

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

+ type StoredReferrer struct

+ CreatedAt *time.Time

+ ID uuid.UUID

+ OrgIDs []uuid.UUID

+ References []*StoredReferrer

+ WorkflowIDs []uuid.UUID

+ type TopWorkflowsByRunsCountItem struct

+ ByStatus map[string]int32

+ Total int32

+ Workflow *Workflow

+ type User struct

+ CreatedAt *time.Time

+ Email string

+ ID string

+ type UserOrgFinder interface

+ CurrentMembership func(ctx context.Context, userID string) (*Membership, 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) CurrentMembership(ctx context.Context, userID string) (*Membership, 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

+ ContractRevisionLatest int

+ CreatedAt *time.Time

+ Description string

+ ID uuid.UUID

+ LastRun *WorkflowRun

+ Name string

+ OrgID uuid.UUID

+ Project string

+ Public bool

+ RunsCounter int

+ Team string

+ type WorkflowContract struct

+ CreatedAt *time.Time

+ Description string

+ ID uuid.UUID

+ LatestRevision int

+ Name string

+ WorkflowIDs []string

+ type WorkflowContractCreateOpts struct

+ AddUniquePrefix bool

+ Description *string

+ Name string

+ OrgID string

+ Schema *schemav1.CraftingSchema

+ 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, orgID uuid.UUID, name string, opts *ContractUpdateOpts) (*WorkflowContractWithVersion, error)

+ type WorkflowContractUpdateOpts struct

+ Description *string

+ Schema *schemav1.CraftingSchema

+ type WorkflowContractUseCase struct

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

+ func (uc *WorkflowContractUseCase) Create(ctx context.Context, opts *WorkflowContractCreateOpts) (*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, name string, opts *WorkflowContractUpdateOpts) (*WorkflowContractWithVersion, error)

+ type WorkflowContractVersion struct

+ BodyV1 *schemav1.CraftingSchema

+ CreatedAt *time.Time

+ ID uuid.UUID

+ Revision int

+ type WorkflowContractWithVersion struct

+ Contract *WorkflowContract

+ Version *WorkflowContractVersion

+ type WorkflowCreateOpts struct

+ ContractID string

+ Description string

+ Name string

+ OrgID string

+ Project string

+ Public bool

+ Team string

+ type WorkflowRepo interface

+ Create func(ctx context.Context, opts *WorkflowCreateOpts) (*Workflow, error)

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

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

+ GetOrgScopedByName func(ctx context.Context, orgID uuid.UUID, workflowName string) (*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

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

+ type WorkflowRun struct

+ Attestation *Attestation

+ CASBackends []*CASBackend

+ ContractRevisionLatest int

+ ContractRevisionUsed int

+ 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

+ CASBackendID uuid.UUID

+ ContractRevision *WorkflowContractWithVersion

+ 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, opts *WorkflowRunRepoCreateOpts) (*WorkflowRun, error)

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

+ FindByAttestationDigest func(ctx context.Context, digest string) (*WorkflowRun, 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 uuid.UUID, f *RunListFilters, ...) ([]*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

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

+ type WorkflowRunRepoCreateOpts struct

+ Backends []uuid.UUID

+ LatestRevision int

+ RunURL string

+ RunnerType string

+ SchemaVersionID uuid.UUID

+ UsedRevision int

+ WorkflowID uuid.UUID

+ 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) Create(ctx context.Context, opts *WorkflowRunCreateOpts) (*WorkflowRun, error)

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

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

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

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

+ func (uc *WorkflowRunUseCase) List(ctx context.Context, orgID string, f *RunListFilters, ...) ([]*WorkflowRun, string, error)

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

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

+ type WorkflowRunWithContract struct

+ type WorkflowUpdateOpts struct

+ ContractID *string

+ Description *string

+ Project *string

+ Public *bool

+ Team *string

+ type WorkflowUseCase struct

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

+ func (uc *WorkflowUseCase) Create(ctx context.Context, opts *WorkflowCreateOpts) (*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) FindByNameInOrg(ctx context.Context, orgID, workflowName string) (*Workflow, error)

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

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

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