memdb

Documentation

Index

• type CustomProvidersMemDb
  • func NewCustomProvidersMemDb(ex CustomProvidersStorage, log *zap.Logger, interval time.Duration) (*CustomProvidersMemDb, error)
  • func (mdb *CustomProvidersMemDb) GetProvider(name string) *custom.Provider
  • func (mdb *CustomProvidersMemDb) GetRouteConfig(name string, path string) *custom.RouteConfig
  • func (mdb *CustomProvidersMemDb) Listen()
  • func (mdb *CustomProvidersMemDb) SetProvider(provider *custom.Provider)
  • func (mdb *CustomProvidersMemDb) Stop()
• type CustomProvidersStorage
• type PoliciesStorage
• type RoutesMemDb
  • func NewRoutesMemDb(ex RoutesStorage, ps PoliciesStorage, log *zap.Logger, interval time.Duration) (*RoutesMemDb, error)
  • func (mdb *RoutesMemDb) GetPolicy(id string) *policy.Policy
  • func (mdb *RoutesMemDb) GetRoute(path string) *route.Route
  • func (mdb *RoutesMemDb) Listen()
  • func (mdb *RoutesMemDb) SetPolicy(p *policy.Policy)
  • func (mdb *RoutesMemDb) SetRoute(r *route.Route)
  • func (mdb *RoutesMemDb) Stop()
• type RoutesStorage

Types

type CustomProvidersMemDb

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

func NewCustomProvidersMemDb

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

func (*CustomProvidersMemDb) GetProvider

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

func (*CustomProvidersMemDb) GetRouteConfig

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

func (*CustomProvidersMemDb) Listen

func (mdb *CustomProvidersMemDb) Listen()

func (*CustomProvidersMemDb) SetProvider

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

func (*CustomProvidersMemDb) Stop

func (mdb *CustomProvidersMemDb) Stop()

type CustomProvidersStorage

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

type PoliciesStorage

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

type RoutesMemDb

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

func NewRoutesMemDb

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

func (*RoutesMemDb) GetPolicy

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

func (*RoutesMemDb) GetRoute

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

func (*RoutesMemDb) Listen

func (mdb *RoutesMemDb) Listen()

func (*RoutesMemDb) SetPolicy

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

func (*RoutesMemDb) SetRoute

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

func (*RoutesMemDb) Stop

func (mdb *RoutesMemDb) Stop()

type RoutesStorage

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