jarvisbase

Documentation

Index

• func BuildLogFilename(logtype string, subname string) string
• func BuildLogSubFilename(appName string, version string) string
• func ClearLogs() error
• func Debug(message string, fields ...zap.Field)
• func Error(message string, fields ...zap.Field)
• func Fatal(message string, fields ...zap.Field)
• func Info(message string, fields ...zap.Field)
• func InitLogger(level zapcore.Level, isConsole bool, logpath string, nodeType string)
• func JSON(key string, obj interface{}) zap.Field
• func MD5Protobuf(pb proto.Message) (string, error)
• func SyncLogger()
• func Warn(message string, fields ...zap.Field)
• type L2BaseTask
  • func (task *L2BaseTask) GetParentID() string
  • func (task *L2BaseTask) GetTaskID() int64
  • func (task *L2BaseTask) Init(pool L2RoutinePool, parentID string)
• type L2RoutinePool
  • func NewL2RoutinePool() L2RoutinePool
• type L2Task
• type RoutinePool
  • func NewRoutinePool() RoutinePool
• type Task

Functions

func BuildLogFilename

func BuildLogFilename(logtype string, subname string) string

BuildLogFilename -

func BuildLogSubFilename

func BuildLogSubFilename(appName string, version string) string

BuildLogSubFilename -

func ClearLogs

func ClearLogs() error

ClearLogs - clear logs

func Debug

func Debug(message string, fields ...zap.Field)

Debug logs a debug message with the given fields

func Error

func Error(message string, fields ...zap.Field)

Error logs a debug message with the given fields

func Fatal

func Fatal(message string, fields ...zap.Field)

Fatal logs a message than calls os.Exit(1)

func Info

func Info(message string, fields ...zap.Field)

Info logs a debug message with the given fields

func InitLogger

func InitLogger(level zapcore.Level, isConsole bool, logpath string,
	nodeType string)

InitLogger - initializes a thread-safe singleton logger

func JSON

func JSON(key string, obj interface{}) zap.Field

JSON - make json to field

func MD5Protobuf

func MD5Protobuf(pb proto.Message) (string, error)

MD5Protobuf - md5 protobuf and return string

func SyncLogger

func SyncLogger()

SyncLogger - sync logger

func Warn

func Warn(message string, fields ...zap.Field)

Warn logs a debug message with the given fields

Types

type L2BaseTask

type L2BaseTask struct {
	// contains filtered or unexported fields
}

L2BaseTask - level 2 basetask

func (*L2BaseTask) GetParentID

func (task *L2BaseTask) GetParentID() string

GetParentID - get parentID

func (*L2BaseTask) GetTaskID

func (task *L2BaseTask) GetTaskID() int64

GetTaskID - get taskID

func (*L2BaseTask) Init

func (task *L2BaseTask) Init(pool L2RoutinePool, parentID string)

Init - init

type L2RoutinePool

type L2RoutinePool interface {
	// SendTask - send new task
	SendTask(task L2Task)
	// Start - start a routine pool
	Start(ctx context.Context, maxNums int) error
	// GetStatus - get status
	GetStatus() string
	// NewTaskID - new taskID
	NewTaskID() int64
	// BuildStatus - build status
	BuildStatus() *jarviscorepb.L2PoolInfo
}

L2RoutinePool - L2RoutinePool

func NewL2RoutinePool

func NewL2RoutinePool() L2RoutinePool

NewL2RoutinePool - new RoutinePool

type L2Task

type L2Task interface {
	// Run - run task
	Run(ctx context.Context) error
	// GetParentID - get parentID
	GetParentID() string
	// GetTaskID - get taskID
	GetTaskID() int64
}

L2Task - level 2 task

type RoutinePool

type RoutinePool interface {
	// SendTask - send new task
	SendTask(task Task)
	// Start - start a routine pool
	Start(ctx context.Context, maxNums int) error
	// GetStatus - get status
	GetStatus() string
}

RoutinePool - RoutinePool

func NewRoutinePool

func NewRoutinePool() RoutinePool

NewRoutinePool - new RoutinePool

type Task

type Task interface {
	Run(ctx context.Context) error
}

Task - task