feedstate

package

v1.3.0 Latest Latest Go to latest Published: Dec 13, 2025 License: GPL-3.0 Imports: 9 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/interline-io/transitland-lib

Links

Open Source Insights

Documentation ¶

Index ¶

type FeedVersionChanges
type Manager
- func NewManager(adapter tldb.Adapter) *Manager

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type FeedVersionChanges ¶

type FeedVersionChanges struct {
	ToDeactivate []int
	ToActivate   []int
}

type Manager ¶

type Manager struct {
	// contains filtered or unexported fields
}

Manager handles feed state and materialized table operations NOTE: Methods do NOT handle transactions - the caller must manage transactions

func NewManager ¶

func NewManager(adapter tldb.Adapter) *Manager

NewManager creates a new feed state manager

func (*Manager) ActivateFeedVersion ¶

func (m *Manager) ActivateFeedVersion(ctx context.Context, feedVersionID int) error

ActivateFeedVersion activates a feed version by setting it in feed_states and adding to materialized tables If another version of the same feed is currently active, it will be deactivated first

func (*Manager) CalculateSetActiveChanges ¶

func (m *Manager) CalculateSetActiveChanges(ctx context.Context, feedVersionIDs []int) (FeedVersionChanges, error)

func (*Manager) DeactivateFeedVersion ¶

func (m *Manager) DeactivateFeedVersion(ctx context.Context, feedVersionID int) error

DeactivateFeedVersion deactivates a feed version by removing it from feed_states and materialized tables If the feed version is not currently active, does nothing

func (*Manager) DematerializeFeedVersion ¶

func (m *Manager) DematerializeFeedVersion(ctx context.Context, feedVersionID int) error

DematerializeFeedVersion removes all routes/stops/agencies for a feed from materialized tables

func (*Manager) GetActiveFeedVersions ¶

func (m *Manager) GetActiveFeedVersions(ctx context.Context) ([]int, error)

GetActiveFeedVersions returns a list of currently active feed version IDs

func (*Manager) GetFeedIDForFeedVersion ¶

func (m *Manager) GetFeedIDForFeedVersion(ctx context.Context, fvid int) (int, error)

GetFeedIDForFeedVersion gets the feed_id for a given feed_version_id (public version)

func (*Manager) GetMaterializedFeedVersions ¶

func (m *Manager) GetMaterializedFeedVersions(ctx context.Context) ([]int, error)

func (*Manager) MaterializeFeedVersion ¶

func (m *Manager) MaterializeFeedVersion(ctx context.Context, feedVersionID int) error

MaterializeFeedVersion inserts routes/stops/agencies for a feed version into materialized tables

func (*Manager) SetActiveFeedVersions ¶

func (m *Manager) SetActiveFeedVersions(ctx context.Context, feedVersionIDs []int) error

SetActiveFeedVersions activates the specified feed versions and deactivates all others This replaces the entire set of active feed versions with the provided list

Source Files ¶

View all Source files

manager.go

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