redpanda

Documentation

Index

• Variables
• func AdminClient(dot *helmette.Dot, dialer DialContextFunc) (*rpadmin.AdminAPI, error)
• func KafkaClient(dot *helmette.Dot, dialer DialContextFunc, opts ...kgo.Opt) (*kgo.Client, error)
• func SchemaRegistryClient(dot *helmette.Dot, dialer DialContextFunc, opts ...sr.ClientOpt) (*sr.Client, error)
• type DialContextFunc

Variables

var (
	ErrServerCertificateNotFound          = errors.New("server TLS certificate not found")
	ErrServerCertificatePublicKeyNotFound = errors.New("server TLS certificate does not contain a public key")

	ErrClientCertificateNotFound           = errors.New("client TLS certificate not found")
	ErrClientCertificatePublicKeyNotFound  = errors.New("client TLS certificate does not contain a public key")
	ErrClientCertificatePrivateKeyNotFound = errors.New("client TLS certificate does not contain a private key")

	ErrSASLSecretNotFound          = errors.New("users secret not found")
	ErrSASLSecretKeyNotFound       = errors.New("users secret key not found")
	ErrSASLSecretSuperuserNotFound = errors.New("users secret has no users")
)

Functions

func AdminClient

func AdminClient(dot *helmette.Dot, dialer DialContextFunc) (*rpadmin.AdminAPI, error)

AdminClient creates a client to talk to a Redpanda cluster admin API based on its helm configuration over its internal listeners.

func KafkaClient

func KafkaClient(dot *helmette.Dot, dialer DialContextFunc, opts ...kgo.Opt) (*kgo.Client, error)

KafkaClient creates a client to talk to a Redpanda cluster based on its helm configuration over its internal listeners.

func SchemaRegistryClient

func SchemaRegistryClient(dot *helmette.Dot, dialer DialContextFunc, opts ...sr.ClientOpt) (*sr.Client, error)

SchemaRegistryClient creates a client to talk to a Redpanda cluster admin API based on its helm configuration over its internal listeners.

Types

type DialContextFunc

type DialContextFunc = func(ctx context.Context, network, host string) (net.Conn, error)

DialContextFunc is a function that acts as a dialer for the underlying Kafka client.