agent

type Agent struct {
	// Node 保存当前业务服务构造出的固定 ServiceNode。
	Node *ServiceNode
	// Client 保存和 sidecar 管理接口交互的 API client。
	Client *ApiClient
	// Source 保存 sidecar watch 事件源。
	Source *WatchSource
	// Controller 保存基于固定节点的控制器。
	Controller *Controller
	// Runner 保存事件驱动运行器。
	Runner *Runner
	// contains filtered or unexported fields
}

type AgentRunError struct {
	// Stage 表示失败发生阶段。
	Stage string
	// Err 表示底层错误。
	Err error
}

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

type Client interface {
	// Register 负责把当前服务注册到本机 sidecar-agent。
	Register(ctx context.Context, request *ServiceNode) error
	// Drain 负责把当前服务切换到摘流状态。
	Drain(ctx context.Context, request DrainRequest) error
	// Deregister 负责把当前服务从本机 sidecar-agent 注销。
	Deregister(ctx context.Context, request DeregisterRequest) error
}

type ConnectionEvent struct {
	// Type 表示事件类型，例如 connected、heartbeat、disconnected。
	Type string
	// Connected 表示当前事件是否意味着连接已建立。
	Connected bool
	// EventId 表示服务端 SSE 事件 ID，便于后续排障与协议增强。
	EventId string
	// Message 保存服务端事件说明文本。
	Message string
	// Service 表示当前发出 watch 事件的服务名。
	Service string
	// Status 表示 sidecar 当前运行态摘要，例如 ready、starting、degraded。
	Status string
	// LifecycleState 表示 sidecar 当前生命周期阶段。
	LifecycleState string
	// Ready 表示 sidecar 主链当前是否 ready；nil 表示服务端未提供该信息。
	Ready *bool
	// GeneratedAt 表示该事件在服务端生成的时间。
	GeneratedAt *time.Time
	// Err 保存连接断开或处理失败时的上下文错误。
	Err error
}

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

type DeregisterRequest struct {
	// AppId 表示应用标识。
	AppId string `json:"app_id"`
	// AppInstanceId 表示应用实例标识。
	AppInstanceId string `json:"app_instance_id"`

	// ServiceName 表示逻辑服务名。
	ServiceName string `json:"service_name"`
	// ServicePort 表示服务端口。
	ServicePort uint `json:"service_port"`
}

type DrainRequest struct {
	// AppId 表示应用标识。
	AppId string `json:"app_id"`
	// AppInstanceId 表示应用实例标识。
	AppInstanceId string `json:"app_instance_id"`

	// ServiceName 表示逻辑服务名。
	ServiceName string `json:"service_name"`
	// GracePeriod 表示摘流宽限期。
	GracePeriod string `json:"grace_period"`
}

type ErrorHandler func(context.Context, error)

type EventSource interface {
	// Subscribe 返回一个持续输出连接事件的只读通道。
	Subscribe(ctx context.Context) (<-chan ConnectionEvent, error)
}

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

type LifecycleRunError struct {
	// Err 表示底层运行失败原因。
	Err error
}

type RegisterReplayError struct {
	// ServiceName 表示当前重放失败的服务名。
	ServiceName string
	// ServicePort 表示当前重放失败的服务端口。
	ServicePort int
	// Err 表示底层 register 调用失败原因。
	Err error
}

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

type ServeFunc func(context.Context) error

type ServiceNode struct {
	*ServiceOptions

	DNS     string `json:"dns"`
	RunDate string `json:"run_date"`

	// ProtoCount 表示业务服务子服务数量。
	ProtoCount uint `json:"proto_count"`
	// Methods 表示业务服务暴露的方法列表。
	Methods []string `json:"methods"`
}

type ServiceOptions struct {
	// App 应用配置
	App app.Config `json:"app"`
	// Kernel 内核配置
	Kernel kernel.Config `json:"kernel"`
	// Service 服务配置
	Service service.Config `json:"service"`

	// Protocol 表示业务协议, grpc / http。
	Protocol string `json:"protocol"`
	// ServerPort 服务端口
	ServerPort uint `json:"server_port"`
	// ManagedPort 管理端口
	ManagedPort uint `json:"managed_port"`
}

type ShutdownFunc func(context.Context) error

type SidecarAgentConfig struct {
	// BaseURL 表示 sidecar-agent 基础 URL。
	BaseURL string `json:"base_url"`
	// WatchURL 表示 sidecar-agent 的 SSE watch 地址；为空时由 BaseURL 自动推导。
	WatchURL string `json:"watch_url"`
	// GracePeriod 表示业务服务优雅下线时使用的默认摘流宽限期。
	GracePeriod string `json:"grace_period"`
	// RequestTimeout 表示 register、drain、deregister 的请求超时。
	RequestTimeout time.Duration `json:"request_timeout"`
	// ReconnectInterval 表示 watch 断开后的重连间隔。
	ReconnectInterval time.Duration `json:"reconnect_interval"`
	// RawServices 表示当前进程注册的 gRPC ServiceDesc 集合，用于构造 methods。
	RawServices []*grpc.ServiceDesc `json:"-"`
	// OnError 用于统一处理 watch 与 register 重放过程中的异步错误。
	OnError ErrorHandler `json:"-"`
	// Serve 表示业务服务真正的阻塞运行入口；为空时仅运行 agent watch/replay 主链。
	Serve ServeFunc `json:"-"`
	// Shutdown 表示业务服务优雅关闭入口；可为空。
	Shutdown ShutdownFunc `json:"-"`
}

type Status struct {
	// Connected 表示当前是否与本机 sidecar-agent 保持连接。
	Connected bool
	// Registered 表示最近一次 register 是否成功完成。
	Registered bool
	// LastServiceName 表示最近一次成功注册的服务名。
	LastServiceName string
	// LastServicePort 表示最近一次成功注册的服务端口。
	LastServicePort int
	// LastEventType 表示最近一次收到的 watch 事件类型。
	LastEventType string
	// LastEventId 表示最近一次收到的 SSE 事件 ID。
	LastEventId string
	// LastEventAt 表示最近一次事件的观测时间。
	LastEventAt string
	// LastConnectedAt 表示最近一次成功建立或恢复连接的时间。
	LastConnectedAt string
	// LastDisconnectedAt 表示最近一次断连的时间。
	LastDisconnectedAt string
	// DisconnectCount 表示运行期间累计收到的断连次数。
	DisconnectCount int
	// RegisterReplayCount 表示累计成功重放 register 的次数。
	RegisterReplayCount int
	// RegisterReplayFailureCount 表示累计 register 重放失败次数。
	RegisterReplayFailureCount int
	// LastErrorKind 表示最近一次错误的分类。
	LastErrorKind string
	// LastError 表示最近一次错误文本。
	LastError string
	// LastErrorAt 表示最近一次错误发生时间。
	LastErrorAt string
}

type WatchEventParseError struct {
	// EventType 表示解析失败的事件类型。
	EventType string
	// EventId 表示服务端 SSE 事件 ID。
	EventId string
	// Payload 表示原始 data 内容，便于调试坏帧。
	Payload string
	// Err 表示底层 JSON 解析错误。
	Err error
}

type WatchHTTPStatusError struct {
	// StatusCode 表示 HTTP 状态码。
	StatusCode int
	// Status 表示原始 HTTP 状态文本。
	Status string
}

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