topaz

Documentation

Index

• func BuildApp(logOutput logger.Writer, errOutput logger.ErrWriter, configPath config.Path, ...) (*app.Topaz, func(), error)
• func BuildTestApp(logOutput logger.Writer, errOutput logger.ErrWriter, configPath config.Path, ...) (*app.Topaz, func(), error)
• func DefaultGRPCOptions() []grpc.ServerOption
• func DefaultServices() map[string]app.ServiceTypes
• func NewRuntimeResolver(ctx context.Context, logger *zerolog.Logger, cfg *config.Config, ...) (resolvers.RuntimeResolver, func(), error)
• type RuntimeResolver
  • func (r *RuntimeResolver) GetRuntime(ctx context.Context, opaInstanceID, policyName string) (*runtime.Runtime, error)
  • func (r *RuntimeResolver) ListRuntimes(ctx context.Context) (map[string]*runtime.Runtime, error)
  • func (r *RuntimeResolver) PeekRuntime(ctx context.Context, opaInstanceID, policyName string) (*runtime.Runtime, error)
  • func (r *RuntimeResolver) ReloadRuntime(ctx context.Context, opaInstanceID, policyName string) error
  • func (r *RuntimeResolver) RuntimeFromContext(ctx context.Context, policyName string) (*runtime.Runtime, error)
  • func (r *RuntimeResolver) UnloadRuntime(ctx context.Context, opaInstanceID, policyName string)

Functions

func BuildApp

func BuildApp(logOutput logger.Writer, errOutput logger.ErrWriter, configPath config.Path, overrides config.Overrider) (*app.Topaz, func(), error)

func BuildTestApp

func BuildTestApp(logOutput logger.Writer, errOutput logger.ErrWriter, configPath config.Path, overrides config.Overrider) (*app.Topaz, func(), error)

func DefaultGRPCOptions

func DefaultGRPCOptions() []grpc.ServerOption

func DefaultServices

func DefaultServices() map[string]app.ServiceTypes

func NewRuntimeResolver

func NewRuntimeResolver(
	ctx context.Context,
	logger *zerolog.Logger,
	cfg *config.Config,
	ctrlf *controller.Factory,
	decisionLogger decisionlog.DecisionLogger,
	directoryResolver resolvers.DirectoryResolver,
) (resolvers.RuntimeResolver, func(), error)

Types

type RuntimeResolver

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

func (*RuntimeResolver) GetRuntime

func (r *RuntimeResolver) GetRuntime(ctx context.Context, opaInstanceID, policyName string) (*runtime.Runtime, error)

func (*RuntimeResolver) ListRuntimes

func (r *RuntimeResolver) ListRuntimes(ctx context.Context) (map[string]*runtime.Runtime, error)

func (*RuntimeResolver) PeekRuntime

func (r *RuntimeResolver) PeekRuntime(ctx context.Context, opaInstanceID, policyName string) (*runtime.Runtime, error)

func (*RuntimeResolver) ReloadRuntime

func (r *RuntimeResolver) ReloadRuntime(ctx context.Context, opaInstanceID, policyName string) error

func (*RuntimeResolver) RuntimeFromContext

func (r *RuntimeResolver) RuntimeFromContext(ctx context.Context, policyName string) (*runtime.Runtime, error)

func (*RuntimeResolver) UnloadRuntime

func (r *RuntimeResolver) UnloadRuntime(ctx context.Context, opaInstanceID, policyName string)