interfaces

Documentation

Index

• type Event
• type IBroker
• type ICache
• type IConfig
• type IController
• type IDatabase
• type ILogger
• type IModules
• type INoSql
• type IRepository
• type IServer
• type IService
• type IStorage
• type LogLevel
  • func GetLogLevel(str string) LogLevel
  • func (t LogLevel) String() string
• type Message
• type RouteFunc
• type Subscriber

Types

type Event

type Event interface {
	Topic() string
	Message() *Message
	Ack() error
	Error() error
}

type IBroker

type IBroker interface {
	Init(app IService) error
	Stop() error
	String() string

	Publish(topic string, m *Message) error
	Subscribe(topic string, s *Subscriber) error
}

type ICache

type ICache interface {
	Init(app IService) error
	Stop() error
	String() string

	Has(key string) bool
	Set(key string, args any, timeout time.Duration) error
	Get(key string) (any, error)
	Delete(key string) error
}

type IConfig

type IConfig interface {
	Init(app IService) error
	Stop() error
	Has(key string) bool
	GetString(key string, def string) string
	GetBool(key string, def bool) bool
	GetInt(key string, def int) int
	GetFloat(key string, def float32) float32
}

type IController

type IController interface {
	Init(app IService) error
	Stop() error
	String() string
}

type IDatabase

type IDatabase interface {
	Init(app IService) error
	Stop() error
	String() string

	Query(ctx context.Context, query interface{}, model interface{}, args ...interface{}) error
	Exec(ctx context.Context, query interface{}, args ...interface{}) error
	GetDb() interface{}
}

type ILogger

type ILogger interface {
	Init(app IService) error
	Stop() error
	SetLevel(level LogLevel)
	Push(level LogLevel, msg string, toParent bool)
	Debug(args ...interface{})
	Info(args ...interface{})
	Warn(args ...interface{})
	Message(args ...interface{})
	Error(err error)
	Fatal(err error)
	Panic(err error)
}

type IModules

type IModules interface {
	Init(app IService) error
	Stop() error
	String() string
}

type INoSql

type INoSql interface {
	Init(app IService) error
	Stop() error
	String() string

	Count(ctx context.Context, key interface{}, query interface{}, args ...interface{}) int64
	Exists(ctx context.Context, key interface{}, query interface{}, args ...interface{}) bool
	Insert(ctx context.Context, key interface{}, query interface{}, args ...interface{}) (interface{}, error)
	FindOne(ctx context.Context, key interface{}, query interface{}, model interface{}, args ...interface{}) error
	Find(ctx context.Context, key interface{}, query interface{}, model interface{}, args ...interface{}) error
	Exec(ctx context.Context, key interface{}, query interface{}, model interface{}, args ...interface{}) error
	Update(ctx context.Context, key interface{}, query interface{}, args ...interface{}) error
	Delete(ctx context.Context, key interface{}, query interface{}, args ...interface{}) int64
	Batch(ctx context.Context, key interface{}, query interface{}, typeOp string, args ...interface{}) (int64, error)
	GetDb() interface{}
}

type IRepository

type IRepository interface {
	Init(app IService) error
	Stop() error
	String() string
}

type IServer

type IServer interface {
	Init(app IService) error
	Start() error
	Stop() error
	String() string
	PushRoute(method string, path string, handler RouteFunc)
}

type IService

type IService interface {
	Init() error
	Stop() error
	GetLogger() ILogger
	GetConfig() IConfig
	PushCache(c ICache) IService
	GetCache(key string) ICache
	PushBroker(c IBroker) IService
	GetBroker(key string) IBroker
	PushDatabase(c IDatabase) IService
	GetDatabase(key string) IDatabase
	PushController(c IController) IService
	GetController(key string) IController
	PushModule(c IModules) IService
	GetModule(key string) IModules
	PushRepository(c IRepository) IService
	GetRepository(key string) IRepository
	PushServer(c IServer) IService
	GetServer(key string) IServer
	PushStorage(c IStorage) IService
	GetStorage(key string) IStorage
}

type IStorage

type IStorage interface {
	Init(app IService) error
	Stop() error
	String() string

	Has(name string) bool
	Put(name string, data []byte) error
	Read(name string) ([]byte, error)
	Delete(name string) error
	List() []string
}

type LogLevel

type LogLevel int

const (
	DEBUG LogLevel = iota
	INFO
	WARNING
	MESSAGE
	ERROR
	CRITICAL
)

func GetLogLevel

func GetLogLevel(str string) LogLevel

func (LogLevel) String

func (t LogLevel) String() string

type Message

type Message struct {
	Header map[string]string
	Body   []byte
}

type RouteFunc

type RouteFunc func(ctx *srvCtx.Ctx)

type Subscriber

type Subscriber interface {
	Handler(event *Event) error
	Unsubscribe() error
}