web

Documentation

Index

• Constants
• type SnapshotRing
  • func NewSnapshotRing(length int) SnapshotRing
  • func (ring SnapshotRing) FirstAfter(t time.Time) (inertia.Snapshot, error)
  • func (ring *SnapshotRing) Push(state inertia.Snapshot)
• type WebDataSink
  • func New(bind string, bufferlength int) *WebDataSink
  • func (wv *WebDataSink) Init(meta inertia.SystemMetadata) error
  • func (wv *WebDataSink) Update(state inertia.Snapshot)

Constants

const BadRequest = 400

const NoNewData = 204

const ServerError = 500

Types

type SnapshotRing

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

Important assumptions: Snapshots are always added in chronological order Elements cannot be removed, only added (such that the ring is always full if ring.first > 0)

func NewSnapshotRing

func NewSnapshotRing(length int) SnapshotRing

func (SnapshotRing) FirstAfter

func (ring SnapshotRing) FirstAfter(t time.Time) (inertia.Snapshot, error)

func (*SnapshotRing) Push

func (ring *SnapshotRing) Push(state inertia.Snapshot)

type WebDataSink

type WebDataSink struct {
	Metadata inertia.SystemMetadata
	States   SnapshotRing
	// contains filtered or unexported fields
}

func New

func New(bind string, bufferlength int) *WebDataSink

func (*WebDataSink) Init

func (wv *WebDataSink) Init(meta inertia.SystemMetadata) error

func (*WebDataSink) Update

func (wv *WebDataSink) Update(state inertia.Snapshot)