config

type ApiDefinition struct {
	ApiRequest protocol.API
	// HandlerFunc returns the API Response payload as a byte array, the API Response header, which is calculated by the request header and an optional error
	HandlerFunc func(req Request, apiVersion int16, opts ...any) ([]byte, int16, error)
}

type Broker struct {
	BrokerID int32
	Rack     *string
	// https://docs.confluent.io/platform/current/installation/configuration/broker-configs.html#listeners
	Listeners []Listener
	// https://docs.confluent.io/platform/current/installation/configuration/broker-configs.html#advertised-listeners
	AdvertisedListeners []Listener
}

type Cluster struct {
	ClusterID string
}

type Config struct {
	OTProfile       OTProfile
	LogLevel        slog.Level
	LogFormat       string
	DebugServerPort int

	Broker  *Broker
	Cluster *Cluster

	Env *viper.Viper

	Plugin plugins.PluginInterface
}

type Listener struct {
	Host string
	Port int32
	// If the listener name is a security protocol, like PLAINTEXT,SSL,SASL_PLAINTEXT,SASL_SSL,
	// the name will be set as SecurityProtocol. Otherwise the name should be mapped in listener.security.protocol.map.
	// see https://docs.confluent.io/platform/current/installation/configuration/broker-configs.html#listener-security-protocol-map.
	SecurityProtocol SecurityProtocol
	ListenerName     string
}

type OTProfile int

type RegisteredAPI struct {
	ApiKey     int16
	MinVersion int16
	MaxVersion int16
}

type Request struct {
	Header  protocol.RequestHeader
	Message []byte
	Conn    net.Conn
	Config  *Config
}

type SecurityProtocol int