storage

package
v0.6.3 Latest Latest
Warning

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

 Go to latest Published: Apr 24, 2020 License: Apache-2.0 Imports: 18 Imported by: 0

Documentation

Index

Constants

View Source 
const ChangefeedTableName = "changefeed"

ChangefeedTableName returns the name used for the changefeed table

View Source 
const TUFFileTableName = "tuf_files"

TUFFileTableName returns the name used for the tuf file table

Variables

View Source 
var (
	// TUFFilesRethinkTable is the table definition of notary server's TUF metadata files
	TUFFilesRethinkTable = rethinkdb.Table{
		Name:       RDBTUFFile{}.TableName(),
		PrimaryKey: "gun_role_version",
		SecondaryIndexes: map[string][]string{

			"gun":                nil,
			"timestamp_checksum": nil,
			// contains filtered or unexported fields
		},

		Config: map[string]string{
			"write_acks": "majority",
		},
		JSONUnmarshaller: rdbTUFFileFromJSON,
	}

	// ChangeRethinkTable is the table definition for changefeed objects
	ChangeRethinkTable = rethinkdb.Table{
		Name:       Change{}.TableName(),
		PrimaryKey: "id",
		SecondaryIndexes: map[string][]string{
			"rdb_created_at_id":     {"created_at", "id"},
			"rdb_gun_created_at_id": {"gun", "created_at", "id"},
		},
		Config: map[string]string{
			"write_acks": "majority",
		},
		JSONUnmarshaller: rdbChangeFromJSON,
	}
)

Functions

func CreateChangefeedTable added in v0.5.0 

func CreateChangefeedTable(db gorm.DB) error

CreateChangefeedTable creates the DB table for Changefeed

func CreateTUFTable 

func CreateTUFTable(db gorm.DB) error

CreateTUFTable creates the DB table for TUFFile

Types

type Change added in v0.5.0 

type Change struct {
	ID        string    `gorethink:"id,omitempty" gorm:"primary_key" sql:"not null"`
	CreatedAt time.Time `gorethink:"created_at"`
	GUN       string    `gorethink:"gun" gorm:"column:gun" sql:"type:varchar(255);not null"`
	Version   int       `gorethink:"version" sql:"not null"`
	SHA256    string    `gorethink:"sha256" gorm:"column:sha256" sql:"type:varchar(64);"`
	Category  string    `gorethink:"category" sql:"type:varchar(20);not null;"`
}

Change defines the fields required for an object in the changefeed

func (Change) TableName added in v0.5.0 

func (rdb Change) TableName() string

TableName sets a specific table name for Changefeed

type ErrBadQuery added in v0.5.1 

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

ErrBadQuery is used when the parameters provided cannot be appropriately coerced.

func (ErrBadQuery) Error added in v0.5.1 

func (err ErrBadQuery) Error() string

type ErrKeyExists 

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

ErrKeyExists is returned when a key already exists

func (ErrKeyExists) Error 

func (err ErrKeyExists) Error() string

ErrKeyExists is returned when a key already exists

type ErrNoKey 

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

ErrNoKey is returned when no timestamp key is found

func (ErrNoKey) Error 

func (err ErrNoKey) Error() string

ErrNoKey is returned when no timestamp key is found

type ErrNotFound 

type ErrNotFound struct{}

ErrNotFound is returned when TUF metadata isn't found for a specific record

func (ErrNotFound) Error 

func (err ErrNotFound) Error() string

Error implements error

type ErrOldVersion 

type ErrOldVersion struct{}

ErrOldVersion is returned when a newer version of TUF metadata is already available

func (ErrOldVersion) Error 

func (err ErrOldVersion) Error() string

ErrOldVersion is returned when a newer version of TUF metadata is already available

type KeyStore 

type KeyStore interface {
	// GetKey returns the algorithm and public key for the given GUN and role.
	// If the GUN+role don't exist, returns an error.
	GetKey(gun, role string) (algorithm string, public []byte, err error)

	// SetKey sets the algorithm and public key for the given GUN and role if
	// it doesn't already exist.  Otherwise an error is returned.
	SetKey(gun, role, algorithm string, public []byte) error
}

