postgres

Documentation

Index

• func WithTransaction(logger *zap.SugaredLogger, db *sqlx.DB, ctx context.Context, fn TxFn) (err error)
• type Client
  • func NewClient(logger *zap.SugaredLogger, db *sqlx.DB) *Client
  • func (c *Client) CalculateRouteShapesFromTrips(ctx context.Context, gtfsFeedID int, routeIDs []int) ([]RouteShapeRow, error)
  • func (c *Client) SetRouteShapes(ctx context.Context, routeShapes []RouteShapeRow, gtfsFeedID int) error
• type RouteShapeRow
• type TransactionError
• type TxFn

Functions

func WithTransaction

func WithTransaction(logger *zap.SugaredLogger, db *sqlx.DB, ctx context.Context, fn TxFn) (err error)

Types

type Client

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

func NewClient

func NewClient(
	logger *zap.SugaredLogger,
	db *sqlx.DB,
) *Client

func (*Client) CalculateRouteShapesFromTrips

func (c *Client) CalculateRouteShapesFromTrips(
	ctx context.Context,
	gtfsFeedID int,
	routeIDs []int,
) ([]RouteShapeRow, error)

func (*Client) SetRouteShapes

func (c *Client) SetRouteShapes(
	ctx context.Context,
	routeShapes []RouteShapeRow,
	gtfsFeedID int,
) error

type RouteShapeRow

type RouteShapeRow struct {
	RouteID              int    `db:"route_id"`
	DirectionID          int    `db:"direction_id"`
	LongestShapeID       int    `db:"longest_shape_id"`
	LongestShapeGeometry string `db:"longest_shape_geometry"`
	LongestShapeCentroid string `db:"longest_shape_centroid"`
}

type TransactionError

type TransactionError struct {
	RollbackNeeded bool
	Error          error
}

type TxFn

type TxFn func(ctx context.Context, tx *sqlx.Tx) *TransactionError