vivard

Feb 26, 2024

Changes in this version

+ var ErrItemNotFound = errors.New("item not found")

Jan 12, 2024

Changes in this version

type GQLOptions

+ StatisticsSnapshotStep time.Duration

+ StatisticsSnapshotsCount int

Jan 11, 2024

Changes in this version

type GQLEngine

+ func (gqe *GQLEngine) SetOptions(options GQLOptions) *GQLEngine

+ type GQLOptions struct

+ LogClientErrors bool

Jan 11, 2024

Changes in this version

type GQLEngine

+ func (gqe *GQLEngine) CollectStatistics(collect bool, length ...time.Duration) *GQLEngine

+ func (gqe *GQLEngine) HTTPStatisticsHandler(pretty ...bool) http.HandlerFunc

+ func (gqe *GQLEngine) SetLogger(logger *zap.Logger) *GQLEngine

Sep 29, 2023

Changes in this version

+ func WithRequestContext(ctx context.Context, requestContext DefaultContext) context.Context

May 20, 2023

Changes in this version

+ const KVStringIntName

+ const KVStringStringName

May 19, 2023

Changes in this version

+ const KVStringInt

+ const KVStringIntInput

+ const KVStringIntInputName

+ const KVStringString

+ const KVStringStringInput

+ const KVStringStringInputName

+ const ServiceCRON

+ const ServiceGQL

+ const ServiceLoggingLogrus

+ const ServiceLoggingZap

+ const ServiceNATS

+ const ServiceSQL

+ const ServiceSQLX

+ const ServiceScripting

+ const ServiceSequenceProvider

+ var ContextID = &struct{ ... }

+ var ErrCurrentWithoutNext = errors.New("current without next")

+ var ErrInvalidDateFormat = errors.New("invalid date format")

+ var ErrInvalidValueType = errors.New("invalid value type")

+ var ErrNoSequenceProvider = errors.New("no SequenceProvider registered")

+ var ErrValueIgnored = errors.New("ignored")

+ func GQLArgToMapStringInt(arg []interface{}) (ret map[string]int, err error)

+ func GQLArgToMapStringString(arg []interface{}) (ret map[string]string, err error)

+ func InitZapLogger(cfg map[string]interface{}) (*zap.Logger, error)

+ func NewContext(ctx context.Context, userID int, userName string, source string, ...) context.Context

+ func Ptr(v T) *T

+ type ArrKV []KVPair

+ func GQLArgToArrKVStringInt(arg []interface{}) (ret ArrKV, err error)

+ func GQLArgToArrKVStringString(arg []interface{}) (ret ArrKV, err error)

+ func MapStringIntToArrKV(m map[string]int) ArrKV

+ func MapStringStringToArrKV(m map[string]string) ArrKV

+ func (akv ArrKV) ToMapStringInt() (map[string]int, error)

+ func (akv ArrKV) ToMapStringString() (map[string]string, error)

+ type CRONService struct

+ func NewCronService(ctx context.Context) *CRONService

+ func (cs *CRONService) AddFunc(spec string, cmd func(ctx context.Context) (interface{}, error)) (JobID, error)

+ func (cs *CRONService) AddNamedFunc(spec string, name string, cmd func(ctx context.Context) (interface{}, error)) (JobID, error)

+ func (cs *CRONService) Cron() *cron.Cron

+ func (cs *CRONService) ListJobs() []*Job

+ func (cs *CRONService) Prepare(eng *Engine, _ dep.Provider) (err error)

+ func (cs *CRONService) Provide() interface{}

+ func (cs *CRONService) SetJobContext(ctx context.Context)

+ func (cs *CRONService) Start(eng *Engine, _ dep.Provider) error

+ type ConfigProvider interface

+ GetConfigValue func(key string) interface{}

+ SetConfigValue func(key string, val interface{}) error

+ type Context interface

+ GetExt func(key string) interface{}

+ HasRole func(role string) bool

+ RolesMask func() int

+ Source func() string

+ UserID func() int

+ UserName func() string

+ UserType func() int

+ type DateIterator struct

+ func (di *DateIterator) Curr() (time.Time, error)

+ func (di *DateIterator) Current() time.Time

+ func (di *DateIterator) Next() bool

+ func (di *DateIterator) SetDateStep(y, m, d int)

+ func (di *DateIterator) SetStep(step time.Duration)

+ func (di *DateIterator) Start(from, to time.Time)

+ func (di *DateIterator) StartString(from, to string) (err error)

+ type DefaultContext struct

+ func RequestContext(ctx context.Context) DefaultContext

+ func (c DefaultContext) GetExt(key string) (interface{}, bool)

+ func (c DefaultContext) HasRole(role string) bool

+ func (c DefaultContext) Roles() []string

+ func (c DefaultContext) RolesMask() int

+ func (c DefaultContext) Source() string

+ func (c DefaultContext) UserID() int

+ func (c DefaultContext) UserName() string

+ func (c DefaultContext) UserType() int

+ type Engine struct

+ func NewEngine() *Engine

+ func (eng *Engine) ConfBool(key string, def ...bool) bool

+ func (eng *Engine) ConfInt(key string, def ...int) int

+ func (eng *Engine) ConfInt64(key string, def ...int64) int64

