Documentation
¶
Index ¶
- Variables
- func NewGatewayClientPluginClient() *plugin.Client
- func NewGatewayServerPluginClient() *plugin.Client
- func NewHTTPHandler() http.Handler
- func NewLocalAuthPluginClient() *plugin.Client
- func NewPluginClient(handshakeConfig plugin.HandshakeConfig, plugins map[string]plugin.Plugin, ...) *plugin.Client
- func Run(_ *cobra.Command, _ []string)
- func SetLogger()
Constants ¶
This section is empty.
Variables ¶
View Source
var Server = &cobra.Command{ Use: "server", Short: "Run the kafka-proxy server", PreRunE: func(cmd *cobra.Command, args []string) error { SetLogger() if err := c.InitSASLCredentials(); err != nil { return err } if err := c.InitBootstrapServers(bootstrapServersMapping); err != nil { return err } if err := c.InitExternalServers(externalServersMapping); err != nil { return err } if err := c.Validate(); err != nil { return err } return nil }, Run: Run, }
Functions ¶
func NewGatewayClientPluginClient ¶ added in v0.0.2
func NewGatewayClientPluginClient() *plugin.Client
func NewGatewayServerPluginClient ¶ added in v0.0.2
func NewGatewayServerPluginClient() *plugin.Client
func NewHTTPHandler ¶
func NewLocalAuthPluginClient ¶ added in v0.0.2
func NewLocalAuthPluginClient() *plugin.Client
func NewPluginClient ¶
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.