mirror of
https://github.com/open-policy-agent/opa.git
synced 2026-08-13 03:42:35 -06:00
Torin Sandall
c786fc9d33
These changes update the storage layer to support multi-reader/single-writer txns: - Writers can read their own writes - Writers can rollback changes - Readers only see writes after a successful commit - Readers can progress during a write txn and only block during a commit These changes also refactor the trigger interface to better support transactions.
116 lines
3.0 KiB
Go
116 lines
3.0 KiB
Go
// Copyright 2016 The OPA Authors. All rights reserved.
|
|
// Use of this source code is governed by an Apache2
|
|
// license that can be found in the LICENSE file.
|
|
|
|
package storage
|
|
|
|
import (
|
|
"fmt"
|
|
)
|
|
|
|
const (
|
|
// InternalErr indicates an unknown, internal error has occurred.
|
|
InternalErr = "storage_internal_error"
|
|
|
|
// NotFoundErr indicates the path used in the storage operation does not
|
|
// locate a document.
|
|
NotFoundErr = "storage_not_found_error"
|
|
|
|
// InvalidPatchErr indicates an invalid patch/write was issued. The patch
|
|
// was rejected.
|
|
InvalidPatchErr = "storage_invalid_patch_error"
|
|
|
|
// InvalidTransactionErr indicates an invalid operation was performed
|
|
// inside of the transaction.
|
|
InvalidTransactionErr = "storage_invalid_txn_error"
|
|
|
|
// TriggersNotSupportedErr indicates the caller attempted to register a
|
|
// trigger against a store that does not support them.
|
|
TriggersNotSupportedErr = "storage_triggers_not_supported_error"
|
|
|
|
// WritesNotSupportedErr indicate the caller attempted to perform a write
|
|
// against a store that does not support them.
|
|
WritesNotSupportedErr = "storage_writes_not_supported_error"
|
|
|
|
// PolicyNotSupportedErr indicate the caller attempted to perform a policy
|
|
// management operation against a store that does not support them.
|
|
PolicyNotSupportedErr = "storage_policy_not_supported_error"
|
|
|
|
// IndexingNotSupportedErr indicate the caller attempted to perform an
|
|
// indexing operation against a store that does not support them.
|
|
IndexingNotSupportedErr = "storage_indexing_not_supported_error"
|
|
)
|
|
|
|
// Error is the error type returned by the storage layer.
|
|
type Error struct {
|
|
Code string `json:"code"`
|
|
Message string `json:"message"`
|
|
}
|
|
|
|
func (err *Error) Error() string {
|
|
if err.Message != "" {
|
|
return fmt.Sprintf("%v: %v", err.Code, err.Message)
|
|
}
|
|
return string(err.Code)
|
|
}
|
|
|
|
// IsNotFound returns true if this error is a NotFoundErr.
|
|
func IsNotFound(err error) bool {
|
|
switch err := err.(type) {
|
|
case *Error:
|
|
return err.Code == NotFoundErr
|
|
}
|
|
return false
|
|
}
|
|
|
|
// IsInvalidPatch returns true if this error is a InvalidPatchErr.
|
|
func IsInvalidPatch(err error) bool {
|
|
switch err := err.(type) {
|
|
case *Error:
|
|
return err.Code == InvalidPatchErr
|
|
}
|
|
return false
|
|
}
|
|
|
|
// IsInvalidTransaction returns true if this error is a InvalidTransactionErr.
|
|
func IsInvalidTransaction(err error) bool {
|
|
switch err := err.(type) {
|
|
case *Error:
|
|
return err.Code == InvalidTransactionErr
|
|
}
|
|
return false
|
|
}
|
|
|
|
// IsIndexingNotSupported returns true if this error is a IndexingNotSupportedErr.
|
|
func IsIndexingNotSupported(err error) bool {
|
|
switch err := err.(type) {
|
|
case *Error:
|
|
return err.Code == IndexingNotSupportedErr
|
|
}
|
|
return false
|
|
}
|
|
|
|
func triggersNotSupportedError() *Error {
|
|
return &Error{
|
|
Code: TriggersNotSupportedErr,
|
|
}
|
|
}
|
|
|
|
func writesNotSupportedError() *Error {
|
|
return &Error{
|
|
Code: WritesNotSupportedErr,
|
|
}
|
|
}
|
|
|
|
func policyNotSupportedError() *Error {
|
|
return &Error{
|
|
Code: PolicyNotSupportedErr,
|
|
}
|
|
}
|
|
|
|
func indexingNotSupportedError() *Error {
|
|
return &Error{
|
|
Code: IndexingNotSupportedErr,
|
|
}
|
|
}
|