Aeon.Acquisition

namespace Aeon.Acquisition

Enums

PriorityLevel

enum Aeon.Acquisition.PriorityLevel

Values:

Notification

Alert

Classes

AeonAudio

class Aeon.Acquisition.AeonAudio : AudioCapture

Inheritance diagram for Aeon::Acquisition::AeonAudio:

Collaboration diagram for Aeon::Acquisition::AeonAudio:

Public Functions

IObservable<Timestamped<Mat>> Generate<TPayload> (IObservable<Timestamped<TPayload>> source)

AvailableDiskSpace

class Aeon.Acquisition.AvailableDiskSpace

Public Functions

IObservable<long> Process<TSource> (IObservable<TSource> source)

Properties

string DrivePath { get; set; }

AvailableMemory

class Aeon.Acquisition.AvailableMemory

Public Functions

IObservable<float> Process<TSource> (IObservable<TSource> source)

CreateLogMessage

class Aeon.Acquisition.CreateLogMessage : Source

Inheritance diagram for Aeon::Acquisition::CreateLogMessage:

Collaboration diagram for Aeon::Acquisition::CreateLogMessage:

Public Functions

override IObservable<LogMessage> Generate ()

IObservable<LogMessage> Generate<TSource> (IObservable<TSource> source)

IObservable<Timestamped<LogMessage>> Generate<TSource> (IObservable<Timestamped<TSource>> source)

IObservable<Timestamped<LogMessage>> Generate (IObservable<HarpMessage> source)

Properties

PriorityLevel Priority { get; set; }

string Type { get; set; } = LogMessage.DefaultType

string Message { get; set; }

CreateRepository

class Aeon.Acquisition.CreateRepository : Source

Inheritance diagram for Aeon::Acquisition::CreateRepository:

Collaboration diagram for Aeon::Acquisition::CreateRepository:

Public Functions

override IObservable<IRepository> Generate ()

Properties

string Path { get; set; }

FormatDate

class Aeon.Acquisition.FormatDate

Public Functions

IObservable<string> Process (IObservable<DateTime> source)

FormatJson

class Aeon.Acquisition.FormatJson

Public Functions

IObservable<string> Process<TSource> (IObservable<TSource> source)

FormatLogMessage

class Aeon.Acquisition.FormatLogMessage : FormatBuilder

Inheritance diagram for Aeon::Acquisition::FormatLogMessage:

Collaboration diagram for Aeon::Acquisition::FormatLogMessage:

Properties

PriorityLevel Priority { get; set; }

string Type { get; set; } = LogMessage.DefaultType

string Timestamp { get; set; }

GetDataPath

class Aeon.Acquisition.GetDataPath

Public Functions

IObservable<string> Process (IObservable<IRepository> source)

Properties

string DataPath { get; set; }

string FallbackPath { get; set; }

GetDateTime

class Aeon.Acquisition.GetDateTime

Public Functions

IObservable<DateTime> Process (IObservable<double> source)

IObservable<DateTime> Process (IObservable<HarpMessage> source)

IObservable<DateTime> Process<T> (IObservable<Timestamped<T>> source)

Public Static Functions

DateTime FromSeconds (double seconds)

GroupByTime

class Aeon.Acquisition.GroupByTime

Public Functions

GroupByTime ()

IObservable<IGroupedObservable<DateTime, Timestamped<TSource>>> Process<TSource> (IObservable<Timestamped<TSource>> source)

IObservable<IGroupedObservable<DateTime, HarpMessage>> Process (IObservable<HarpMessage> source)

IObservable<IGroupedObservable<DateTime, Timestamped<TSource>>> Process<TSource> (IObservable<Tuple<TSource, double>> source)

IObservable<IGroupedObservable<DateTime, Timestamped<TSource>>> Process<TSource> (IObservable<Timestamped<TSource>> source, IObservable<HarpMessage> heartbeats)

IObservable<IGroupedObservable<DateTime, HarpMessage>> Process (IObservable<HarpMessage> source, IObservable<HarpMessage> heartbeats)

IObservable<IGroupedObservable<DateTime, Timestamped<TSource>>> Process<TSource> (IObservable<Tuple<TSource, double>> source, IObservable<HarpMessage> heartbeats)

Properties

int ChunkSize { get; set; }

TimeSpan? ClosingDuration { get; set; }

string ClosingDurationXml { get; set; }

IsRepositoryClean

class Aeon.Acquisition.IsRepositoryClean

Public Functions

