Versions in this module Expand all Collapse all v0 v0.1.1 May 17, 2023 v0.1.0 Aug 18, 2022 Changes in this version + func RegisterRemoteInterfaceFactory(protocol string, factory RemoteInterfaceFactory) + func TimeSpansOverlap(t1 TimeSpan, t2 TimeSpan) bool + type AUID = common.AUID + type AvailabilitySpan struct + FrameType int + Time TimeSpan + type BasicAvailability struct + Availability []AvailabilitySpan + Existence TimeSpan + func (ba *BasicAvailability) MarshalJSON() ([]byte, error) + func (ba *BasicAvailability) UnmarshalJSON(data []byte) error + type BasicChannel = common.BasicChannel + type ChannelAndAvailability struct + Avail BasicAvailability + Channel BasicChannel + Local bool + func (c *ChannelAndAvailability) ExistsDuring(span common.TimeSpan) bool + func (c *ChannelAndAvailability) ExistsDuringGpsSecond(second common.GpsSecond, fv *FrameView) bool + type ChannelHandler = func(availability *ChannelAndAvailability) + type ChannelListHash = string + type ChannelPredicate interface + Matches func(channel *BasicChannel) bool + type ChannelView struct + func (db *ChannelView) ApplyToChannelsIf(handler ChannelHandler, pred ChannelPredicate, span common.TimeSpan) + func (db *ChannelView) ApplyToChannelsIfConstrained(handler ChannelHandler, pred ChannelPredicate, epoch common.TimeSpan) + func (db *ChannelView) ResolveChannel(reference common.BasicChannel, epoch common.TimeSpan) (*ChannelAndAvailability, bool) + type FrameExistence []TimeSpan + type FrameType struct + FrameLabel string + FrameName string + PrintName string + func NewFrameType(label, name string) FrameType + type FrameTypeRegistrar struct + func CreateFrameTypeRegistrar() *FrameTypeRegistrar + func (fr *FrameTypeRegistrar) AddChannelListFile(fname string) + func (fr *FrameTypeRegistrar) AddChannelListFromReader(input io.Reader) + type FrameView struct + func (fv *FrameView) Copy() FrameView + func (fv *FrameView) FrameExistance(frameIndex int) []TimeSpan + func (fv *FrameView) FrameExistsAt(frameIndex int, second common.GpsSecond) bool + func (fv *FrameView) FrameIndex(frameType string) int + func (fv *FrameView) GetFrameType(index int) (string, bool) + func (fv *FrameView) GetTransactionalSpan(index int) (*TransactionalSpan, string, bool) + type GpsSecond = common.GpsSecond + type InternalJSONDB struct + Channels []ChannelAndAvailability + FrameSource string + FrameTypes map[string]int + Frames [][]JsonDBFrameInfo + type JsonDBFrameInfo struct + FrameType string + TimeSpan TimeSpan + type MetaDataStore struct + func LoadDatabaseFromChannelLists(channelLists []string, frameServer common.FrameServer) *MetaDataStore + func LoadDatabaseFromFrames(framePath, jsonPath string) (*MetaDataStore, error) + func LoadDatabaseFromJsonDB(path string) (*MetaDataStore, error) + func LoadDatabaseFromReplicationStream(reader io.Reader) (*MetaDataStore, error) + func (db *MetaDataStore) AddRemote(remote RemoteDataStore) error + func (db *MetaDataStore) DebugDump(dest io.Writer, maxDump int) + func (db *MetaDataStore) FrameFileIntervals(frameType string, span common.TimeSpan) []common.TimeSpan + func (db *MetaDataStore) FrameFilePaths(frameType string, span common.TimeSpan) []string + func (db *MetaDataStore) GetChannelView(requiredPrefix string) ChannelView + func (db *MetaDataStore) GetReplicationSummary() ReplicationHeader + func (db *MetaDataStore) ReplicationStream(dest io.Writer, summaryRequest SummaryRequest) error + func (db *MetaDataStore) SetExternalFrameServer(server common.FrameServer) + func (db *MetaDataStore) UpdateRemotes() error + func (mds *MetaDataStore) FrameView() *FrameView + func (mds *MetaDataStore) GetRemoteProxy(prefix string) (RemoteProxyInterface, error) + type RemoteDataStore struct + ConnString string + Label string + type RemoteInterface interface + ReplicationStream func(summary SummaryRequest) (io.ReadCloser, error) + ReplicationSummary func() (ReplicationHeader, error) + func GetRemoteInterface(connStr string) (RemoteInterface, error) + type RemoteInterfaceFactory func(string) (RemoteInterface, error) + type RemoteProxyInterface interface + ProxyDataStream func(frameType string, channels []string, span common.TimeSpan) (io.ReadCloser, error) + type ReplicationHeader struct + ChannelConfig string + FrameSource string + FrameTypes []string + NumChannels int + SkippedChannels bool + type ResolveChanEvaluator struct + func CreateResolveChanEvaluator(reference common.BasicChannel, timespan common.TimeSpan) *ResolveChanEvaluator + func (rc *ResolveChanEvaluator) Match() (*ChannelAndAvailability, bool) + func (rc *ResolveChanEvaluator) Process(chanAndAvail *ChannelAndAvailability) + type SummaryRequest struct + ChannelConfigHash string + FrameState map[string]common.GpsSecond + type TimeSpan struct + func CombineTimeSpans(t1 TimeSpan, t2 TimeSpan) TimeSpan + func CreateTimeSpan(start GpsSecond, end GpsSecond) TimeSpan + func (ts *TimeSpan) Contains(second common.GpsSecond) bool + func (ts *TimeSpan) Empty() bool + func (ts *TimeSpan) End() GpsSecond + func (ts *TimeSpan) Extend(new_end GpsSecond) + func (ts *TimeSpan) MarshalJSON() ([]byte, error) + func (ts *TimeSpan) Start() GpsSecond + func (ts *TimeSpan) ToCommon() common.TimeSpan + func (ts *TimeSpan) UnmarshalJSON(data []byte) error + type TransactionalSpan struct + func CreateTransactionalSpan(input []common.TimeSpan) *TransactionalSpan + func (ts *TransactionalSpan) Read() FrameExistence + func (ts *TransactionalSpan) Write(updater WriteOperation) + type WriteOperation func(FrameExistence) FrameExistence