certifier

type Certifier interface {
	// CertifyComponent takes a GUAC component and generates processor.documents that are
	// push to the docChannel to be ingested.
	// Note: there is an implicit contract with "QueryComponents" where the compChan type must be the same as
	// the one used by "components"
	CertifyComponent(ctx context.Context, components interface{}, docChannel chan<- *processor.Document) error
}

type CertifierType string

type Emitter func(*processor.Document) error

type ErrHandler func(error) bool

type QueryComponents interface {
	// GetComponents runs as a goroutine to get the GUAC components that will be certified by the Certifier interface
	// Note: there is an implicit contract with "CertifyComponent" where the components type must be the same as
	// the one used by "compChan"
	GetComponents(ctx context.Context, compChan chan<- interface{}) error
}