drivers

type BlacklistConfigAssistance struct {
}

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

type ConfigVersion struct {
	Version   uint64      `json:"version"`
	Config    interface{} `json:"config"`
	Timestamp time.Time   `json:"timestamp"`
}

type ErrorType int

type IPConnectivityConfig struct {
	CheckInterval  time.Duration `yaml:"check_interval"`    // 存量IP定时检查间隔
	CheckTimeout   time.Duration `yaml:"check_timeout"`     // 单个IP检查超时时间
	NewIPQueueSize int           `yaml:"new_ip_queue_size"` // 新IP检查队列大小
}

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

type IPStatus struct {
	IP string
	// 是否可达
	IsReachable bool
	// 最近一次的检查时间
	LastChecked time.Time
}

type KafkaConfigCompareOptions struct {
	// 是否对比broker的顺序
	StrictBrokerOrder bool
}

type KafkaConsumer struct {
	KafkaConsumerValidator
	Reader *kafka.Reader
	// contains filtered or unexported fields
}

type KafkaConsumerConfig struct {
	GroupID            string `yaml:"groupId" json:"groupId" mapstructure:"groupId"`
	AutoOffsetReset    string `yaml:"autoOffsetReset,omitempty" json:"autoOffsetReset,omitempty" mapstructure:"autoOffsetReset,omitempty"`
	EnableAutoCommit   bool   `yaml:"enableAutoCommit,omitempty" json:"enableAutoCommit,omitempty" mapstructure:"enableAutoCommit,omitempty"`
	AutoCommitInterval string `yaml:"autoCommitInterval,omitempty" json:"autoCommitInterval,omitempty" mapstructure:"autoCommitInterval,omitempty"`

	// 连接和验证超时配置(这两项配置变更不需要做same config做新老驱动的替换)
	ConnectTimeout  string `yaml:"connectTimeout,omitempty" json:"connectTimeout,omitempty" mapstructure:"connectTimeout,omitempty"`
	ValidateTimeout string `yaml:"validateTimeout,omitempty" json:"validateTimeout,omitempty" mapstructure:"validateTimeout,omitempty"`

	// 读消息和提交偏移量超时配置
	ReadTimeout   string `yaml:"readTimeout,omitempty" json:"readTimeout,omitempty" mapstructure:"readTimeout,omitempty"`       // 读消息超时
	CommitTimeout string `yaml:"commitTimeout,omitempty" json:"commitTimeout,omitempty" mapstructure:"commitTimeout,omitempty"` // 提交偏移量超时

	Brokers  []string        `yaml:"brokers" json:"brokers" mapstructure:"brokers"`
	Topic    string          `yaml:"topic" json:"topic" mapstructure:"topic"`
	Security *SecurityConfig `yaml:"security,omitempty" json:"security,omitempty" mapstructure:"security,omitempty"`
	Retry    *RetryConfig    `yaml:"retry,omitempty" json:"retry,omitempty" mapstructure:"retry,omitempty"`
}

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

type KafkaProducer struct {
	KafkaProducerValidator
	Writer *kafka.Writer
	// contains filtered or unexported fields
}

type KafkaProducerConfig struct {
	RequiredAcks    string `yaml:"requiredAcks,omitempty" json:"requiredAcks,omitempty" mapstructure:"requiredAcks,omitempty"`
	Timeout         string `yaml:"timeout,omitempty" json:"timeout,omitempty" mapstructure:"timeout,omitempty"`
	BatchTimeout    string `yaml:"batchTimeout,omitempty" json:"batchTimeout,omitempty" mapstructure:"batchTimeout,omitempty"`
	BatchBytes      int64  `yaml:"batchBytes,omitempty" json:"batchBytes,omitempty" mapstructure:"batchBytes,omitempty"`
	BatchSize       int    `yaml:"batchSize,omitempty" json:"batchSize,omitempty" mapstructure:"batchSize,omitempty"`
	Retries         int    `yaml:"retries,omitempty" json:"retries,omitempty" mapstructure:"retries,omitempty"`
	RetryBackoffMin string `yaml:"retryBackoffMin,omitempty" json:"retryBackoffMin,omitempty" mapstructure:"retryBackoffMin,omitempty"`
	RetryBackoffMax string `yaml:"retryBackoffMax,omitempty" json:"retryBackoffMax,omitempty" mapstructure:"retryBackoffMax,omitempty"`
	Compression     string `yaml:"compression,omitempty" json:"compression,omitempty" mapstructure:"compression,omitempty"`

	// 连接和验证超时配置(不需要做same config的比较替换)
	ConnectTimeout  string `yaml:"connectTimeout,omitempty" json:"connectTimeout,omitempty" mapstructure:"connectTimeout,omitempty"`
	ValidateTimeout string `yaml:"validateTimeout,omitempty" json:"validateTimeout,omitempty" mapstructure:"validateTimeout,omitempty"`

	Brokers  []string        `yaml:"brokers" json:"brokers" mapstructure:"brokers"`
	Topic    string          `yaml:"topic" json:"topic" mapstructure:"topic"`
	Security *SecurityConfig `yaml:"security,omitempty" json:"security,omitempty" mapstructure:"security,omitempty"`
}

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

