internal

package
v1.24.0 Latest Latest
Warning

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

Go to latest
Published: Dec 3, 2021 License: Apache-2.0 Imports: 19 Imported by: 0

Documentation

Index

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)

func TopicExists

func TopicExists(client *sarama.Client, name string) (bool, 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

type Config struct {
	Name  string
	Value string
}

func ListConfigs

func ListConfigs(admin *sarama.ClusterAdmin, resource sarama.ConfigResource) ([]Config, error)

type DocsFlags

type DocsFlags struct {
	Directory  string
	DocType    string
	SinglePage bool
}

type DocsOperation

type DocsOperation struct {
}

func (*DocsOperation) GenerateDocs

func (operation *DocsOperation) GenerateDocs(rootCmd *cobra.Command, flags DocsFlags) error

type K8sConfig

type K8sConfig struct {
	Enabled     bool
	Binary      string
	KubeConfig  string
	KubeContext string
	Namespace   string
}

type SaslConfig

type SaslConfig struct {
	Enabled   bool
	Username  string
	Password  string
	Mechanism string
}

type TLSConfig

type TLSConfig struct {
	Enabled  bool
	CA       string
	Cert     string
	CertKey  string
	Insecure bool
}

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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