proxy

package
v0.0.0-...-a7bc12e Latest Latest
Warning

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

Go to latest
Published: Aug 10, 2026 License: MIT Imports: 3 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Component

type Component struct {
	nmq.ComponentBase
}

func NewComponent

func NewComponent(ctx nmq.Context) *Component

NewComponent 创建网络组件实例

func (*Component) GetInterface

func (c *Component) GetInterface(uuid string) any

GetInterface 获取组件内部某个接口的实现

@param uuid string 接口唯一标识 @return any 接口实现对象或 nil

func (*Component) GetName

func (c *Component) GetName() string

GetName 获取组件名称

@return string 组件名称

func (*Component) GetStatus

func (c *Component) GetStatus() nmq.ComponentStatus

GetStatus 获取组件当前状态

@return ComponentStatus 当前状态

func (*Component) GetVersion

func (c *Component) GetVersion() string

GetVersion 获取组件版本号

@return string 版本号

func (*Component) Init

func (c *Component) Init() error

Init 初始化组件

@param ctx NmqContext 上下文环境 @return error 错误信息

func (*Component) Notify

func (c *Component) Notify(event string, data any)

Notify 接收系统广播事件

@param event string 事件名称 @param data any 附加数据

func (*Component) Reset

func (c *Component) Reset() error

Reset 重置组件

@return error 错误信息

func (*Component) Run

func (c *Component) Run(cmd *cobra.Command, args []string) error

func (*Component) Start

func (c *Component) Start() error

Start 启动组件

@return error 错误信息

func (*Component) Stop

func (c *Component) Stop() error

Stop 停止组件

@return error 错误信息

Directories

Path Synopsis
Package healthcheck 提供主动和被动两种健康检查机制。
Package healthcheck 提供主动和被动两种健康检查机制。
middlewares
tcp
service/loadbalancer/failover
Package failover 实现故障转移(Failover)机制: 当主后端(handler)不可用或返回特定错误状态码时, 自动将请求转发给备用后端(fallbackHandler); 两个后端都不可用时返回 503 Service Unavailable。
Package failover 实现故障转移(Failover)机制: 当主后端(handler)不可用或返回特定错误状态码时, 自动将请求转发给备用后端(fallbackHandler); 两个后端都不可用时返回 503 Service Unavailable。
service/loadbalancer/hrw
Package hrw 实现了 Highest Random Weight (HRW),即 Rendezvous Hashing 一致性哈希负载均衡算法。
Package hrw 实现了 Highest Random Weight (HRW),即 Rendezvous Hashing 一致性哈希负载均衡算法。
service/loadbalancer/mirror
Package mirror 实现 HTTP 请求流量镜像(Traffic Mirroring)。
Package mirror 实现 HTTP 请求流量镜像(Traffic Mirroring)。
service/tcp
Package tcp 提供 TCP 服务的管理和构建能力。
Package tcp 提供 TCP 服务的管理和构建能力。
Package tcp 提供 TCP 服务的加权轮询(Weighted Round Robin)负载均衡器。
Package tcp 提供 TCP 服务的加权轮询(Weighted Round Robin)负载均衡器。
tls

Jump to

Keyboard shortcuts

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