repository

package

Go to main page

Versions in this module

v0

v0.4.0

Sep 2, 2020

v0.3.1

Aug 8, 2020

Changes in this version

type SQLTrainAlarmModel

+ FinalDestinationName string

v0.3.0

Aug 6, 2020

v0.2.3

Aug 4, 2020

Changes in this version

type MemoryDatabase

+ func (m *MemoryDatabase) DeleteOldStates(ctx context.Context, threshold time.Time) error

type MemoryStateModel

+ UpdatedAt time.Time

type SQLDatabase

+ func (s *SQLDatabase) DeleteOldStates(ctx context.Context, threshold time.Time) error

v0.2.2

Aug 1, 2020

v0.2.1

Aug 1, 2020

v0.2.0

Aug 1, 2020

v0.1.0

Aug 1, 2020

Changes in this version

+ type MemoryDatabase struct

+ CurrentState []*MemoryStateModel

+ Mutex *sync.Mutex

+ TrainAlarms map[string]*trainalarm.TrainAlarm

+ func NewMemoryDatabase() *MemoryDatabase

+ func (m *MemoryDatabase) DeleteOldTrainAlarms(ctx context.Context, threshold time.Time) error

+ func (m *MemoryDatabase) DeleteTrainAlarm(ctx context.Context, id string) error

+ func (m *MemoryDatabase) GetOrCreateTrainAlarm(ctx context.Context, alarm *trainalarm.TrainAlarm) (*trainalarm.TrainAlarm, error)

+ func (m *MemoryDatabase) GetState(ctx context.Context, identifyer string, plattform string) (string, string, error)

+ func (m *MemoryDatabase) GetTrainAlarm(ctx context.Context, alarmID string) (*trainalarm.TrainAlarm, error)

+ func (m *MemoryDatabase) GetTrainAlarms(ctx context.Context, identifyer string, plattform string) ([]*trainalarm.TrainAlarm, error)

+ func (m *MemoryDatabase) GetTrainAlarmsSortByLastNotificationAt(ctx context.Context, limit int) ([]*trainalarm.TrainAlarm, error)

+ func (m *MemoryDatabase) UpdateState(ctx context.Context, identifyer string, plattform string, ...) error

+ func (m *MemoryDatabase) UpdateTrainAlarm(ctx context.Context, alarmID string, ...) error

+ type MemoryStateModel struct

+ Identifyer string

+ Plattform string

+ State string

+ StatePlayload string

+ type SQLDatabase struct

+ func NewSQLDatabase(dialect string, path string) *SQLDatabase

+ func (s *SQLDatabase) Close()

+ func (s *SQLDatabase) DeleteOldTrainAlarms(ctx context.Context, threshold time.Time) error

+ func (s *SQLDatabase) DeleteTrainAlarm(ctx context.Context, id string) error

+ func (s *SQLDatabase) GetOrCreateTrainAlarm(ctx context.Context, alarm *trainalarm.TrainAlarm) (*trainalarm.TrainAlarm, error)

+ func (s *SQLDatabase) GetState(ctx context.Context, identifyer string, plattform string) (string, string, error)

+ func (s *SQLDatabase) GetTrainAlarm(ctx context.Context, alarmID string) (*trainalarm.TrainAlarm, error)

+ func (s *SQLDatabase) GetTrainAlarms(ctx context.Context, identifyer string, plattform string) ([]*trainalarm.TrainAlarm, error)

+ func (s *SQLDatabase) GetTrainAlarmsSortByLastNotificationAt(ctx context.Context, limit int) ([]*trainalarm.TrainAlarm, error)

+ func (s *SQLDatabase) UpdateState(ctx context.Context, identifyer string, plattform string, ...) error

+ func (s *SQLDatabase) UpdateTrainAlarm(ctx context.Context, alarmID string, ...) error

+ type SQLStateModel struct

+ CreatedAt time.Time

+ Identifyer string

+ Plattform string

+ State string

+ StatePayload string

+ UpdatedAt time.Time

+ type SQLTrainAlarmModel struct

+ CreatedAt time.Time

+ DelayThresholdMinutes int

+ FinalArrivalAt time.Time

+ ID string

+ Identifyer string

+ LastDelayMinutes int

+ LastNotificationAt *time.Time

+ Plattform string

+ StationDate int64

+ StationEVA int

+ TrainName string

+ UpdatedAt time.Time

+ func NewSQLTrainAlarmModel(alarm *trainalarm.TrainAlarm) *SQLTrainAlarmModel

+ func (s *SQLTrainAlarmModel) TrainAlarm() *trainalarm.TrainAlarm

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