internal

Aug 12, 2022

Changes in this version

type UnitTest

+ InstallCustom func(f func() interface{})

type UnitTestImpl

+ func (u *UnitTestImpl) InstallCustom(f func() interface{})

Aug 15, 2021

Changes in this version

type Entity

+ GetPubEvents func() []DomainEvent

+ GetSubEvents func() []DomainEvent

May 8, 2021

Changes in this version

+ const TransactionKey

Feb 27, 2021

Changes in this version

type Application

+ func (app *Application) BindBooting(f func(bootManager BootManager))

+ func (app *Application) BindControllerWithParty(router IrisParty, controller IrisController)

+ func (app *Application) FetchInfra(ctx IrisContext, com interface{})

+ func (app *Application) FetchService(ctx IrisContext, service interface{})

+ func (app *Application) FetchSingleInfra(com interface{}) bool

+ func (app *Application) InstallCustom(f func() interface{})

+ type BootManager interface

+ EventsPath func(infra interface{}) map[string]string

+ FetchSingleInfra func(infra interface{}) bool

+ Iris func() *iris.Application

+ RegisterShutdown func(func())

type Infra

+ func (infra *Infra) FetchCustom(obj interface{})

+ func (infra *Infra) FetchOnlyDB(db interface{}) error

+ func (infra *Infra) FetchSingleInfra(com interface{}) bool

type InfraPool

+ func (pool *InfraPool) FetchSingleInfra(ptr reflect.Value) bool

type Initiator

+ BindBooting func(f func(bootManager BootManager))

+ BindControllerWithParty func(party iris.Party, controller interface{})

+ FetchInfra func(ctx iris.Context, com interface{})

+ FetchService func(ctx iris.Context, service interface{})

type Repository

+ func (repo *Repository) FetchCustom(obj interface{})

+ func (repo *Repository) FetchOnlyDB(db interface{}) error

type UnitTest

+ FetchFactory func(factory interface{})

+ FetchRepository func(repository interface{})

+ FetchService func(service interface{})

type UnitTestImpl

+ func (u *UnitTestImpl) FetchFactory(factory interface{})

+ func (u *UnitTestImpl) FetchRepository(repository interface{})

+ func (u *UnitTestImpl) FetchService(service interface{})

Jan 17, 2021

Changes in this version

type Application

+ func (app *Application) AddStarter(f func(starter Starter))

+ func (app *Application) AsyncCacheWarmUp(f func(repo *Repository))

+ func (app *Application) BindControllerWithRouter(router IrisParty, controller IrisController)

+ func (app *Application) CacheWarmUp(f func(repo *Repository))

+ func (app *Application) GetServiceLocator() *ServiceLocatorImpl

+ func (app *Application) InjectIntoController(f Dependency)

+ func (app *Application) SetPrefixPath(prefixPath string)

+ func (app *Application) SubRouter(relativePath string, handlers ...IrisHandler) IrisParty

+ type Dependency = interface

type DomainEvent

+ Unmarshal func([]byte) error

+ type IrisApplication = iris.Application

+ type IrisConfiguration = iris.Configuration

+ type IrisContext = iris.Context

+ type IrisController = interface

+ type IrisHandler = context.Handler

+ type IrisHostConfigurator = host.Configurator

+ type IrisMVCApplication = mvc.Application

+ type IrisParty = iris.Party

+ type IrisRunner = iris.Runner

+ type ServiceLocatorImpl struct

+ func (locator *ServiceLocatorImpl) Call(fun interface{})

+ func (locator *ServiceLocatorImpl) InstallBeginCallBack(f func(Worker))

+ func (locator *ServiceLocatorImpl) InstallEndCallBack(f func(Worker))

type Starter

+ AsyncCacheWarmUp func(f func(repo *Repository))

+ CacheWarmUp func(f func(repo *Repository))

type UnitTest

+ func NewUnitTest() UnitTest

Dec 19, 2020

Changes in this version

type Entity

+ Worker func() Worker

Nov 15, 2020

Changes in this version

+ type DomainEvent interface

+ GetPrototypes func() map[string]interface{}

+ Identity func() interface{}

+ Marshal func() []byte

+ SetIdentity func(identity interface{})

+ SetPrototypes func(map[string]interface{})

+ Topic func() string

type Entity

+ AddPubEvent func(DomainEvent)

+ AddSubEvent func(DomainEvent)

+ GetPubEvent func() []DomainEvent

+ GetSubEvent func() []DomainEvent

+ RemoveAllPubEvent func()

+ RemoveAllSubEvent func()

