logbot

Documentation

Index

• Constants
• Variables
• func AfterServerBootstrapped(rail miso.Rail) error
• func BeforeServerBootstrap(rail miso.Rail) error
• func InitPipeline(rail miso.Rail)
• func IsRmErrorLogTaskEnabled() bool
• func RemoveErrorLogsBefore(rail miso.Rail, upperBound time.Time) error
• func SaveErrorLog(rail miso.Rail, evt LogLineEvent) error
• func WatchLogFile(rail miso.Rail, wc WatchConfig, nodeName string) error
• type Config
  • func LoadLogBotConfig() Config
• type ErrorLog
• type ListErrorLogReq
• type ListErrorLogResp
  • func ListErrorLogs(rail miso.Rail, r ListErrorLogReq) (ListErrorLogResp, error)
• type ListedErrorLog
• type LogBotConfig
• type LogLine
• type LogLineEvent
• type SaveErrorLogCmd
• type WatchConfig

Constants

const (
	ErrorLogEventBus = "event.bus.logbot.log.error"
)

const (
	PropEnableRemoveErrLogTask = "logbot.remove-history-error-log"
)

const (
	ResourceManageLogbot = "manage-logbot"
)

Variables

var (
	ReportLogPipeline = rabbit.NewEventPipeline[ErrorLog]("logbot:error-log:report:pipeline").
		LogPayload()
)

Functions

func AfterServerBootstrapped

func AfterServerBootstrapped(rail miso.Rail) error

func BeforeServerBootstrap

func BeforeServerBootstrap(rail miso.Rail) error

func InitPipeline

func InitPipeline(rail miso.Rail)

func IsRmErrorLogTaskEnabled

func IsRmErrorLogTaskEnabled() bool

func RemoveErrorLogsBefore

func RemoveErrorLogsBefore(rail miso.Rail, upperBound time.Time) error

func SaveErrorLog

func SaveErrorLog(rail miso.Rail, evt LogLineEvent) error

func WatchLogFile

func WatchLogFile(rail miso.Rail, wc WatchConfig, nodeName string) error

Types

type Config

type Config struct {
	Config LogBotConfig `mapstructure:"logbot"`
}

func LoadLogBotConfig

func LoadLogBotConfig() Config

type ErrorLog

type ErrorLog struct {
	Node     string
	App      string
	Time     util.ETime
	TraceId  string
	SpanId   string
	FuncName string
	Message  string
}

type ListErrorLogReq

type ListErrorLogReq struct {
	App  string      `json:"app"`
	Page miso.Paging `json:"page"`
}

type ListErrorLogResp

type ListErrorLogResp struct {
	Page    miso.Paging      `json:"page"`
	Payload []ListedErrorLog `json:"payload"`
}

func ListErrorLogs

func ListErrorLogs(rail miso.Rail, r ListErrorLogReq) (ListErrorLogResp, error)

type ListedErrorLog

type ListedErrorLog struct {
	Id      int64      `json:"id"`
	Node    string     `json:"node"`
	App     string     `json:"app"`
	Caller  string     `json:"caller"`
	TraceId string     `json:"traceId"`
	SpanId  string     `json:"spanId"`
	ErrMsg  string     `json:"errMsg"`
	RTime   util.ETime `json:"rtime" gorm:"column:rtime"`
}

type LogBotConfig

type LogBotConfig struct {
	NodeName     string        `mapstructure:"node"`
	WatchConfigs []WatchConfig `mapstructure:"watch"`
}

type LogLine

type LogLine struct {
	Time    util.ETime
	Level   string
	TraceId string
	SpanId  string
	Caller  string
	Message string
}

type LogLineEvent

type LogLineEvent struct {
	App     string
	Node    string
	Time    util.ETime
	Level   string
	TraceId string
	SpanId  string
	Caller  string
	Message string
}

type SaveErrorLogCmd

type SaveErrorLogCmd struct {
	Node    string
	App     string
	Caller  string
	TraceId string
	SpanId  string
	ErrMsg  string
	RTime   util.ETime `gorm:"column:rtime"`
}

type WatchConfig

type WatchConfig struct {
	App  string
	File string
	Type string
}