biz

Dec 17, 2025

Changes in this version

type Organization

+ RestrictContractCreationToOrgAdmins bool

type WorkflowCreateOpts

+ OrgRestrictContractCreationToAdmins bool

+ UserIsOrgAdmin bool

Dec 5, 2025

Changes in this version

type WorkflowRunUseCase

+ func (uc *WorkflowRunUseCase) VerifyRun(ctx context.Context, run *WorkflowRun) (*VerificationResult, error)

Nov 20, 2025

Changes in this version

type WorkflowContractVersion

+ Description string

Nov 17, 2025

Changes in this version

+ type AuthzUseCase struct

+ RestrictOrgCreation bool

+ func NewAuthzUseCase(config *AuthzUseCaseConfig) *AuthzUseCase

+ func (e *AuthzUseCase) Enforce(ctx context.Context, sub string, p *authz.Policy) (ok bool, err error)

+ type AuthzUseCaseConfig struct

+ APITokenRepo APITokenRepo

+ CasbinEnforcer *authz.CasbinEnforcer

+ Logger log.Logger

+ RestrictOrgCreation bool

type RunListFilters

+ PolicyViolationsFilter *bool

type WorkflowRun

+ HasPolicyViolations *bool

type WorkflowRunRepo

+ UpdatePolicyViolationsStatus func(ctx context.Context, ID uuid.UUID, hasPolicyViolations bool) error

Nov 13, 2025

Changes in this version

type WorkflowRunCreateOpts

+ RequireExistingVersion bool

type WorkflowRunRepoCreateOpts

+ RequireExistingVersion bool

Nov 11, 2025

Changes in this version

+ var ErrImplicitWorkflowCreationDisabled = errors.New("implicit workflow and project creation is disabled for this organization")

type Organization

+ PreventImplicitWorkflowCreation bool

type WorkflowCreateOpts

+ ImplicitCreation bool

Nov 10, 2025

Changes in this version

type APIToken

+ Policies []*authz.Policy

type CASBackendCheckerOpts

+ InitialDelay time.Duration

Oct 28, 2025

Changes in this version

type Contract

+ Schemav2 *schemav1.CraftingSchemaV2

Oct 24, 2025

Changes in this version

+ type ReferrerSharedIndexConfig struct

+ AllowedOrgs []string

+ Enabled bool

+ func NewIndexConfig(cfg *conf.ReferrerSharedIndex) (*ReferrerSharedIndexConfig, error)

Oct 13, 2025

Changes in this version

type CASBackend

+ UpdatedAt *time.Time

Oct 6, 2025

Changes in this version

+ const MinCASBackendMaxBytes

type CASBackendUpdateOpts

+ MaxBytes *int64

Oct 2, 2025

Changes in this version

type ProjectVersion

+ LastRunAt *time.Time

Sep 4, 2025

Changes in this version

+ var CASBackendInlineDescription = "Embed artifacts content in the attestation (fallback)"

Sep 2, 2025

Changes in this version

type CASBackend

+ ValidationError *string

+ type CASBackendChecker struct

+ func NewCASBackendChecker(logger log.Logger, casBackendRepo CASBackendRepo, ...) *CASBackendChecker

+ func (c *CASBackendChecker) CheckAllBackends(ctx context.Context, onlyDefaults bool) error

+ func (c *CASBackendChecker) Start(ctx context.Context, opts *CASBackendCheckerOpts)

+ type CASBackendCheckerOpts struct

+ CheckInterval time.Duration

+ OnlyDefaults bool

+ ValidationTimeout time.Duration

type CASBackendOpts

+ ValidationError *string

+ ValidationStatus CASBackendValidationStatus

type CASBackendRepo

+ ListBackends func(ctx context.Context, onlyDefaults bool) ([]*CASBackend, error)

Aug 12, 2025

Changes in this version

type MembershipUseCase

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

type Organization

+ UpdatedAt *time.Time

type OrganizationUseCase

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

type ProjectVersion

+ ProjectID uuid.UUID

type User

+ UpdatedAt *time.Time

type WorkflowContract

+ UpdatedAt *time.Time

+ type WorkflowRunRepoCreateResult struct

+ Project *Project

+ Run *WorkflowRun

+ VersionCreated bool

