Documentation
¶
Index ¶
- Variables
- func Execute()
- func RunECreate(cmd *cobra.Command, args []string) error
- func RunEDelete(cmd *cobra.Command, args []string) error
- func RunEDeploy(cmd *cobra.Command, args []string) error
- func RunEPause(cmd *cobra.Command, args []string) error
- func RunEResume(cmd *cobra.Command, args []string) error
- func RunEUpdate(cmd *cobra.Command, args []string) error
- type CustomHeader
- type HeadersFlag
Constants ¶
This section is empty.
Variables ¶
View Source
var ( SSLInsecure bool SSLClientCertificate string SSLClientPrivateKey string )
View Source
var RootCmd = &cobra.Command{
Use: "kccli [command] [args]",
Short: "CLI wrapper for kafka-connect API",
Long: `This is a small tool to perform all available task on kafka-connect API via a CLI.
also contains two 'bonus' features:
- deploy connectors
- synchronous operations
`,
}
Functions ¶
Types ¶
type CustomHeader ¶
CustomHeader represents a single HTTP header name/value pair to be attached to outbound HTTP requests against the Connect REST API.
func (*CustomHeader) Parse ¶
func (h *CustomHeader) Parse(raw string) error
func (*CustomHeader) String ¶
func (h *CustomHeader) String() string
type HeadersFlag ¶
type HeadersFlag struct {
Headers []CustomHeader
}
HeadersFlag implements the Value interface from pflag in order to support parsing flag values of the form '<name>:<value>' directly into a list of CustomHeader instances.
func (*HeadersFlag) Set ¶
func (h *HeadersFlag) Set(raw string) error
func (*HeadersFlag) String ¶
func (h *HeadersFlag) String() string
func (*HeadersFlag) Type ¶
func (h *HeadersFlag) Type() string
Source Files
Click to show internal directories.
Click to hide internal directories.