deployment

Documentation

Index

• func GetDefaultModelRoute(ctx context.Context, tx *sql.Tx, mdID string, repository mrRepo.Repository) (string, error)
• type EventPublisher
• type Service
  • func NewService(repo repo.Repository, mrRepo mrRepo.Repository, eventPub EventPublisher) Service

Functions

func GetDefaultModelRoute

func GetDefaultModelRoute(ctx context.Context, tx *sql.Tx, mdID string, repository mrRepo.Repository) (string, error)

Types

type EventPublisher

type EventPublisher interface {
	PublishEvent(ctx context.Context, tx *sql.Tx, event event.Event) (err error)
}

type Service

type Service interface {
	GetModelDeployment(ctx context.Context, id string) (*deployment.ModelDeployment, error)
	GetModelDeploymentList(ctx context.Context, options ...filter.ListOption) ([]deployment.ModelDeployment, error)
	DeleteModelDeployment(ctx context.Context, id string) error
	SetDeletionMark(ctx context.Context, id string, value bool) error
	UpdateModelDeployment(ctx context.Context, mt *deployment.ModelDeployment) error
	// Try to update status. If spec in storage differs from spec snapshot then update does not happen
	UpdateModelDeploymentStatus(
		ctx context.Context, id string, status v1alpha1.ModelDeploymentStatus, spec v1alpha1.ModelDeploymentSpec) error
	CreateModelDeployment(ctx context.Context, mt *deployment.ModelDeployment) error
	GetDefaultModelRoute(ctx context.Context, mdID string) (*deployment.ModelRoute, error)
}

func NewService

func NewService(repo repo.Repository, mrRepo mrRepo.Repository, eventPub EventPublisher) Service