type Infra

+ func (infra *Infra) GetSingleInfra(com interface{}) bool

Nov 7, 2020

Changes in this version

type Application

+ func (app *Application) NewAutoTLSRunner(addr string, domain string, email string, configurators ...host.Configurator) iris.Runner

+ func (app *Application) NewH2CRunner(addr string, configurators ...host.Configurator) iris.Runner

+ func (app *Application) NewRunner(addr string, configurators ...host.Configurator) iris.Runner

+ func (app *Application) NewTLSRunner(addr string, certFile, keyFile string, configurators ...host.Configurator) iris.Runner

Sep 5, 2020

Changes in this version

type Application

+ func (app *Application) RegisterShutdown(f func())

type Infra

+ func (infra *Infra) NewHTTPRequest(url string, transferBus ...bool) requests.Request

type Repository

+ func (repo *Repository) NewHTTPRequest(url string, transferBus ...bool) requests.Request

type SingleBoot

+ RegisterShutdown func(func())

Aug 21, 2020

Changes in this version

type Application

+ func (app *Application) CallService(fun interface{}, worker ...Worker)

type Worker

+ SetLogger func(Logger)

Aug 12, 2020

Changes in this version

type UnitTest

+ GetFactory func(factory interface{})

Aug 8, 2020

Changes in this version

type Application

+ func (app *Application) InstallDB(f func() interface{})

type Infra

+ func (c *Infra) SourceDB() (db interface{})

type Repository

+ func (repo *Repository) FetchDB(db interface{}) error

+ func (repo *Repository) FetchSourceDB(db interface{}) error

type UnitTest

+ InstallDB func(f func() (db interface{}))

type UnitTestImpl

+ func (u *UnitTestImpl) InstallDB(f func() (db interface{}))

Jul 25, 2020

Changes in this version

type UnitTestImpl

+ func (u *UnitTestImpl) GetFactory(factory interface{})

Jul 19, 2020

Changes in this version

type Application

+ func (app *Application) BindFactory(f interface{})

+ type FactoryPool struct

type Initiator

+ BindFactory func(f interface{})

Jul 3, 2020

Changes in this version

type Worker

+ Rand func() *rand.Rand

Jun 15, 2020

Changes in this version

type Infra

+ func (infra *Infra) GetWorker() Worker

+ func (infra *Infra) InjectBaseEntity(entity Entity)

+ func (infra *Infra) InjectBaseEntitys(entitys interface{})

+ func (infra *Infra) Other(obj interface{})

Jun 14, 2020

Changes in this version

+ const WorkerKey

+ func ConvertAssign(dest, src interface{}) error

+ func HandleBusMiddleware(worker Worker)

+ func InSlice(array interface{}, item interface{}) bool

+ func NewMap(dst interface{}) error

+ func NewSlice(dsc interface{}, len int) error

+ func Prepare(f func(Initiator))

+ func SliceDelete(arr interface{}, indexArr ...int) error

+ type Application struct

+ Cache struct{ ... }

+ ControllerDep []interface{}

+ Database struct{ ... }

+ IrisApp *iris.Application

+ Middleware []context.Handler

+ Prometheus *Prometheus

+ func NewApplication() *Application

+ func (app *Application) AsyncCachePreheat(f func(repo *Repository))

+ func (app *Application) BindController(relativePath string, controller interface{}, handlers ...context.Handler)

+ func (app *Application) BindControllerByParty(party iris.Party, controller interface{})

+ func (app *Application) BindInfra(single bool, com interface{})

+ func (app *Application) BindRepository(f interface{})

+ func (app *Application) BindService(f interface{})

+ func (app *Application) CachePreheat(f func(repo *Repository))

+ func (app *Application) Closeing(f func())

+ func (app *Application) CreateH2CRunner(addr string, configurators ...host.Configurator) iris.Runner

+ func (app *Application) CreateParty(relativePath string, handlers ...context.Handler) iris.Party

+ func (app *Application) CreateRunner(addr string, configurators ...host.Configurator) iris.Runner

+ func (app *Application) EventsPath(infra interface{}) map[string]string

+ func (app *Application) GetInfra(ctx iris.Context, com interface{})

+ func (app *Application) GetService(ctx iris.Context, service interface{})

+ func (app *Application) GetSingleInfra(com interface{})

+ func (app *Application) InjectController(f interface{})

+ func (app *Application) InstallBusMiddleware(handle ...BusHandler)

+ func (app *Application) InstallDomainEventInfra(eventInfra DomainEventInfra)

