dump

Documentation

Index

• type DumpSink
  • func NewDumpSink(appId string, bufferSize uint32, inactivityDuration time.Duration) *DumpSink
  • func (d *DumpSink) AppID() string
  • func (d *DumpSink) Dump() []*events.Envelope
  • func (d *DumpSink) Identifier() string
  • func (d *DumpSink) Run(inputChan <-chan *events.Envelope)
  • func (d *DumpSink) ShouldReceiveErrors() bool

Types

type DumpSink

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

func NewDumpSink

func NewDumpSink(appId string, bufferSize uint32, inactivityDuration time.Duration) *DumpSink

func (*DumpSink) AppID

func (d *DumpSink) AppID() string

func (*DumpSink) Dump

func (d *DumpSink) Dump() []*events.Envelope

func (*DumpSink) Identifier

func (d *DumpSink) Identifier() string

func (*DumpSink) Run

func (d *DumpSink) Run(inputChan <-chan *events.Envelope)

func (*DumpSink) ShouldReceiveErrors

func (d *DumpSink) ShouldReceiveErrors() bool