interfaces

Dec 12, 2024

Changes in this version

type IClientResponse

+ GetCode func() int

Nov 22, 2024

Changes in this version

type IMongoDB

+ FindOneAndUpdate func(ctx context.Context, collection string, query interface{}, update interface{}, ...) (NoSQLRow, error)

Nov 20, 2024

Changes in this version

type IClientResponse

+ GetLazyBody func() io.Reader

Nov 19, 2024

Changes in this version

+ type IAerospike interface

+ Count func(ctx context.Context, key *aerospike.Key, policy *aerospike.BasePolicy) int64

+ Delete func(ctx context.Context, key *aerospike.Key, policy *aerospike.WritePolicy) int64

+ DeleteMany func(ctx context.Context, keys []*aerospike.Key, policy *aerospike.BatchPolicy, ...) int64

+ Exec func(ctx context.Context, key *aerospike.Key, policy *aerospike.WritePolicy, ...) (NoSQLRows, error)

+ Exists func(ctx context.Context, key *aerospike.Key, policy *aerospike.BasePolicy) bool

+ Find func(ctx context.Context, query *aerospike.Statement, policy *aerospike.QueryPolicy) (NoSQLRows, error)

+ FindOne func(ctx context.Context, key *aerospike.Key, policy *aerospike.BasePolicy, ...) (NoSQLRow, error)

+ GetDb func() *aerospike.Client

+ Insert func(ctx context.Context, key *aerospike.Key, query interface{}, ...) (interface{}, error)

+ Operate func(ctx context.Context, query []aerospike.BatchRecordIfc) (int64, error)

+ type IMongoDB interface

+ Batch func(ctx context.Context, collection string, query []mongo.WriteModel, ...) (int64, error)

+ Count func(ctx context.Context, collection string, query interface{}, ...) int64

+ Delete func(ctx context.Context, collection string, query interface{}, ...) int64

+ Exec func(ctx context.Context, collection string, query interface{}, ...) (NoSQLRows, error)

+ Exists func(ctx context.Context, collection string, query interface{}) bool

+ Find func(ctx context.Context, collection string, query interface{}, ...) (NoSQLRows, error)

+ FindOne func(ctx context.Context, collection string, query interface{}, ...) (NoSQLRow, error)

+ GetDb func() *mongo.Database

+ Insert func(ctx context.Context, collection string, query interface{}, ...) (interface{}, error)

+ Update func(ctx context.Context, collection string, query interface{}, update interface{}, ...) error

Sep 5, 2024

Changes in this version

+ type IClientBase interface

+ Fetch func(ctx context.Context, method string, host string, data []byte, ...) chan IClientResponse

+ type IClientGrpc interface

+ GetClient func() *grpc.ClientConn

type IEngine

+ SetTrace func(c ITrace)

+ type IServerBase interface

+ PushRoute func(method string, path string, handler RouteFunc, middlewares []string)

+ type IServerGRPC interface

+ RegisterService func(desc *grpc.ServiceDesc, impl any)

+ type ITrace interface

+ Init func(app IEngine) error

+ Start func() error

+ Stop func() error

Aug 24, 2024

Changes in this version

type ICache

+ Expire func(key string, timeout time.Duration) error

+ type IEngine interface

+ GetCache func(key string) ICache

+ GetClient func(key string) IClient

+ GetConfig func() IConfig

+ GetController func(key string) IController

+ GetDatabase func(key string) IDatabase

+ GetLogger func() ILogger

+ GetMiddleware func(key string) IMiddleware

+ GetModule func(key string) IModules

+ GetNoSql func(key string) INoSql

+ GetRepository func(key string) IRepository

+ GetServer func(key string) IServer

+ GetService func(key string) IService

+ GetStorage func(key string) IStorage

+ GetTask func(key string) ITask

+ Init func() error

+ PushCache func(c ICache) IEngine

+ PushClient func(c IClient) IEngine

+ PushController func(c IController) IEngine

+ PushDatabase func(c IDatabase) IEngine

+ PushMiddleware func(c IMiddleware) IEngine

+ PushModule func(c IModules) IEngine

+ PushNoSql func(c INoSql) IEngine

+ PushRepository func(c IRepository) IEngine

+ PushServer func(c IServer) IEngine

+ PushService func(c IService) IEngine

+ PushStorage func(c IStorage) IEngine

+ PushTask func(c ITask) IEngine

+ RemoveTask func(key string)

+ RunTask func(key string, args map[string]interface{}) error

+ SetMetrics func(c IMetrics)

+ Stop func() error

type IService

+ String func() string

+ type ITask interface

+ Init func(app IEngine) error

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

+ Start func() []ITaskRunConfiguration

+ Stop func() error

+ String func() string

+ type ITaskRunConfiguration interface

+ type TaskRunAfter struct

+ After time.Duration

+ Restart <-chan time.Duration

+ type TaskRunTime struct

+ Restart <-chan time.Time

+ To time.Time

Aug 4, 2024

Changes in this version

type IConfig

+ GetMapBool func(key string, def map[string]bool) map[string]bool

+ GetMapFloat func(key string, def map[string]float64) map[string]float64

+ GetMapInt func(key string, def map[string]int) map[string]int

+ GetMapString func(key string, def map[string]string) map[string]string

+ GetSliceBool func(key string, def []bool) []bool

+ GetSliceFloat func(key string, def []float64) []float64

+ GetSliceInt func(key string, def []int) []int

+ GetSliceString func(key string, def []string) []string

Jul 23, 2024

Changes in this version

type ICtx

+ GetRouterValue func(key string) string

+ SetRouteProps func(values map[string]string)

type IStorage

+ GetModified func(name string) (int64, error)

+ GetSize func(name string) (int64, error)

+ IsFolder func(name string) (bool, error)

+ StoreFolder func(name string) error

Jul 3, 2024

Changes in this version

+ type ICookie interface

+ Get func(key string) string

+ GetAsMap func() map[string]string

+ Set func(key string, value string, path string, expires time.Duration)

+ type ICtx interface

+ Done func() <-chan struct{}

+ GetRequest func() IRequest

+ GetResponse func() IResponse

+ GetUserValue func(key string) (interface{}, error)

+ PushUserValue func(key string, val interface{})

+ StartTimeout func(t time.Duration) context.CancelFunc

+ type IHeader interface

+ Add func(key, value string)

+ Del func(key string)

+ Get func(key string) string

+ GetAsMap func() map[string][]string

+ Set func(key string, value string)

+ Values func(key string) []string

+ type IQuery interface

+ Get func(key string) string

+ type IRequest interface

+ GetBody func() io.ReadCloser

+ GetBodySize func() int64

+ GetCookie func() ICookie

+ GetHeader func() IHeader

+ GetMethod func() string

+ GetQuery func() IQuery

+ GetRemoteHost func() string

+ GetRemoteIP func() string

+ GetURI func() string

+ GetUserAgent func() string

+ type IResponse interface

+ Clear func()

+ Cookie func() ICookie

+ GetBody func() []byte

+ GetStatus func() int

+ Header func() IHeader

+ SetBody func(data []byte)

+ SetStatus func(status int)

Jun 27, 2024

Changes in this version

type ICache

+ Decrement func(key string, val int64, timeout time.Duration) (int64, error)

+ DecrementIn func(key string, key2 string, val int64, timeout time.Duration) (int64, error)

+ GetIn func(key string, key2 string) (any, error)

+ GetMap func(key string) (any, error)

+ Increment func(key string, val int64, timeout time.Duration) (int64, error)

+ IncrementIn func(key string, key2 string, val int64, timeout time.Duration) (int64, error)

+ SetIn func(key string, key2 string, args any, timeout time.Duration) error

+ SetMap func(key string, args any, timeout time.Duration) error

+ type IClient interface

+ Fetch func(method string, host string, data []byte, headers map[string][]string) chan IClientResponse

+ Init func(app IService) error

+ Stop func() error

+ String func() string

+ type IClientResponse interface

+ Error func() error

+ GetBody func() []byte

+ GetHeader func() map[string][]string

+ GetRetries func() int

+ type IMetrics interface

+ Init func(app IService) error

+ Start func() error

+ Stop func() error

+ type IMiddleware interface

+ Init func(app IService) error

+ Invoke func(next RouteFunc) RouteFunc

+ Stop func() error

+ String func() string

type IService

+ GetClient func(key string) IClient

+ GetMiddleware func(key string) IMiddleware

+ GetNoSql func(key string) INoSql

+ PushClient func(c IClient) IService

+ PushMiddleware func(c IMiddleware) IService

+ PushNoSql func(c INoSql) IService

+ SetMetrics func(c IMetrics)

May 22, 2024

Changes in this version

type IDatabase

+ QueryRow func(ctx context.Context, query string, args ...interface{}) (SQLRow, error)

+ type NoSQLRow interface

+ Scan func(dest any) error

+ type NoSQLRows interface

+ Close func() error

+ Next func() bool

+ Scan func(dest any) error

+ type SQLRow interface

+ Scan func(dest ...any) error

+ type SQLRows interface

+ Close func() error

+ Next func() bool

+ Scan func(dest ...any) error

May 20, 2024

Changes in this version

type IDatabase

+ Query func(ctx context.Context, query interface{}, model interface{}, args ...interface{}) error

+ type INoSql interface

+ Batch func(ctx context.Context, key interface{}, query interface{}, typeOp string, ...) (int64, error)

+ Count func(ctx context.Context, key interface{}, query interface{}, args ...interface{}) int64