+ func (app *Application) InstallGorm(f func() (db *gorm.DB))

+ func (app *Application) InstallMiddleware(handler iris.Handler)

+ func (app *Application) InstallOther(f func() interface{})

+ func (app *Application) InstallParty(relativePath string)

+ func (app *Application) InstallRedis(f func() (client redis.Cmdable))

+ func (app *Application) InstallSerializer(marshal func(v interface{}) ([]byte, error), ...)

+ func (app *Application) Iris() *iris.Application

+ func (app *Application) ListenEvent(eventName string, objectMethod string, appointInfra ...interface{})

+ func (app *Application) Logger() *golog.Logger

+ func (app *Application) Run(serve iris.Runner, irisConf iris.Configuration)

+ func (app *Application) Start(f func(starter Starter))

+ type BeginRequest interface

+ BeginRequest func(Worker Worker)

+ type Builder struct

+ func (b *Builder) Order() interface{}

+ func (b *Builder) SelectColumn(column ...string) *Builder

+ func (b *Builder) SelectPrimary() *Builder

+ func (b *Builder) SetPage(page, pageSize int) *Builder

+ func (p *Builder) Execute(db *gorm.DB, object interface{}) (e error)

+ func (p *Builder) TotalPage() int

+ type Bus struct

+ func (b *Bus) Add(key, obj string)

+ func (b *Bus) Del(key string)

+ func (b *Bus) Get(key string) string

+ func (b *Bus) Set(key, obj string)

+ type BusHandler func(Worker)

+ type DomainEventInfra interface

+ DomainEvent func(producer, topic string, data []byte, worker Worker, ...)

+ type Entity interface

+ DomainEvent func(eventName string, object interface{}, header ...map[string]string)

+ GetWorker func() Worker

+ Identity func() string

+ Marshal func() []byte

+ SetProducer func(string)

+ type EventBus struct

+ func (msgBus *EventBus) EventsPath(infra interface{}) (msgs map[string]string)

+ type GORMRepository interface

+ DB func() *gorm.DB

+ GetWorker func() Worker

+ InjectBaseEntity func(entity Entity)

+ InjectBaseEntitys func(entitys interface{})

+ type Infra struct

+ Worker Worker

+ func (c *Infra) BeginRequest(rt Worker)

+ func (c *Infra) DB() (db *gorm.DB)

+ func (c *Infra) NewH2CRequest(url string, transferBus ...bool) Request

+ func (c *Infra) NewHttpRequest(url string, transferBus ...bool) Request

+ func (c *Infra) Redis() redis.Cmdable

+ func (repo *Infra) GetOther(obj interface{})

+ type InfraPool struct

+ func (pool *InfraPool) Closeing(f func())

+ func (pool *InfraPool) GetSingleInfra(ptr reflect.Value) bool

+ type Initiator interface

+ BindController func(relativePath string, controller interface{}, handlers ...context.Handler)

+ BindControllerByParty func(party iris.Party, controller interface{})

+ BindInfra func(single bool, com interface{})

+ BindRepository func(f interface{})

+ BindService func(f interface{})

+ CreateParty func(relativePath string, handlers ...context.Handler) iris.Party

+ GetInfra func(ctx iris.Context, com interface{})

+ GetService func(ctx iris.Context, service interface{})

+ InjectController func(f interface{})

+ Iris func() *iris.Application

+ ListenEvent func(eventName string, objectMethod string, appointInfra ...interface{})

+ Start func(f func(starter Starter))

+ type JMap struct

+ func NewJMap(openLock ...bool) *JMap

+ func (jm *JMap) AllKey() []interface{}

+ func (jm *JMap) DelAll()

+ func (jm *JMap) Exist(key interface{}) bool

+ func (jm *JMap) Get(key interface{}, value interface{}) error

+ func (jm *JMap) Interface(key interface{}) interface{}

+ func (jm *JMap) Remove(key interface{})

+ func (jm *JMap) Set(key interface{}, value interface{})

+ func (jm *JMap) SetOrStore(key interface{}, value interface{}) (v interface{}, set bool)

+ type Logger interface

+ Debug func(v ...interface{})

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

+ Error func(v ...interface{})

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

+ Fatal func(v ...interface{})

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

+ Info func(v ...interface{})

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

+ Log func(level golog.Level, v ...interface{})

+ Logf func(level golog.Level, format string, args ...interface{})

+ Print func(v ...interface{})

+ Printf func(format string, args ...interface{})

+ Println func(v ...interface{})

+ Warn func(v ...interface{})

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

+ type Prometheus struct

