transport

type Config struct {
	Address              string
	ConnectTimeout       time.Duration
	ReadTimeout          time.Duration
	WriteTimeout         time.Duration
	HeartbeatInterval    time.Duration
	BufferSize           int
	CompressionEnabled   bool
	CompressionThreshold int
}

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

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

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

type ManagerConfig struct {
	WSAddress           string        // WebSocket 地址
	GRPCAddress         string        // gRPC 地址
	HTTPAddress         string        // HTTP 地址
	APIKey              string        // API Key (用于 HTTP transport)
	EnabledTransports   []string      // 启用的传输协议 (websocket, grpc, http)
	MaxRetries          int           // 最大重试次数
	RetryDelay          time.Duration // 重试延迟
	HealthCheckInterval time.Duration // 健康检查间隔
	FailoverThreshold   int           // 触发故障转移的连续失败次数
	PingInterval        time.Duration // Ping 间隔
	MaxSendRetries      int           // 消息发送最大重试次数
}

type State uint8

type Transport interface {
	Connect(ctx context.Context) error
	Close() error
	Send(ctx context.Context, envelope *message.Envelope) error
	Receive(ctx context.Context) (*message.Envelope, error)
	State() State
	IsHealthy() bool
}

type TransportType uint8

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