Aug 8, 2025

Changes in this version

type Organization

+ PoliciesAllowedHostnames []string

Aug 4, 2025

Changes in this version

type ListGroupOpts

+ UserID *uuid.UUID

Aug 1, 2025

Changes in this version

type OrgInvitationContext

+ ExternalMetadata json.RawMessage

Jul 29, 2025

Changes in this version

type ProjectMembership

+ ParentResourceID *uuid.UUID

Jul 28, 2025

Changes in this version

type ProjectMembership

+ ParentID *uuid.UUID

Jul 24, 2025

Changes in this version

type Membership

+ ParentID *uuid.UUID

Jul 18, 2025

Changes in this version

+ type ListByOrgOpts struct

+ Email *string

+ MembershipID *uuid.UUID

+ Name *string

+ Role *authz.Role

type ListMembersOpts

+ RequesterID uuid.UUID

Jul 15, 2025

Changes in this version

type GroupRepo

+ UpdateGroupMemberCount func(ctx context.Context, groupID uuid.UUID) error

Jul 11, 2025

Changes in this version

+ type GroupProjectInfo struct

+ CreatedAt *time.Time

+ Description string

+ ID uuid.UUID

+ LatestVersionID *uuid.UUID

+ Name string

+ Role authz.Role

type GroupRepo

+ ListProjectsByGroup func(ctx context.Context, orgID uuid.UUID, groupID uuid.UUID, ...) ([]*GroupProjectInfo, int, error)

type GroupUseCase

+ func (uc *GroupUseCase) ListProjectsByGroup(ctx context.Context, orgID uuid.UUID, opts *ListProjectsByGroupOpts, ...) ([]*GroupProjectInfo, int, error)

+ type ListProjectsByGroupOpts struct

+ FilterByProject []uuid.UUID

type ProjectMembership

+ LatestProjectVersionID *uuid.UUID

Jul 11, 2025

Changes in this version

+ type APITokenCreateOpt func(*apiTokenOptions)

+ type APITokenListFilters struct

+ FilterByProjects []uuid.UUID

+ FilterByScope APITokenScope

+ IncludeRevoked bool

+ type APITokenListOpt func(*APITokenListFilters)

+ func WithAPITokenProjectFilter(projectIDs []uuid.UUID) APITokenListOpt

+ func WithAPITokenRevoked(includeRevoked bool) APITokenListOpt

+ func WithAPITokenScope(scope APITokenScope) APITokenListOpt

type APITokenRepo

+ FindByIDInOrg func(ctx context.Context, orgID uuid.UUID, id uuid.UUID) (*APIToken, error)

+ type APITokenScope string

+ const APITokenScopeGlobal

+ const APITokenScopeProject

type APITokenUseCase

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

type GroupRepo

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

Jul 10, 2025

Changes in this version

type ContractCreateOpts

+ ProjectID *uuid.UUID

+ type ContractScope string

+ const ContractScopeOrg

+ const ContractScopeProject

+ func (ContractScope) Values() (values []string)

type MembershipUseCase

+ func (uc *MembershipUseCase) GetOrgsAndRBACInfoForUser(ctx context.Context, userID uuid.UUID) ([]uuid.UUID, map[uuid.UUID][]uuid.UUID, error)

+ type ScopedEntity struct

+ ID uuid.UUID

+ Name string

+ Type string

type WorkflowContract

+ ScopedEntity *ScopedEntity

+ func (c *WorkflowContract) IsGlobalScoped() bool

+ func (c *WorkflowContract) IsProjectScoped() bool

type WorkflowContractCreateOpts

+ ProjectID *uuid.UUID

+ type WorkflowContractListFilters struct

+ FilterByProjects []uuid.UUID

+ type WorkflowListOpt func(opts *WorkflowContractListFilters)

+ func WithProjectFilter(projectIDs []uuid.UUID) WorkflowListOpt

Jul 9, 2025

Changes in this version

type UpsertByEmailOpts

+ SSOGroups []string

Jul 8, 2025

Changes in this version

type GroupRepo

+ UpdateMemberMaintainerStatus func(ctx context.Context, orgID uuid.UUID, groupID uuid.UUID, userID uuid.UUID, ...) error

type GroupUseCase

