grpc

type AcceptConnectionConfig struct {
	CPUUtilization  float64 `mapstructure:"cpu_utilization"`  // The max CPU utilization limit
	ConnectionCount int32   `mapstructure:"connection_count"` // The max connection count
}

type AcceptLimiter struct {
	Config           AcceptConnectionConfig
	ActiveConnection int32
	CurrentCPU       float64

	telemetry.Counter
	// contains filtered or unexported fields
}

type ConnectionManager struct {
	net.Listener
	// contains filtered or unexported fields
}

type ConnectionWrapper struct {
	net.Conn
	// contains filtered or unexported fields
}

type OriginalData struct {
	Content []byte
}

type Server struct {
	config.CommonFields
	Address              string `mapstructure:"address"`                // The address of grpc server.
	Network              string `mapstructure:"network"`                // The network of grpc.
	MaxRecvMsgSize       int    `mapstructure:"max_recv_msg_size"`      // The max size of the received log.
	MaxConcurrentStreams uint32 `mapstructure:"max_concurrent_streams"` // The max concurrent stream channels.
	TLSCertFile          string `mapstructure:"tls_cert_file"`          // The TLS cert file path.
	TLSKeyFile           string `mapstructure:"tls_key_file"`           // The TLS key file path.

	AcceptLimit AcceptConnectionConfig `mapstructure:"accept_limit"` // To Accept Connection Limiter when reach the resource
	// contains filtered or unexported fields
}