connect

type Client struct {
	ioc.ObjectImpl

	ServerAddress string `json:"server_address" yaml:"server_address" toml:"server_address" env:"SERVER_ADDRESS" validate:"required,url"`
	AgentId       string `json:"agent_id" yaml:"agent_id" toml:"agent_id" env:"AGENT_ID" validate:"required"`
	AgentKey      string `json:"agent_key" yaml:"agent_key" toml:"agent_key" env:"AGENT_KEY" validate:"required"`
	PingInterval  int    `json:"ping_interval" yaml:"ping_interval" toml:"ping_interval" env:"PING_INTERVAL" validate:"required"`
	// 握手超时时间, 默认5秒
	HandshakeTimeoutSecond int `` /* 146-byte string literal not displayed */

	// 消息重试队列配置
	// 重试队列存储目录，默认 data/retry-queue
	RetryQueueDir string `json:"retry_queue_dir" yaml:"retry_queue_dir" toml:"retry_queue_dir" env:"RETRY_QUEUE_DIR"`
	// 内存队列最大容量，默认1000
	RetryQueueMemorySize int `json:"retry_queue_memory_size" yaml:"retry_queue_memory_size" toml:"retry_queue_memory_size" env:"RETRY_QUEUE_MEMORY_SIZE"`
	// 磁盘队列最大文件数，默认10000
	RetryQueueDiskSize int `json:"retry_queue_disk_size" yaml:"retry_queue_disk_size" toml:"retry_queue_disk_size" env:"RETRY_QUEUE_DISK_SIZE"`
	// 单条消息最大重试次数，默认3
	RetryQueueMaxRetries int `json:"retry_queue_max_retries" yaml:"retry_queue_max_retries" toml:"retry_queue_max_retries" env:"RETRY_QUEUE_MAX_RETRIES"`
	// 磁盘文件保留时间，默认24小时
	RetryQueueDiskTTL string `json:"retry_queue_disk_ttl" yaml:"retry_queue_disk_ttl" toml:"retry_queue_disk_ttl" env:"RETRY_QUEUE_DISK_TTL"`
	// 磁盘队列告警阈值，默认5000
	RetryQueueWarningThreshold int `` /* 146-byte string literal not displayed */
	// 后台加载间隔，默认500ms
	RetryQueueLoadInterval string `` /* 130-byte string literal not displayed */
	// 单次加载最大消息数，默认100
	RetryQueueBatchLoadSize int `` /* 138-byte string literal not displayed */
	// 过期文件清理间隔，默认1小时
	RetryQueueCleanupInterval string `` /* 142-byte string literal not displayed */
	// contains filtered or unexported fields
}

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

type RetryMessage struct {
	Message   *protocol.Message `json:"message"`
	RetryAt   time.Time         `json:"retry_at"`   // 下次重试时间
	Attempt   int               `json:"attempt"`    // 已重试次数
	CreatedAt time.Time         `json:"created_at"` // 创建时间
	ID        string            `json:"id"`         // 消息唯一ID
	Status    string            `json:"status"`     // 消息状态: pending, processing, completed
}

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