Versions in this module Expand all Collapse all v0 v0.1.0 Mar 17, 2023 Changes in this version + func Create(flight string, schema *codec.Schema, s *server.Server, ...) error + type EventDataMarker uint8 + const JobEvent + const SnapshotEvent + type Job struct + Consumer string + EndSeq uint64 + Id uint64 + NodeIP string + StartSeq uint64 + Status JobStatus + Time int64 + type JobStatus byte + const Active + const Build + const Done + const Idle + const Upload + type StateMatchine struct + Jobs map[uint64]Job + LastEventSeq uint64 + LastJobID uint64 + LastMsgSeq uint64 + LastUpdate time.Time + type Terminal struct + func Start(flight string, s *server.Server, nodeIP string, ...) (*Terminal, error) + func (t *Terminal) Delete() + func (t *Terminal) GetSchema() *codec.Schema + func (t *Terminal) ParseJson(body []byte) ([][]byte, error) + func (t *Terminal) SerializeTransientColumnEntity() (uint64, []byte) + func (t *Terminal) UpdateSchema(schema *codec.Schema, prev uint64) error