var cfgScheme … var validEgressSelectorNames … func init() { … } // ReadEgressSelectorConfiguration reads the egress selector configuration at the specified path. // It returns the loaded egress selector configuration if the input file aligns with the required syntax. // If it does not align with the provided syntax, it returns a default configuration which should function as a no-op. // It does this by returning a nil configuration, which preserves backward compatibility. // This works because prior to this there was no egress selector configuration. // It returns an error if the file did not exist. func ReadEgressSelectorConfiguration(configFilePath string) (*apiserver.EgressSelectorConfiguration, error) { … } // ValidateEgressSelectorConfiguration checks the apiserver.EgressSelectorConfiguration for // common configuration errors. It will return error for problems such as configuring mtls/cert // settings for protocol which do not support security. It will also try to catch errors such as // incorrect file paths. It will return nil if it does not find anything wrong. func ValidateEgressSelectorConfiguration(config *apiserver.EgressSelectorConfiguration) field.ErrorList { … } func validateHTTPConnectTransport(transport *apiserver.Transport, fldPath *field.Path) field.ErrorList { … } func validateGRPCTransport(transport *apiserver.Transport, fldPath *field.Path) field.ErrorList { … } func validateDirectConnection(connection apiserver.Connection, fldPath *field.Path) field.ErrorList { … } func validateUDSConnection(udsConfig *apiserver.UDSTransport, fldPath *field.Path) field.ErrorList { … } func validateTCPConnection(tcpConfig *apiserver.TCPTransport, fldPath *field.Path) field.ErrorList { … } func validateTLSConfig(tlsConfig *apiserver.TLSConfig, fldPath *field.Path) field.ErrorList { … }
Codebase Browser
kubernetes