namespace

Documentation

Index

• Variables
• func NewNamespaceManager() *namespaceManager
• type Namespace
  • func (n *Namespace) Close()
  • func (n *Namespace) GetRouter() router.Router
  • func (n *Namespace) Name() string
  • func (n *Namespace) User() string
• type NamespaceManager

Variables

var (
	ErrDuplicatedUser      = errors.New("duplicated user")
	ErrInvalidSelectorType = errors.New("invalid selector type")

	ErrNilBreakerName              = errors.New("breaker name nil")
	ErrInvalidFailureRateThreshold = errors.New("invalid FailureRateThreshold")
	ErrInvalidopenStatusDurationMs = errors.New("invalid OpenStatusDurationMs")
	ErrInvalidSqlTimeout           = errors.New("invalid sql timeout")

	ErrInvalidScope = errors.New("invalid scope")
)

Functions

func NewNamespaceManager

func NewNamespaceManager() *namespaceManager

Types

type Namespace

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

func (*Namespace) Close

func (n *Namespace) Close()

func (*Namespace) GetRouter

func (n *Namespace) GetRouter() router.Router

func (*Namespace) Name

func (n *Namespace) Name() string

func (*Namespace) User

func (n *Namespace) User() string

type NamespaceManager

type NamespaceManager interface {
	Init(logger *zap.Logger, nscs []*config.Namespace, tpFetcher observer.TopologyFetcher,
		promFetcher metricsreader.PromInfoFetcher, httpCli *http.Client, cfgMgr *mconfig.ConfigManager,
		metricsReader metricsreader.MetricsReader) error
	CommitNamespaces(nss []*config.Namespace, nssDelete []bool) error
	GetNamespace(nm string) (*Namespace, bool)
	GetNamespaceByUser(user string) (*Namespace, bool)
	RedirectConnections() []error
	Ready() bool
	Close() error
}