certify

Documentation

Index

• Constants
• func Certify(ctx context.Context, query certifier.QueryComponents, ...) error
• func Publish(ctx context.Context, d *processor.Document, blobStore *blob.BlobStore, ...) error
• func RegisterCertifier(c func() certifier.Certifier, certifierType certifier.CertifierType) error

Constants

const (
	BufferChannelSize int = 1000
)

Functions

func Certify

func Certify(ctx context.Context, query certifier.QueryComponents, emitter certifier.Emitter, handleErr certifier.ErrHandler, poll bool, interval time.Duration) error

Certify queries the graph DB to get the components to scan. Utilizing the registered certifiers, it generates new nodes and attestations.

func Publish

func Publish(ctx context.Context, d *processor.Document, blobStore *blob.BlobStore, pubsub *emitter.EmitterPubSub) error

Publish is used by NATS JetStream to stream the documents and send them to the processor

func RegisterCertifier

func RegisterCertifier(c func() certifier.Certifier, certifierType certifier.CertifierType) error

RegisterCertifier registers the active certifier for to generate attestations