destination

Documentation

Index

• type KafkaResource
  • func SetupKafka(pool *dockertest.Pool, d deferer, opts ...Option) (*KafkaResource, error)
  • func (k *KafkaResource) Destroy() error
• type MINIOResource
  • func SetupMINIO(pool *dockertest.Pool, d deferer) (*MINIOResource, error)
• type Option
  • func WithBrokers(noOfBrokers uint) Option
  • func WithLogger(l logger) Option
  • func WithSASLPlain(conf *SASLConfig) Option
  • func WithSASLScramSHA256(conf *SASLConfig) Option
  • func WithSASLScramSHA512(conf *SASLConfig) Option
• type PostgresResource
  • func SetupPostgres(pool *dockertest.Pool, d deferer) (*PostgresResource, error)
• type RedisResource
  • func SetupRedis(pool *dockertest.Pool, d deferer) (*RedisResource, error)
• type SASLConfig
• type TransformerResource
  • func SetupTransformer(pool *dockertest.Pool, d deferer) (*TransformerResource, error)
• type User

Types

type KafkaResource

type KafkaResource struct {
	Port string
	// contains filtered or unexported fields
}

func SetupKafka

func SetupKafka(pool *dockertest.Pool, d deferer, opts ...Option) (*KafkaResource, error)

func (*KafkaResource) Destroy

func (k *KafkaResource) Destroy() error

type MINIOResource

type MINIOResource struct {
	MinioEndpoint   string
	MinioBucketName string
	Port            string
}

func SetupMINIO

func SetupMINIO(pool *dockertest.Pool, d deferer) (*MINIOResource, error)

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 WithLogger

func WithLogger(l logger) Option

WithLogger allows to set a logger that prints debugging information

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)

type PostgresResource

type PostgresResource struct {
	DB       *sql.DB
	DB_DSN   string
	Database string
	Password string
	User     string
	Host     string
	Port     string
}

func SetupPostgres

func SetupPostgres(pool *dockertest.Pool, d deferer) (*PostgresResource, error)

type RedisResource

type RedisResource struct {
	RedisAddress string
}

func SetupRedis

func SetupRedis(pool *dockertest.Pool, d deferer) (*RedisResource, error)

type SASLConfig

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

type TransformerResource

type TransformerResource struct {
	TransformURL string
	Port         string
}

func SetupTransformer

func SetupTransformer(pool *dockertest.Pool, d deferer) (*TransformerResource, error)

type User

type User struct {
	Username, Password string
}