tao

Jul 2, 2026

Changes in this version

type BaseMultiConfig

+ ExtraReserved []string

+ func (b *BaseMultiConfig[C]) GetExtraReserved() []string

May 2, 2026

Changes in this version

type BaseMultiConfig

+ func (b *BaseMultiConfig[C]) GetInstanceByName(name string) (C, bool)

+ type Instance struct

+ Cfg C

+ Name string

Apr 5, 2026

Changes in this version

+ const DefaultInstanceKey

+ const InstancesNotClosed

+ const TaskRunError

+ var UniverseInitTimeout = time.Minute

+ type BaseFactory struct

+ func NewBaseFactory[T any]() *BaseFactory[T]

+ func (f *BaseFactory[T]) Close(name string) error

+ func (f *BaseFactory[T]) CloseAll() error

+ func (f *BaseFactory[T]) Count() int

+ func (f *BaseFactory[T]) Get(name string) (T, error)

+ func (f *BaseFactory[T]) Has(name string) bool

+ func (f *BaseFactory[T]) Names() []string

+ func (f *BaseFactory[T]) Register(name string, instance T) error

+ func (f *BaseFactory[T]) RegisterWithCloser(name string, instance T, closer func() error) error

+ type BaseMultiConfig struct

+ Default string

+ Instances map[string]C

+ func (b *BaseMultiConfig[C]) GetDefaultInstanceName() string

+ func (b *BaseMultiConfig[C]) GetInstances() map[string]C

+ func (b *BaseMultiConfig[C]) MarshalJSON() ([]byte, error)

+ func (b *BaseMultiConfig[C]) SetDefaultInstanceName(name string)

+ func (b *BaseMultiConfig[C]) SetInstances(instances map[string]C)

+ type Factory interface

+ Get func(name string) (T, error)

+ Has func(name string) bool

+ Names func() []string

+ type MultiConfig interface

+ GetDefaultInstanceName func() string

+ GetInstances func() map[string]C

+ SetDefaultInstanceName func(name string)

+ SetInstances func(instances map[string]C)

Sep 21, 2022

Changes in this version

+ func LoadConfig(configKey string, config Config) error

type Config

+ Name func() string

Sep 21, 2022

Changes in this version

+ func SetAllConfigBytes(data []byte, configType ConfigType) (err error)

+ type Banner struct

+ Content string

+ Hide bool

type Log

+ Flag LogFlag

+ type LogFlag int

+ func (l *LogFlag) UnmarshalText(text []byte) error

+ func (l LogFlag) MarshalText() ([]byte, error)

+ func (l LogFlag) String() string

Apr 22, 2022

Changes in this version

+ var Add = tao.Add

+ var Done = tao.Done

+ type Universe struct

Mar 20, 2022

Changes in this version

type Log

+ Disable bool

Mar 14, 2022

Changes in this version

type ConfigType

+ const JSON

type Log

+ CallDepth int

+ type PipeTask struct

type TaskState

+ const Closed

Feb 17, 2022

Changes in this version

+ const UniverseNotInit

+ func DevelopMode()

+ func Register(configKey string, fn func() error) error

+ func SetConfigPath(confPath string)

type ConfigType

+ const None

type Task

+ State func() TaskState

Feb 7, 2022

Changes in this version

+ func DeleteLogger(configKey string) error

+ func DeleteWriter(configKey string) error

+ func GetWriter(configKey string) io.Writer

+ func SetLogger(configKey string, logger Logger) error

+ func SetWriter(configKey string, w io.Writer) error

type ErrorUnWrapper

+ func NewErrorWrapped(format string, e error) ErrorUnWrapper

type LogLevel

+ func (l *LogLevel) UnmarshalText(text []byte) error

+ func (l LogLevel) MarshalText() ([]byte, error)

+ func (l LogLevel) String() string

type LogType

+ const Console

+ func (l *LogType) UnmarshalText(text []byte) error

+ func (l LogType) MarshalText() ([]byte, error)

+ func (l LogType) String() string

type Logger

+ func GetLogger(configKey string) Logger

Jan 17, 2022

Changes in this version

+ func SetConfigBytesAll(data []byte, configType ConfigType) (err error)