IObservable<bool> Process (IObservable<IRepository> source)

LoadConfigFile

class Aeon.Acquisition.LoadConfigFile : Source

Inheritance diagram for Aeon::Acquisition::LoadConfigFile:

Collaboration diagram for Aeon::Acquisition::LoadConfigFile:

Public Functions

override IObservable<Dictionary<string, string>> Generate ()

Properties

string FileName { get; set; }

LogMessage

class Aeon.Acquisition.LogMessage

Public Functions

LogMessage (PriorityLevel priority, string message)

LogMessage (PriorityLevel priority, string type, string message)

override string ToString ()

Properties

PriorityLevel Priority { get; set; }

string Type { get; set; }

string Message { get; set; }

Public Static Attributes

const string DefaultType = "Annotation"

MetadataSource-1-g

class Aeon.Acquisition.MetadataSource-1-g<TMetadata>

Inheritance diagram for Aeon::Acquisition::MetadataSource-1-g:

Subclassed by Aeon.Environment.AnnotationSource, Aeon.Environment.ButtonSource, Aeon.Environment.EnvironmentState, Aeon.Environment.EnvironmentSubjectState, Aeon.Environment.TareWeight, Aeon.Foraging.DispenserController

Public Functions

void OnNext (TMetadata value)

IObservable<TMetadata> Process ()

IObservable<Timestamped<TMetadata>> Process (IObservable<HarpMessage> source)

ObservableExtensions

class Aeon.Acquisition.ObservableExtensions

Public Static Functions

IObservable<Unit> MergeUnit<TSource, TOther> (this IObservable<TSource> source, IObservable<TOther> other)

IObservable<Timestamped<TSource>> Timestamp<TSource> (this IObservable<TSource> source, IObservable<HarpMessage> clock)

PrependOnce

class Aeon.Acquisition.PrependOnce

Public Functions

IObservable<TSource> Process<TSource> (IObservable<TSource> source, IObservable<TSource> other)

RangeThreshold

class Aeon.Acquisition.RangeThreshold : Transform

Inheritance diagram for Aeon::Acquisition::RangeThreshold:

Collaboration diagram for Aeon::Acquisition::RangeThreshold:

Public Functions

override IObservable<bool> Process (IObservable<double> source)

IObservable<Timestamped<bool>> Process (IObservable<Timestamped<double>> source)

Properties

double? Lower { get; set; }

double? Upper { get; set; }

StateRecoverySubject-1-g.RecoverySubject

class Aeon.Acquisition.StateRecoverySubject-1-g.RecoverySubject

SendMessageCard

class Aeon.Acquisition.SendMessageCard

Public Functions

IObservable<TSource> Process<TSource> (IObservable<TSource> source)

Properties

string Address { get; set; }

ServiceAccountName

class Aeon.Acquisition.ServiceAccountName : Source

Inheritance diagram for Aeon::Acquisition::ServiceAccountName:

Collaboration diagram for Aeon::Acquisition::ServiceAccountName:

Public Functions

override IObservable<string> Generate ()

IObservable<string> Generate<TSource> (IObservable<TSource> source)

StateRecovery-1-g

class Aeon.Acquisition.StateRecovery-1-g<TState>

Public Static Functions

void Serialize (string name, TState value)

TState Deserialize (string name)

StateRecoverySubject

class Aeon.Acquisition.StateRecoverySubject : SubjectBuilder

Inheritance diagram for Aeon::Acquisition::StateRecoverySubject:

Collaboration diagram for Aeon::Acquisition::StateRecoverySubject:

StateRecoverySubject-1-g

class Aeon.Acquisition.StateRecoverySubject-1-g<T> : SubjectBuilder

Inheritance diagram for Aeon::Acquisition::StateRecoverySubject-1-g:

Collaboration diagram for Aeon::Acquisition::StateRecoverySubject-1-g:

Public Functions

RecoverySubject (string name)

void OnCompleted ()

void OnError (Exception error)

void OnNext (T value)

IDisposable Subscribe (IObserver<T> observer)

void Dispose ()

StripSubstring

class Aeon.Acquisition.StripSubstring

Public Functions

IObservable<string> Process (IObservable<string> source)

Properties

string Separator { get; set; }

Synchronizer

class Aeon.Acquisition.Synchronizer

ThrowException

class Aeon.Acquisition.ThrowException

Public Functions

IObservable<TSource> Process<TSource> (IObservable<TSource> source)

Properties

string Message { get; set; }