server

package
v0.0.2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 18, 2018 License: Apache-2.0 Imports: 23 Imported by: 2

Documentation

Index

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,
}
View Source
var Version = &cobra.Command{
	Use:   "version",
	Short: "Print the kafka-proxy version",
	Run: func(cmd *cobra.Command, args []string) {
		fmt.Println(config.Version)
	},
}

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 NewHTTPHandler() http.Handler

func NewLocalAuthPluginClient added in v0.0.2

func NewLocalAuthPluginClient() *plugin.Client

func NewPluginClient

func NewPluginClient(handshakeConfig plugin.HandshakeConfig, plugins map[string]plugin.Plugin, logLevel string, command string, params []string) *plugin.Client

func Run

func Run(_ *cobra.Command, _ []string)

func SetLogger

func SetLogger()

Types

This section is empty.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL