stream

Documentation

Index

• type Event
• type EventWindow
  • func NewEventWindow(maxAge time.Duration, exit func(head Event, tail []Event)) *EventWindow
  • func (ew *EventWindow) Push(e Event)
  • func (ew *EventWindow) Window() (events []Event)

Types

type Event

type Event struct {
	Date      time.Time `json:"date"`
	Type      string    `json:"type"`
	SessionID string    `json:"sessionID"`
}

Event to be windowed.

type EventWindow

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

EventWindow on a stream.

func NewEventWindow

func NewEventWindow(maxAge time.Duration, exit func(head Event, tail []Event)) *EventWindow

NewEventWindow creates a window against events.

func (*EventWindow) Push

func (ew *EventWindow) Push(e Event)

Push an event into the Windower.

func (*EventWindow) Window

func (ew *EventWindow) Window() (events []Event)

Window returns the window of current events.