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 (*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 (*X509CertificateRepository) Update

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 (*X509CertificateSubscriptionRepository) Delete

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

func (*X509CertificateSubscriptionRepository) FindByIDs

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

Jump to

Keyboard shortcuts

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