diodes

Documentation

Index

• Variables
• type Alerter
• type ManyToOne
  • func (d *ManyToOne) Next() []byte
  • func (d *ManyToOne) Set(data []byte)
  • func (d *ManyToOne) TryNext() ([]byte, bool)
• type ManyToOneEnvelope
  • func (d *ManyToOneEnvelope) Next() *events.Envelope
  • func (d *ManyToOneEnvelope) Set(data *events.Envelope)
  • func (d *ManyToOneEnvelope) TryNext() (*events.Envelope, bool)
• type OneToOne
  • func (d *OneToOne) Next() []byte
  • func (d *OneToOne) Set(data []byte)
  • func (d *OneToOne) TryNext() ([]byte, bool)

Variables

var NewManyToOne = func(size int, alerter Alerter) *ManyToOne {
	d := &ManyToOne{
		buffer:  make([]unsafe.Pointer, size),
		alerter: alerter,
	}
	d.writeIndex = ^d.writeIndex
	return d
}

var NewManyToOneEnvelope = func(size int, alerter Alerter) *ManyToOneEnvelope {
	d := &ManyToOneEnvelope{
		buffer:  make([]unsafe.Pointer, size),
		alerter: alerter,
	}
	d.writeIndex = ^d.writeIndex
	return d
}

var NewOneToOne = func(size int, alerter Alerter) *OneToOne {
	d := &OneToOne{
		buffer:  make([]unsafe.Pointer, size),
		alerter: alerter,
	}
	d.writeIndex = ^d.writeIndex
	return d
}

Types

type Alerter

type Alerter interface {
	Alert(missed int)
}

type ManyToOne

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

ManyToOne diode is optimal for many writers and a single reader.

func (*ManyToOne) Next

func (d *ManyToOne) Next() []byte

func (*ManyToOne) Set

func (d *ManyToOne) Set(data []byte)

func (*ManyToOne) TryNext

func (d *ManyToOne) TryNext() ([]byte, bool)

type ManyToOneEnvelope

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

ManyToOneEnvelope diode is optimal for many writers and a single reader.

func (*ManyToOneEnvelope) Next

func (d *ManyToOneEnvelope) Next() *events.Envelope

func (*ManyToOneEnvelope) Set

func (d *ManyToOneEnvelope) Set(data *events.Envelope)

func (*ManyToOneEnvelope) TryNext

func (d *ManyToOneEnvelope) TryNext() (*events.Envelope, bool)

type OneToOne

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

OneToOne diode is optimized for a single writer and a single reader

func (*OneToOne) Next

func (d *OneToOne) Next() []byte

func (*OneToOne) Set

func (d *OneToOne) Set(data []byte)

func (*OneToOne) TryNext

func (d *OneToOne) TryNext() ([]byte, bool)