kafka

package

v0.30.0 Latest Latest Go to latest Published: Apr 30, 2024 License: AGPL-3.0 Imports: 9 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/rudderlabs/rudder-go-kit

Links

Open Source Insights

Documentation ¶

Index ¶

type Option
type Resource
- func Setup(pool *dockertest.Pool, cln resource.Cleaner, opts ...Option) (*Resource, error)
- func (k *Resource) Destroy() error
type SASLConfig
type User

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Option ¶

type Option interface {
	// contains filtered or unexported methods
}

func WithBrokers ¶

func WithBrokers(noOfBrokers uint) Option

WithBrokers allows to set the number of brokers in the cluster

func WithCustomAdvertisedListener ¶

func WithCustomAdvertisedListener(listener string) Option

WithCustomAdvertisedListener allows to set a custom advertised listener

func WithNetwork ¶

func WithNetwork(network *dc.Network) Option

WithNetwork allows to set a docker network to use for the cluster

func WithSASLPlain ¶

func WithSASLPlain(conf *SASLConfig) Option

WithSASLPlain is used to configure SASL authentication (PLAIN)

func WithSASLScramSHA256 ¶

func WithSASLScramSHA256(conf *SASLConfig) Option

WithSASLScramSHA256 is used to configure SASL authentication (Scram SHA-256)

func WithSASLScramSHA512 ¶

func WithSASLScramSHA512(conf *SASLConfig) Option

WithSASLScramSHA512 is used to configure SASL authentication (Scram SHA-512)

func WithSchemaRegistry ¶

func WithSchemaRegistry() Option

WithSchemaRegistry allows to use the schema registry

func WithoutDockerHostListeners ¶

func WithoutDockerHostListeners() Option

WithoutDockerHostListeners allows to not set the advertised listener to the host mapped port

type Resource ¶

type Resource struct {
	Ports             []string
	SchemaRegistryURL string
	// contains filtered or unexported fields
}

func Setup ¶

func Setup(pool *dockertest.Pool, cln resource.Cleaner, opts ...Option) (*Resource, error)

func (*Resource) Destroy ¶

func (k *Resource) Destroy() error

type SASLConfig ¶

type SASLConfig struct {
	BrokerUser                   User
	Users                        []User
	CertificatePassword          string
	KeyStorePath, TrustStorePath string
	// contains filtered or unexported fields
}

type User ¶

type User struct {
	Username, Password string
}

Source Files ¶

View all Source files

kafka.go

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