event

Documentation

Index

• type Event
• type Events
  • func NewEvents() *Events
  • func (e *Events) Append(evt *Event)
  • func (e *Events) Close()
  • func (e *Events) SetPrems(prems func(context.Context) *Event)
  • func (e *Events) Since(since int) []*Event
  • func (e *Events) Size() int
  • func (e *Events) Subscribe(ctx context.Context, since int) chan *Event

Types

type Event

type Event struct {
	DataExists bool
	Data       string
	Id         string
	Event      string
	Retry      time.Duration
	Ending     bool
}

type Events

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

func NewEvents

func NewEvents() *Events

func (*Events) Append

func (e *Events) Append(evt *Event)

func (*Events) Close

func (e *Events) Close()

func (*Events) SetPrems

func (e *Events) SetPrems(prems func(context.Context) *Event)

func (*Events) Since

func (e *Events) Since(since int) []*Event

func (*Events) Size

func (e *Events) Size() int

func (*Events) Subscribe

func (e *Events) Subscribe(ctx context.Context, since int) chan *Event