data

package

Go to main page

Versions in this module

v0

v0.86.0

May 8, 2024

Changes in this version

type WorkflowRepo

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

v0.85.1

May 3, 2024

Changes in this version

type ReferrerRepo

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

v0.85.0

Apr 30, 2024

v0.84.0

Apr 24, 2024

v0.83.0

Apr 24, 2024

v0.82.0

Apr 16, 2024

v0.81.2

Apr 4, 2024

v0.81.1

Apr 2, 2024

v0.81.0

Mar 28, 2024

v0.80.1

Mar 13, 2024

v0.80.0

Mar 13, 2024

Changes in this version

type OrgMetricsRepo

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

v0.75.2

Mar 6, 2024

v0.75.1

Mar 4, 2024

v0.75.0

Mar 4, 2024

Changes in this version

type MembershipRepo

+ func (r *MembershipRepo) FindByIDInOrg(ctx context.Context, orgID, membershipID uuid.UUID) (*biz.Membership, error)

+ func (r *MembershipRepo) SetRole(ctx context.Context, membershipID uuid.UUID, role authz.Role) (*biz.Membership, error)

type OrgInvitation

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

v0.70.0

Feb 29, 2024

v0.66.0

Feb 19, 2024

v0.65.0

Feb 16, 2024

v0.60.0

Feb 12, 2024

Changes in this version

+ func NewAttestationStateRepo(data *Data, logger log.Logger) biz.AttestationStateRepo

+ type AttestationStateRepo struct

+ func (r *AttestationStateRepo) Initialized(ctx context.Context, runID uuid.UUID) (bool, error)

+ func (r *AttestationStateRepo) Read(ctx context.Context, runID uuid.UUID) ([]byte, error)

+ func (r *AttestationStateRepo) Reset(ctx context.Context, runID uuid.UUID) error

+ func (r *AttestationStateRepo) Save(ctx context.Context, runID uuid.UUID, state []byte) error

v0.56.0

Jan 29, 2024

v0.55.0

Dec 18, 2023

Changes in this version

+ func NewAPITokenRepo(data *Data, logger log.Logger) biz.APITokenRepo

+ type APITokenRepo struct

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

+ func (r *APITokenRepo) FindByID(ctx context.Context, id uuid.UUID) (*biz.APIToken, error)

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

+ func (r *APITokenRepo) Revoke(ctx context.Context, orgID, id uuid.UUID) error

type MembershipRepo

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

v0.50.0

Dec 4, 2023

Changes in this version

type OrganizationRepo

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

v0.40.0

Nov 17, 2023

Changes in this version

type WorkflowRepo

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

v0.30.0

Nov 9, 2023

Changes in this version

+ func NewReferrerRepo(data *Data, logger log.Logger) biz.ReferrerRepo

+ type ReferrerRepo struct

+ func (r *ReferrerRepo) GetFromRoot(ctx context.Context, digest string, orgIDs []uuid.UUID) (*biz.StoredReferrer, error)

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

v0.25.0

Oct 31, 2023

Changes in this version

+ func NewOrgInvitation(data *Data, logger log.Logger) biz.OrgInvitationRepo

+ type OrgInvitation struct

+ func (r *OrgInvitation) ChangeStatus(ctx context.Context, id uuid.UUID, status biz.OrgInvitationStatus) error

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

+ func (r *OrgInvitation) FindByID(ctx context.Context, id uuid.UUID) (*biz.OrgInvitation, error)

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

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

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

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

v0.21.1

Oct 17, 2023

v0.21.0

Oct 17, 2023

v0.20.0

Oct 11, 2023

v0.19.1

Sep 28, 2023

v0.19.0

Sep 27, 2023

v0.18.0

Sep 15, 2023

Changes in this version

type WorkflowRunRepo

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

v0.17.1

Sep 5, 2023

v0.17.0

Sep 5, 2023

Changes in this version

+ func NewCASMappingRepo(data *Data, cbRepo biz.CASBackendRepo, logger log.Logger) biz.CASMappingRepo