type MessageHandler func(ctx context.Context, msg *kafka.Message) error

type PendingConnection struct {
	ResponseWriter http.ResponseWriter
	Context        context.Context
	Cancel         context.CancelFunc
	ConnectedAt    time.Time
	ClientID       string

	// 客户端网络信息
	PublicIPs   []string
	InternalIPs []string
}

type PollingClientSecurityConfig struct {
	// 客户端认证token
	Token string `json:"token,omitempty" mapstructure:"token,omitempty" yaml:"token,omitempty"`

	// HTTPS配置
	InsecureSkipVerify bool `json:"insecure_skip_verify" mapstructure:"insecure_skip_verify" yaml:"insecure_skip_verify"`
}

type PollingConsumer struct {
	PollingConsumerValidator
	// contains filtered or unexported fields
}

type PollingConsumerConfig struct {
	// 服务器URL配置(第一版admin跟server不分离)
	URL string `json:"url,omitempty" mapstructure:"url,omitempty" yaml:"url,omitempty"`

	// 轮询配置
	PollInterval   string `json:"poll_interval" mapstructure:"poll_interval" yaml:"poll_interval"`       // 普通轮询间隔
	RequestTimeout string `json:"request_timeout" mapstructure:"request_timeout" yaml:"request_timeout"` // HTTP请求超时时间，建议配置比服务端LongPollTimeout大

	// HTTP配置
	Headers   map[string]string `json:"headers,omitempty" mapstructure:"headers,omitempty" yaml:"headers,omitempty"`          // 自定义请求头
	UserAgent string            `json:"user_agent,omitempty" mapstructure:"user_agent,omitempty" yaml:"user_agent,omitempty"` // User-Agent

	// 客户端安全配置
	Security *PollingClientSecurityConfig `json:"security,omitempty" mapstructure:"security,omitempty" yaml:"security,omitempty"`

	// 其他配置
	IgnoreExceptions bool `json:"ignore_exceptions" mapstructure:"ignore_exceptions" yaml:"ignore_exceptions"` // 是否忽略异常

	Retry *RetryConfig `json:"retry,omitempty" mapstructure:"retry,omitempty" yaml:"retry,omitempty"`
}

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

type PollingError struct {
	Type ErrorType
	Err  error
}

type PollingMessageHandler func(ctx context.Context, data json.RawMessage) error

type PollingProducer struct {
	PollingProducerValidator
	// contains filtered or unexported fields
}

type PollingProducerConfig struct {
	// 服务器端口配置(polling的server端端口)
	Port string `json:"port" mapstructure:"port" yaml:"port"`

	// 轮询配置
	LongPollTimeout string `json:"long_poll_timeout" mapstructure:"long_poll_timeout" yaml:"long_poll_timeout"` // 长轮询超时

	// 服务器超时配置
	ServerReadTimeout  string `json:"server_read_timeout" mapstructure:"server_read_timeout" yaml:"server_read_timeout"`    // 服务器读取超时
	ServerWriteTimeout string `json:"server_write_timeout" mapstructure:"server_write_timeout" yaml:"server_write_timeout"` // 服务器写入超时
	ServerIdleTimeout  string `json:"server_idle_timeout" mapstructure:"server_idle_timeout" yaml:"server_idle_timeout"`    // 服务器空闲超时

	// 服务端安全配置
	Security *PollingServerSecurityConfig `json:"security,omitempty" mapstructure:"security,omitempty" yaml:"security,omitempty"`

	Retry *RetryConfig `json:"retry,omitempty" mapstructure:"retry,omitempty" yaml:"retry,omitempty"`
}

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