KeyStore provides a minimal interface for managing key persistence

type MemStorage 

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

MemStorage is really just designed for dev and testing. It is very inefficient in many scenarios

func NewMemStorage 

func NewMemStorage() *MemStorage

NewMemStorage instantiates a memStorage instance

func (*MemStorage) Delete 

func (st *MemStorage) Delete(gun data.GUN) error

Delete deletes all the metadata for a given GUN

func (*MemStorage) GetChanges added in v0.5.0 

func (st *MemStorage) GetChanges(changeID string, records int, filterName string) ([]Change, error)

GetChanges returns a []Change starting from but excluding the record identified by changeID. In the context of the memory store, changeID is simply an index into st.changes. The ID of a change is its index+1, both to match the SQL implementations, and so that the first change can be retrieved by providing ID 0.

func (*MemStorage) GetChecksum 

func (st *MemStorage) GetChecksum(gun data.GUN, role data.RoleName, checksum string) (*time.Time, []byte, error)

GetChecksum returns the createupdate date and metadata for a given role, under a GUN.

func (*MemStorage) GetCurrent 

func (st *MemStorage) GetCurrent(gun data.GUN, role data.RoleName) (*time.Time, []byte, error)

GetCurrent returns the createupdate date metadata for a given role, under a GUN.

func (*MemStorage) GetVersion added in v0.5.1 

func (st *MemStorage) GetVersion(gun data.GUN, role data.RoleName, version int) (*time.Time, []byte, error)

GetVersion gets a specific TUF record by its version

func (*MemStorage) UpdateCurrent 

func (st *MemStorage) UpdateCurrent(gun data.GUN, update MetaUpdate) error

UpdateCurrent updates the meta data for a specific role

func (*MemStorage) UpdateMany 

func (st *MemStorage) UpdateMany(gun data.GUN, updates []MetaUpdate) error

UpdateMany updates multiple TUF records

type MetaStore 

type MetaStore interface {
	// UpdateCurrent adds new metadata version for the given GUN if and only
	// if it's a new role, or the version is greater than the current version
	// for the role. Otherwise an error is returned.
	UpdateCurrent(gun data.GUN, update MetaUpdate) error

	// UpdateMany adds multiple new metadata for the given GUN.  It can even
	// add multiple versions for the same role, so long as those versions are
	// all unique and greater than any current versions.  Otherwise,
	// none of the metadata is added, and an error is be returned.
	UpdateMany(gun data.GUN, updates []MetaUpdate) error

	// GetCurrent returns the modification date and data part of the metadata for
	// the latest version of the given GUN and role.  If there is no data for
	// the given GUN and role, an error is returned.
	GetCurrent(gun data.GUN, tufRole data.RoleName) (created *time.Time, data []byte, err error)

	// GetChecksum returns the given TUF role file and creation date for the
	// GUN with the provided checksum. If the given (gun, role, checksum) are
	// not found, it returns storage.ErrNotFound
	GetChecksum(gun data.GUN, tufRole data.RoleName, checksum string) (created *time.Time, data []byte, err error)

	// GetVersion returns the given TUF role file and creation date for the
	// GUN with the provided version. If the given (gun, role, version) are
	// not found, it returns storage.ErrNotFound
	GetVersion(gun data.GUN, tufRole data.RoleName, version int) (created *time.Time, data []byte, err error)

	// Delete removes all metadata for a given GUN.  It does not return an
	// error if no metadata exists for the given GUN.
	Delete(gun data.GUN) error

	// GetChanges returns an ordered slice of changes. It starts from
	// the change matching changeID, but excludes this change from the results
	// on the assumption that if a user provides an ID, they've seen that change.
	// If changeID is 0, it starts from the
	// beginning, and if changeID is -1, it starts from the most recent
	// change. The number of results returned is limited by records.
	// If records is negative, we will return that number of changes preceding
	// the given changeID.
	// The returned []Change should always be ordered oldest to newest.
	GetChanges(changeID string, records int, filterName string) ([]Change, error)
}

MetaStore holds the methods that are used for a Metadata Store

