repository

package
v0.0.0-...-d3b8ba1 Latest Latest
Warning

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

 Go to latest Published: Jun 7, 2023 License: MIT Imports: 14 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Bundle 

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

func NewRepositoryBundle 

func NewRepositoryBundle(x509CertificateRepository *X509CertificateRepository, x509CertificateSubscriptionRepository *X509CertificateSubscriptionRepository, privateKeyRepository *X509PrivateKeyRepository, transactionManager *TransactionManager) *Bundle

func (*Bundle) TransactionManager 

func (p *Bundle) TransactionManager() templaterepository.TransactionManager

func (*Bundle) X509CertificateRepository 

func (p *Bundle) X509CertificateRepository() templaterepository.X509CertificateRepository

func (*Bundle) X509CertificateSubscriptionRepository 

func (p *Bundle) X509CertificateSubscriptionRepository() templaterepository.X509CertificateSubscriptionRepository

func (*Bundle) X509PrivateKeyRepository 

func (p *Bundle) X509PrivateKeyRepository() templaterepository.PrivateKeyRepository

type TransactionManager 

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

func NewTransactionManager 

func NewTransactionManager(db *sql.DB) *TransactionManager

func (*TransactionManager) BeginTx 

func (t *TransactionManager) BeginTx(ctx context.Context) (context.Context, error)

func (*TransactionManager) CommitTx 

func (t *TransactionManager) CommitTx(ctx context.Context) error

func (*TransactionManager) RollbackTx 

func (t *TransactionManager) RollbackTx(ctx context.Context) error

type TxCtxKey 

type TxCtxKey struct{}

type X509CertificateRepository 

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

func NewX509CertificateRepository 

func NewX509CertificateRepository(db *sql.DB, privateKeyRepository *X509PrivateKeyRepository, clock clockwork.Clock) *X509CertificateRepository

func (*X509CertificateRepository) FindAllByByteHashes 

func (r *X509CertificateRepository) FindAllByByteHashes(ctx context.Context, byteHashes []*[]byte) ([]*repository.X509CertificateDao, error)

func (*X509CertificateRepository) FindByIssuerHashAndNoParentSet 

func (r *X509CertificateRepository) FindByIssuerHashAndNoParentSet(ctx context.Context, issuerHash []byte) ([]*repository.X509CertificateDao, error)

func (*X509CertificateRepository) FindByPublicKeyHashAndNoPrivateKeySet 

func (r *X509CertificateRepository) FindByPublicKeyHashAndNoPrivateKeySet(ctx context.Context, pubKeyHash []byte) ([]*repository.X509CertificateDao, error)

func (*X509CertificateRepository) FindBySubjectHash 

func (r *X509CertificateRepository) FindBySubjectHash(ctx context.Context, subjectHash []byte) ([]*repository.X509CertificateDao, error)

func (*X509CertificateRepository) FindCertificateChain 

func (r *X509CertificateRepository) FindCertificateChain(ctx context.Context, startCertId uuid.UUID) ([]*repository.X509CertificateDao, error)

func (*X509CertificateRepository) FindLatestActiveBySANsAndCreatedAtAfter 

func (r *X509CertificateRepository) FindLatestActiveBySANsAndCreatedAtAfter(
	ctx context.Context, subjectAltNames []string, sinceAfter time.Time,
) ([]*repository.X509CertificateDao, error)

func (*X509CertificateRepository) GetOrCreate 

func (r *X509CertificateRepository) GetOrCreate(
	ctx context.Context, cert *repository.X509CertificateDao,
) (*repository.X509CertificateDao, error)

func (*X509CertificateRepository) Update 

func (r *X509CertificateRepository) Update(ctx context.Context, cert *repository.X509CertificateDao) (updatedCert *repository.X509CertificateDao, updated bool, err error)

type X509CertificateSubscriptionRepository 

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

func NewX509CertificateSubscriptionRepository 

func NewX509CertificateSubscriptionRepository(db *sql.DB, clock clockwork.Clock) *X509CertificateSubscriptionRepository

func (*X509CertificateSubscriptionRepository) Create 

func (x *X509CertificateSubscriptionRepository) Create(
	ctx context.Context, certSub *repository.X509CertificateSubscriptionDao,
) (*repository.X509CertificateSubscriptionDao, error)

func (*X509CertificateSubscriptionRepository) Delete 

func (x *X509CertificateSubscriptionRepository) Delete(
	ctx context.Context, id uuid.UUID,
) (rowsDeleted int64, err error)

func (*X509CertificateSubscriptionRepository) FindByIDs 

func (x *X509CertificateSubscriptionRepository) FindByIDs(
	ctx context.Context, IDs []uuid.UUID,
) ([]*repository.X509CertificateSubscriptionDao, error)

type X509PrivateKeyRepository 

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

func NewX509PrivateKeyRepository 

func NewX509PrivateKeyRepository(db *sql.DB, clock clockwork.Clock) *X509PrivateKeyRepository

func (*X509PrivateKeyRepository) FindByID 

func (p *X509PrivateKeyRepository) FindByID(
	ctx context.Context, id uuid.UUID,
) (privKey *repository.X509PrivateKeyDao, exists bool, err error)

func (*X509PrivateKeyRepository) FindByIDs 

func (p *X509PrivateKeyRepository) FindByIDs(
	ctx context.Context, ids []uuid.UUID,
) (privKeys []*repository.X509PrivateKeyDao, err error)

func (*X509PrivateKeyRepository) FindByPublicKeyHash 

func (p *X509PrivateKeyRepository) FindByPublicKeyHash(
	ctx context.Context, pubKeyHash []byte,
) (privKey *repository.X509PrivateKeyDao, exists bool, err error)

func (*X509PrivateKeyRepository) GetOrCreate 

func (p *X509PrivateKeyRepository) GetOrCreate(
	ctx context.Context, privKey *repository.X509PrivateKeyDao,
) (*repository.X509PrivateKeyDao, error)

Source Files

View all Source files

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.