+ func (uc *GroupUseCase) UpdateMemberMaintainerStatus(ctx context.Context, orgID uuid.UUID, opts *UpdateMemberMaintainerStatusOpts) error

+ type UpdateMemberMaintainerStatusOpts struct

+ IsMaintainer bool

+ RequesterID uuid.UUID

+ UserReference *IdentityReference

Jul 7, 2025

Changes in this version

+ type AddMemberToProjectResult struct

+ InvitationSent bool

+ Membership *ProjectMembership

type OrgInvitationContext

+ ProjectIDToJoin uuid.UUID

+ ProjectRole authz.Role

type ProjectUseCase

+ func (uc *ProjectUseCase) ListPendingInvitations(ctx context.Context, orgID uuid.UUID, projectRef *IdentityReference, ...) ([]*OrgInvitation, int, error)

type ProjectsRepo

+ ListPendingInvitationsByProject func(ctx context.Context, orgID uuid.UUID, projectID uuid.UUID, ...) ([]*OrgInvitation, int, error)

Jul 4, 2025

Changes in this version

type APIToken

+ LastUsedAt *time.Time

type APITokenRepo

+ UpdateLastUsedAt func(ctx context.Context, ID uuid.UUID, lastUsedAt time.Time) error

type APITokenUseCase

+ func (uc *APITokenUseCase) UpdateLastUsedAt(ctx context.Context, tokenID string) error

+ type AddMemberToGroupResult struct

+ InvitationSent bool

+ Membership *GroupMembership

type GroupRepo

+ ListPendingInvitationsByGroup func(ctx context.Context, orgID uuid.UUID, groupID uuid.UUID, ...) ([]*OrgInvitation, int, error)

type GroupUseCase

+ func (uc *GroupUseCase) ListPendingInvitations(ctx context.Context, orgID uuid.UUID, groupID *uuid.UUID, groupName *string, ...) ([]*OrgInvitation, int, error)

type InvitationCreateOpt

+ func WithInvitationContext(ctx *OrgInvitationContext) InvitationCreateOpt

type OrgInvitation

+ Context *OrgInvitationContext

+ type OrgInvitationContext struct

+ GroupIDToJoin uuid.UUID

+ GroupMaintainer bool

type WorkflowCreateOpts

+ ContractBytes []byte

+ DetectedContract *Contract

Jul 3, 2025

Changes in this version

type ProjectUseCase

+ func (uc *ProjectUseCase) UpdateMemberRole(ctx context.Context, orgID uuid.UUID, opts *UpdateMemberRoleOpts) error

type ProjectsRepo

+ UpdateMemberRoleInProject func(ctx context.Context, orgID uuid.UUID, projectID uuid.UUID, memberID uuid.UUID, ...) (*ProjectMembership, error)

+ type UpdateMemberRoleOpts struct

+ GroupReference *IdentityReference

+ NewRole authz.Role

+ ProjectReference *IdentityReference

+ RequesterID uuid.UUID

+ UserEmail string

Jul 2, 2025

Changes in this version

type AddMemberToProjectOpts

+ GroupReference *IdentityReference

type MembershipRepo

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

type ProjectMembership

+ Group *Group

+ MembershipType authz.MembershipType

type RemoveMemberFromProjectOpts

+ GroupReference *IdentityReference

Jul 2, 2025

Changes in this version

type Group

+ MemberCount int

Jul 1, 2025

Changes in this version

+ type AddMemberToProjectOpts struct

+ ProjectReference *IdentityReference

+ RequesterID uuid.UUID

+ Role authz.Role

+ UserEmail string

+ type ProjectMembership struct

+ CreatedAt *time.Time

+ Role authz.Role

+ UpdatedAt *time.Time

+ User *User

type ProjectUseCase

+ func (uc *ProjectUseCase) AddMemberToProject(ctx context.Context, orgID uuid.UUID, opts *AddMemberToProjectOpts) (*ProjectMembership, error)

+ func (uc *ProjectUseCase) ListMembers(ctx context.Context, orgID uuid.UUID, projectRef *IdentityReference, ...) ([]*ProjectMembership, int, error)

+ func (uc *ProjectUseCase) RemoveMemberFromProject(ctx context.Context, orgID uuid.UUID, opts *RemoveMemberFromProjectOpts) error

