Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type TruncatingBuffer ¶
type TruncatingBuffer struct {
// contains filtered or unexported fields
}
func NewTruncatingBuffer ¶
func (*TruncatingBuffer) CloseOutputChannel ¶
func (r *TruncatingBuffer) CloseOutputChannel()
func (*TruncatingBuffer) GetDroppedMessageCount ¶
func (r *TruncatingBuffer) GetDroppedMessageCount() int64
func (*TruncatingBuffer) GetOutputChannel ¶
func (r *TruncatingBuffer) GetOutputChannel() <-chan *events.Envelope
func (*TruncatingBuffer) Run ¶
func (r *TruncatingBuffer) Run()
Click to show internal directories.
Click to hide internal directories.