core

Documentation

Index

• type Capability
• type ComplianceEngine
  • func NewComplianceEngine(checker *compliance.ComplianceChecker, exchange *quantum.KeyExchange, ...) *ComplianceEngine
  • func (ce *ComplianceEngine) ProcessRequest(ctx context.Context, req *Request) (*Response, error)
  • func (ce *ComplianceEngine) RegisterProcessor(name string, processor Processor) error
• type Processor
• type Request
• type RequestType
• type Response
• type Status

Types

type Capability

type Capability string

type ComplianceEngine

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

func NewComplianceEngine

func NewComplianceEngine(
	checker *compliance.ComplianceChecker,
	exchange *quantum.KeyExchange,
	metrics *metrics.QuantumStorageMetrics,
	tracer tracing.Tracer,
) *ComplianceEngine

func (*ComplianceEngine) ProcessRequest

func (ce *ComplianceEngine) ProcessRequest(ctx context.Context, req *Request) (*Response, error)

func (*ComplianceEngine) RegisterProcessor

func (ce *ComplianceEngine) RegisterProcessor(name string, processor Processor) error

type Processor

type Processor interface {
	Process(context.Context, *Request) (*Response, error)
	Validate(context.Context, *Request) error
	GetCapabilities() []Capability
}

type Request

type Request struct {
	ID           string
	Type         RequestType
	Data         []byte
	Metadata     map[string]interface{}
	Priority     int
	Deadline     time.Time
	Requirements []Requirement
}

type RequestType

type RequestType string

type Response

type Response struct {
	RequestID    string
	Status       Status
	Result       []byte
	Metrics      map[string]float64
	CompletedAt  time.Time
	Attestations []Attestation
}

type Status

type Status string

const (
	StatusPending  Status = "pending"
	StatusComplete Status = "complete"
	StatusFailed   Status = "failed"
)