Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ManyToOneEnvelopeV2 ¶
type ManyToOneEnvelopeV2 struct {
// contains filtered or unexported fields
}
ManyToOneEnvelopeV2 diode is optimal for many writers and a single reader for V2 envelopes.
func NewManyToOneEnvelopeV2 ¶
func NewManyToOneEnvelopeV2(size int, alerter gendiodes.Alerter) *ManyToOneEnvelopeV2
NewManyToOneEnvelopeV2 returns a new ManyToOneEnvelopeV2 diode to be used with many writers and a single reader.
func (*ManyToOneEnvelopeV2) Next ¶
func (d *ManyToOneEnvelopeV2) Next() *loggregator_v2.Envelope
Next will return the next V2 envelope to be read from the diode. If the diode is empty this method will block until anenvelope is available to be read.
func (*ManyToOneEnvelopeV2) Set ¶
func (d *ManyToOneEnvelopeV2) Set(data *loggregator_v2.Envelope)
Set inserts the given V2 envelope into the diode.
func (*ManyToOneEnvelopeV2) TryNext ¶
func (d *ManyToOneEnvelopeV2) TryNext() (*loggregator_v2.Envelope, bool)
TryNext returns the next V2 envelope to be read from the diode. If the diode is empty it will return a nil envelope and false for the bool.
type OneToOne ¶
type OneToOne struct {
// contains filtered or unexported fields
}
OneToOne diode is optimized for a single writer and a single reader for byte slices.
func NewOneToOne ¶
func NewOneToOne(size int, alerter gendiodes.Alerter, opts ...gendiodes.WaiterConfigOption) *OneToOne
NewOneToOne initializes a new one to one diode of a given size and alerter. The alerter is called whenever data is dropped with an integer representing the number of byte slices that were dropped.
func (*OneToOne) Next ¶
Next will return the next item to be read from the diode. If the diode is empty this method will block until an item is available to be read.
type OneToOneEnvelopeV2 ¶
type OneToOneEnvelopeV2 struct {
// contains filtered or unexported fields
}
OneToOneEnvelopeV2 diode is optimized for a single writer and a single reader for byte slices.
func NewOneToOneEnvelopeV2 ¶
func NewOneToOneEnvelopeV2(size int, alerter gendiodes.Alerter, opts ...gendiodes.WaiterConfigOption) *OneToOneEnvelopeV2
NewOneToOneEnvelopeV2 initializes a new one to one diode of a given size and alerter. The alerter is called whenever data is dropped with an integer representing the number of byte slices that were dropped.
func (*OneToOneEnvelopeV2) Next ¶
func (d *OneToOneEnvelopeV2) Next() *loggregator_v2.Envelope
Next will return the next item to be read from the diode. If the diode is empty this method will block until an item is available to be read.
func (*OneToOneEnvelopeV2) Set ¶
func (d *OneToOneEnvelopeV2) Set(data *loggregator_v2.Envelope)
Set inserts the given data into the diode.
func (*OneToOneEnvelopeV2) TryNext ¶
func (d *OneToOneEnvelopeV2) TryNext() (*loggregator_v2.Envelope, bool)
TryNext returns the next item to be read from the diode. If the diode is empty it will return a nil slice of bytes and false for the bool.
Source Files