+ func (p *Prometheus) KafkaProducerWithLabelValues(topic string, e error, starTime time.Time)

+ func (p *Prometheus) OrmWithLabelValues(model, method string, e error, starTime time.Time)

+ func (p *Prometheus) RegisterCounter(conter *prometheus.CounterVec)

+ func (p *Prometheus) RegisterHistogram(histogram *prometheus.HistogramVec)

+ type QueryBuilder interface

+ Execute func(db *gorm.DB, object interface{}) (e error)

+ Order func() interface{}

+ type Reorder struct

+ func (o *Reorder) NewBuilder() *Builder

+ func (o *Reorder) NewPageBuilder(page, pageSize int) *Builder

+ func (o *Reorder) Order() interface{}

+ type Repository struct

+ Worker Worker

+ func (repo *Repository) BeginRequest(rt Worker)

+ func (repo *Repository) DB() (db *gorm.DB)

+ func (repo *Repository) GetWorker() Worker

+ func (repo *Repository) InjectBaseEntity(entity Entity)

+ func (repo *Repository) InjectBaseEntitys(entitys interface{})

+ func (repo *Repository) NewH2CRequest(url string, transferBus ...bool) Request

+ func (repo *Repository) NewHttpRequest(url string, transferBus ...bool) Request

+ func (repo *Repository) NewORMAscBuilder(column string, columns ...string) *Reorder

+ func (repo *Repository) NewORMBuilder() *Builder

+ func (repo *Repository) NewORMDescBuilder(column string, columns ...string) *Reorder

+ func (repo *Repository) Other(obj interface{})

+ func (repo *Repository) Redis() redis.Cmdable

+ func (repo *Repository) SourceDB() (db *gorm.DB)

+ type RepositoryPool struct

+ type Request requests.Request

+ type Scanner interface

+ Scan func(src interface{}) error

+ type ServicePool struct

+ type SingleBoot interface

+ Closeing func(func())

+ EventsPath func(infra interface{}) map[string]string

+ Iris func() *iris.Application

+ type Starter interface

+ AsyncCachePreheat func(f func(repo *Repository))

+ CachePreheat func(f func(repo *Repository))

+ GetSingleInfra func(com interface{})

+ Iris func() *iris.Application

+ type Store struct

+ func (s *Store) Exist(key interface{}) bool

+ func (s *Store) Get(key interface{}, value interface{}) error

+ func (s *Store) Keys() []interface{}

+ func (s *Store) Remove(key interface{})

+ func (s *Store) RemoveAll()

+ func (s *Store) Set(key interface{}, value interface{})

+ func (s *Store) SetOrStore(key interface{}, value interface{}) (v interface{}, set bool)

+ func (s *Store) ToInterface(key interface{}) interface{}

+ func (s *Store) ToMap() map[interface{}]interface{}

+ func (s *Store) Values() []interface{}

+ type UnitTest interface

+ GetRepository func(repository interface{})

+ GetService func(service interface{})

+ InjectBaseEntity func(entity interface{})

+ InstallDomainEventInfra func(eventInfra DomainEventInfra)

+ InstallGorm func(f func() (db *gorm.DB))

+ InstallRedis func(f func() (client redis.Cmdable))

+ NewDomainEventInfra func(call ...func(producer, topic string, data []byte, header map[string]string)) DomainEventInfra

+ Run func()

+ SetRequest func(request *http.Request)

+ type UnitTestImpl struct

+ func (u *UnitTestImpl) GetRepository(repository interface{})

+ func (u *UnitTestImpl) GetService(service interface{})

+ func (u *UnitTestImpl) InjectBaseEntity(entity interface{})

+ func (u *UnitTestImpl) InstallDomainEventInfra(eventInfra DomainEventInfra)

+ func (u *UnitTestImpl) InstallGorm(f func() (db *gorm.DB))

+ func (u *UnitTestImpl) InstallRedis(f func() (client redis.Cmdable))

+ func (u *UnitTestImpl) NewDomainEventInfra(call ...func(producer, topic string, data []byte, header map[string]string)) DomainEventInfra

+ func (u *UnitTestImpl) Run()

+ func (u *UnitTestImpl) SetRequest(request *http.Request)

+ type Worker interface

+ Bus func() *Bus

+ Context func() stdContext.Context

+ DeferRecycle func()

+ IrisContext func() iris.Context

+ IsDeferRecycle func() bool

+ Logger func() Logger

+ StartTime func() time.Time

+ Store func() *memstore.Store

+ WithContext func(stdContext.Context)