leveldb

Documentation

Index

• func CopyDB(src *leveldb.DB, dst *leveldb.DB) (ncopied uint64, err error)
• type Store
  • func Open(path string) (*Store, error)
  • func (s *Store) Backup(path string) (err error)
  • func (s *Store) Close() error
  • func (s *Store) CreateCertReq(r *models.CertificateRequest) (id string, err error)
  • func (s *Store) CreateVASP(v *pb.VASP) (id string, err error)
  • func (s *Store) DeleteCertReq(id string) (err error)
  • func (s *Store) DeleteVASP(id string) (err error)
  • func (s *Store) ListCertReqs() iterator.CertificateIterator
  • func (s *Store) ListVASPs() iterator.DirectoryIterator
  • func (s *Store) Reindex() (err error)
  • func (s *Store) RetrieveCertReq(id string) (r *models.CertificateRequest, err error)
  • func (s *Store) RetrieveVASP(id string) (v *pb.VASP, err error)
  • func (s *Store) SearchVASPs(query map[string]interface{}) (vasps []*pb.VASP, err error)
  • func (s *Store) UpdateCertReq(r *models.CertificateRequest) (err error)
  • func (s *Store) UpdateVASP(v *pb.VASP) (err error)

Functions

func CopyDB

func CopyDB(src *leveldb.DB, dst *leveldb.DB) (ncopied uint64, err error)

CopyDB is a utility function to copy all the records from one leveldb database object to another.

Types

type Store

type Store struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

Store implements store.Store for some basic LevelDB operations and simple protocol buffer storage in a key/value database.

func Open

func Open(path string) (*Store, error)

Open LevelDB directory Store at the specified path.

func (*Store) Backup

func (s *Store) Backup(path string) (err error)

Backup copies the leveldb database to a new directory and archives it as gzip tar. See: https://github.com/wbolster/plyvel/issues/46

func (*Store) Close

func (s *Store) Close() error

Close the database, allowing no further interactions. This method also synchronizes the indices to ensure that they are saved between sessions.

func (*Store) CreateCertReq

func (s *Store) CreateCertReq(r *models.CertificateRequest) (id string, err error)

CreateCertReq and assign a new ID and return the version.

func (*Store) CreateVASP

func (s *Store) CreateVASP(v *pb.VASP) (id string, err error)

CreateVASP into the directory. This method requires the VASP to have a unique name and ignores any ID fields that are set on the VASP, instead assigning new IDs.

func (*Store) DeleteCertReq

func (s *Store) DeleteCertReq(id string) (err error)

DeleteCertReq removes a certificate request from the store.

func (*Store) DeleteVASP

func (s *Store) DeleteVASP(id string) (err error)

DeleteVASP record, removing it completely from the database and indices.

func (*Store) ListCertReqs

func (s *Store) ListCertReqs() iterator.CertificateIterator

ListCertReqs returns all certificate requests that are currently in the store.

func (*Store) ListVASPs

func (s *Store) ListVASPs() iterator.DirectoryIterator

ListVASPs returns all of the VASPs in the database

func (*Store) Reindex

func (s *Store) Reindex() (err error)

Reindex rebuilds the name and country indices for the server and synchronizes them back to disk to ensure they're complete and accurate.

func (*Store) RetrieveCertReq

func (s *Store) RetrieveCertReq(id string) (r *models.CertificateRequest, err error)

RetrieveCertReq returns a certificate request by certificate request ID.

func (*Store) RetrieveVASP

func (s *Store) RetrieveVASP(id string) (v *pb.VASP, err error)

RetrieveVASP record by id; returns an error if the record does not exist.

func (*Store) SearchVASPs

func (s *Store) SearchVASPs(query map[string]interface{}) (vasps []*pb.VASP, err error)

SearchVASPs uses the names and countries index to find VASPs that match the specified query. This is a very simple search and is not intended for robust usage. To find a VASP by name, a case insensitive search is performed if the query exists in any of the VASP entity names. If there is not an exact match a prefix lookup is used so long as the prefix > 3 characters. The search also looks up website matches by parsing urls to match hostnames rather than scheme or path. Finally the query is filtered by country and category.

func (*Store) UpdateCertReq

func (s *Store) UpdateCertReq(r *models.CertificateRequest) (err error)

UpdateCertReq can create or update a certificate request. The request should be as complete as possible, including an ID generated by the caller.

func (*Store) UpdateVASP

func (s *Store) UpdateVASP(v *pb.VASP) (err error)

UpdateVASP by the VASP ID (required). This method simply overwrites the entire VASP record and does not update individual fields.