redact

type BidiStreamRedactor[Req any, Res any] struct {
	grpc.BidiStreamingServer[Req, Res]
	Resolver  PolicyResolver
	Operation string
}

type Bypass interface {
	CheckInternal(ctx context.Context) bool
}

type ClientStreamRedactor[Req any, Res any] struct {
	grpc.ClientStreamingServer[Req, Res]
	Resolver  PolicyResolver
	Operation string
}

type CustomRedactor func(string) string

type Direction uint8

type DynamicRedactor interface {
	RedactWith(ctx context.Context, resolver PolicyResolver)
}

type EntityFieldAccessor interface {
	ValueOf(context.Context, any, string) (any, bool, error)
	Set(context.Context, any, string, any) error
}

type FieldPolicy struct {
	Mode        PolicyMode
	Transform   func(value any) any
	RuleID      int64
	RuleVersion int32
	Fingerprint string
}

type PolicyMode uint8

type PolicyResolver interface {
	Resolve(ctx context.Context, fieldRef string) (FieldPolicy, bool)
}

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

type Redactor interface {
	Redact()
}

type ResponseEntity struct {
	RecordID int64
	Entity   any
}

type ServerStreamRedactor[Res any] struct {
	grpc.ServerStreamingServer[Res]
	Resolver  PolicyResolver
	Operation string
}

type StorageFieldPolicy struct {
	ID         int64
	TableName  string
	ColumnName string
	Rule       FieldPolicy
}

type StoragePolicyResolver interface {
	ListStoragePolicies(context.Context, string) []StorageFieldPolicy
}

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

type StorageValue struct {
	ID              int64
	StoragePolicyID int64
	RecordID        int64
	Ciphertext      []byte
	Digest          []byte
}

type StorageValueStore interface {
	Find(context.Context, int64, int64) (*StorageValue, error)
	ListByRecords(context.Context, int64, []int64) ([]*StorageValue, error)
	ListByDigest(context.Context, int64, []byte) ([]*StorageValue, error)
	Save(context.Context, *StorageValue) error
	Delete(context.Context, *StorageValue) error
}

type Wrapper func(ctx context.Context) bool