postgres

Documentation

Index

• Constants
• Variables
• type RouteRepo
  • func (repo RouteRepo) BeginTransaction(ctx context.Context) (*sql.Tx, error)
  • func (repo RouteRepo) DefaultExists(ctx context.Context, mdID string, tx *sql.Tx) (bool, error)
  • func (repo RouteRepo) DeleteModelRoute(ctx context.Context, tx *sql.Tx, id string) error
  • func (repo RouteRepo) GetModelRoute(ctx context.Context, tx *sql.Tx, id string) (*route.ModelRoute, error)
  • func (repo RouteRepo) GetModelRouteList(ctx context.Context, tx *sql.Tx, options ...filter.ListOption) ([]route.ModelRoute, error)
  • func (repo RouteRepo) IsDefault(ctx context.Context, id string, tx *sql.Tx) (bool, error)
  • func (repo RouteRepo) SaveModelRoute(ctx context.Context, tx *sql.Tx, md *route.ModelRoute) error
  • func (repo RouteRepo) SetDeletionMark(ctx context.Context, tx *sql.Tx, id string, value bool) error
  • func (repo RouteRepo) UpdateModelRoute(ctx context.Context, tx *sql.Tx, md *route.ModelRoute) error
  • func (repo RouteRepo) UpdateModelRouteStatus(ctx context.Context, tx *sql.Tx, id string, s v1alpha1.ModelRouteStatus) error

Constants

const (
	ModelRouteTable = "odahu_operator_route"

	ClID          = "id"
	ClSpec        = "spec"
	ClStatus      = "status"
	ClDelMark     = "deletionmark"
	ClCreated     = "created"
	ClUpdated     = "updated"
	ClIsDefault   = "is_default"
	ClFirstMDName = "spec->'modelDeployments'->0->>'mdName'"
)

Variables

var (
	MaxSize   = 500
	FirstPage = 0
)

Types

type RouteRepo

type RouteRepo struct {
	DB *sql.DB
}

func (RouteRepo) BeginTransaction

func (repo RouteRepo) BeginTransaction(ctx context.Context) (*sql.Tx, error)

func (RouteRepo) DefaultExists

func (repo RouteRepo) DefaultExists(ctx context.Context, mdID string, tx *sql.Tx) (bool, error)

Check whether the default ModelRoute for ModelDeployment with id=mdID is existed

func (RouteRepo) DeleteModelRoute

func (repo RouteRepo) DeleteModelRoute(ctx context.Context, tx *sql.Tx, id string) error

func (RouteRepo) GetModelRoute

func (repo RouteRepo) GetModelRoute(
	ctx context.Context, tx *sql.Tx, id string) (*route.ModelRoute, error)

func (RouteRepo) GetModelRouteList

func (repo RouteRepo) GetModelRouteList(
	ctx context.Context, tx *sql.Tx, options ...filter.ListOption) ([]route.ModelRoute, error)

func (RouteRepo) IsDefault

func (repo RouteRepo) IsDefault(ctx context.Context, id string, tx *sql.Tx) (bool, error)

Check whether the the route is default route

func (RouteRepo) SaveModelRoute

func (repo RouteRepo) SaveModelRoute(
	ctx context.Context, tx *sql.Tx, md *route.ModelRoute) error

func (RouteRepo) SetDeletionMark

func (repo RouteRepo) SetDeletionMark(ctx context.Context, tx *sql.Tx, id string, value bool) error

func (RouteRepo) UpdateModelRoute

func (repo RouteRepo) UpdateModelRoute(
	ctx context.Context, tx *sql.Tx, md *route.ModelRoute) error

func (RouteRepo) UpdateModelRouteStatus

func (repo RouteRepo) UpdateModelRouteStatus(
	ctx context.Context, tx *sql.Tx, id string, s v1alpha1.ModelRouteStatus) error