Versions in this module Expand all Collapse all v0 v0.0.6 Dec 1, 2023 v0.0.5 Nov 19, 2023 v0.0.4 Nov 18, 2023 v0.0.3 Nov 18, 2023 v0.0.2 Nov 18, 2023 Changes in this version + func GetRpc() (session rpc.Session) type ApplicationBuilder + func (h *ApplicationBuilder) EnableRpcClient(rpcOpts ...rpc.RpcClientOptions) *ApplicationBuilder + func (h *ApplicationBuilder) EnableRpcServer(rpcOpts ...rpc.RpcServerOptions) *ApplicationBuilder + func (h *ApplicationBuilder) RegisterRpcMethods(methods ...any) *ApplicationBuilder v0.0.1 Nov 18, 2023 Changes in this version + const Disable + const Enable + func AmqpPub(m rabbit.Message) error + func GetAmqp() (session rabbit.Session) + func GetCache() (c cache.C) + func GetMqtt() (session mqtt.Session) + func GetNamedOrm(aliaName string) *persistence.OrmContext + func GetOrm() *persistence.OrmContext + func MqttPub(topic string, qos byte, retained bool, data []byte) error + func MqttPublish(topic string, data []byte) error + func Query(h func(ctx persistence.OrmContext) (err error)) (err error) + func Transaction(h func(ctx persistence.TxContext) error) (err error) + type Application interface + Start func(buildHandler func(ctx context.Context, builder *ApplicationBuilder) error, ...) error + func New() (instance Application) + type ApplicationBuilder struct + func (h *ApplicationBuilder) ComponentAfter(component func(context.Context) (err error)) *ApplicationBuilder + func (h *ApplicationBuilder) ComponentBefore(component func(context.Context) (err error)) *ApplicationBuilder + func (h *ApplicationBuilder) EnableAmqp(c amqp.Connector, options ...rabbit.SessionOption) *ApplicationBuilder + func (h *ApplicationBuilder) EnableCache(redisOpts cache.RedisOptions, cacheOpts cache.Options) *ApplicationBuilder + func (h *ApplicationBuilder) EnableDatabase(config persistence.BaseConfig, models ...interface{}) *ApplicationBuilder + func (h *ApplicationBuilder) EnableMqtt(options ...mqtt.ClientOption) *ApplicationBuilder + func (h *ApplicationBuilder) EnableOrmLog() *ApplicationBuilder + func (h *ApplicationBuilder) EnableStaticWeb(assetFile func() http.FileSystem) *ApplicationBuilder + func (h *ApplicationBuilder) EnableTokenValidator(builder TokenValidatorBuilder) *ApplicationBuilder + func (h *ApplicationBuilder) EnableWeb(listen string, components ...server.Component) *ApplicationBuilder + func (h *ApplicationBuilder) HealthyHandler(handler func() int) *ApplicationBuilder + func (h *ApplicationBuilder) LoadConfig(config interface{}, callback func(etc.Loader)) (err error) + func (h *ApplicationBuilder) PrintVersion() *ApplicationBuilder + func (h *ApplicationBuilder) ReadyHandler(handler func() int) *ApplicationBuilder + func (h *ApplicationBuilder) RegisterAmqpHandlers(handlers ...amqp.Handler) *ApplicationBuilder + func (h *ApplicationBuilder) SetMonitorPrefix(prefix string) *ApplicationBuilder + func (h *ApplicationBuilder) SetWebLogLevel(lvl string) *ApplicationBuilder + type OperatorChangeInfo struct + UpdateOperator int + type OperatorInfo struct + CreateOperator int + type Pager struct + Data []interface{} + More int + PageNum int + PageSize int + TotalPage int + func QueryList(req Pager, dataPtr interface{}, ...) (p Pager, err error) + func (p *Pager) Offset() int + func (p *Pager) Total(count int64) int + type PagerResponse struct + type Pk struct + Id int + type Response struct + Code int + Message string + Status interface{} + Success string + func (r *Response) SetCode(code int) + type ResponseWrapper struct + Data interface{} + type TableChangeInfo struct + Status int + UpdateTime time.Time + type TableInfo struct + CreateTime time.Time + type Tenant struct + Org int + type TenantPk struct + type TokenValidatorBuilder func(injectFunc TokenValidatorInjectFunc) + type TokenValidatorInjectFunc func(storage token.Storage)
Go to main page