+ func (uc *ProjectUseCase) ValidateProjectIdentifier(ctx context.Context, orgID uuid.UUID, projectRef *IdentityReference) (uuid.UUID, error)

type ProjectsRepo

+ AddMemberToProject func(ctx context.Context, orgID uuid.UUID, projectID uuid.UUID, userID uuid.UUID, ...) (*ProjectMembership, error)

+ FindProjectMembershipByProjectAndID func(ctx context.Context, projectID uuid.UUID, userID uuid.UUID) (*ProjectMembership, error)

+ ListMembers func(ctx context.Context, orgID uuid.UUID, projectID uuid.UUID, ...) ([]*ProjectMembership, int, error)

+ RemoveMemberFromProject func(ctx context.Context, orgID uuid.UUID, projectID uuid.UUID, userID uuid.UUID) error

+ type RemoveMemberFromProjectOpts struct

+ ProjectReference *IdentityReference

+ RequesterID uuid.UUID

+ UserEmail string

Jun 30, 2025

Changes in this version

+ func WithVisibleProjectIDs(projectIDs map[OrgID][]ProjectID) func(*GetFromRootFilters)

type APIToken

+ ProjectID *uuid.UUID

+ ProjectName *string

+ type APITokenUseCaseOpt func(*apiTokenOptions)

+ func APITokenShowOnlySystemTokens(show bool) APITokenUseCaseOpt

+ func APITokenWithProject(project *Project) APITokenUseCaseOpt

+ type AddMemberToGroupOpts struct

+ Maintainer bool

+ RequesterID uuid.UUID

+ UserEmail string

type GroupRepo

+ AddMemberToGroup func(ctx context.Context, orgID uuid.UUID, groupID uuid.UUID, userID uuid.UUID, ...) (*GroupMembership, error)

+ FindGroupMembershipByGroupAndID func(ctx context.Context, groupID uuid.UUID, userID uuid.UUID) (*GroupMembership, error)

+ RemoveMemberFromGroup func(ctx context.Context, orgID uuid.UUID, groupID uuid.UUID, userID uuid.UUID) error

type GroupUseCase

+ func (uc *GroupUseCase) AddMemberToGroup(ctx context.Context, orgID uuid.UUID, opts *AddMemberToGroupOpts) (*GroupMembership, error)

+ func (uc *GroupUseCase) Delete(ctx context.Context, orgID uuid.UUID, opts *IdentityReference) error

+ func (uc *GroupUseCase) Get(ctx context.Context, orgID uuid.UUID, opts *IdentityReference) (*Group, error)

+ func (uc *GroupUseCase) RemoveMemberFromGroup(ctx context.Context, orgID uuid.UUID, opts *RemoveMemberFromGroupOpts) error

+ func (uc *GroupUseCase) ValidateGroupIdentifier(ctx context.Context, orgID uuid.UUID, groupID *uuid.UUID, groupName *string) (uuid.UUID, error)

+ type IdentityReference struct

+ ID *uuid.UUID

+ Name *string

type MembershipRepo

+ FindByOrgIDAndUserEmail func(ctx context.Context, orgID uuid.UUID, userEmail string) (*Membership, error)

+ FindByUserAndResourceID func(ctx context.Context, userID, resourceID uuid.UUID) (*Membership, error)

+ type OrgID = uuid.UUID

+ type ProjectID = uuid.UUID

+ type RemoveMemberFromGroupOpts struct

+ RequesterID uuid.UUID

+ UserEmail string

type StoredReferrer

+ ProjectIDs []uuid.UUID

type UpdateGroupOpts

+ NewDescription *string

+ NewName *string

Jun 26, 2025

Changes in this version

+ func WithProjectIDs(projectIDs []uuid.UUID) func(*GetFromRootFilters)

type CASMapping

+ ProjectID uuid.UUID

+ type CASMappingCreateOpts struct

+ ProjectID *uuid.UUID

+ WorkflowRunID *uuid.UUID

+ type CASMappingFindOptions struct

+ Orgs []uuid.UUID

+ ProjectIDs []uuid.UUID

+ type CreateGroupOpts struct

+ Description string

+ Name string

+ UserID uuid.UUID

type GetFromRootFilters

