processors

Documentation

Index

• type ComplianceProcessor
  • func NewComplianceProcessor(checker *compliance.ComplianceChecker, metrics *metrics.QuantumStorageMetrics, ...) *ComplianceProcessor
  • func (cp *ComplianceProcessor) GetCapabilities() []core.Capability
  • func (cp *ComplianceProcessor) Process(ctx context.Context, req *core.Request) (*core.Response, error)
  • func (cp *ComplianceProcessor) Validate(ctx context.Context, req *core.Request) error
• type QuantumProcessor
  • func NewQuantumProcessor(quantumService *quantum.Service, metrics *metrics.QuantumStorageMetrics, ...) *QuantumProcessor
  • func (qp *QuantumProcessor) GetCapabilities() []core.Capability
  • func (qp *QuantumProcessor) Process(ctx context.Context, req *core.Request) (*core.Response, error)
  • func (qp *QuantumProcessor) Validate(ctx context.Context, req *core.Request) error

Types

type ComplianceProcessor

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

func NewComplianceProcessor

func NewComplianceProcessor(
	checker *compliance.ComplianceChecker,
	metrics *metrics.QuantumStorageMetrics,
	tracer tracing.Tracer,
) *ComplianceProcessor

func (*ComplianceProcessor) GetCapabilities

func (cp *ComplianceProcessor) GetCapabilities() []core.Capability

func (*ComplianceProcessor) Process

func (cp *ComplianceProcessor) Process(ctx context.Context, req *core.Request) (*core.Response, error)

func (*ComplianceProcessor) Validate

func (cp *ComplianceProcessor) Validate(ctx context.Context, req *core.Request) error

type QuantumProcessor

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

func NewQuantumProcessor

func NewQuantumProcessor(
	quantumService *quantum.Service,
	metrics *metrics.QuantumStorageMetrics,
	tracer tracing.Tracer,
) *QuantumProcessor

func (*QuantumProcessor) GetCapabilities

func (qp *QuantumProcessor) GetCapabilities() []core.Capability

func (*QuantumProcessor) Process

func (qp *QuantumProcessor) Process(ctx context.Context, req *core.Request) (*core.Response, error)

func (*QuantumProcessor) Validate

func (qp *QuantumProcessor) Validate(ctx context.Context, req *core.Request) error