driver

Documentation

Index

• Constants
• type Handler
• type Registry
  • func NewDefaultRegistry(ctx context.Context, flags *pflag.FlagSet) (Registry, error)
  • func NewMemoryTestRegistry(t *testing.T, namespaces []*namespace.Namespace) Registry
• type RegistryDefault
  • func (r *RegistryDefault) BuildDate() string
  • func (r *RegistryDefault) BuildHash() string
  • func (r *RegistryDefault) BuildVersion() string
  • func (r *RegistryDefault) Config() *config.Provider
  • func (r *RegistryDefault) ExpandEngine() *expand.Engine
  • func (r *RegistryDefault) GetVersion(_ context.Context, _ *acl.GetVersionRequest) (*acl.GetVersionResponse, error)
  • func (r *RegistryDefault) HealthHandler() *healthx.Handler
  • func (r *RegistryDefault) HealthServer() *health.Server
  • func (r *RegistryDefault) Init(ctx context.Context) error
  • func (r *RegistryDefault) Logger() *logrusx.Logger
  • func (r *RegistryDefault) Migrator() persistence.Migrator
  • func (r *RegistryDefault) NamespaceMigrator() namespace.Migrator
  • func (r *RegistryDefault) PermissionEngine() *check.Engine
  • func (r *RegistryDefault) Persister() persistence.Persister
  • func (r *RegistryDefault) ReadGRPCServer() *grpc.Server
  • func (r *RegistryDefault) ReadRouter() http.Handler
  • func (r *RegistryDefault) RelationTupleManager() relationtuple.Manager
  • func (r *RegistryDefault) ServeAll(ctx context.Context) error
  • func (r *RegistryDefault) ServeAllSQA(cmd *cobra.Command) error
  • func (r *RegistryDefault) ServeRead(ctx context.Context) func() error
  • func (r *RegistryDefault) ServeWrite(ctx context.Context) func() error
  • func (r *RegistryDefault) Tracer() *tracing.Tracer
  • func (r *RegistryDefault) WriteGRPCServer() *grpc.Server
  • func (r *RegistryDefault) WriteRouter() http.Handler
  • func (r *RegistryDefault) Writer() herodot.Writer

Constants

const LogrusHookContextKey contextKeys = "logrus hook"

Types

type Handler

type Handler interface {
	RegisterReadRoutes(r *x.ReadRouter)
	RegisterWriteRoutes(r *x.WriteRouter)
	RegisterReadGRPC(s *grpc.Server)
	RegisterWriteGRPC(s *grpc.Server)
}

type Registry

type Registry interface {
	Init(context.Context) error
	BuildVersion() string
	BuildDate() string
	BuildHash() string
	Config() *config.Provider

	x.LoggerProvider
	x.WriterProvider

	relationtuple.ManagerProvider
	namespace.MigratorProvider
	expand.EngineProvider
	check.EngineProvider
	persistence.MigratorProvider
	persistence.Provider

	HealthHandler() *healthx.Handler
	Tracer() *tracing.Tracer

	ReadRouter() http.Handler
	WriteRouter() http.Handler

	ReadGRPCServer() *grpc.Server
	WriteGRPCServer() *grpc.Server

	ServeAll(ctx context.Context) error
	ServeAllSQA(cmd *cobra.Command) error
	ServeRead(ctx context.Context) func() error
	ServeWrite(ctx context.Context) func() error
}

func NewDefaultRegistry

func NewDefaultRegistry(ctx context.Context, flags *pflag.FlagSet) (Registry, error)

func NewMemoryTestRegistry

func NewMemoryTestRegistry(t *testing.T, namespaces []*namespace.Namespace) Registry

type RegistryDefault

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

func (*RegistryDefault) BuildDate

func (r *RegistryDefault) BuildDate() string

func (*RegistryDefault) BuildHash

func (r *RegistryDefault) BuildHash() string

func (*RegistryDefault) BuildVersion

func (r *RegistryDefault) BuildVersion() string

func (*RegistryDefault) Config

func (r *RegistryDefault) Config() *config.Provider

func (*RegistryDefault) ExpandEngine

func (r *RegistryDefault) ExpandEngine() *expand.Engine

func (*RegistryDefault) GetVersion

func (r *RegistryDefault) GetVersion(_ context.Context, _ *acl.GetVersionRequest) (*acl.GetVersionResponse, error)

func (*RegistryDefault) HealthHandler

func (r *RegistryDefault) HealthHandler() *healthx.Handler

func (*RegistryDefault) HealthServer

func (r *RegistryDefault) HealthServer() *health.Server

func (*RegistryDefault) Init

func (r *RegistryDefault) Init(ctx context.Context) error

func (*RegistryDefault) Logger

func (r *RegistryDefault) Logger() *logrusx.Logger

func (*RegistryDefault) Migrator

func (r *RegistryDefault) Migrator() persistence.Migrator

func (*RegistryDefault) NamespaceMigrator

func (r *RegistryDefault) NamespaceMigrator() namespace.Migrator

func (*RegistryDefault) PermissionEngine

func (r *RegistryDefault) PermissionEngine() *check.Engine

func (*RegistryDefault) Persister

func (r *RegistryDefault) Persister() persistence.Persister

func (*RegistryDefault) ReadGRPCServer

func (r *RegistryDefault) ReadGRPCServer() *grpc.Server

func (*RegistryDefault) ReadRouter

func (r *RegistryDefault) ReadRouter() http.Handler

func (*RegistryDefault) RelationTupleManager

func (r *RegistryDefault) RelationTupleManager() relationtuple.Manager

func (*RegistryDefault) ServeAll

func (r *RegistryDefault) ServeAll(ctx context.Context) error

func (*RegistryDefault) ServeAllSQA

func (r *RegistryDefault) ServeAllSQA(cmd *cobra.Command) error

func (*RegistryDefault) ServeRead

func (r *RegistryDefault) ServeRead(ctx context.Context) func() error

func (*RegistryDefault) ServeWrite

func (r *RegistryDefault) ServeWrite(ctx context.Context) func() error

func (*RegistryDefault) Tracer

func (r *RegistryDefault) Tracer() *tracing.Tracer

func (*RegistryDefault) WriteGRPCServer

func (r *RegistryDefault) WriteGRPCServer() *grpc.Server

func (*RegistryDefault) WriteRouter

func (r *RegistryDefault) WriteRouter() http.Handler

func (*RegistryDefault) Writer

func (r *RegistryDefault) Writer() herodot.Writer