engine

package
v0.4.1 Latest Latest
Warning

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

 Go to latest Published: Feb 6, 2019 License: GPL-3.0 Imports: 12 Imported by: 6

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var CacheRevocationChecks = true

Functions

This section is empty.

Types

type Engine 

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

There is one engine per perspective (a perspective is a controlling entity)

func NewEngine 

func NewEngine(ctx context.Context, state iapi.WaveState, st iapi.StorageInterface, perspective *iapi.EntitySecrets, perspectiveLoc iapi.LocationSchemeInstance) (*Engine, error)

func NewEngineWithNoPerspective 

func NewEngineWithNoPerspective(ctx context.Context, state iapi.WaveState, st iapi.StorageInterface) (*Engine, error)

func (*Engine) CheckAttestation 

func (e *Engine) CheckAttestation(ctx context.Context, d *iapi.Attestation) (*Validity, error)

Unlike checkDot, this should not touch the DB, it is a read-only operation

func (*Engine) CheckEntity 

func (e *Engine) CheckEntity(ctx context.Context, ent *iapi.Entity) (*Validity, error)

func (*Engine) CheckNameDeclaration added in v0.2.0 

func (e *Engine) CheckNameDeclaration(ctx context.Context, nd *iapi.NameDeclaration) (*Validity, error)

func (*Engine) InsertAttestation 

func (e *Engine) InsertAttestation(ctx context.Context, att *iapi.Attestation) error

External function: insert a DOT learned out of band

func (*Engine) InsertReverseName added in v0.2.0 

func (e *Engine) InsertReverseName(ctx context.Context, name string, hi iapi.HashSchemeInstance) wve.WVE

func (*Engine) IsAttestationRevoked added in v0.2.1 

func (e *Engine) IsAttestationRevoked(att *iapi.Attestation) (bool, error)

func (*Engine) IsEntityRevoked added in v0.2.1 

func (e *Engine) IsEntityRevoked(ent *iapi.Entity) (bool, error)

func (*Engine) IsNameDeclarationRevoked added in v0.2.1 

func (e *Engine) IsNameDeclarationRevoked(nd *iapi.NameDeclaration) (bool, error)

func (*Engine) LookupAttestationInPerspective 

func (e *Engine) LookupAttestationInPerspective(ctx context.Context, hash iapi.HashSchemeInstance, location iapi.LocationSchemeInstance) (*iapi.Attestation, *Validity, error)

func (*Engine) LookupAttestationNoPerspective 

func (e *Engine) LookupAttestationNoPerspective(ctx context.Context, hash iapi.HashSchemeInstance, verifierKey []byte, location iapi.LocationSchemeInstance) (*iapi.Attestation, *Validity, error)

This should try find and decrypt a dot given the hash and aesk. No information from our perspective (active entity) is used

func (*Engine) LookupAttestationsFrom 

func (e *Engine) LookupAttestationsFrom(ctx context.Context, entityHash iapi.HashSchemeInstance, filter *iapi.LookupFromFilter) (chan *LookupResult, chan error)

External function: get dots granted from an entity on a namespace. global grants will also be returned. The returned channel must be consumed completely, or the context must be cancelled

func (*Engine) LookupAttestationsTo 

func (e *Engine) LookupAttestationsTo(ctx context.Context, entityHash iapi.HashSchemeInstance, filter *iapi.LookupFromFilter) (chan *LookupResult, chan error)

func (*Engine) LookupEntity 

func (e *Engine) LookupEntity(ctx context.Context, hash iapi.HashSchemeInstance, loc iapi.LocationSchemeInstance) (*iapi.Entity, *Validity, error)

func (*Engine) LookupFullName added in v0.2.0 

func (e *Engine) LookupFullName(ctx context.Context, attester iapi.HashSchemeInstance, name string) ([]*iapi.NameDeclaration, wve.WVE)

func (*Engine) LookupName added in v0.2.0 

func (e *Engine) LookupName(ctx context.Context, attester iapi.HashSchemeInstance, name string) (*iapi.NameDeclaration, wve.WVE)

func (*Engine) LookupNameDeclaration added in v0.2.1 

func (e *Engine) LookupNameDeclaration(ctx context.Context, hi iapi.HashSchemeInstance, loc iapi.LocationSchemeInstance) (*iapi.NameDeclaration, *Validity, error)

func (*Engine) LookupReverseName added in v0.2.0 

func (e *Engine) LookupReverseName(ctx context.Context, hi iapi.HashSchemeInstance) (string, wve.WVE)

func (*Engine) MarkEntityInterestingAndQueueForSync 

func (e *Engine) MarkEntityInterestingAndQueueForSync(dest *iapi.Entity, loc iapi.LocationSchemeInstance) error

This function should be quick. Processing should happen elsewhere

func (*Engine) Perspective added in v0.2.0 

func (e *Engine) Perspective() *iapi.EntitySecrets

func (*Engine) PerspectiveLocation added in v0.2.0 

func (e *Engine) PerspectiveLocation() iapi.LocationSchemeInstance

func (*Engine) ResetRevocationCache added in v0.2.1 

func (e *Engine) ResetRevocationCache(ctx context.Context)

func (*Engine) ResyncEntireGraph 

func (e *Engine) ResyncEntireGraph(ctx context.Context) error

func (*Engine) SyncStatus 

func (e *Engine) SyncStatus(ctx context.Context) (*SyncStatus, error)

func (*Engine) WaitForEmptySyncQueue 

func (e *Engine) WaitForEmptySyncQueue() chan struct{}

The returned channel will be closed the next time the sync queue is empty

type EngineDecryptionContext 

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

func NewEngineDecryptionContext 

func NewEngineDecryptionContext(e *Engine) *EngineDecryptionContext

The map is just for IBE keys decrypting the partition. The OAQUE keys must come from E

func (*EngineDecryptionContext) AttestationByHashLoc added in v0.2.1 

func (dctx *EngineDecryptionContext) AttestationByHashLoc(ctx context.Context, hash iapi.HashSchemeInstance, loc iapi.LocationSchemeInstance) (*iapi.Attestation, wve.WVE)

func (*EngineDecryptionContext) AutoLoadPartitionSecrets added in v0.2.0 

func (dctx *EngineDecryptionContext) AutoLoadPartitionSecrets(v bool)

func (*EngineDecryptionContext) EntityByHashLoc 

func (dctx *EngineDecryptionContext) EntityByHashLoc(ctx context.Context, hash iapi.HashSchemeInstance, loc iapi.LocationSchemeInstance) (*iapi.Entity, wve.WVE)

func (*EngineDecryptionContext) LoadAllPartitionSecrets added in v0.2.0 

func (dctx *EngineDecryptionContext) LoadAllPartitionSecrets(issuer iapi.HashSchemeInstance) wve.WVE

func (*EngineDecryptionContext) SetPartitionSecrets 

func (dctx *EngineDecryptionContext) SetPartitionSecrets(m map[int]iapi.EntitySecretKeySchemeInstance)

func (*EngineDecryptionContext) SetProverKey 

func (dctx *EngineDecryptionContext) SetProverKey(k []byte)

func (*EngineDecryptionContext) SetVerifierKey 

func (dctx *EngineDecryptionContext) SetVerifierKey(k []byte)

func (*EngineDecryptionContext) WR1AttesterDirectDecryptionKey added in v0.2.1 

func (dctx *EngineDecryptionContext) WR1AttesterDirectDecryptionKey(ctx context.Context, onResult func(k iapi.EntitySecretKeySchemeInstance) bool) error

func (*EngineDecryptionContext) WR1DirectDecryptionKey 

func (dctx *EngineDecryptionContext) WR1DirectDecryptionKey(ctx context.Context, dst iapi.HashSchemeInstance, onResult func(k iapi.EntitySecretKeySchemeInstance) bool) error

func (*EngineDecryptionContext) WR1EntityFromHash added in v0.2.1 

func (dctx *EngineDecryptionContext) WR1EntityFromHash(ctx context.Context, hi iapi.HashSchemeInstance, loc iapi.LocationSchemeInstance) (*iapi.Entity, error)

func (*EngineDecryptionContext) WR1IBEKeysForPartitionLabel 

func (dctx *EngineDecryptionContext) WR1IBEKeysForPartitionLabel(ctx context.Context, dst iapi.HashSchemeInstance, onResult func(k iapi.EntitySecretKeySchemeInstance) bool) error

func (*EngineDecryptionContext) WR1OAQUEKeysForContent 

func (dctx *EngineDecryptionContext) WR1OAQUEKeysForContent(ctx context.Context, dst iapi.HashSchemeInstance, delegable bool, slots [][]byte, onResult func(k iapi.SlottedSecretKey) bool) error

func (*EngineDecryptionContext) WR1ProverBodyKey 

func (dctx *EngineDecryptionContext) WR1ProverBodyKey(ctx context.Context) []byte

func (*EngineDecryptionContext) WR1VerifierBodyKey 

func (dctx *EngineDecryptionContext) WR1VerifierBodyKey(ctx context.Context) []byte

type Filter 

type Filter struct {
	//Like namespace and permissions and stuff
	//backend might be able to index some of it
	//also validity
	Valid *bool
}

type LookupResult 

type LookupResult struct {
	//The dot but also its validity
	Attestation    *iapi.Attestation
	KnownLocations []iapi.LocationSchemeInstance
	Validity       *Validity
}

type SyncStatus 

type SyncStatus struct {
	WaitSyncEmpty       chan struct{}
	StorageStatus       map[string]iapi.StorageDriverStatus
	TotalSyncRequests   int64
	TotalCompletedSyncs int64
}

type Validity 

type Validity struct {
	//Like if revoked / expired / entExpired etc
	//shared between entity and dot
	Valid        bool
	Revoked      bool
	Expired      bool
	NotValidYet  bool
	Malformed    bool
	NotDecrypted bool

	//Only for dots
	SrcInvalid bool
	DstInvalid bool

	Message string
}

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.