servicecatalog

type Catalog interface {
	Delete(RouteID string, log *zap.SugaredLogger)
	CreateOrUpdate(route Route) error
}

type EventFetcher interface {
	// GetLastEvents get last events from event source using cursor to determine offset of events
	// If returned error implements interface with func Temporary() and Temporary() == true
	// then attempt to fetch events will be retried
	GetLastEvents(cursor int) (LatestGenericEvents, error)
}

type EventHandler interface {
	// Handle function will be called for each new event that was fetched by EventFetcher
	// Type assertion can be applied to event to get access for underlying concrete event value.
	//
	// if error is returned that event will be rescheduled for further processing using
	// exponential backoff algorithm
	Handle(event interface{}, logger *zap.SugaredLogger) (err error)
}

type GenericEvent struct {
	EntityID string
	Event    interface{}
}

type LatestGenericEvents struct {
	Cursor int
	Events []GenericEvent
}

type ModelRouteCatalog struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

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

type ReflectorOpts struct {
	// How many concurrent workers will process event using EventHandler.Handle
	WorkersCount int
	// How often EventFetcher will fetch new events from source
	FetchTimeout time.Duration
}

type Route struct {
	ID     string
	Prefix string

	IsDefault bool
	// If route serves more than one model than model is chosen randomly
	Model model_types.DeployedModel
}

type RouteEventFetcher struct {
	APIClient RouteEventsAPIClient
}

type RouteEventsAPIClient interface {
	GetLastEvents(cursor int) (event_types.LatestRouteEvents, error)
}

type UpdateHandler struct {
	Inspectors       map[string]inspectors.ModelServerInspector
	Catalog          Catalog
	DeploymentClient deployment.Client
}