type MetaUpdate 

type MetaUpdate struct {
	Role    data.RoleName
	Version int
	Data    []byte
}

MetaUpdate packages up the fields required to update a TUF record

type RDBTUFFile added in v0.3.0 

type RDBTUFFile struct {
	rethinkdb.Timing
	GunRoleVersion []interface{} `gorethink:"gun_role_version"`
	Gun            string        `gorethink:"gun"`
	Role           string        `gorethink:"role"`
	Version        int           `gorethink:"version"`
	SHA256         string        `gorethink:"sha256"`
	Data           []byte        `gorethink:"data"`
	TSchecksum     string        `gorethink:"timestamp_checksum"`
}

RDBTUFFile is a TUF file record

func (RDBTUFFile) TableName added in v0.3.0 

func (r RDBTUFFile) TableName() string

TableName returns the table name for the record type

type RethinkDB added in v0.3.0 

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

RethinkDB implements a MetaStore against the Rethink Database

func NewRethinkDBStorage added in v0.3.0 

func NewRethinkDBStorage(dbName, user, password string, sess *gorethink.Session) RethinkDB

NewRethinkDBStorage initializes a RethinkDB object

func (RethinkDB) Bootstrap added in v0.3.0 

func (rdb RethinkDB) Bootstrap() error

Bootstrap sets up the database and tables, also creating the notary server user with appropriate db permission

func (RethinkDB) CheckHealth added in v0.3.0 

func (rdb RethinkDB) CheckHealth() error

CheckHealth checks that all tables and databases exist and are query-able

func (RethinkDB) Delete added in v0.3.0 

func (rdb RethinkDB) Delete(gun data.GUN) error

Delete removes all metadata for a given GUN. It does not return an error if no metadata exists for the given GUN.

func (RethinkDB) GetChanges added in v0.5.0 

func (rdb RethinkDB) GetChanges(changeID string, pageSize int, filterName string) ([]Change, error)

GetChanges returns up to pageSize changes starting from changeID. It uses the blackout to account for RethinkDB's eventual consistency model

func (RethinkDB) GetChecksum added in v0.3.0 

func (rdb RethinkDB) GetChecksum(gun data.GUN, role data.RoleName, checksum string) (created *time.Time, data []byte, err error)

GetChecksum returns the given TUF role file and creation date for the GUN with the provided checksum. If the given (gun, role, checksum) are not found, it returns storage.ErrNotFound

func (RethinkDB) GetCurrent added in v0.3.0 

func (rdb RethinkDB) GetCurrent(gun data.GUN, role data.RoleName) (created *time.Time, data []byte, err error)

GetCurrent returns the modification date and data part of the metadata for the latest version of the given GUN and role. If there is no data for the given GUN and role, an error is returned.

func (RethinkDB) GetVersion added in v0.5.1 

func (rdb RethinkDB) GetVersion(gun data.GUN, role data.RoleName, version int) (*time.Time, []byte, error)

GetVersion gets a specific TUF record by its version

func (RethinkDB) UpdateCurrent added in v0.3.0 

func (rdb RethinkDB) UpdateCurrent(gun data.GUN, update MetaUpdate) error

UpdateCurrent adds new metadata version for the given GUN if and only if it's a new role, or the version is greater than the current version for the role. Otherwise an error is returned.

func (RethinkDB) UpdateMany added in v0.3.0 

func (rdb RethinkDB) UpdateMany(gun data.GUN, updates []MetaUpdate) error

UpdateMany adds multiple new metadata for the given GUN. RethinkDB does not support transactions, therefore we will attempt to insert the timestamp last as this represents a published version of the repo. However, we will insert all other role data in alphabetical order first, and also include the associated timestamp checksum so that we can easily roll back this pseudotransaction

type SQLChange added in v0.5.1 

type SQLChange struct {
	ID        uint `gorm:"primary_key" sql:"not null" json:",string"`
	CreatedAt time.Time
	GUN       string `gorm:"column:gun" sql:"type:varchar(255);not null"`
	Version   int    `sql:"not null"`
	SHA256    string `gorm:"column:sha256" sql:"type:varchar(64);"`
	Category  string `sql:"type:varchar(20);not null;"`
}

