publisher

Documentation

Index

• type Publisher
  • func New() *Publisher
  • func (pub *Publisher) Close()
  • func (pub *Publisher) Flush()
  • func (pub *Publisher) Log(srcApp string, level log.Level, message []byte) error
  • func (pub *Publisher) Subscribe(srcApp string, level log.Level, handler RecordHandler) (ex.Handle, error)
  • func (pub *Publisher) Unsubscribe(handle ex.Handle) error
• type RecordHandler

Types

type Publisher

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

func New

func New() *Publisher

func (*Publisher) Close

func (pub *Publisher) Close()

func (*Publisher) Flush

func (pub *Publisher) Flush()

func (*Publisher) Log

func (pub *Publisher) Log(srcApp string, level log.Level, message []byte) error

func (*Publisher) Subscribe

func (pub *Publisher) Subscribe(srcApp string, level log.Level, handler RecordHandler) (ex.Handle, error)

func (*Publisher) Unsubscribe

func (pub *Publisher) Unsubscribe(handle ex.Handle) error

type RecordHandler

type RecordHandler func(level log.Level, record []byte)