cmd

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
  • func (h *CustomHeader) Parse(raw string) error
  • func (h *CustomHeader) String() string
• type HeadersFlag
  • func (h *HeadersFlag) Set(raw string) error
  • func (h *HeadersFlag) String() string
  • func (h *HeadersFlag) Type() string

Variables

var (
	SSLInsecure bool

	SSLClientCertificate string
	SSLClientPrivateKey  string
)

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

func Execute

func Execute()

func RunECreate

func RunECreate(cmd *cobra.Command, args []string) error

RunECreate ...

func RunEDelete

func RunEDelete(cmd *cobra.Command, args []string) error

RunEDelete ...

func RunEDeploy

func RunEDeploy(cmd *cobra.Command, args []string) error

func RunEPause

func RunEPause(cmd *cobra.Command, args []string) error

RunEPause ...

func RunEResume

func RunEResume(cmd *cobra.Command, args []string) error

RunEResume ...

func RunEUpdate

func RunEUpdate(cmd *cobra.Command, args []string) error

RunEUpdate ...

Types

type CustomHeader

type CustomHeader struct {
	Name  string
	Value string
}

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