+ Delete func(ctx context.Context, key interface{}, query interface{}, args ...interface{}) int64

+ Exec func(ctx context.Context, key interface{}, query interface{}, model interface{}, ...) error

+ Exists func(ctx context.Context, key interface{}, query interface{}, args ...interface{}) bool

+ Find func(ctx context.Context, key interface{}, query interface{}, model interface{}, ...) error

+ FindOne func(ctx context.Context, key interface{}, query interface{}, model interface{}, ...) error

+ GetDb func() interface{}

+ Init func(app IService) error

+ Insert func(ctx context.Context, key interface{}, query interface{}, args ...interface{}) (interface{}, error)

+ Stop func() error

+ String func() string

+ Update func(ctx context.Context, key interface{}, query interface{}, args ...interface{}) error

type IService

+ GetConfig func() IConfig

May 14, 2024

Changes in this version

type IServer

+ Start func() error

May 14, 2024

Changes in this version

type IServer

+ PushRoute func(method string, path string, handler RouteFunc)

+ type RouteFunc func(ctx *context.Context)

May 14, 2024

Changes in this version

+ type Event interface

+ Ack func() error

+ Error func() error

+ Message func() *Message

+ Topic func() string

+ type IBroker interface

+ Init func(app IService) error

+ Publish func(topic string, m *Message) error

+ Stop func() error

+ String func() string

+ Subscribe func(topic string, s *Subscriber) error

+ type ICache interface

+ Delete func(key string) error

+ Get func(key string) (any, error)

+ Has func(key string) bool

+ Init func(app IService) error

+ Set func(key string, args any, timeout time.Duration) error

+ Stop func() error

+ String func() string

+ type IConfig interface

+ GetBool func(key string, def bool) bool

+ GetFloat func(key string, def float32) float32

+ GetInt func(key string, def int) int

+ GetString func(key string, def string) string

+ Has func(key string) bool

+ Init func(app IService) error

+ Stop func() error

+ type IController interface

+ Init func(app IService) error

+ Stop func() error

+ String func() string

+ type IDatabase interface

+ Count func(ctx context.Context, query interface{}, args ...interface{}) int64

+ Delete func(ctx context.Context, query interface{}, args ...interface{}) int64

+ Exec func(ctx context.Context, query interface{}, model interface{}, args ...interface{}) error

+ Exists func(ctx context.Context, query interface{}, args ...interface{}) bool

+ Find func(ctx context.Context, query interface{}, model interface{}, args ...interface{}) error

+ FindOne func(ctx context.Context, query interface{}, model interface{}, args ...interface{}) error

+ GetDb func() interface{}

+ Init func(app IService) error

+ Stop func() error

+ String func() string

+ Update func(ctx context.Context, query interface{}, args ...interface{}) error

+ type ILogger interface

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

+ Error func(err error)

+ Fatal func(err error)

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

+ Init func(app IService) error

+ Message func(args ...interface{})

+ Panic func(err error)

+ Push func(level LogLevel, msg string, toParent bool)

+ SetLevel func(level LogLevel)

+ Stop func() error

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

+ type IModules interface

+ Init func(app IService) error

+ Stop func() error

+ String func() string

+ type IRepository interface

+ Init func(app IService) error

+ Stop func() error

+ String func() string

+ type IServer interface

+ Init func(app IService) error

+ Stop func() error

+ String func() string

+ type IService interface

+ GetBroker func(key string) IBroker

+ GetCache func(key string) ICache

+ GetController func(key string) IController

+ GetDatabase func(key string) IDatabase

+ GetLogger func() ILogger

+ GetModule func(key string) IModules

+ GetRepository func(key string) IRepository

+ GetServer func(key string) IServer

+ GetStorage func(key string) IStorage

+ Init func() error

+ PushBroker func(c IBroker) IService

+ PushCache func(c ICache) IService

+ PushController func(c IController) IService

+ PushDatabase func(c IDatabase) IService

+ PushModule func(c IModules) IService

+ PushRepository func(c IRepository) IService

+ PushServer func(c IServer) IService

+ PushStorage func(c IStorage) IService

+ Stop func() error

+ type IStorage interface

+ Delete func(name string) error

+ Has func(name string) bool

+ Init func(app IService) error

+ List func() []string

+ Put func(name string, data []byte) error

+ Read func(name string) ([]byte, error)

+ Stop func() error

+ String func() string

+ type LogLevel int

+ const CRITICAL

+ const DEBUG

+ const ERROR

+ const INFO

+ const MESSAGE

+ const WARNING

+ func GetLogLevel(str string) LogLevel

+ func (t LogLevel) String() string

+ type Message struct

+ Body []byte

+ Header map[string]string

+ type Subscriber interface

+ Handler func(event *Event) error

+ Unsubscribe func() error