+ type ConfigType uint8

+ const Json

+ const Yaml

+ type Log struct

+ Level LogLevel

+ Path string

+ Type LogType

+ type LogType string

+ const COMMAND

+ const File

type TaoConfig

+ HideBanner bool

+ var T *TaoConfig

Dec 27, 2021

Changes in this version

+ const ConfigKey

+ const ConfigNotFound

+ const ContextCanceled

+ const DuplicateCall

+ const ParamInvalid

+ const TaskCloseTwice

+ const TaskClosed

+ const TaskRunTwice

+ const TaskRunning

+ const Unknown

+ var LevelPrefix = map[LogLevel]string

+ var TaoLevel = DEBUG

+ var TaoWriter io.Writer

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

+ func Debugf(format string, v ...interface{})

+ func Error(v ...interface{})

+ func Errorf(format string, v ...interface{})

+ func Fatal(v ...interface{})

+ func Fatalf(format string, v ...interface{})

+ func GetConfigBytes(key string) ([]byte, error)

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

+ func Infof(format string, v ...interface{})

+ func NewPipeTask(task Task, runAfter ...string) *pipeTask

+ func Panic(v ...interface{})

+ func Panicf(format string, v ...interface{})

+ func Run(ctx context.Context, param Parameter) (err error)

+ func SetConfig(key string, c Config) error

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

+ func Warnf(format string, v ...interface{})

+ type Config interface

+ Default func() Config

+ RunAfter func() []string

+ ToTask func() Task

+ ValidSelf func()

+ type ErrorTao interface

+ Cause func() error

+ Code func() string

+ Wrap func(err error)

+ func NewError(code, message string, a ...interface{}) ErrorTao

+ type ErrorUnWrapper interface

+ Unwrap func() error

+ func NewErrorUnWrapper(format string, e error) ErrorUnWrapper

+ type LogLevel uint8

+ const DEBUG

+ const ERROR

+ const FATAL

+ const INFO

+ const PANIC

+ const WARNING

+ type Logger interface

+ Debug func(calldepth int, v ...interface{})

+ Debugf func(calldepth int, format string, v ...interface{})

+ Error func(calldepth int, v ...interface{})

+ Errorf func(calldepth int, format string, v ...interface{})

+ Fatal func(calldepth int, v ...interface{})

+ Fatalf func(calldepth int, format string, v ...interface{})

+ Info func(calldepth int, v ...interface{})

+ Infof func(calldepth int, format string, v ...interface{})

+ Panic func(calldepth int, v ...interface{})

+ Panicf func(calldepth int, format string, v ...interface{})

+ Warn func(calldepth int, v ...interface{})

+ Warnf func(calldepth int, format string, v ...interface{})

+ var TaoLogger Logger

+ type Parameter interface

+ Clone func() Parameter

+ Delete func(key string)

+ Get func(key string) (val interface{})

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

+ String func() string

+ func NewParameter() Parameter

+ type Pipeline interface

+ Register func(task *pipeTask) error

+ func NewPipeline(name string, options ...PipelineOption) Pipeline

+ type PipelineOption func(p *pipeline)

+ func SetPostStartTask(t *pipeTask) PipelineOption

+ func SetPreStopTask(t *pipeTask) PipelineOption

+ type TaoConfig struct

+ func (t *TaoConfig) Default() Config

+ func (t *TaoConfig) RunAfter() []string

+ func (t *TaoConfig) ToTask() Task

+ func (t *TaoConfig) ValidSelf()

+ type Task interface

+ Close func() error

+ Error func() string

+ Name func() string

+ Result func() Parameter

+ Run func(ctx context.Context, param Parameter) error

+ func NewTask(name string, fun TaskRun, options ...TaskOption) Task

+ type TaskOption func(t *task)

+ func SetClose(cf func() error) TaskOption

+ func SetPostStart(tr TaskRun) TaskOption

+ func SetPreStop(tr TaskRun) TaskOption

+ type TaskRun func(ctx context.Context, param Parameter) (Parameter, error)

+ type TaskState uint8

+ const Close

+ const Over

+ const Runnable

+ const Running