internal

package
v5.18.0 Latest Latest
Warning

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

Go to latest
Published: Feb 12, 2026 License: Apache-2.0 Imports: 26 Imported by: 0

Documentation

Index

Constants

View Source
const (
	WireFormatBytes = 5
	MagicByte       = 0
)

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 GetClientID

func GetClientID(context *ClientContext, defaultPrefix string) string

func IsKubernetesEnabled added in v5.7.0

func IsKubernetesEnabled() bool

func TopicExists

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

Types

type AvroConfig added in v5.2.0

type AvroConfig struct {
	JSONCodec avro.JSONCodec
}

type CachingSchemaRegistry added in v5.5.0

type CachingSchemaRegistry struct {
	srclient.ISchemaRegistryClient
	// contains filtered or unexported fields
}

func CreateCachingSchemaRegistry added in v5.5.0

func CreateCachingSchemaRegistry(context *ClientContext) (*CachingSchemaRegistry, error)

func (*CachingSchemaRegistry) ExtractPayload added in v5.6.0

func (registry *CachingSchemaRegistry) ExtractPayload(data []byte) []byte

func (*CachingSchemaRegistry) ExtractSchemaID added in v5.6.0

func (registry *CachingSchemaRegistry) ExtractSchemaID(data []byte) (int, error)

func (*CachingSchemaRegistry) GetSubjects added in v5.7.0

func (registry *CachingSchemaRegistry) GetSubjects() ([]string, error)

func (*CachingSchemaRegistry) SubjectOfTypeExists added in v5.7.0

func (registry *CachingSchemaRegistry) SubjectOfTypeExists(subject string, expectedSchemaType srclient.SchemaType) (bool, error)

type ClientContext

type ClientContext struct {
	Name           string
	Brokers        []string
	TLS            TLSConfig
	Sasl           SaslConfig
	Kubernetes     K8sConfig
	RequestTimeout time.Duration
	ClientID       string
	KafkaVersion   sarama.KafkaVersion
	Avro           AvroConfig
	Protobuf       ProtobufConfig
	SchemaRegistry SchemaRegistryConfig
	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
	TLSSecret       string
	ServiceAccount  string
	AsUser          string
	KeepPod         bool
	Labels          map[string]string
	Annotations     map[string]string
	NodeSelector    map[string]string
	Affinity        map[string]any
	Resources       map[string]any
	Tolerations     []K8sToleration
}

type K8sToleration added in v5.3.0

type K8sToleration struct {
	Key      string `json:"key" yaml:"key"`
	Operator string `json:"operator" yaml:"operator"`
	Value    string `json:"value" yaml:"value"`
	Effect   string `json:"effect" yaml:"effect"`
}

type ProducerConfig

type ProducerConfig struct {
	Partitioner     string
	RequiredAcks    string
	MaxMessageBytes int
	ValueSerializer string
	KeySerializer   string
}

type ProtobufConfig added in v5.7.0

type ProtobufConfig struct {
	ProtosetFiles    []string
	ProtoFiles       []string
	ProtoImportPaths []string
	MarshalOptions   ProtobufMarshalOptions
}

type ProtobufMarshalOptions added in v5.8.0

type ProtobufMarshalOptions struct {
	AllowPartial      bool
	UseProtoNames     bool
	UseEnumNumbers    bool
	EmitUnpopulated   bool
	EmitDefaultValues bool
}

type SaslConfig

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

type SchemaRegistryConfig added in v5.6.0

type SchemaRegistryConfig struct {
	URL            string
	RequestTimeout time.Duration
	TLS            TLSConfig
	Username       string
	Password       string
}

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
}

Jump to

Keyboard shortcuts

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