cmgr

Documentation

Index

• Constants
• type Cmgr
  • func NewCmgr(cfg *Config) (Cmgr, error)
• type Config
  • func (c *Config) Adjust()
  • func (c *Config) NeedMetrics() bool
  • func (c *Config) NeedSync() bool
• type StatsPerRule
• type VersionInfo

Constants

const (
	ConnectionTypeActive = "active"
	ConnectionTypeClosed = "closed"
)

Types

type Cmgr

type Cmgr interface {
	ListConnections(connType string, page, pageSize int) []conn.RelayConn

	// AddConnection adds a connection to the connection manager.
	AddConnection(conn conn.RelayConn)

	// RemoveConnection removes a connection from the connection manager.
	RemoveConnection(conn conn.RelayConn)

	// CountConnection returns the number of active connections.
	CountConnection(connType string) int

	GetActiveConnectCntByRelayLabel(label string) int

	// Start starts the connection manager.
	Start(ctx context.Context, errCH chan error)

	// Metrics related
	QueryNodeMetrics(ctx context.Context, req *ms.QueryNodeMetricsReq, refresh bool) (*ms.QueryNodeMetricsResp, error)
	QueryRuleMetrics(ctx context.Context, req *ms.QueryRuleMetricsReq, refresh bool) (*ms.QueryRuleMetricsResp, error)
}

connection manager interface/ TODO support closed connection

func NewCmgr

func NewCmgr(cfg *Config) (Cmgr, error)

type Config

type Config struct {
	SyncURL      string
	MetricsURL   string
	SyncInterval int // in seconds
}

func (*Config) Adjust

func (c *Config) Adjust()

func (*Config) NeedMetrics

func (c *Config) NeedMetrics() bool

func (*Config) NeedSync

func (c *Config) NeedSync() bool

type StatsPerRule

type StatsPerRule struct {
	RelayLabel string `json:"relay_label"`

	Up               int64 `json:"up_bytes"`
	Down             int64 `json:"down_bytes"`
	ConnectionCnt    int   `json:"connection_count"`
	HandShakeLatency int64 `json:"latency_in_ms"`
}

type VersionInfo

type VersionInfo struct {
	Version     string `json:"version"`
	ShortCommit string `json:"short_commit"`
}