Versions in this module Expand all Collapse all v1 v1.6.11 Dec 13, 2019 v1.6.10 Dec 12, 2019 Changes in this version + const AuthenticatedType + const ChannelAbortEvent + const ControlMessageType + const DataType + const EndOfChannelEvent + const ErrorType + const EventType + const ExpiredTSIDType + const JobDetectedLag + const JobInitialMaxDelay + const JobProgressEvent + const JobRunningResolution + const JobStartEvent + const MessageType + const MetadataType + const StreamStartEvent + const WebsocketErrorType + type AuthenticatedMessage struct + OrgID string + UserID string + type BaseChannelMessage struct + Chan string + func (bcm *BaseChannelMessage) Channel() string + type BaseControlMessage struct + Event string + type BaseJSONChannelMessage struct + func (j *BaseJSONChannelMessage) String() string + type BaseJSONMessage struct + func (bjm *BaseJSONMessage) JSONBase() *BaseJSONMessage + func (j *BaseJSONMessage) RawData() map[string]interface{} + func (j *BaseJSONMessage) String() string + type BaseMessage struct + Typ string + func (bm *BaseMessage) Base() *BaseMessage + func (bm *BaseMessage) String() string + func (bm *BaseMessage) Type() string + type BinaryMessageHeader struct + Channel [16]byte + Flags uint8 + MessageType uint8 + Reserved uint8 + Version uint8 + type ChannelMessage interface + Channel func() string + type DataMessage struct + Payloads []DataPayload + func (dm *DataMessage) String() string + type DataMessageHeader struct + ElementCount uint32 + TimestampMillis uint64 + type DataPayload struct + TSID idtool.ID + Type ValType + Val [8]byte + func (dp *DataPayload) Float64() float64 + func (dp *DataPayload) Int32() int32 + func (dp *DataPayload) Int64() int64 + func (dp *DataPayload) Value() interface{} + type ErrorContext struct + BindingName string + Column int + Line int + ProgramText string + Reference string + Traceback interface{} + type ErrorMessage struct + Context ErrorContext + Error int + ErrorType string + Message string + type EventMessage struct + type ExpiredTSIDMessage struct + TSID string + type InfoMessage struct + LogicalTimestampMillis uint64 + func (im *InfoMessage) LogicalTimestamp() time.Time + func (im *InfoMessage) UnmarshalJSON(raw []byte) error + type JSONMessage interface + JSONBase func() *BaseJSONMessage + RawData func() map[string]interface{} + type JobDetectedLagContents map[string]interface + func (jm JobDetectedLagContents) LagMS() int + type JobInitialMaxDelayContents map[string]interface + func (jm JobInitialMaxDelayContents) MaxDelayMS() int + type JobRunningResolutionContents map[string]interface + func (jm JobRunningResolutionContents) ResolutionMS() int + type JobStartControlMessage struct + Handle string + type Message interface + Base func() *BaseMessage + Type func() string + func ParseMessage(msg []byte, isText bool) (Message, error) + type MessageBlock struct + Code string + Contents interface{} + ContentsRaw map[string]interface{} + Level string + NumInputTimeseries int + type MetadataMessage struct + Properties MetadataProperties + TSID idtool.ID + type MetadataProperties struct + CreatedOnMS int + CustomProperties map[string]string + InternalProperties map[string]interface{} + Metric string + OriginatingMetric string + ResolutionMS int + func (mp *MetadataProperties) MarshalJSON() ([]byte, error) + func (mp *MetadataProperties) UnmarshalJSON(b []byte) error + type TimestampedMessage struct + TimestampMillis uint64 + func (tsm *TimestampedMessage) Timestamp() time.Time + type ValType uint8 + const ValTypeDouble + const ValTypeInt + const ValTypeLong + func (vt ValType) String() string