namespace

Documentation

Index

• Variables
• type Namespace
  • func (n *Namespace) Close()
  • func (n *Namespace) GetRouter() router.Router
  • func (n *Namespace) Name() string
  • func (n *Namespace) User() string
• type NamespaceManager
  • func NewNamespaceManager() *NamespaceManager
  • func (n *NamespaceManager) Close() error
  • func (mgr *NamespaceManager) CommitNamespaces(nss []*config.Namespace, nss_delete []bool) error
  • func (n *NamespaceManager) GetNamespace(nm string) (*Namespace, bool)
  • func (n *NamespaceManager) GetNamespaceByUser(user string) (*Namespace, bool)
  • func (mgr *NamespaceManager) Init(logger *zap.Logger, nscs []*config.Namespace, tpFetcher router.TopologyFetcher, ...) error
  • func (n *NamespaceManager) RedirectConnections() []error

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")
)

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 struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewNamespaceManager

func NewNamespaceManager() *NamespaceManager

func (*NamespaceManager) Close

func (n *NamespaceManager) Close() error

func (*NamespaceManager) CommitNamespaces

func (mgr *NamespaceManager) CommitNamespaces(nss []*config.Namespace, nss_delete []bool) error

func (*NamespaceManager) GetNamespace

func (n *NamespaceManager) GetNamespace(nm string) (*Namespace, bool)

func (*NamespaceManager) GetNamespaceByUser

func (n *NamespaceManager) GetNamespaceByUser(user string) (*Namespace, bool)

func (*NamespaceManager) Init

func (mgr *NamespaceManager) Init(logger *zap.Logger, nscs []*config.Namespace, tpFetcher router.TopologyFetcher, httpCli *http.Client) error

func (*NamespaceManager) RedirectConnections

func (n *NamespaceManager) RedirectConnections() []error