+ type CASMappingRepo struct

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

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

type WorkflowRepo

+ func (r *WorkflowRepo) ChangeVisibility(ctx context.Context, id uuid.UUID, public bool) (*biz.Workflow, error)

v0.16.2

Aug 31, 2023

v0.16.1

Aug 31, 2023

v0.16.0

Aug 23, 2023

v0.15.0

Jul 31, 2023

v0.14.0

Jul 20, 2023

Changes in this version

+ func NewCASBackendRepo(data *Data, logger log.Logger) biz.CASBackendRepo

+ type CASBackendRepo struct

+ func (r *CASBackendRepo) Create(ctx context.Context, opts *biz.CASBackendCreateOpts) (*biz.CASBackend, error)

+ func (r *CASBackendRepo) Delete(ctx context.Context, id uuid.UUID) error

+ func (r *CASBackendRepo) FindByID(ctx context.Context, id uuid.UUID) (*biz.CASBackend, error)

+ func (r *CASBackendRepo) FindByIDInOrg(ctx context.Context, orgID, id uuid.UUID) (*biz.CASBackend, error)

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

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

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

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

+ func (r *CASBackendRepo) Update(ctx context.Context, opts *biz.CASBackendUpdateOpts) (*biz.CASBackend, error)

+ func (r *CASBackendRepo) UpdateValidationStatus(ctx context.Context, id uuid.UUID, status biz.CASBackendValidationStatus) error

v0.13.0

Jul 10, 2023

Changes in this version

type Data

+ func (data *Data) SchemaLoad() error

v0.12.0

Jun 28, 2023

v0.11.1

Jun 19, 2023

Changes in this version

type WorkflowRunRepo

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

v0.10.0

May 31, 2023

v0.9.1

May 19, 2023

v0.9.0

May 9, 2023

v0.8.99

Apr 19, 2023

v0.8.98

Apr 16, 2023

v0.8.97

Apr 14, 2023

v0.8.96

Mar 31, 2023

v0.8.95

Mar 23, 2023

v0.8.94

Mar 13, 2023

v0.8.93

Mar 7, 2023

Changes in this version

+ var ProviderSet = wire.NewSet(NewData, NewWorkflowRepo, NewUserRepo, NewRobotAccountRepo, NewWorkflowRunRepo, ...)

+ func NewIntegrationAttachmentRepo(data *Data, logger log.Logger) biz.IntegrationAttachmentRepo

+ func NewIntegrationRepo(data *Data, logger log.Logger) biz.IntegrationRepo

+ func NewMembershipRepo(data *Data, logger log.Logger) biz.MembershipRepo

+ func NewOCIRepositoryRepo(data *Data, logger log.Logger) biz.OCIRepositoryRepo

+ func NewOrgMetricsRepo(data *Data, l log.Logger) biz.OrgMetricsRepo

+ func NewOrganizationRepo(data *Data, logger log.Logger) biz.OrganizationRepo

+ func NewRobotAccountRepo(data *Data, logger log.Logger) biz.RobotAccountRepo

+ func NewUserRepo(data *Data, logger log.Logger) biz.UserRepo

+ func NewWorkflowContractRepo(data *Data, logger log.Logger) biz.WorkflowContractRepo

+ func NewWorkflowRepo(data *Data, logger log.Logger) biz.WorkflowRepo

+ func NewWorkflowRunRepo(data *Data, logger log.Logger) biz.WorkflowRunRepo

+ type Data struct

+ func NewData(c *conf.Data, logger log.Logger) (*Data, func(), error)

+ type IntegrationAttachmentRepo struct

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

+ func (r *IntegrationAttachmentRepo) FindByIDInOrg(ctx context.Context, orgID, id uuid.UUID) (*biz.IntegrationAttachment, error)

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

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

+ type IntegrationRepo struct

+ func (r *IntegrationRepo) Create(ctx context.Context, orgID uuid.UUID, kind, secretName string, ...) (*biz.Integration, error)

