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.
func NewManyToOneEnvelopeV2 ¶
func NewManyToOneEnvelopeV2(size int, alerter gendiodes.Alerter) *ManyToOneEnvelopeV2
func (*ManyToOneEnvelopeV2) Next ¶
func (d *ManyToOneEnvelopeV2) Next() *v2.Envelope
func (*ManyToOneEnvelopeV2) Set ¶
func (d *ManyToOneEnvelopeV2) Set(data *v2.Envelope)
type OneToOne ¶
type OneToOne struct {
// contains filtered or unexported fields
}
OneToOne diode is optimized for a single writer and a single reader
func NewOneToOne ¶
func (*OneToOne) Next ¶
func (d *OneToOne) Next() *loggregator_v2.Envelope
func (*OneToOne) Set ¶
func (d *OneToOne) Set(data *loggregator_v2.Envelope)
Source Files
Click to show internal directories.
Click to hide internal directories.