destination

Documentation

Index

• type KafkaResource
  • func SetupKafka(pool *dockertest.Pool, cln cleaner, opts ...Option) (*KafkaResource, error)
  • func (k *KafkaResource) Destroy() error
• type MINIOResource
  • func SetupMINIO(pool *dockertest.Pool, d cleaner) (*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 cleaner) (*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 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 MINIOResource

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

func SetupMINIO

func SetupMINIO(pool *dockertest.Pool, d cleaner) (*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
	DBDsn    string
	Database string
	Password string
	User     string
	Host     string
	Port     string
}

func SetupPostgres

func SetupPostgres(pool *dockertest.Pool, d cleaner) (*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
}