nozzle

Documentation

Index

• type BMDebugPrinter
  • func (p *BMDebugPrinter) Print(title, body string)
• type Nozzle
  • func New(config *configuration.Configuration, logger *gosteno.Logger) *Nozzle
  • func (n *Nozzle) Start()
• type RLPLogger
  • func NewRLPLogger(logger *gosteno.Logger) *RLPLogger
  • func (l RLPLogger) Write(p []byte) (n int, err error)

Types

type BMDebugPrinter

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

BMDebugPrinter prints consumer messages to log

func (*BMDebugPrinter) Print

func (p *BMDebugPrinter) Print(title, body string)

Print prints message to log

type Nozzle

type Nozzle struct {
	Messages chan *loggregator_v2.Envelope
	// contains filtered or unexported fields
}

func New

func New(config *configuration.Configuration, logger *gosteno.Logger) *Nozzle

func (*Nozzle) Start

func (n *Nozzle) Start()

Start starts consuming events from firehose

type RLPLogger

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

func NewRLPLogger

func NewRLPLogger(logger *gosteno.Logger) *RLPLogger

func (RLPLogger) Write

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