Versions in this module Expand all Collapse all v1 v1.8.13 Jul 21, 2022 Changes in this version + const TransactionKey + 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{ ... } + Database struct{ ... } + IrisApp *IrisApplication + Middleware []IrisHandler + Prometheus *Prometheus + func NewApplication() *Application + func (app *Application) BindBooting(f func(bootManager BootManager)) + func (app *Application) BindController(relativePath string, controller IrisController, handlers ...IrisHandler) + func (app *Application) BindControllerByParty(router IrisParty, controller interface{}) + func (app *Application) BindControllerWithParty(router IrisParty, controller IrisController) + func (app *Application) BindFactory(f interface{}) + func (app *Application) BindInfra(single bool, com interface{}) + func (app *Application) BindRepository(f interface{}) + func (app *Application) BindService(f interface{}) + func (app *Application) CreateParty(relativePath string, handlers ...IrisHandler) IrisParty + func (app *Application) EventsPath(infra interface{}) map[string]string + 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) GetInfra(ctx IrisContext, com interface{}) + func (app *Application) GetService(ctx IrisContext, service interface{}) + func (app *Application) GetServiceLocator() *ServiceLocatorImpl + func (app *Application) InjectController(f Dependency) + func (app *Application) InjectIntoController(f Dependency) + func (app *Application) InstallBusMiddleware(handle ...BusHandler) + func (app *Application) InstallCustom(f func() interface{}) + func (app *Application) InstallDB(f func() interface{}) + func (app *Application) InstallMiddleware(handler IrisHandler) + func (app *Application) InstallParty(prefixPath string) + func (app *Application) InstallRedis(f func() (client redis.Cmdable)) + func (app *Application) InstallSerializer(marshal func(v interface{}) ([]byte, error), ...) + func (app *Application) Iris() *IrisApplication + func (app *Application) ListenEvent(eventName string, objectMethod string, appointInfra ...interface{}) + func (app *Application) Logger() *golog.Logger + func (app *Application) NewAutoTLSRunner(addr string, domain string, email string, ...) IrisRunner + func (app *Application) NewH2CRunner(addr string, configurators ...IrisHostConfigurator) IrisRunner + func (app *Application) NewRunner(addr string, configurators ...IrisHostConfigurator) IrisRunner + func (app *Application) NewTLSRunner(addr string, certFile, keyFile string, configurators ...IrisHostConfigurator) IrisRunner + func (app *Application) RegisterShutdown(f func()) + func (app *Application) Run(runner IrisRunner, conf IrisConfiguration) + func (app *Application) SetPrefixPath(prefixPath string) + func (app *Application) SubRouter(relativePath string, handlers ...IrisHandler) IrisParty + type BeginRequest interface + BeginRequest func(Worker Worker) + type BootManager interface + EventsPath func(infra interface{}) map[string]string + FetchSingleInfra func(infra interface{}) bool + Iris func() *iris.Application + RegisterShutdown func(func()) + 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 Dependency = interface + type DomainEvent interface + GetPrototypes func() map[string]interface{} + Identity func() string + Marshal func() ([]byte, error) + SetIdentity func(identity string) + SetPrototypes func(map[string]interface{}) + Topic func() string + Unmarshal func([]byte) error + type Entity interface + AddPubEvent func(DomainEvent) + AddSubEvent func(DomainEvent) + GetPubEvents func() []DomainEvent + GetSubEvents func() []DomainEvent + Identity func() string + Marshal func() ([]byte, error) + RemoveAllPubEvent func() + RemoveAllSubEvent func() + Worker func() Worker + type Infra struct + func (infra *Infra) BeginRequest(rt Worker) + func (infra *Infra) FetchCustom(obj interface{}) + func (infra *Infra) FetchOnlyDB(db interface{}) error + func (infra *Infra) FetchSingleInfra(com interface{}) bool + func (infra *Infra) InjectBaseEntity(entity Entity) + func (infra *Infra) InjectBaseEntitys(entitys interface{}) + func (infra *Infra) NewH2CRequest(url string, transferBus ...bool) requests.Request + func (infra *Infra) NewHTTPRequest(url string, transferBus ...bool) requests.Request + func (infra *Infra) Redis() redis.Cmdable + func (infra *Infra) Worker() Worker + type Initiator interface + BindBooting func(f func(bootManager BootManager)) + BindController func(relativePath string, controller interface{}, handlers ...context.Handler) + BindControllerWithParty func(party iris.Party, controller interface{}) + BindFactory func(f interface{}) + BindInfra func(single bool, com interface{}) + BindRepository func(f interface{}) + BindService func(f interface{}) + CreateParty func(relativePath string, handlers ...context.Handler) iris.Party + FetchInfra func(ctx iris.Context, com interface{}) + FetchService func(ctx iris.Context, service interface{}) + 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{}) + 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 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{}) + Print func(v ...interface{}) + Println func(v ...interface{}) + Warn func(v ...interface{}) + Warnf func(format string, args ...interface{}) + type Prometheus struct + 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 Repository struct + func (repo *Repository) BeginRequest(rt Worker) + func (repo *Repository) FetchCustom(obj interface{}) + func (repo *Repository) FetchDB(db interface{}) error + func (repo *Repository) FetchOnlyDB(db interface{}) error + func (repo *Repository) InjectBaseEntity(entity Entity) + func (repo *Repository) InjectBaseEntitys(entitys interface{}) + func (repo *Repository) NewH2CRequest(url string, transferBus ...bool) requests.Request + func (repo *Repository) NewHTTPRequest(url string, transferBus ...bool) requests.Request + func (repo *Repository) Redis() redis.Cmdable + func (repo *Repository) Worker() Worker + type Scanner interface + Scan func(src interface{}) error + type ServiceLocatorImpl struct + func (locator *ServiceLocatorImpl) Call(fun interface{}) error + func (locator *ServiceLocatorImpl) InstallBeginCallBack(f func(Worker)) + func (locator *ServiceLocatorImpl) InstallEndCallBack(f func(Worker)) + type UnitTest interface + FetchFactory func(factory interface{}) + FetchRepository func(repository interface{}) + FetchService func(service interface{}) + InjectBaseEntity func(entity interface{}) + InstallCustom func(f func() interface{}) + InstallDB func(f func() (db interface{})) + InstallRedis func(f func() (client redis.Cmdable)) + Run func() + SetRequest func(request *http.Request) + func NewUnitTest() UnitTest + type UnitTestImpl struct + func (u *UnitTestImpl) FetchFactory(factory interface{}) + func (u *UnitTestImpl) FetchRepository(repository interface{}) + func (u *UnitTestImpl) FetchService(service interface{}) + func (u *UnitTestImpl) InjectBaseEntity(entity interface{}) + func (u *UnitTestImpl) InstallCustom(f func() interface{}) + func (u *UnitTestImpl) InstallDB(f func() (db interface{})) + func (u *UnitTestImpl) InstallRedis(f func() (client redis.Cmdable)) + 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 + Rand func() *rand.Rand + SetLogger func(Logger) + StartTime func() time.Time + Store func() *memstore.Store + WithContext func(stdContext.Context)