internal

Documentation

Index

• func CreateAvroSchemaRegistryClient(context *ClientContext) (srclient.ISchemaRegistryClient, error)
• 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
  • func CreateClientContext() (ClientContext, error)
• type Config
  • func ListConfigs(admin *sarama.ClusterAdmin, resource sarama.ConfigResource, ...) ([]Config, error)
• type ConsumerConfig
• type DocsFlags
• type DocsOperation
  • func (operation *DocsOperation) GenerateDocs(rootCmd *cobra.Command, flags DocsFlags) error
• type K8sConfig
• type ProducerConfig
• type SaslConfig
• type TLSConfig
• type TokenProvider

Functions

func CreateAvroSchemaRegistryClient

func CreateAvroSchemaRegistryClient(context *ClientContext) (srclient.ISchemaRegistryClient, error)

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 GetClientID

func GetClientID(context *ClientContext, defaultPrefix string) string

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
	AvroJSONCodec      avro.JSONCodec
	AvroRequestTimeout time.Duration
	AvroTLS            TLSConfig
	Protobuf           protobuf.SearchContext
	Producer           ProducerConfig
	Consumer           ConsumerConfig
}

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, includeDefaults bool) ([]Config, error)

type ConsumerConfig

type ConsumerConfig struct {
	IsolationLevel string
}

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
	Image           string
	ImagePullSecret string
	ServiceAccount  string
	KeepPod         bool
	Labels          map[string]string
	Annotations     map[string]string
	NodeSelector    map[string]string
}

type ProducerConfig

type ProducerConfig struct {
	Partitioner     string
	RequiredAcks    string
	MaxMessageBytes int
}

type SaslConfig

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

type TLSConfig

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

type TokenProvider

type TokenProvider struct {
	PluginName string
	Options    map[string]any
}