+ ProjectIDs []uuid.UUID

+ type Group struct

+ CreatedAt *time.Time

+ DeletedAt *time.Time

+ Description string

+ ID uuid.UUID

+ Members []*GroupMembership

+ Name string

+ Organization *Organization

+ UpdatedAt *time.Time

+ type GroupMembership struct

+ CreatedAt *time.Time

+ DeletedAt *time.Time

+ Maintainer bool

+ UpdatedAt *time.Time

+ User *User

+ type GroupRepo interface

+ Create func(ctx context.Context, orgID uuid.UUID, opts *CreateGroupOpts) (*Group, error)

+ FindByOrgAndID func(ctx context.Context, orgID uuid.UUID, groupID uuid.UUID) (*Group, error)

+ List func(ctx context.Context, orgID uuid.UUID, filterOpts *ListGroupOpts, ...) ([]*Group, int, error)

+ ListMembers func(ctx context.Context, orgID uuid.UUID, groupID uuid.UUID, opts *ListMembersOpts, ...) ([]*GroupMembership, int, error)

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

+ Update func(ctx context.Context, orgID uuid.UUID, groupID uuid.UUID, opts *UpdateGroupOpts) (*Group, error)

+ type GroupUseCase struct

+ func NewGroupUseCase(logger log.Logger, groupRepo GroupRepo, membershipRepo MembershipRepo, ...) *GroupUseCase

+ func (uc *GroupUseCase) Create(ctx context.Context, orgID uuid.UUID, name string, description string, ...) (*Group, error)

+ func (uc *GroupUseCase) FindByOrgAndID(ctx context.Context, orgID uuid.UUID, groupID uuid.UUID) (*Group, error)

+ func (uc *GroupUseCase) List(ctx context.Context, orgID uuid.UUID, filterOpts *ListGroupOpts, ...) ([]*Group, int, error)

+ func (uc *GroupUseCase) ListMembers(ctx context.Context, orgID uuid.UUID, groupID uuid.UUID, maintainers *bool, ...) ([]*GroupMembership, int, error)

+ func (uc *GroupUseCase) SoftDelete(ctx context.Context, orgID uuid.UUID, groupID uuid.UUID) error

+ func (uc *GroupUseCase) Update(ctx context.Context, orgID uuid.UUID, groupID uuid.UUID, description *string, ...) (*Group, error)

type IntegrationUseCase

+ func (uc *IntegrationUseCase) GetAttachment(ctx context.Context, orgID, attID uuid.UUID) (*IntegrationAttachment, error)

+ type ListAttachmentsOpts struct

+ ProjectIDs []uuid.UUID

+ WorkflowID *uuid.UUID

+ type ListGroupOpts struct

+ Description string

+ MemberEmail string

+ Name string

+ type ListMembersOpts struct

+ Maintainers *bool

+ MemberEmail *string

type MembershipRepo

+ AddResourceRole func(ctx context.Context, resourceType authz.ResourceType, resID uuid.UUID, ...) error

+ ListAllByResource func(ctx context.Context, rt authz.ResourceType, id uuid.UUID) ([]*Membership, error)

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

type MembershipUseCase

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

+ func (uc *MembershipUseCase) SetProjectOwner(ctx context.Context, projectID, userID uuid.UUID) error

+ type MembershipsRBAC interface

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

type ProjectsRepo

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

type RunListFilters

+ ProjectIDs []uuid.UUID

+ type UpdateGroupOpts struct

+ Description *string

+ Name *string

type WorkflowCreateOpts

+ Owner *uuid.UUID

type WorkflowListOpts

+ ProjectIDs []uuid.UUID

Jun 18, 2025

Changes in this version

+ const MembershipTypeGroup

+ const MembershipTypeUser

+ const ResourceTypeOrganization

+ const ResourceTypeProject

type Membership

+ MemberID uuid.UUID

+ MembershipType MembershipType

+ ResourceID uuid.UUID

+ ResourceType ResourceType

+ type MembershipType string

+ func (MembershipType) Values() (values []string)

+ type ResourceType string

+ func (ResourceType) Values() (values []string)

Jun 6, 2025

Changes in this version

+ type APITokenJWTConfig struct

+ SymmetricHmacKey string

type APITokenRepo

