adapters

Documentation

Index

• func CreateLocalCache(config *ristretto.Config) (*ristretto.Cache, error)
• 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 NewReaderWithTLS(cfg *KafkaConnectionConfig) *kafka.Reader
• func NewWriterWithMechanism(cfg *KafkaWriterWithMechanismConfig) *kafka.Writer
• type Adapter
• type KafkaConnectionConfig
• type KafkaMechanismConfig
• type KafkaWriterWithMechanismConfig
• type MongoConfig
• type PostgresConfig
• type RedisConfig
• type SentryConfig

Functions

func CreateLocalCache

func CreateLocalCache(config *ristretto.Config) (*ristretto.Cache, error)

func CreateMongoClient

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

func CreatePostgresClient

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

func CreateRedisClient

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

func CreateSentry

func CreateSentry(sentryConfig SentryConfig) error

func NewKafkaConn

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

func NewReaderWithTLS

func NewReaderWithTLS(cfg *KafkaConnectionConfig) *kafka.Reader

func NewWriterWithMechanism

func NewWriterWithMechanism(cfg *KafkaWriterWithMechanismConfig) *kafka.Writer

Types

type Adapter

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

type KafkaConnectionConfig

type KafkaConnectionConfig struct {
	Brokers []string
}

type KafkaMechanismConfig

type KafkaMechanismConfig struct {
	Username string
	Password string
}

type KafkaWriterWithMechanismConfig

type KafkaWriterWithMechanismConfig struct {
	MechanismConfig KafkaMechanismConfig
	Addr            []string
	Topic           string
	Balancer        kafka.Balancer
	Async           bool
	MaxAttempts     int
}

type MongoConfig

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

type PostgresConfig

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

type RedisConfig

type RedisConfig struct {
	Addr string
	DB   int
	URL  string
}

type SentryConfig

type SentryConfig struct {
	DSN                 string
	Env                 string
	TracesSampleRate    float64
	TracesSampler       sentry.TracesSampler
	EnableTracing       bool
	EnableProfiling     bool
	ProfilingSampleRate float64
}