sttp

package

Go to main page

Versions in this module

v0

v0.6.0

Mar 19, 2022

v0.5.0

Oct 13, 2021

Changes in this version

+ type Config struct

+ AutoReconnect bool

+ AutoRequestMetadata bool

+ AutoSubscribe bool

+ CompressMetadata bool

+ CompressPayloadData bool

+ CompressSignalIndexCache bool

+ MaxRetries int32

+ MaxRetryInterval int32

+ MetadataFilters string

+ RetryInterval int32

+ RfcGuidEncoding bool

+ Version byte

+ func NewConfig() *Config

+ type MeasurementReader struct

+ func (mr *MeasurementReader) NextMeasurement() *transport.Measurement

+ type Settings struct

+ ConstraintParameters string

+ ExtraConnectionStringParameters string

+ IncludeTime bool

+ ProcessingInterval int32

+ PublishInterval float64

+ RequestNaNValueFilter bool

+ StartTime string

+ StopTime string

+ Throttled bool

+ UdpPort uint16

+ UseMillisecondResolution bool

+ func NewSettings() *Settings

type Subscriber

+ func NewSubscriber() *Subscriber

+ func (sb *Subscriber) ActiveSignalIndexCache() *transport.SignalIndexCache

+ func (sb *Subscriber) AdjustedValue(measurement *transport.Measurement) float64

+ func (sb *Subscriber) Close()

+ func (sb *Subscriber) DefaultConnectionEstablishedReceiver()

+ func (sb *Subscriber) DefaultConnectionTerminatedReceiver()

+ func (sb *Subscriber) DefaultErrorMessageLogger(message string)

+ func (sb *Subscriber) DefaultStatusMessageLogger(message string)

+ func (sb *Subscriber) Dial(address string, config *Config) error

+ func (sb *Subscriber) Disconnect()

+ func (sb *Subscriber) IsConnected() bool

+ func (sb *Subscriber) IsSubscribed() bool

+ func (sb *Subscriber) LookupMetadata(signalID guid.Guid) *transport.MeasurementMetadata

+ func (sb *Subscriber) Metadata(measurement *transport.Measurement) *transport.MeasurementMetadata

+ func (sb *Subscriber) ReadMeasurements() *MeasurementReader

+ func (sb *Subscriber) RequestMetadata()

+ func (sb *Subscriber) SetConfigurationChangedReceiver(callback func())

+ func (sb *Subscriber) SetConnectionEstablishedReceiver(callback func())

+ func (sb *Subscriber) SetConnectionTerminatedReceiver(callback func())

+ func (sb *Subscriber) SetDataStartTimeReceiver(callback func(startTime time.Time))

+ func (sb *Subscriber) SetErrorMessageLogger(callback func(message string))

+ func (sb *Subscriber) SetHistoricalReadCompleteReceiver(callback func())

+ func (sb *Subscriber) SetMetadataReceiver(callback func(dataSet *data.DataSet))

+ func (sb *Subscriber) SetNewBufferBlocksReceiver(callback func(bufferBlocks []transport.BufferBlock))

+ func (sb *Subscriber) SetNewMeasurementsReceiver(callback func(measurements []transport.Measurement))

+ func (sb *Subscriber) SetNotificationReceiver(callback func(notification string))

+ func (sb *Subscriber) SetStatusMessageLogger(callback func(message string))

+ func (sb *Subscriber) SetSubscriptionUpdatedReceiver(callback func(signalIndexCache *transport.SignalIndexCache))

+ func (sb *Subscriber) Subscribe(filterExpression string, settings *Settings)

+ func (sb *Subscriber) SubscriberID() guid.Guid

+ func (sb *Subscriber) TotalCommandChannelBytesReceived() uint64

+ func (sb *Subscriber) TotalDataChannelBytesReceived() uint64

+ func (sb *Subscriber) TotalMeasurementsReceived() uint64

+ func (sb *Subscriber) Unsubscribe()

v0.4.0

Sep 27, 2021

v0.3.0

Sep 24, 2021

Changes in this version

type SubscriberBase

+ func (sb *SubscriberBase) AdjustedValue(measurement *transport.Measurement) float64

+ func (sb *SubscriberBase) LookupMetadata(signalID guid.Guid) *transport.MeasurementMetadata

+ func (sb *SubscriberBase) Metadata(measurement *transport.Measurement) *transport.MeasurementMetadata

v0.2.0

Sep 20, 2021

Changes in this version

type SubscriberBase

+ AutoRequestMetadata bool

+ AutoSubscribe bool

+ Version byte

+ func (sb *SubscriberBase) IsConnected() bool

+ func (sb *SubscriberBase) IsSubscribed() bool

+ func (sb *SubscriberBase) RequestMetadata()

+ func (sb *SubscriberBase) Subscribe()

+ func (sb *SubscriberBase) Unsubscribe()

v0.1.0

Sep 17, 2021

Changes in this version

+ type Subscriber interface

+ ConfigurationChanged func()

+ ConnectionEstablished func()

+ ConnectionTerminated func()

+ DataStartTime func(startTime time.Time)

+ ErrorMessage func(message string)

+ HistoricalReadComplete func()

+ ReceivedMetadata func(metadata []byte)

+ ReceivedNewBufferBlocks func(bufferBlocks []BufferBlock)

+ ReceivedNewMeasurements func(measurements []Measurement)

+ ReceivedNotification func(notification string)

+ StatusMessage func(message string)

+ SubscriptionUpdated func(signalIndexCache *SignalIndexCache)

+ type SubscriberBase struct

+ AutoParseMetadata bool

+ AutoReconnect bool

+ CompressMetadata bool

+ CompressPayloadData bool

+ CompressSignalIndexCache bool

+ Hostname string

+ MaxRetries int32

+ MaxRetryInterval int32

+ MetadataFilters string

+ Port uint16

+ RetryInterval int32

+ func NewSubscriberBase(subscriber Subscriber) SubscriberBase

+ func (sb *SubscriberBase) ActiveSignalIndexCache() *SignalIndexCache

+ func (sb *SubscriberBase) ConfigurationChanged()

+ func (sb *SubscriberBase) Connect()

+ func (sb *SubscriberBase) ConnectionEstablished()

+ func (sb *SubscriberBase) ConnectionTerminated()

+ func (sb *SubscriberBase) DataStartTime(startTime time.Time)

+ func (sb *SubscriberBase) Disconnect()

+ func (sb *SubscriberBase) Dispose()

+ func (sb *SubscriberBase) ErrorMessage(message string)

+ func (sb *SubscriberBase) HistoricalReadComplete()

+ func (sb *SubscriberBase) ReceivedMetadata(metadata []byte)

+ func (sb *SubscriberBase) ReceivedNewBufferBlocks(bufferBlocks []BufferBlock)

+ func (sb *SubscriberBase) ReceivedNewMeasurements(measurements []Measurement)

+ func (sb *SubscriberBase) ReceivedNotification(notification string)

+ func (sb *SubscriberBase) StatusMessage(message string)

+ func (sb *SubscriberBase) SubscriberID() guid.Guid

+ func (sb *SubscriberBase) Subscription() *SubscriptionInfo

+ func (sb *SubscriberBase) SubscriptionUpdated(signalIndexCache *SignalIndexCache)

+ func (sb *SubscriberBase) TotalCommandChannelBytesReceived() uint64

+ func (sb *SubscriberBase) TotalDataChannelBytesReceived() uint64

+ func (sb *SubscriberBase) TotalMeasurementsReceived() uint64

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL