data

package
v0.96.14 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 8, 2024 License: Apache-2.0 Imports: 40 Imported by: 0

README

Data

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var ProviderSet = wire.NewSet(
	NewData,
	NewWorkflowRepo,
	NewUserRepo,
	NewRobotAccountRepo,
	NewWorkflowRunRepo,
	NewOrganizationRepo,
	NewWorkflowContractRepo,
	NewCASBackendRepo,
	NewOrgMetricsRepo,
	NewIntegrationRepo,
	NewIntegrationAttachmentRepo,
	NewCASMappingRepo,
	NewMembershipRepo,
	NewOrgInvitation,
	NewReferrerRepo,
	NewAPITokenRepo,
	NewAttestationStateRepo,
)

ProviderSet is data providers.

Functions

func NewAPITokenRepo 

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

func NewAttestationStateRepo 

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

func NewCASBackendRepo 

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

func NewCASMappingRepo 

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

func NewIntegrationAttachmentRepo 

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

func NewIntegrationRepo 

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

func NewMembershipRepo 

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

func NewOrgInvitation 

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

func NewOrgMetricsRepo 

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

func NewOrganizationRepo 

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

func NewReferrerRepo 

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

func NewRobotAccountRepo 

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

func NewUserRepo 

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

func NewWorkflowContractRepo 

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

func NewWorkflowRepo 

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

func NewWorkflowRunRepo 

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

Types

type APITokenRepo 

type APITokenRepo struct {
	// contains filtered or unexported fields
}

func (*APITokenRepo) Create 

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

Persist the APIToken to the database.

func (*APITokenRepo) FindByID 

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

func (*APITokenRepo) FindByNameInOrg added in v0.93.1 

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

func (*APITokenRepo) List 

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

func (*APITokenRepo) Revoke 

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

type AttestationStateRepo 

type AttestationStateRepo struct {
	// contains filtered or unexported fields
}

func (*AttestationStateRepo) Initialized 

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

find the workflow run by its ID and check that it has attestation state

func (*AttestationStateRepo) Read 

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

func (*AttestationStateRepo) Reset 

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

func (*AttestationStateRepo) Save 

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

baseDigest, when provided will be used to check that it matches the digest of the state currently in the DB if the digests do not match, the state has been modified and the caller should retry

type CASBackendRepo 

type CASBackendRepo struct {
	// contains filtered or unexported fields
}

func (*CASBackendRepo) Create 

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

Create creates a new CAS backend in the given organization If it's set as default, it will unset the previous default backend

func (*CASBackendRepo) Delete 

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

Delete deletes a CAS backend from the DB

func (*CASBackendRepo) FindByID 

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

FindByID finds a CAS backend by ID If not found, returns nil and no error

func (*CASBackendRepo) FindByIDInOrg 

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

FindByIDInOrg finds a CAS backend by ID in the given organization. If not found, returns nil and no error

func (*CASBackendRepo) FindByNameInOrg added in v0.93.0 

func (r *CASBackendRepo) FindByNameInOrg(ctx context.Context, orgID uuid.UUID, name string) (*biz.CASBackend, error)

func (*CASBackendRepo) FindDefaultBackend 

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

FindDefaultBackend finds the CAS backend that's set as default for the given organization

func (*CASBackendRepo) FindFallbackBackend 

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

FindFallbackBackend finds the CAS backend that's set as fallback for the given organization

func (*CASBackendRepo) List 

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

func (*CASBackendRepo) SoftDelete 

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

Set deleted at instead of actually deleting the backend

func (*CASBackendRepo) Update 

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

func (*CASBackendRepo) UpdateValidationStatus 

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

UpdateValidationStatus updates the validation status of an OCI repository

type CASMappingRepo 

type CASMappingRepo struct {
	// contains filtered or unexported fields
}

func (*CASMappingRepo) Create 

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

func (*CASMappingRepo) FindByDigest 

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

type Data 

type Data struct {
	DB *ent.Client
}

Data .

func NewData 

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

NewData .

func (*Data) SchemaLoad 

func (data *Data) SchemaLoad() error

Load DB schema NOTE: this is different than running migrations this method is used to load the schema into the DB for TESTING!

type IntegrationAttachmentRepo 

type IntegrationAttachmentRepo struct {
	// contains filtered or unexported fields
}

func (*IntegrationAttachmentRepo) Create 

func (r *IntegrationAttachmentRepo) Create(ctx context.Context, integrationID, workflowID uuid.UUID, config []byte) (*biz.IntegrationAttachment, error)

func (*IntegrationAttachmentRepo) FindByIDInOrg 

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

func (*IntegrationAttachmentRepo) List 

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

func (*IntegrationAttachmentRepo) SoftDelete 

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

type IntegrationRepo 

type IntegrationRepo struct {
	// contains filtered or unexported fields
}

func (*IntegrationRepo) Create 

func (r *IntegrationRepo) Create(ctx context.Context, opts *biz.IntegrationCreateOpts) (*biz.Integration, error)

func (*IntegrationRepo) FindByIDInOrg 

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

func (*IntegrationRepo) FindByNameInOrg added in v0.93.0 

func (r *IntegrationRepo) FindByNameInOrg(ctx context.Context, orgID uuid.UUID, name string) (*biz.Integration, error)

func (*IntegrationRepo) List 

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

func (*IntegrationRepo) SoftDelete 

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

type MembershipRepo 

type MembershipRepo struct {
	// contains filtered or unexported fields
}

func (*MembershipRepo) Create 

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

func (*MembershipRepo) Delete 

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

Delete deletes a membership by ID.

func (*MembershipRepo) FindByIDInOrg 

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

func (*MembershipRepo) FindByIDInUser 

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

func (*MembershipRepo) FindByOrg 

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

FindByOrg finds all memberships for a given organization

func (*MembershipRepo) FindByOrgAndUser 

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

FindByOrgAndUser finds the membership for a given organization and user

func (*MembershipRepo) FindByUser 

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

func (*MembershipRepo) SetCurrent 

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

func (*MembershipRepo) SetRole 

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

type NewConfig 

type NewConfig struct {
	Driver, Source string
}

type OrgInvitation 

type OrgInvitation struct {
	// contains filtered or unexported fields
}

func (*OrgInvitation) ChangeStatus 

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

func (*OrgInvitation) Create 

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

func (*OrgInvitation) FindByID 

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

func (*OrgInvitation) ListByOrg 

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

func (*OrgInvitation) PendingInvitation 

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

func (*OrgInvitation) PendingInvitations 

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

func (*OrgInvitation) SoftDelete 

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

type OrgMetricsRepo 

type OrgMetricsRepo struct {
	// contains filtered or unexported fields
}

func (*OrgMetricsRepo) DailyRunsCount 

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

func (*OrgMetricsRepo) RunsByRunnerTypeTotal 

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

func (*OrgMetricsRepo) RunsByStatusTotal 

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

func (*OrgMetricsRepo) RunsTotal 

func (repo *OrgMetricsRepo) RunsTotal(ctx context.Context, orgID uuid.UUID, tw *biz.TimeWindow) (int32, error)

func (*OrgMetricsRepo) TopWorkflowsByRunsCount 

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

type OrganizationRepo 

type OrganizationRepo struct {
	// contains filtered or unexported fields
}

func (*OrganizationRepo) Create 

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

func (*OrganizationRepo) Delete 

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

Delete deletes an organization by ID.

func (*OrganizationRepo) FindByID 

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

func (*OrganizationRepo) FindByName added in v0.91.8 

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

FindByName finds an organization by name.

type ReferrerRepo 

type ReferrerRepo struct {
	// contains filtered or unexported fields
}

func (*ReferrerRepo) Exist 

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

Check if a given referrer by digest exist. The query can be scoped further down if needed by providing the kind or visibility status

func (*ReferrerRepo) GetFromRoot 

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

func (*ReferrerRepo) Save 

func (r *ReferrerRepo) Save(ctx context.Context, referrers []*biz.Referrer, workflowID uuid.UUID) error

type RobotAccountRepo 

type RobotAccountRepo struct {
	// contains filtered or unexported fields
}

func (*RobotAccountRepo) Create 

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

func (*RobotAccountRepo) FindByID 

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

func (*RobotAccountRepo) List 

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

func (*RobotAccountRepo) Revoke 

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

type WorkflowContractRepo 

type WorkflowContractRepo struct {
	// contains filtered or unexported fields
}

func (*WorkflowContractRepo) Create 

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

func (*WorkflowContractRepo) Describe 

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

func (*WorkflowContractRepo) FindByIDInOrg 

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

func (*WorkflowContractRepo) FindByNameInOrg added in v0.93.0 

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

func (*WorkflowContractRepo) FindVersionByID 

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

func (*WorkflowContractRepo) List 

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

func (*WorkflowContractRepo) SoftDelete 

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

func (*WorkflowContractRepo) Update 

func (r *WorkflowContractRepo) Update(ctx context.Context, orgID uuid.UUID, name string, opts *biz.ContractUpdateOpts) (*biz.WorkflowContractWithVersion, error)

Update will add a new version of the contract. NOTE: ContractVersions are immutable

type WorkflowRepo 

type WorkflowRepo struct {
	// contains filtered or unexported fields
}

func (*WorkflowRepo) Create 

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

func (*WorkflowRepo) FindByID 

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

func (*WorkflowRepo) GetOrgScoped 

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

GetOrgScoped Gets a workflow making sure it belongs to a given org

func (*WorkflowRepo) GetOrgScopedByName 

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

GetOrgScopedByName Gets a workflow by name making sure it belongs to a given org

func (*WorkflowRepo) IncRunsCounter 

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

func (*WorkflowRepo) List 

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

func (*WorkflowRepo) SoftDelete 

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

func (*WorkflowRepo) Update 

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

type WorkflowRunRepo 

type WorkflowRunRepo struct {
	// contains filtered or unexported fields
}

func (*WorkflowRunRepo) Create 

func (r *WorkflowRunRepo) Create(ctx context.Context, opts *biz.WorkflowRunRepoCreateOpts) (*biz.WorkflowRun, error)

func (*WorkflowRunRepo) Expire 

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

func (*WorkflowRunRepo) FindByAttestationDigest 

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

func (*WorkflowRunRepo) FindByID 

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

func (*WorkflowRunRepo) FindByIDInOrg 

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

func (*WorkflowRunRepo) List 

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

List the runs in an organization, optionally filtered out by workflow

func (*WorkflowRunRepo) ListNotFinishedOlderThan 

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

func (*WorkflowRunRepo) MarkAsFinished 

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

func (*WorkflowRunRepo) SaveAttestation 

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

Save the attestation for a workflow run in the database

Source Files

View all Source files

Directories

Path Synopsis
ent
apitoken
casbackend
casmapping
enttest
hook
integration
integrationattachment
membership
migrate
organization
orginvitation
predicate
referrer
robotaccount
runtime
schema
user
workflow
workflowcontract
workflowcontractversion
workflowrun

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.