+ func (eng *Engine) ConfString(key string, def ...string) string

+ func (eng *Engine) ConfValue(key string) interface{}

+ func (eng *Engine) Config() dep.ConfigProvider

+ func (eng *Engine) Engine(name string) SubEngine

+ func (eng *Engine) GetConfig(name string) interface{}

+ func (eng *Engine) GetService(tip string) Service

+ func (eng *Engine) Logger(name string) *zap.Logger

+ func (eng *Engine) RegisterConfigProvider(p ConfigProvider, priority int)

+ func (eng *Engine) SetConfValue(key string, val interface{}) error

+ func (eng *Engine) Start() error

+ func (eng *Engine) WithEngine(se SubEngine) *Engine

+ func (eng *Engine) WithLogger(l *zap.Logger) *Engine

+ func (eng *Engine) WithService(name string, srv Service) *Engine

+ type GQLDescriptor struct

+ func (gqld *GQLDescriptor) AddInputGenerator(name string, g GQLInputTypeGenerator)

+ func (gqld *GQLDescriptor) AddMutationGenerator(name string, g GQLQueryGenerator)

+ func (gqld *GQLDescriptor) AddQueryGenerator(name string, g GQLQueryGenerator)

+ func (gqld *GQLDescriptor) AddTypeGenerator(name string, g GQLTypeGenerator)

+ func (gqld *GQLDescriptor) GetInputType(name string) gql.Input

+ func (gqld *GQLDescriptor) GetType(name string) gql.Output

+ type GQLEngine struct

+ func (gqe *GQLEngine) Descriptor() *GQLDescriptor

+ func (gqe *GQLEngine) HTTPHandler() http.HandlerFunc

+ func (gqe *GQLEngine) Prepare(_ *Engine, _ dep.Provider) error

+ func (gqe *GQLEngine) Provide() interface{}

+ func (gqe *GQLEngine) Start(eng *Engine, _ dep.Provider) error

+ type GQLInputTypeGenerator func() gql.Input

+ type GQLQueryGenerator func() *gql.Field

+ type GQLTypeGenerator func() gql.Output

+ type Generator func(eng *Engine) error

+ type Job struct

+ Duration time.Duration

+ ID JobID

+ LastError error

+ LastErrorTime time.Time

+ LastResult interface{}

+ LastRunAt time.Time

+ LastRunDuration time.Duration

+ Name string

+ RunCount int

+ Spec string

+ func (j *Job) Cancel()

+ func (j *Job) IsRunning() bool

+ func (j *Job) Run()

+ func (j *Job) ScheduledAt() *time.Time

+ type JobID int

+ type KVPair struct

+ Key interface{}

+ Val interface{}

+ func GQLArgToKVStringInt(arg map[string]interface{}) (ret KVPair, err error)

+ func GQLArgToKVStringString(arg map[string]interface{}) (ret KVPair, err error)

+ func (kv KVPair) KeyInt() int

+ func (kv KVPair) KeyInteger() (int, error)

+ func (kv KVPair) KeyStr() string

+ func (kv KVPair) KeyString() (string, error)

+ func (kv KVPair) ValInt() int

+ func (kv KVPair) ValInteger() (int, error)

+ func (kv KVPair) ValStr() string

+ func (kv KVPair) ValString() (string, error)

+ type LoggerService struct

+ func NewLoggerService(log *zap.Logger) *LoggerService

+ func (ls *LoggerService) Log() *zap.Logger

+ func (ls *LoggerService) Named(name string) *zap.Logger

+ func (ls *LoggerService) Prepare(eng *Engine, _ dep.Provider) (err error)

+ func (ls *LoggerService) Provide() any

+ func (ls *LoggerService) Start(_ *Engine, _ dep.Provider) error

+ type LogrusService struct

+ func NewLogrusService(log *logrus.Entry) *LogrusService

+ func (ls *LogrusService) Log() *logrus.Entry

+ func (ls *LogrusService) Named(name string) *logrus.Entry

+ func (ls *LogrusService) Prepare(eng *Engine, _ dep.Provider) (err error)

+ func (ls *LogrusService) Provide() interface{}

+ func (ls *LogrusService) Start(eng *Engine, _ dep.Provider) error

+ type Sequence interface

+ Current func(ctx context.Context) (int, error)

+ Next func(ctx context.Context) (int, error)

+ SetCurrent func(ctx context.Context, value int) (int, error)

+ type SequenceProvider interface

+ ListSequences func(ctx context.Context, mask string) (map[string]int, error)

+ Sequence func(ctx context.Context, name string) (Sequence, error)

+ type Service interface

+ Prepare func(eng *Engine, provider dep.Provider) error

+ Provide func() interface{}

+ Start func(eng *Engine, provider dep.Provider) error

+ type ServiceProvider interface

+ ProvideServices func(engine *Engine)

+ type SubEngine interface

+ Name func() string

+ Prepare func(engine *Engine) error

+ Start func() error

+ type ViperConfig struct

+ func NewViperConfig() ViperConfig

+ func NewViperConfigForViper(v *viper.Viper) ViperConfig

+ func (vc ViperConfig) GetConfigValue(key string) interface{}

+ func (vc ViperConfig) SetConfigValue(key string, val interface{}) error