SQLChange defines the fields required for an object in the changefeed

func (SQLChange) TableName added in v0.5.1 

func (c SQLChange) TableName() string

TableName sets a specific table name for Changefeed

type SQLStorage 

type SQLStorage struct {
	gorm.DB
}

SQLStorage implements a versioned store using a relational database. See server/storage/models.go

func NewSQLStorage 

func NewSQLStorage(dialect string, args ...interface{}) (*SQLStorage, error)

NewSQLStorage is a convenience method to create a SQLStorage

func (*SQLStorage) CheckHealth 

func (db *SQLStorage) CheckHealth() error

CheckHealth asserts that the tuf_files table is present

func (*SQLStorage) Delete 

func (db *SQLStorage) Delete(gun data.GUN) error

Delete deletes all the records for a specific GUN - we have to do a hard delete using Unscoped otherwise we can't insert for that GUN again

func (*SQLStorage) GetChanges added in v0.5.0 

func (db *SQLStorage) GetChanges(changeID string, records int, filterName string) ([]Change, error)

GetChanges returns up to pageSize changes starting from changeID.

func (*SQLStorage) GetChecksum 

func (db *SQLStorage) GetChecksum(gun data.GUN, tufRole data.RoleName, checksum string) (*time.Time, []byte, error)

GetChecksum gets a specific TUF record by its hex checksum

func (*SQLStorage) GetCurrent 

func (db *SQLStorage) GetCurrent(gun data.GUN, tufRole data.RoleName) (*time.Time, []byte, error)

GetCurrent gets a specific TUF record

func (*SQLStorage) GetVersion added in v0.5.1 

func (db *SQLStorage) GetVersion(gun data.GUN, tufRole data.RoleName, version int) (*time.Time, []byte, error)

GetVersion gets a specific TUF record by its version

func (*SQLStorage) UpdateCurrent 

func (db *SQLStorage) UpdateCurrent(gun data.GUN, update MetaUpdate) error

UpdateCurrent updates a single TUF.

func (*SQLStorage) UpdateMany 

func (db *SQLStorage) UpdateMany(gun data.GUN, updates []MetaUpdate) error

UpdateMany atomically updates many TUF records in a single transaction

type TUFFile 

type TUFFile struct {
	gorm.Model
	Gun     string `sql:"type:varchar(255);not null"`
	Role    string `sql:"type:varchar(255);not null"`
	Version int    `sql:"not null"`
	SHA256  string `gorm:"column:sha256" sql:"type:varchar(64);"`
	Data    []byte `sql:"type:longblob;not null"`
}

TUFFile represents a TUF file in the database

func (TUFFile) TableName 

func (g TUFFile) TableName() string

TableName sets a specific table name for TUFFile

type TUFMetaStorage added in v0.3.0 

type TUFMetaStorage struct {
	MetaStore
	// contains filtered or unexported fields
}

TUFMetaStorage wraps a MetaStore in order to walk the TUF tree for GetCurrent in a consistent manner, by always starting from a current timestamp and then looking up other data by hash

func NewTUFMetaStorage added in v0.3.0 

func NewTUFMetaStorage(m MetaStore) *TUFMetaStorage

NewTUFMetaStorage instantiates a TUFMetaStorage instance

func (TUFMetaStorage) Bootstrap added in v0.3.0 

func (tms TUFMetaStorage) Bootstrap() error

Bootstrap the store with tables if possible

func (TUFMetaStorage) GetChecksum added in v0.3.0 

func (tms TUFMetaStorage) GetChecksum(gun data.GUN, tufRole data.RoleName, checksum string) (*time.Time, []byte, error)

GetChecksum gets a specific TUF record by checksum, also checking the internal cache

func (TUFMetaStorage) GetCurrent added in v0.3.0 

func (tms TUFMetaStorage) GetCurrent(gun data.GUN, tufRole data.RoleName) (*time.Time, []byte, error)

GetCurrent gets a specific TUF record, by walking from the current Timestamp to other metadata by checksum

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.