Documentation
¶
Index ¶
- Constants
- Variables
- func Factory() plugins.Factory
- func NewUnknownBufferTypeError(s string) error
- func NewUnknownOutputTypeError(s string) error
- func NewUnknownServiceError(s string) error
- func ResourceKey(input string) string
- type Config
- type DropProcessor
- type Logger
- type MaskProcessor
- type OutputProcessors
- type Stream
- type UnknownBufferTypeError
- type UnknownOutputTypeError
- type UnknownServiceError
Constants ¶
View Source
const DLPluginName = "eopa_dl" // OPA DL plugin
Variables ¶
View Source
var ( ErrNoDefaultPlugin = fmt.Errorf("%s cannot be used without OPA's decision logging", DLPluginName) ErrNoOutputs = errors.New("no outputs configured") )
Functions ¶
func NewUnknownServiceError ¶
func ResourceKey ¶
Types ¶
type Config ¶
type Config struct {
Output json.RawMessage `json:"output"`
Buffer json.RawMessage `json:"buffer"`
// contains filtered or unexported fields
}
type DropProcessor ¶
type DropProcessor struct {
// contains filtered or unexported fields
}
func NewDrop ¶
func NewDrop(pc *service.ParsedConfig, r *registerer) (*DropProcessor, error)
func (*DropProcessor) Process ¶
func (r *DropProcessor) Process(ctx context.Context, m *service.Message) (service.MessageBatch, error)
type Logger ¶
type Logger struct {
// contains filtered or unexported fields
}
func (*Logger) Reconfigure ¶
type MaskProcessor ¶
type MaskProcessor struct {
// contains filtered or unexported fields
}
func NewMask ¶
func NewMask(pc *service.ParsedConfig, r *registerer) (*MaskProcessor, error)
func (*MaskProcessor) Process ¶
func (r *MaskProcessor) Process(ctx context.Context, m *service.Message) (service.MessageBatch, error)
type OutputProcessors ¶
type OutputProcessors struct {
Mask string `json:"mask_decision,omitempty"`
Drop string `json:"drop_decision,omitempty"`
}
func (*OutputProcessors) Extra ¶
func (s *OutputProcessors) Extra() []map[string]any
func (*OutputProcessors) NumOutputProcessors ¶
func (s *OutputProcessors) NumOutputProcessors() (count int)
type UnknownBufferTypeError ¶
type UnknownBufferTypeError struct {
// contains filtered or unexported fields
}
func (*UnknownBufferTypeError) Error ¶
func (e *UnknownBufferTypeError) Error() string
type UnknownOutputTypeError ¶
type UnknownOutputTypeError struct {
// contains filtered or unexported fields
}
func (*UnknownOutputTypeError) Error ¶
func (e *UnknownOutputTypeError) Error() string
type UnknownServiceError ¶
type UnknownServiceError struct {
// contains filtered or unexported fields
}
func (*UnknownServiceError) Error ¶
func (e *UnknownServiceError) Error() string
Click to show internal directories.
Click to hide internal directories.