destination

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

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

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

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

type RedisResource struct {
	RedisAddress string
}

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

type TransformerResource struct {
	TransformURL string
	Port         string
}

type User struct {
	Username, Password string
}