pubsub

Documentation

Index

• type LogMessage
• type Logger
  • func NewLogger() *Logger
  • func (l *Logger) Publish(msg string)
  • func (l *Logger) Subscribe() <-chan *string
  • func (l *Logger) Write(p []byte) (n int, err error)

Types

type LogMessage

type LogMessage struct {
	Msg string // The actual log message.
}

LogMessage struct represents a single log entry.

type Logger

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

Logger provides functionality for logging and subscribing to logs.

func NewLogger

func NewLogger() *Logger

NewLogger initializes and returns a new instance of Logger.

func (*Logger) Publish

func (l *Logger) Publish(msg string)

Publish sends a log message to the log channel. It ensures that log writes are thread-safe using a mutex.

func (*Logger) Subscribe

func (l *Logger) Subscribe() <-chan *string

Subscribe provides a read-only channel to receive log messages. This allows external components to "listen" for new logs.

func (*Logger) Write

func (l *Logger) Write(p []byte) (n int, err error)

Write allows the Logger to be used as a Writer and in structured logging.