destination

Documentation

Index

• type Cleaner
• type KafkaResource
  • func SetupKafka(pool *dockertest.Pool, cln Cleaner, opts ...Option) (*KafkaResource, error)
  • func (k *KafkaResource) Destroy() error
• type Logger
• type MINIOResource
  • func SetupMINIO(pool *dockertest.Pool, d Cleaner) (*MINIOResource, error)
• type NOPLogger
  • func (*NOPLogger) Log(...interface{})
• type Option
  • func WithBrokers(noOfBrokers uint) Option
  • func WithLogger(l Logger) Option
  • func WithNetwork(network *dc.Network) Option
  • func WithSASLPlain(conf *SASLConfig) Option
  • func WithSASLScramSHA256(conf *SASLConfig) Option
  • func WithSASLScramSHA512(conf *SASLConfig) Option
  • func WithoutDockerHostListeners() Option
• type PostgresResource
  • func SetupPostgres(pool *dockertest.Pool, d Cleaner, opts ...string) (*PostgresResource, error)
• type RedisOption
  • func WithRedisCmdArg(key, value string) RedisOption
  • func WithRedisEnv(envs ...string) RedisOption
• type RedisResource
  • func SetupRedis(ctx context.Context, pool *dockertest.Pool, d Cleaner, opts ...RedisOption) (*RedisResource, error)
• type SASLConfig
• type TransformerResource
  • func SetupTransformer(pool *dockertest.Pool, d Cleaner) (*TransformerResource, error)
• type User

Types

type Cleaner

type Cleaner interface {
	Cleanup(func())
	Logger
}

type KafkaResource

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

func SetupKafka

func SetupKafka(pool *dockertest.Pool, cln Cleaner, opts ...Option) (*KafkaResource, error)

func (*KafkaResource) Destroy

func (k *KafkaResource) Destroy() error

type Logger

type Logger interface {
	Log(...interface{})
}

type MINIOResource

type MINIOResource struct {
	Endpoint     string
	BucketName   string
	Port         string
	AccessKey    string
	SecretKey    string
	SiteRegion   string
	ResourceName string
	Client       *minio.Client
}

func SetupMINIO

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

type NOPLogger

type NOPLogger struct{}

func (*NOPLogger) Log

func (*NOPLogger) Log(...interface{})

Log for the NOP logger does nothing.

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 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 WithoutDockerHostListeners

func WithoutDockerHostListeners() Option

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

type PostgresResource

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

func SetupPostgres

func SetupPostgres(pool *dockertest.Pool, d Cleaner, opts ...string) (*PostgresResource, error)

type RedisOption

type RedisOption func(*redisConfig)

func WithRedisCmdArg

func WithRedisCmdArg(key, value string) RedisOption

WithRedisCmdArg is used to specify the save argument when running the container.

func WithRedisEnv

func WithRedisEnv(envs ...string) RedisOption

WithRedisEnv is used to pass environment variables to the container.

type RedisResource

type RedisResource struct {
	Addr string
}

func SetupRedis

func SetupRedis(ctx context.Context, pool *dockertest.Pool, d Cleaner, opts ...RedisOption) (*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 Cleaner) (*TransformerResource, error)

type User

type User struct {
	Username, Password string
}