Documentation ¶
Index ¶
- func CheckAndCreateDB(client *kivik.Client, db string) error
- func CreateCouchDBConnection(logger *logrus.Entry, cfg config.CouchDBPSEConfig) (*kivik.Client, error)
- func NewCouchCARepository(client *kivik.Client) (storage.CACertificatesRepo, error)
- func NewCouchCertificateRepository(client *kivik.Client) (storage.CertificatesRepo, error)
- func NewCouchDMSRepository(client *kivik.Client) (storage.DMSRepo, error)
- func NewCouchDeviceRepository(client *kivik.Client) (storage.DeviceManagerRepo, error)
- type CouchDBCAStorage
- func (db *CouchDBCAStorage) Count(ctx context.Context) (int, error)
- func (db *CouchDBCAStorage) CountByEngine(ctx context.Context, engineID string) (int, error)
- func (db *CouchDBCAStorage) CountByStatus(ctx context.Context, status models.CertificateStatus) (int, error)
- func (db *CouchDBCAStorage) Delete(ctx context.Context, id string) error
- func (db *CouchDBCAStorage) Insert(ctx context.Context, caCertificate *models.CACertificate) (*models.CACertificate, error)
- func (db *CouchDBCAStorage) SelectAll(ctx context.Context, req storage.StorageListRequest[models.CACertificate]) (string, error)
- func (db *CouchDBCAStorage) SelectByCommonName(ctx context.Context, commonName string, ...) (string, error)
- func (db *CouchDBCAStorage) SelectByParentCA(ctx context.Context, parentCAID string, ...) (string, error)
- func (db *CouchDBCAStorage) SelectByType(ctx context.Context, CAType models.CertificateType, ...) (string, error)
- func (db *CouchDBCAStorage) SelectExistsByID(ctx context.Context, id string) (bool, *models.CACertificate, error)
- func (db *CouchDBCAStorage) SelectExistsBySerialNumber(ctx context.Context, serialNumber string) (bool, *models.CACertificate, error)
- func (db *CouchDBCAStorage) Update(ctx context.Context, caCertificate *models.CACertificate) (*models.CACertificate, error)
- type CouchDBCertificateStorage
- func (db *CouchDBCertificateStorage) Count(ctx context.Context) (int, error)
- func (db *CouchDBCertificateStorage) CountByCA(ctx context.Context, caID string) (int, error)
- func (db *CouchDBCertificateStorage) CountByCAIDAndStatus(ctx context.Context, caID string, status models.CertificateStatus) (int, error)
- func (db *CouchDBCertificateStorage) Insert(ctx context.Context, certificate *models.Certificate) (*models.Certificate, error)
- func (db *CouchDBCertificateStorage) SelectAll(ctx context.Context, req storage.StorageListRequest[models.Certificate]) (string, error)
- func (db *CouchDBCertificateStorage) SelectByCA(ctx context.Context, caID string, ...) (string, error)
- func (db *CouchDBCertificateStorage) SelectByCAIDAndStatus(ctx context.Context, CAID string, status models.CertificateStatus, ...) (string, error)
- func (db *CouchDBCertificateStorage) SelectByExpirationDate(ctx context.Context, beforeExpirationDate time.Time, ...) (string, error)
- func (db *CouchDBCertificateStorage) SelectByParentCA(ctx context.Context, parentCAID string, ...) (string, error)
- func (db *CouchDBCertificateStorage) SelectByStatus(ctx context.Context, status models.CertificateStatus, ...) (string, error)
- func (db *CouchDBCertificateStorage) SelectByType(ctx context.Context, CAType models.CertificateType, ...) (string, error)
- func (db *CouchDBCertificateStorage) SelectExistsBySerialNumber(ctx context.Context, id string) (bool, *models.Certificate, error)
- func (db *CouchDBCertificateStorage) Update(ctx context.Context, certificate *models.Certificate) (*models.Certificate, error)
- type CouchDBDMSStorage
- func (db *CouchDBDMSStorage) Count(ctx context.Context) (int, error)
- func (db *CouchDBDMSStorage) Insert(ctx context.Context, dms *models.DMS) (*models.DMS, error)
- func (db *CouchDBDMSStorage) SelectAll(ctx context.Context, exhaustiveRun bool, applyFunc func(models.DMS), ...) (string, error)
- func (db *CouchDBDMSStorage) SelectExists(ctx context.Context, ID string) (bool, *models.DMS, error)
- func (db *CouchDBDMSStorage) Update(ctx context.Context, dms *models.DMS) (*models.DMS, error)
- type CouchDBDeviceStorage
- func (db *CouchDBDeviceStorage) Count(ctx context.Context) (int, error)
- func (db *CouchDBDeviceStorage) CountByStatus(ctx context.Context, status models.DeviceStatus) (int, error)
- func (db *CouchDBDeviceStorage) Insert(ctx context.Context, device *models.Device) (*models.Device, error)
- func (db *CouchDBDeviceStorage) SelectAll(ctx context.Context, exhaustiveRun bool, applyFunc func(models.Device), ...) (string, error)
- func (db *CouchDBDeviceStorage) SelectByDMS(ctx context.Context, dmsID string, exhaustiveRun bool, ...) (string, error)
- func (db *CouchDBDeviceStorage) SelectExists(ctx context.Context, ID string) (bool, *models.Device, error)
- func (db *CouchDBDeviceStorage) Update(ctx context.Context, device *models.Device) (*models.Device, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CheckAndCreateDB ¶
func CreateCouchDBConnection ¶
func CreateCouchDBConnection(logger *logrus.Entry, cfg config.CouchDBPSEConfig) (*kivik.Client, error)
func NewCouchCARepository ¶
func NewCouchCARepository(client *kivik.Client) (storage.CACertificatesRepo, error)
func NewCouchCertificateRepository ¶
func NewCouchCertificateRepository(client *kivik.Client) (storage.CertificatesRepo, error)
func NewCouchDMSRepository ¶
func NewCouchDeviceRepository ¶
func NewCouchDeviceRepository(client *kivik.Client) (storage.DeviceManagerRepo, error)
Types ¶
type CouchDBCAStorage ¶
type CouchDBCAStorage struct {
// contains filtered or unexported fields
}
func (*CouchDBCAStorage) Count ¶
func (db *CouchDBCAStorage) Count(ctx context.Context) (int, error)
func (*CouchDBCAStorage) CountByEngine ¶
func (*CouchDBCAStorage) CountByStatus ¶
func (db *CouchDBCAStorage) CountByStatus(ctx context.Context, status models.CertificateStatus) (int, error)
func (*CouchDBCAStorage) Delete ¶
func (db *CouchDBCAStorage) Delete(ctx context.Context, id string) error
func (*CouchDBCAStorage) Insert ¶
func (db *CouchDBCAStorage) Insert(ctx context.Context, caCertificate *models.CACertificate) (*models.CACertificate, error)
func (*CouchDBCAStorage) SelectAll ¶
func (db *CouchDBCAStorage) SelectAll(ctx context.Context, req storage.StorageListRequest[models.CACertificate]) (string, error)
func (*CouchDBCAStorage) SelectByCommonName ¶
func (db *CouchDBCAStorage) SelectByCommonName(ctx context.Context, commonName string, req storage.StorageListRequest[models.CACertificate]) (string, error)
func (*CouchDBCAStorage) SelectByParentCA ¶
func (db *CouchDBCAStorage) SelectByParentCA(ctx context.Context, parentCAID string, req storage.StorageListRequest[models.CACertificate]) (string, error)
func (*CouchDBCAStorage) SelectByType ¶
func (db *CouchDBCAStorage) SelectByType(ctx context.Context, CAType models.CertificateType, req storage.StorageListRequest[models.CACertificate]) (string, error)
func (*CouchDBCAStorage) SelectExistsByID ¶
func (db *CouchDBCAStorage) SelectExistsByID(ctx context.Context, id string) (bool, *models.CACertificate, error)
func (*CouchDBCAStorage) SelectExistsBySerialNumber ¶
func (db *CouchDBCAStorage) SelectExistsBySerialNumber(ctx context.Context, serialNumber string) (bool, *models.CACertificate, error)
func (*CouchDBCAStorage) Update ¶
func (db *CouchDBCAStorage) Update(ctx context.Context, caCertificate *models.CACertificate) (*models.CACertificate, error)
type CouchDBCertificateStorage ¶
type CouchDBCertificateStorage struct {
// contains filtered or unexported fields
}
func (*CouchDBCertificateStorage) Count ¶
func (db *CouchDBCertificateStorage) Count(ctx context.Context) (int, error)
func (*CouchDBCertificateStorage) CountByCAIDAndStatus ¶
func (db *CouchDBCertificateStorage) CountByCAIDAndStatus(ctx context.Context, caID string, status models.CertificateStatus) (int, error)
func (*CouchDBCertificateStorage) Insert ¶
func (db *CouchDBCertificateStorage) Insert(ctx context.Context, certificate *models.Certificate) (*models.Certificate, error)
func (*CouchDBCertificateStorage) SelectAll ¶
func (db *CouchDBCertificateStorage) SelectAll(ctx context.Context, req storage.StorageListRequest[models.Certificate]) (string, error)
func (*CouchDBCertificateStorage) SelectByCA ¶
func (db *CouchDBCertificateStorage) SelectByCA(ctx context.Context, caID string, req storage.StorageListRequest[models.Certificate]) (string, error)
func (*CouchDBCertificateStorage) SelectByCAIDAndStatus ¶
func (db *CouchDBCertificateStorage) SelectByCAIDAndStatus(ctx context.Context, CAID string, status models.CertificateStatus, req storage.StorageListRequest[models.Certificate]) (string, error)
func (*CouchDBCertificateStorage) SelectByExpirationDate ¶
func (db *CouchDBCertificateStorage) SelectByExpirationDate(ctx context.Context, beforeExpirationDate time.Time, afterExpirationDate time.Time, req storage.StorageListRequest[models.Certificate]) (string, error)
func (*CouchDBCertificateStorage) SelectByParentCA ¶
func (db *CouchDBCertificateStorage) SelectByParentCA(ctx context.Context, parentCAID string, req storage.StorageListRequest[models.Certificate]) (string, error)
func (*CouchDBCertificateStorage) SelectByStatus ¶
func (db *CouchDBCertificateStorage) SelectByStatus(ctx context.Context, status models.CertificateStatus, req storage.StorageListRequest[models.Certificate]) (string, error)
func (*CouchDBCertificateStorage) SelectByType ¶
func (db *CouchDBCertificateStorage) SelectByType(ctx context.Context, CAType models.CertificateType, req storage.StorageListRequest[models.Certificate]) (string, error)
func (*CouchDBCertificateStorage) SelectExistsBySerialNumber ¶
func (db *CouchDBCertificateStorage) SelectExistsBySerialNumber(ctx context.Context, id string) (bool, *models.Certificate, error)
func (*CouchDBCertificateStorage) Update ¶
func (db *CouchDBCertificateStorage) Update(ctx context.Context, certificate *models.Certificate) (*models.Certificate, error)
type CouchDBDMSStorage ¶
type CouchDBDMSStorage struct {
// contains filtered or unexported fields
}
func (*CouchDBDMSStorage) Count ¶
func (db *CouchDBDMSStorage) Count(ctx context.Context) (int, error)
func (*CouchDBDMSStorage) SelectExists ¶
type CouchDBDeviceStorage ¶
type CouchDBDeviceStorage struct {
// contains filtered or unexported fields
}
func (*CouchDBDeviceStorage) Count ¶
func (db *CouchDBDeviceStorage) Count(ctx context.Context) (int, error)
func (*CouchDBDeviceStorage) CountByStatus ¶
func (db *CouchDBDeviceStorage) CountByStatus(ctx context.Context, status models.DeviceStatus) (int, error)
func (*CouchDBDeviceStorage) SelectByDMS ¶
func (*CouchDBDeviceStorage) SelectExists ¶
Click to show internal directories.
Click to hide internal directories.