adapters

Documentation

Index

• 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 NewTraceProvider(ctx context.Context, cfg Config) *sdktrace.TracerProvider
• func NewWriterWithMechanism(cfg *KafkaWriterWithMechanismConfig) *kafka.Writer
• type Adapter
• type Config
• type ExporterConfig
• type KafkaConnectionConfig
• type KafkaMechanismConfig
• type KafkaWriterWithMechanismConfig
• type LauncherConfig
• type MongoConfig
• type PostgresConfig
• type RedisConfig
• type SentryConfig
• type TraceProviderConfig

Functions

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 NewTraceProvider

func NewTraceProvider(ctx context.Context, cfg Config) *sdktrace.TracerProvider

func NewWriterWithMechanism

func NewWriterWithMechanism(cfg *KafkaWriterWithMechanismConfig) *kafka.Writer

Types

type Adapter

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

type Config

type Config struct {
	ExporterConfig      ExporterConfig
	TraceProviderConfig TraceProviderConfig
}

type ExporterConfig

type ExporterConfig struct {
	Endpoint    string
	AccessToken string
}

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 LauncherConfig

type LauncherConfig struct {
	ServiceName string
	AccessToken string
}

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
}

type TraceProviderConfig

type TraceProviderConfig struct {
	ServiceName    string
	ServiceVersion string
	Env            string
}