Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

internal

package

Go to main page

Versions in this module

v5

v5.0.6

Mar 14, 2024

v5.0.5

Mar 12, 2024

v5.0.4

Mar 12, 2024

Changes in this version

type K8sConfig

+ KeepPod bool

v5.0.3

Mar 12, 2024

v5.0.2

Mar 8, 2024

v5.0.1

Mar 8, 2024

Changes in this version

+ func CreateClient(context *ClientContext) (sarama.Client, error)

+ func CreateClientConfig(context *ClientContext) (*sarama.Config, error)

+ func CreateClusterAdmin(context *ClientContext) (sarama.ClusterAdmin, error)

+ func GetClientID(context *ClientContext, defaultPrefix string) string

+ func TopicExists(client *sarama.Client, name string) (bool, error)

+ type ClientContext struct

+ AvroJSONCodec avro.JSONCodec

+ AvroSchemaRegistry string

+ Brokers []string

+ ClientID string

+ Consumer ConsumerConfig

+ KafkaVersion sarama.KafkaVersion

+ Kubernetes K8sConfig

+ Name string

+ Producer ProducerConfig

+ Protobuf protobuf.SearchContext

+ RequestTimeout time.Duration

+ Sasl SaslConfig

+ TLS TLSConfig

+ func CreateClientContext() (ClientContext, error)

+ type Config struct

+ Name string

+ Value string

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

+ type ConsumerConfig struct

+ IsolationLevel string

+ type DocsFlags struct

+ Directory string

+ DocType string

+ SinglePage bool

+ type DocsOperation struct

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

+ type K8sConfig struct

+ Annotations map[string]string

+ Binary string

+ Enabled bool

+ Image string

+ ImagePullSecret string

+ KubeConfig string

+ KubeContext string

+ Labels map[string]string

+ Namespace string

+ NodeSelector map[string]string

+ ServiceAccount string

+ type ProducerConfig struct

+ MaxMessageBytes int

+ Partitioner string

+ RequiredAcks string

+ type SaslConfig struct

+ Enabled bool

+ Mechanism string

+ Password string

+ TokenProvider TokenProvider

+ Username string

+ type TLSConfig struct

+ CA string

+ Cert string

+ CertKey string

+ Enabled bool

+ Insecure bool

+ type TokenProvider struct

+ Options map[string]any

+ PluginName string

Other modules containing this package

github.com/deviceinsight/kafkactl