inspector

Documentation

Index

• type Inspector
  • func New(logger log.CtxLogger, bufferSize int) *Inspector
  • func (i *Inspector) NewSession(ctx context.Context) *Session
  • func (i *Inspector) Send(ctx context.Context, r record.Record)
• type Session

Types

type Inspector

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

Inspector is attached to an inspectable pipeline component and makes returns records coming in or out of the component. An Inspector is a "proxy" between the pipeline component being inspected and the API, which broadcasts records to all clients.

func New

func New(logger log.CtxLogger, bufferSize int) *Inspector

func (*Inspector) NewSession

func (i *Inspector) NewSession(ctx context.Context) *Session

func (*Inspector) Send

func (i *Inspector) Send(ctx context.Context, r record.Record)

Send the given record to all registered sessions. The method does not wait for consumers to get the records.

type Session

type Session struct {
	C chan record.Record
	// contains filtered or unexported fields
}

Session wraps a channel of records and provides: 1. a way to send records to it asynchronously 2. a way to know if it's closed or not