Documentation ¶
Index ¶
- func CreateClient(context *ClientContext) (sarama.Client, error)
- func CreateClientConfig(context *ClientContext) (*sarama.Config, error)
- func CreateClusterAdmin(context *ClientContext) (sarama.ClusterAdmin, error)
- func TopicExists(client *sarama.Client, name string) (bool, error)
- type ClientContext
- type Config
- type DocsFlags
- type DocsOperation
- type K8sConfig
- type SaslConfig
- type TLSConfig
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CreateClient ¶
func CreateClient(context *ClientContext) (sarama.Client, error)
func CreateClientConfig ¶
func CreateClientConfig(context *ClientContext) (*sarama.Config, error)
func CreateClusterAdmin ¶
func CreateClusterAdmin(context *ClientContext) (sarama.ClusterAdmin, error)
Types ¶
type ClientContext ¶
type ClientContext struct { Name string Brokers []string TLS TLSConfig Sasl SaslConfig Kubernetes K8sConfig RequestTimeout time.Duration ClientID string KafkaVersion sarama.KafkaVersion AvroSchemaRegistry string Protobuf protobuf.SearchContext DefaultPartitioner string RequiredAcks string }
func CreateClientContext ¶
func CreateClientContext() (ClientContext, error)
type Config ¶
func ListConfigs ¶
func ListConfigs(admin *sarama.ClusterAdmin, resource sarama.ConfigResource) ([]Config, error)
type DocsOperation ¶
type DocsOperation struct { }
func (*DocsOperation) GenerateDocs ¶
func (operation *DocsOperation) GenerateDocs(rootCmd *cobra.Command, flags DocsFlags) error
type SaslConfig ¶
Click to show internal directories.
Click to hide internal directories.