component

Nov 26, 2022

Changes in this version

+ func CacheBuilder() *cache.Builder

+ func DB() *db.Instance

+ func Mgo() *mongo.Instance

Oct 18, 2022

Changes in this version

type Curl

+ func (c *Curl) WithTracer(tracer *jaeger.Tracer) *Curl

type EventDispatcher

+ func (instance *EventDispatcher) TriggerAsync(eventName string, param any)

type Logger

+ func NewLoggerWithInterface(delegate LoggerInterface) *Logger

+ type LoggerInterface interface

+ Println func(v ...any)

+ type Metric struct

+ type MetricJaeger struct

Sep 27, 2022

Changes in this version

+ func ListenEvent(eventName string, handler func(param T))

+ type Discovery interface

+ Discover func(name string) (*Service, error)

+ Register func(service Service)

+ Unregister func(service Service)

+ type EtcdDiscovery struct

type Event

+ func NewEvent(name string) Event[T]

+ func (e Event[T]) Bind(handler func(param T))

+ type FileDiscovery struct

+ type Service struct

+ func NewService(name string) *Service

+ func (s *Service) WithWeight(weight int) *Service

Aug 25, 2022

Changes in this version

+ const Async

+ const Sync

+ var EmptyResponse = errors.New("empty response")

+ var ErrTokenInvalid = errors.New("token is invalid")

+ func Initialize(provider IProvider)

+ type Cache struct

+ func NewCache() *Cache

+ func (c *Cache) Build() *cache.Cache

+ func (c *Cache) BuildWith(defaultExpiration, cleanupInterval time.Duration) *cache.Cache

+ func (c *Cache) Default() *cache.Cache

+ func (c *Cache) WithCleanupInterval(cleanupInterval time.Duration) *Cache

+ func (c *Cache) WithDefaultExpiration(defaultExpiration time.Duration) *Cache

+ type Component interface

+ Name func() string

+ type Config struct

+ func NewConfig() *Config

+ func (c *Config) LoadFile(paths ...string) error

+ type Container struct

+ func NewContainer() *Container

+ func (c *Container) Cache() *Cache

+ func (c *Container) Config() *Config

+ func (c *Container) Cron() *Cron

+ func (c *Container) Curl() *Curl

+ func (c *Container) DI() *DI

+ func (c *Container) EventDispatcher() *EventDispatcher

+ func (c *Container) Get(name string) (Component, bool)

+ func (c *Container) GetOrInit(name string) Component

+ func (c *Container) Gorm() *Gorm

+ func (c *Container) Jwt() *JWT

+ func (c *Container) Logger() *Logger

+ func (c *Container) Mongo() *Mongo

+ func (c *Container) Redis() *Redis

+ func (c *Container) Register(components ...Component)

+ func (c *Container) Tracer() *Tracer

+ func (c *Container) Validator() *Validator

+ type Cron struct

+ func NewCron() *Cron

+ type Curl struct

+ func NewCurl() *Curl

+ func (c *Curl) Delete(url string, body io.Reader) (serializer.Serializer, error)

+ func (c *Curl) Get(url string) (serializer.Serializer, error)

+ func (c *Curl) Post(url string, body io.Reader) (serializer.Serializer, error)

+ func (c *Curl) PostFile(url string, files map[string]string, params map[string]string) (serializer.Serializer, error)

+ func (c *Curl) Put(url string, body io.Reader) (serializer.Serializer, error)

+ func (c *Curl) ReadResponse(resp *http.Response) (serializer.Serializer, error)

+ func (c *Curl) Send(request *http.Request) (serializer.Serializer, error)

+ func (c *Curl) WithHttpClient(httpClient *http.Client) *Curl

+ type DI struct

+ func NewDI() *DI

+ func (d *DI) Container() *dig.Container

+ func (d *DI) Inject(constructor interface{}) error

+ func (d *DI) Invoke(constructor interface{}) error

