status

Documentation

Index

• Constants
• Variables
• type ModelReadyCaller
• type ModelRestCaller
  • func NewModelRestStatusCaller(logger logrus.FieldLogger, envoyHost string, envoyPort int) (*ModelRestCaller, error)
  • func (mr *ModelRestCaller) CheckModelReady(ctx context.Context, modelName string, requestId string) (bool, error)
• type PipelineReadyChecker
• type PipelineSchedulerClient
  • func NewPipelineSchedulerClient(logger logrus.FieldLogger, pipelineStatusUpdater PipelineStatusUpdater) *PipelineSchedulerClient
  • func (pc *PipelineSchedulerClient) Start(host string, plainTxtPort int, tlsPort int) error
  • func (pc *PipelineSchedulerClient) Stop()
  • func (pc *PipelineSchedulerClient) SubscribePipelineEvents() error
• type PipelineStatusManager
  • func NewPipelineStatusManager() *PipelineStatusManager
  • func (sm *PipelineStatusManager) Get(name string) *pipeline.PipelineVersion
  • func (sm *PipelineStatusManager) Update(version *pipeline.PipelineVersion)
• type PipelineStatusProvider
• type PipelineStatusUpdater
• type SimpleReadyChecker
  • func NewSimpleReadyChecker(pipelineStatusProvider PipelineStatusProvider, ...) *SimpleReadyChecker
  • func (s *SimpleReadyChecker) CheckPipelineReady(ctx context.Context, pipelineName string, requestId string) (bool, error)

Constants

const (
	SubscriberName = "seldon-pipelinegateway"
)

Variables

var PipelineNotFoundErr = errors.New("Pipeline not found")

Types

type ModelReadyCaller

type ModelReadyCaller interface {
	CheckModelReady(ctx context.Context, modelName string, requestId string) (bool, error)
}

type ModelRestCaller

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

func NewModelRestStatusCaller

func NewModelRestStatusCaller(logger logrus.FieldLogger, envoyHost string, envoyPort int) (*ModelRestCaller, error)

func (*ModelRestCaller) CheckModelReady

func (mr *ModelRestCaller) CheckModelReady(ctx context.Context, modelName string, requestId string) (bool, error)

type PipelineReadyChecker

type PipelineReadyChecker interface {
	CheckPipelineReady(ctx context.Context, pipelineName string, requestId string) (bool, error)
}

type PipelineSchedulerClient

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

func NewPipelineSchedulerClient

func NewPipelineSchedulerClient(logger logrus.FieldLogger, pipelineStatusUpdater PipelineStatusUpdater) *PipelineSchedulerClient

func (*PipelineSchedulerClient) Start

func (pc *PipelineSchedulerClient) Start(host string, plainTxtPort int, tlsPort int) error

func (*PipelineSchedulerClient) Stop

func (pc *PipelineSchedulerClient) Stop()

func (*PipelineSchedulerClient) SubscribePipelineEvents

func (pc *PipelineSchedulerClient) SubscribePipelineEvents() error

type PipelineStatusManager

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

func NewPipelineStatusManager

func NewPipelineStatusManager() *PipelineStatusManager

func (*PipelineStatusManager) Get

func (sm *PipelineStatusManager) Get(name string) *pipeline.PipelineVersion

func (*PipelineStatusManager) Update

func (sm *PipelineStatusManager) Update(version *pipeline.PipelineVersion)

type PipelineStatusProvider

type PipelineStatusProvider interface {
	Get(name string) *pipeline.PipelineVersion
}

type PipelineStatusUpdater

type PipelineStatusUpdater interface {
	Update(version *pipeline.PipelineVersion)
}

type SimpleReadyChecker

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

func NewSimpleReadyChecker

func NewSimpleReadyChecker(pipelineStatusProvider PipelineStatusProvider, modelReadyCaller ModelReadyCaller) *SimpleReadyChecker

func (*SimpleReadyChecker) CheckPipelineReady

func (s *SimpleReadyChecker) CheckPipelineReady(ctx context.Context, pipelineName string, requestId string) (bool, error)