+ func (r *IntegrationRepo) FindByIDInOrg(ctx context.Context, orgID, id uuid.UUID) (*biz.Integration, error)

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

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

+ type MembershipRepo struct

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

+ func (r *MembershipRepo) Delete(ctx context.Context, id uuid.UUID) error

+ func (r *MembershipRepo) FindByIDInUser(ctx context.Context, userID, membershipID uuid.UUID) (*biz.Membership, error)

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

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

+ func (r *MembershipRepo) SetCurrent(ctx context.Context, membershipID uuid.UUID) (*biz.Membership, error)

+ type OCIRepositoryRepo struct

+ func (r *OCIRepositoryRepo) Create(ctx context.Context, opts *biz.OCIRepoCreateOpts) (*biz.OCIRepository, error)

+ func (r *OCIRepositoryRepo) Delete(ctx context.Context, id uuid.UUID) error

+ func (r *OCIRepositoryRepo) FindByID(ctx context.Context, id uuid.UUID) (*biz.OCIRepository, error)

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

+ func (r *OCIRepositoryRepo) Update(ctx context.Context, opts *biz.OCIRepoUpdateOpts) (*biz.OCIRepository, error)

+ func (r *OCIRepositoryRepo) UpdateValidationStatus(ctx context.Context, id uuid.UUID, status biz.OCIRepoValidationStatus) error

+ type OrgMetricsRepo struct

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

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

+ func (repo *OrgMetricsRepo) RunsTotal(ctx context.Context, orgID uuid.UUID, tw time.Duration) (int32, error)

+ func (repo *OrgMetricsRepo) TopWorkflowsByRunsCount(ctx context.Context, orgID uuid.UUID, numWorkflows int, tw time.Duration) ([]*biz.TopWorkflowsByRunsCountItem, error)

+ type OrganizationRepo struct

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

+ func (r *OrganizationRepo) Delete(ctx context.Context, id uuid.UUID) error

+ func (r *OrganizationRepo) FindByID(ctx context.Context, id uuid.UUID) (*biz.Organization, error)

+ type RobotAccountRepo struct

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

+ func (r *RobotAccountRepo) FindByID(ctx context.Context, id uuid.UUID) (*biz.RobotAccount, error)

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

+ func (r *RobotAccountRepo) Revoke(ctx context.Context, orgID, id uuid.UUID) error

+ type WorkflowContractRepo struct

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

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

+ func (r *WorkflowContractRepo) FindByIDInOrg(ctx context.Context, orgID, contractID uuid.UUID) (*biz.WorkflowContract, error)

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

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

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

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

+ type WorkflowRepo struct

+ func (r *WorkflowRepo) Create(ctx context.Context, opts *biz.CreateOpts) (*biz.Workflow, error)

+ func (r *WorkflowRepo) FindByID(ctx context.Context, id uuid.UUID) (*biz.Workflow, error)

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

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

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

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

+ type WorkflowRunRepo struct

+ func (r *WorkflowRunRepo) Create(ctx context.Context, workflowID, robotaccountID, schemaVersionID uuid.UUID, ...) (*biz.WorkflowRun, error)

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

+ func (r *WorkflowRunRepo) FindByID(ctx context.Context, id uuid.UUID) (*biz.WorkflowRun, error)

+ func (r *WorkflowRunRepo) FindByIDInOrg(ctx context.Context, orgID, id uuid.UUID) (*biz.WorkflowRun, error)

+ func (r *WorkflowRunRepo) List(ctx context.Context, orgID, workflowID uuid.UUID, p *pagination.Options) (result []*biz.WorkflowRun, cursor string, err error)

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

+ func (r *WorkflowRunRepo) MarkAsFinished(ctx context.Context, id uuid.UUID, status biz.WorkflowRunStatus, reason string) error

+ func (r *WorkflowRunRepo) SaveAttestationRef(ctx context.Context, id uuid.UUID, ref *biz.AttestationRef) error

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL