ordering

Documentation

Index

• type Callback
• type EventBuffer
  • func New(buffSize int, callback Callback) *EventBuffer
  • func (buf *EventBuffer) Clear()
  • func (buf *EventBuffer) IsBuffered(id hash.Event) bool
  • func (buf *EventBuffer) PushEvent(e *inter.Event, peer string)

Types

type Callback

type Callback struct {
	Process func(e *inter.Event) error
	Drop    func(e *inter.Event, peer string, err error)
	Get     func(hash.Event) *inter.EventHeaderData
	Exists  func(hash.Event) bool
	Check   func(e *inter.Event, parents []*inter.EventHeaderData) error
}

Callback is a set of EventBuffer()'s args.

type EventBuffer

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

func New

func New(buffSize int, callback Callback) *EventBuffer

func (*EventBuffer) Clear

func (buf *EventBuffer) Clear()

func (*EventBuffer) IsBuffered

func (buf *EventBuffer) IsBuffered(id hash.Event) bool

func (*EventBuffer) PushEvent

func (buf *EventBuffer) PushEvent(e *inter.Event, peer string)