adapters

package

v0.5.12 Latest Latest Go to latest Published: Sep 19, 2022 License: MIT Imports: 15 Imported by: 0

Details

This section is empty.

This section is empty.

func CreateMongoClient(ctx context.Context, mongoConfig MongoConfig) *mongo.Client

func CreatePostgresClient(ctx context.Context, postgresConfig PostgresConfig) *gorm.DB

func CreateRedisClient(ctx context.Context, redisConfig RedisConfig) *redis.Client

func CreateSentry(sentryConfig SentryConfig) error

func NewKafkaConn(cfg *config.Config) (*kafka.Conn, error)

func NewLauncher(launcherConfig LauncherConfig) *launcher.Launcher

type Adapter interface {
	CreateClient(ctx context.Context, options *models.DBOptions) interface{}
}

type LauncherConfig struct {
	ServiceName string
	AccessToken string
}

type MongoConfig struct {
	URI         string
	MaxPoolSize uint64
	MinPoolSize uint64
	RetryWrites bool
}

type PostgresConfig struct {
	URL      string
	Host     string
	Port     int
	DB       string
	User     string
	Password string
}

type RedisConfig struct {
	Addr string
	DB   int
}

type SentryConfig struct {
	DSN              string
	Env              string
	TracesSampleRate float64
}