+ UpdateExpiration func(ctx context.Context, ID uuid.UUID, expiresAt time.Time) error

type APITokenUseCase

+ func (uc *APITokenUseCase) RegenerateJWT(ctx context.Context, tokenID uuid.UUID, expiresIn time.Duration) (*APIToken, error)

+ type UpsertByEmailOpts struct

+ DisableAutoOnboarding *bool

+ FirstName *string

+ LastName *string

type User

+ FirstName string

+ LastName string

type UserRepo

+ UpdateNameAndLastName func(ctx context.Context, userID uuid.UUID, firstName, lastName *string) (*User, error)

type UserUseCase

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

May 19, 2025

Changes in this version

type WorkflowContract

+ LatestRevisionCreatedAt *time.Time

May 15, 2025

Changes in this version

type NewUserUseCaseParams

+ UserAccessSyncer *UserAccessSyncerUseCase

type UserAccessSyncerUseCase

+ func (u *UserAccessSyncerUseCase) SyncUserAccess(ctx context.Context) error

+ func (u *UserAccessSyncerUseCase) UpdateUserAccessRestriction(ctx context.Context, user *User) (*User, error)

type UserRepo

+ FindUsersWithAccessPropertyNotSet func(ctx context.Context) ([]*User, error)

+ HasUsersWithAccessPropertyNotSet func(ctx context.Context) (bool, error)

May 5, 2025

Changes in this version

type SigningUseCase

+ func (s *SigningUseCase) GetSigningCA() ca.CertificateAuthority

Mar 27, 2025

Changes in this version

+ func ToPtr[T any](v T) *T

+ func UserEmailInAllowlist(allowList []string, email string) (bool, error)

type User

+ HasRestrictedAccess bool

+ type UserAccessSyncerUseCase struct

+ func NewUserAccessSyncerUseCase(logger log.Logger, userRepo UserRepo, allowList *conf.Auth_AllowList) *UserAccessSyncerUseCase

+ func (u *UserAccessSyncerUseCase) StartSyncingUserAccess(ctx context.Context) error

type UserRepo

+ CountUsersWithRestrictedOrUnsetAccess func(ctx context.Context) (int, error)

+ FindAll func(ctx context.Context, pagination *pagination.OffsetPaginationOpts) ([]*User, int, error)

+ UpdateAccess func(ctx context.Context, userID uuid.UUID, isAccessRestricted bool) error

Mar 25, 2025

Changes in this version

type WorkflowListOpts

+ JSONFilters []*jsonfilter.JSONFilter

Feb 21, 2025

Changes in this version

type SigningUseCase

+ TimestampAuthorities []*TimestampAuthority

+ func (s *SigningUseCase) GetCurrentTSA() *TimestampAuthority

+ type TimestampAuthority struct

+ CertChain []*x509.Certificate

+ Issuer bool

+ URL *url.URL

type TrustedRoot

+ TimestampAuthorities map[string][]string

Feb 17, 2025

Changes in this version

+ type VerificationResult struct

+ FailureReason string

+ Result bool

type WorkflowRunUseCase

+ func (uc *WorkflowRunUseCase) Verify(ctx context.Context, run *WorkflowRun) (*VerificationResult, error)

Feb 12, 2025

Changes in this version

type SigningUseCase

+ CAs *ca.CertificateAuthorities

+ func (s *SigningUseCase) GetTrustedRoot(ctx context.Context) (*TrustedRoot, error)

+ type TrustedRoot struct

+ Keys map[string][]string

Feb 7, 2025

Changes in this version

type Attestation

+ Bundle []byte

type AttestationUseCase

+ func (uc *AttestationUseCase) UploadAttestationToCAS(ctx context.Context, content []byte, backend *CASBackend, workflowRunID string, ...) error

type WorkflowRunRepo

+ GetBundle func(ctx context.Context, wrID uuid.UUID) ([]byte, error)

Feb 3, 2025

Changes in this version

type WorkflowRunRepo

+ SaveBundle func(ctx context.Context, ID uuid.UUID, bundle []byte) error

Jan 31, 2025

Changes in this version

type ProjectVersion

+ ReleasedAt *time.Time

Jan 23, 2025

Changes in this version

type OrganizationUseCase

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

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)