type PollingServerSecurityConfig struct {
	// 服务端验证客户端token的配置
	ValidTokens []string `json:"valid_tokens,omitempty" mapstructure:"valid_tokens,omitempty" yaml:"valid_tokens,omitempty"`

	// HTTPS配置
	CertFile string `json:"cert_file,omitempty" mapstructure:"cert_file,omitempty" yaml:"cert_file,omitempty"`
	KeyFile  string `json:"key_file,omitempty" mapstructure:"key_file,omitempty" yaml:"key_file,omitempty"`
}

type RetryConfig struct {
	Count   int    `json:"count" mapstructure:"count" yaml:"count"`
	Backoff string `json:"backoff" mapstructure:"backoff" yaml:"backoff"`
}

type SASLConfig struct {
	Enabled   bool   `yaml:"enabled" json:"enabled" mapstructure:"enabled"`
	Mechanism string `yaml:"mechanism,omitempty" json:"mechanism,omitempty" mapstructure:"mechanism,omitempty"`
	Username  string `yaml:"username,omitempty" json:"username,omitempty" mapstructure:"username,omitempty"`
	Password  string `yaml:"password,omitempty" json:"password,omitempty" mapstructure:"password,omitempty"`
}

type SecurityConfig struct {
	SASL *SASLConfig `yaml:"sasl,omitempty" json:"sasl,omitempty" mapstructure:"sasl,omitempty"`
	TLS  *TLSConfig  `yaml:"tls,omitempty" json:"tls,omitempty" mapstructure:"tls,omitempty"`
}

type TLSConfig struct {
	Enabled            bool   `yaml:"enabled" json:"enabled" mapstructure:"enabled"`
	CaFile             string `yaml:"caFile,omitempty" json:"caFile,omitempty" mapstructure:"caFile,omitempty"`
	CertFile           string `yaml:"certFile,omitempty" json:"certFile,omitempty" mapstructure:"certFile,omitempty"`
	KeyFile            string `yaml:"keyFile,omitempty" json:"keyFile,omitempty" mapstructure:"keyFile,omitempty"`
	InsecureSkipVerify bool   `yaml:"insecureSkipVerify" json:"insecureSkipVerify" mapstructure:"insecureSkipVerify"`
}

type WebhookConsumer struct {
	WebhookConsumerValidator
	// contains filtered or unexported fields
}

type WebhookConsumerConfig struct {
	BlacklistConfigAssistance
	BlacklistIPs []string `json:"blacklistIPs,omitempty" mapstructure:"blacklistIPs,omitempty" yaml:"blacklistIPs,omitempty"`

	// 客户端端口配置
	Port     string                 `json:"port" mapstructure:"port" yaml:"port"`
	Retry    *RetryConfig           `json:"retry,omitempty" mapstructure:"retry,omitempty" yaml:"retry,omitempty"`
	Security *WebhookSecurityConfig `json:"security,omitempty" mapstructure:"security,omitempty" yaml:"security,omitempty"`
}

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

type WebhookMessageHandler func(ctx context.Context, body json.RawMessage) error

type WebhookProducer struct {
	WebhookProducerValidator
	// contains filtered or unexported fields
}

type WebhookProducerConfig struct {
	BlacklistConfigAssistance
	BlacklistIPs []string `json:"blacklistIPs,omitempty" mapstructure:"blacklistIPs,omitempty" yaml:"blacklistIPs,omitempty"`
	// 客户端端口配置
	Port string `json:"port" mapstructure:"port" yaml:"port"`
	// 基础配置
	IgnoreExceptions bool                   `json:"ignoreExceptions" mapstructure:"ignoreExceptions" yaml:"ignoreExceptions"`
	TimeOut          string                 `json:"timeOut" mapstructure:"timeOut" yaml:"timeOut"`
	Retry            *RetryConfig           `json:"retry,omitempty" mapstructure:"retry,omitempty" yaml:"retry,omitempty"`
	Security         *WebhookSecurityConfig `json:"security,omitempty" mapstructure:"security,omitempty" yaml:"security,omitempty"`
}

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

type WebhookSecurityConfig struct {
	Secret string `json:"secret" mapstructure:"secret" yaml:"secret"`
}