rpclog

Documentation

Index

• type RPCAppender
  • func NewRPCAppender(writer io.WriteCloser, layout *logger.Appender) (fa *RPCAppender, err error)
  • func (f *RPCAppender) Close()
  • func (f *RPCAppender) Reset(intervalStr string, writer io.WriteCloser) error
  • func (f *RPCAppender) Write(event *logger.LogEvent)
• type RPCLogger
  • func NewRPCLogger(spath string, registryAddr string, log *logger.Logger, platName string, ...) (r *RPCLogger, err error)
  • func (r *RPCLogger) Close() error
  • func (r *RPCLogger) GetType() string
  • func (r *RPCLogger) MakeAppender(l *logger.Appender, event *logger.LogEvent) (logger.IAppender, error)
  • func (r *RPCLogger) MakeUniq(l *logger.Appender, event *logger.LogEvent) string

Types

type RPCAppender

type RPCAppender struct {
	Level int
	// contains filtered or unexported fields
}

RPCAppender 文件输出器

func NewRPCAppender

func NewRPCAppender(writer io.WriteCloser, layout *logger.Appender) (fa *RPCAppender, err error)

NewRPCAppender 构建writer日志输出对象

func (*RPCAppender) Close

func (f *RPCAppender) Close()

Close 关闭当前appender

func (*RPCAppender) Reset

func (f *RPCAppender) Reset(intervalStr string, writer io.WriteCloser) error

Reset 重置保存周期

func (*RPCAppender) Write

func (f *RPCAppender) Write(event *logger.LogEvent)

Write 写入日志

type RPCLogger

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

func NewRPCLogger

func NewRPCLogger(spath string, registryAddr string, log *logger.Logger, platName string, systemName string, clusterName string, serverTypes []string) (r *RPCLogger, err error)

NewRPCLogger 创建RPC日志程序

func (*RPCLogger) Close

func (r *RPCLogger) Close() error

Close 关闭RPC日志

func (*RPCLogger) GetType

func (r *RPCLogger) GetType() string

GetType 日志类型

func (*RPCLogger) MakeAppender

func (r *RPCLogger) MakeAppender(l *logger.Appender, event *logger.LogEvent) (logger.IAppender, error)

MakeAppender 构建Appender

func (*RPCLogger) MakeUniq

func (r *RPCLogger) MakeUniq(l *logger.Appender, event *logger.LogEvent) string

MakeUniq 获取日志标识