connect

Jul 8, 2024

Changes in this version

+ func InitializeMySQLConn(databaseDSN string, opt *MySQLConnectionOptions) (conn *gorm.DB, healthCheckStopFunc func(), err error)

type CockroachDBConnectionOptions

+ PingTimeout time.Duration

+ type MySQLConnectionOptions struct

+ ConnMaxLifetime time.Duration

+ LogLevel string

+ MaxIdleConns int

+ MaxOpenConns int

+ PingInterval time.Duration

+ PingTimeout time.Duration

+ ReconnectCallback func(db *gorm.DB)

+ RetryAttempts int

+ UseOpenTelemetry bool

Nov 16, 2023

Changes in this version

type HTTPConnectionOptions

+ EnableKeepAlives bool

Apr 5, 2023

Changes in this version

+ func RegisterHealthCheckService(registrar grpc.ServiceRegistrar, customHandler grpc_health_v1.HealthServer)

+ type HealthCheckService struct

+ func (s HealthCheckService) Check(_ context.Context, _ *grpc_health_v1.HealthCheckRequest) (*grpc_health_v1.HealthCheckResponse, error)

+ func (s HealthCheckService) Watch(_ *grpc_health_v1.HealthCheckRequest, server grpc_health_v1.Health_WatchServer) error

Apr 3, 2023

Changes in this version

+ type GRPCRateLimiter struct

+ ExcludedIPs []string

+ ExcludedUserAgents []string

+ Limit int64

+ Period time.Duration

type GRPCUnaryInterceptorOptions

+ RateLimiter *GRPCRateLimiter

Mar 27, 2023

Changes in this version

type GRPCUnaryInterceptorOptions

+ RecoveryHandlerFunc RecoveryHandlerFunc

+ type RecoveryHandlerFunc func(ctx context.Context, p interface{}) (err error)

Feb 1, 2023

Changes in this version

+ var CockroachDB *gorm.DB

+ var Span trace.Span

+ var StopTickerCh chan bool

+ func InitTraceProvider(token, collectorURL, serviceName string, traceRatio float64) *sdktrace.TracerProvider

+ func InitializeCockroachConn(databaseDSN string, opt *CockroachDBConnectionOptions)

+ func NewElasticsearchClient(url string, httpClient *http.Client, opt *ElasticsearchConnectionOptions) (*elastic.Client, error)

+ func UnaryServerInterceptor(opts *GRPCUnaryInterceptorOptions) grpc.UnaryServerInterceptor

+ type CockroachDBConnectionOptions struct

+ ConnMaxLifetime time.Duration

+ LogLevel string

+ MaxIdleConns int

+ MaxOpenConns int

+ PingInterval time.Duration

+ RetryAttempts int

+ UseOpenTelemetry bool

+ type ESErrorLogger struct

+ func (*ESErrorLogger) Printf(format string, values ...interface{})

+ type ESInfoLogger struct

+ func (*ESInfoLogger) Printf(format string, values ...interface{})

+ type ESTraceLogger struct

+ func (*ESTraceLogger) Printf(format string, values ...interface{})

+ type ElasticsearchConnectionOptions struct

+ MaxConnsPerHost int

+ MaxIdleConnections int

+ SetHealthcheck bool

+ SetSniff bool

+ TLSHandshakeTimeout time.Duration

+ TLSInsecureSkipVerify bool

+ UseOpenTelemetry bool

type GRPCUnaryInterceptorOptions

+ UseOpenTelemetry bool

+ type GormCustomLogger struct

+ func NewGormCustomLogger() *GormCustomLogger

+ func (g *GormCustomLogger) Error(ctx context.Context, message string, values ...interface{})

+ func (g *GormCustomLogger) Info(ctx context.Context, message string, values ...interface{})

+ func (g *GormCustomLogger) LogMode(level gormLogger.LogLevel) gormLogger.Interface

+ func (g *GormCustomLogger) Trace(ctx context.Context, begin time.Time, fc func() (string, int64), err error)

+ func (g *GormCustomLogger) Warn(ctx context.Context, message string, values ...interface{})

type HTTPConnectionOptions

+ UseOpenTelemetry bool

+ type Option func(t *Transport)

+ func WithRoundTripper(rt http.RoundTripper) Option

+ type Transport struct

+ func NewTransport(opts ...Option) *Transport

+ func (t *Transport) RoundTrip(req *http.Request) (*http.Response, error)

Jan 6, 2023

Changes in this version

+ func NewUnaryGRPCConnection(target string, dialOptions ...grpc.DialOption) (*grpc.ClientConn, error)

Apr 20, 2020

Changes in this version

type RedisConnectionPoolOptions

+ ReadOnly bool

Apr 6, 2020

Changes in this version

+ func NewGRPCConnection(target string, poolSetting *GRPCConnectionPoolSetting, ...) (*grpcpool.Pool, error)

+ type GRPCConnectionPool struct

+ Conn *grpcpool.Pool

+ type GRPCConnectionPoolSetting struct

+ IdleTimeout time.Duration

+ MaxActive int

+ MaxConnLifetime time.Duration

+ MaxIdle int

Apr 3, 2020

Changes in this version

+ func ConfigureCircuitBreaker(setting *CircuitSetting)

+ func UnaryClientInterceptor(opts *GRPCUnaryInterceptorOptions) grpc.UnaryClientInterceptor

+ type CircuitSetting struct

+ ErrorPercentThreshold int

+ MaxConcurrentRequests int

+ RequestVolumeThreshold int

+ SleepWindow int

+ Timeout int

+ type GRPCUnaryInterceptorOptions struct

+ IsPooled bool

+ RetryCount int

+ RetryInterval time.Duration

+ Timeout time.Duration

+ UseCircuitBreaker bool

Mar 18, 2020

Changes in this version

type RedisConnectionPoolOptions

+ DialTimeout time.Duration

+ ReadTimeout time.Duration

+ WriteTimeout time.Duration

Mar 11, 2020

Changes in this version

+ func NewGoRedisClusterConnectionPool(url []string, opt *RedisConnectionPoolOptions) *goredis.ClusterClient

+ func NewGoRedisConnectionPool(url string, opt *RedisConnectionPoolOptions) *goredis.Client

+ func NewHTTPConnection(opt *HTTPConnectionOptions) *http.Client

+ func NewRedigoRedisConnectionPool(url string, opt *RedisConnectionPoolOptions) *redigo.Pool

+ type HTTPConnectionOptions struct

+ TLSHandshakeTimeout time.Duration

+ TLSInsecureSkipVerify bool

+ Timeout time.Duration

+ type RedisConnectionPoolOptions struct

+ IdleCount int

+ IdleTimeout time.Duration

+ MaxConnLifetime time.Duration

+ PoolSize int