+ type Event struct

+ Name string

+ Params interface{}

+ type EventDispatcher struct

+ func NewEventDispatcher() *EventDispatcher

+ func (instance *EventDispatcher) Has(eventName string) bool

+ func (instance *EventDispatcher) Listen(eventName string, handler Handler)

+ func (instance *EventDispatcher) Register(eventName string, listener Listener)

+ func (instance *EventDispatcher) Trigger(eventName string, params interface{})

+ type Gorm struct

+ func NewGorm() *Gorm

+ func (g *Gorm) EnableConnectionPool(maxIdleConns int, maxOpenConns int, connMaxLifetime time.Duration) error

+ func (g *Gorm) Open(dialector gorm.Dialector, config *gorm.Config) error

+ func (g *Gorm) OpenMySQL(dsn string) error

+ func (g *Gorm) RegisterResolverConfig(config dbresolver.Config, tables ...interface{})

+ func (g *Gorm) UseResolver(resolver *dbresolver.DBResolver) error

+ type Handler func(ev Event)

+ type IProvider interface

+ Cache func() *Cache

+ Config func() *Config

+ Cron func() *Cron

+ Curl func() *Curl

+ EventDispatcher func() *EventDispatcher

+ Get func(name string) (Component, bool)

+ Gorm func() *Gorm

+ Jwt func() *JWT

+ Logger func() *Logger

+ Redis func() *Redis

+ Register func(components ...Component)

+ Tracer func() *Tracer

+ Validator func() *Validator

+ func Provider() IProvider

+ type JWT struct

+ func NewJWT() *JWT

+ func (impl *JWT) WithSignKey(key []byte) *JWT

+ func (impl JWT) GenerateToken(claims jwt.Claims) (string, error)

+ func (impl JWT) ParseToken(token string) (jwt.Claims, error)

+ type Listener struct

+ Handler Handler

+ Mode int

+ type LogLevel string

+ const LevelDebug

+ const LevelError

+ const LevelFatal

+ const LevelInfo

+ const LevelPanic

+ const LevelWarn

+ type Logger struct

+ func NewLogger() *Logger

+ func (l *Logger) Debug(message string)

+ func (l *Logger) Debugf(format string, args ...interface{})

+ func (l *Logger) Error(message string)

+ func (l *Logger) Errorf(format string, args ...interface{})

+ func (l *Logger) Fatal(message string)

+ func (l *Logger) Fatalf(format string, args ...interface{})

+ func (l *Logger) Info(message string)

+ func (l *Logger) Infof(format string, args ...interface{})

+ func (l *Logger) Log(level LogLevel, message string)

+ func (l *Logger) Logf(level LogLevel, format string, a ...interface{})

+ func (l *Logger) Panic(message string)

+ func (l *Logger) Warn(message string)

+ func (l *Logger) Warnf(format string, args ...interface{})

+ type Mongo struct

+ func NewMongo() *Mongo

+ func (m *Mongo) Close() error

+ func (m *Mongo) Collection(name string, opts ...*options.CollectionOptions) *mongo.Collection

+ func (m *Mongo) Connect(config *MongoConfig, timeout time.Duration) error

+ func (m *Mongo) Database(database string, opts ...*options.DatabaseOptions) *mongo.Database

+ type MongoConfig struct

+ Address string

+ AuthSource string

+ Database string

+ Password string

+ Timeout time.Duration

+ Username string

+ type Named string

+ func (n Named) Name() string

+ type Redis struct

+ func NewRedis() *Redis

+ func (r *Redis) Connect(options *redis.Options) error

+ type Tracer struct

+ func NewTracer() *Tracer

+ func (tracer *Tracer) Get() string

+ func (tracer *Tracer) Release()

+ func (tracer *Tracer) Set(id string)

+ type Validator struct

+ func NewValidator() *Validator

+ func (v *Validator) ValidateStruct(obj interface{}) error