log.go 1006 B

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647
  1. package log
  2. import (
  3. "sync/atomic"
  4. "unsafe"
  5. "v2ray.com/core/common/serial"
  6. )
  7. // Message is the interface for all log messages.
  8. type Message interface {
  9. String() string
  10. }
  11. // Handler is the interface for log handler.
  12. type Handler interface {
  13. Handle(msg Message)
  14. }
  15. // GeneralMessage is a general log message that can contain all kind of content.
  16. type GeneralMessage struct {
  17. Severity Severity
  18. Content interface{}
  19. }
  20. // String implements Message.
  21. func (m *GeneralMessage) String() string {
  22. return serial.Concat("[", m.Severity, "]: ", m.Content)
  23. }
  24. // Record writes a message into log stream.
  25. func Record(msg Message) {
  26. h := (*Handler)(atomic.LoadPointer(&logHandler))
  27. (*h).Handle(msg)
  28. }
  29. var (
  30. logHandler unsafe.Pointer
  31. )
  32. // RegisterHandler register a new handler as current log handler. Previous registered handler will be discarded.
  33. func RegisterHandler(handler Handler) {
  34. if handler == nil {
  35. panic("Log handler is nil")
  36. }
  37. atomic.StorePointer(&logHandler, unsafe.Pointer(&handler))
  38. }