authz

Documentation

Index

• Variables
• func WithDataSource(source DataSource, pollDuration time.Duration) containers.Option[Engine]
• func WithPollDuration(dur time.Duration) containers.Option[Engine]
• type CachedSource
• type DataSource
• type Engine
  • func NewEngine(ctx context.Context, logger *zap.Logger, source PolicySource, ...) (*Engine, error)
  • func (e *Engine) IsAllowed(ctx context.Context, input map[string]interface{}) (bool, error)
• type PolicySource
• type Verifier

Variables

var (

	// ErrNotModified is returned from a source when the data has not
	// been modified, identified based on the provided hash value
	ErrNotModified = errors.New("not modified")
)

Functions

func WithDataSource

func WithDataSource(source DataSource, pollDuration time.Duration) containers.Option[Engine]

func WithPollDuration

func WithPollDuration(dur time.Duration) containers.Option[Engine]

Types

type CachedSource

type CachedSource[T any] interface {
	Get(_ context.Context, hash []byte) (T, []byte, error)
}

type DataSource

type DataSource CachedSource[map[string]any]

type Engine

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

func NewEngine

func NewEngine(ctx context.Context, logger *zap.Logger, source PolicySource, opts ...containers.Option[Engine]) (*Engine, error)

func (*Engine) IsAllowed

func (e *Engine) IsAllowed(ctx context.Context, input map[string]interface{}) (bool, error)

type PolicySource

type PolicySource CachedSource[[]byte]

type Verifier

type Verifier interface {
	IsAllowed(ctx context.Context, input map[string]any) (bool, error)
}