memdb

package
v1.34.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jul 30, 2024 License: MIT Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type CustomProvidersMemDb added in v1.3.0

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

func NewCustomProvidersMemDb added in v1.3.0

func NewCustomProvidersMemDb(ex CustomProvidersStorage, log *zap.Logger, interval time.Duration) (*CustomProvidersMemDb, error)

func (*CustomProvidersMemDb) GetProvider added in v1.3.0

func (mdb *CustomProvidersMemDb) GetProvider(name string) *custom.Provider

func (*CustomProvidersMemDb) GetRouteConfig added in v1.3.0

func (mdb *CustomProvidersMemDb) GetRouteConfig(name string, path string) *custom.RouteConfig

func (*CustomProvidersMemDb) Listen added in v1.3.0

func (mdb *CustomProvidersMemDb) Listen()

func (*CustomProvidersMemDb) SetProvider added in v1.3.0

func (mdb *CustomProvidersMemDb) SetProvider(provider *custom.Provider)

func (*CustomProvidersMemDb) Stop added in v1.3.0

func (mdb *CustomProvidersMemDb) Stop()

type CustomProvidersStorage added in v1.3.0

type CustomProvidersStorage interface {
	GetCustomProviders() ([]*custom.Provider, error)
	GetUpdatedCustomProviders(updatedAt int64) ([]*custom.Provider, error)
}

type PoliciesStorage added in v1.13.0

type PoliciesStorage interface {
	GetAllPolicies() ([]*policy.Policy, error)
	GetUpdatedPolicies(updatedAt int64) ([]*policy.Policy, error)
}

type RoutesMemDb added in v1.7.0

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

func NewRoutesMemDb added in v1.7.0

func NewRoutesMemDb(ex RoutesStorage, ps PoliciesStorage, log *zap.Logger, interval time.Duration) (*RoutesMemDb, error)

func (*RoutesMemDb) GetPolicy added in v1.13.0

func (mdb *RoutesMemDb) GetPolicy(id string) *policy.Policy

func (*RoutesMemDb) GetRoute added in v1.7.0

func (mdb *RoutesMemDb) GetRoute(path string) *route.Route

func (*RoutesMemDb) Listen added in v1.7.0

func (mdb *RoutesMemDb) Listen()

func (*RoutesMemDb) SetPolicy added in v1.13.0

func (mdb *RoutesMemDb) SetPolicy(p *policy.Policy)

func (*RoutesMemDb) SetRoute added in v1.7.0

func (mdb *RoutesMemDb) SetRoute(r *route.Route)

func (*RoutesMemDb) Stop added in v1.7.0

func (mdb *RoutesMemDb) Stop()

type RoutesStorage added in v1.7.0

type RoutesStorage interface {
	GetRoutes() ([]*route.Route, error)
	GetUpdatedRoutes(updatedAt int64) ([]*route.Route, error)
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL