service

Sep 18, 2025

Changes in this version

+ type ConfigMapProviderConfig struct

+ Clientset kubernetes.Interface

+ Name string

+ Namespace string

+ RegistryName string

+ func (c *ConfigMapProviderConfig) Validate() error

+ type DefaultRegistryProviderFactory struct

+ func (f *DefaultRegistryProviderFactory) CreateProvider(config *RegistryProviderConfig) (RegistryDataProvider, error)

+ type FileProviderConfig struct

+ FilePath string

+ RegistryName string

+ func (c *FileProviderConfig) Validate() error

+ type FileRegistryDataProvider struct

+ func NewFileRegistryDataProvider(filePath, registryName string) *FileRegistryDataProvider

+ func (p *FileRegistryDataProvider) GetRegistryData(_ context.Context) (*registry.Registry, error)

+ func (p *FileRegistryDataProvider) GetRegistryName() string

+ func (p *FileRegistryDataProvider) GetSource() string

type K8sRegistryDataProvider

+ func (p *K8sRegistryDataProvider) GetRegistryName() string

type RegistryDataProvider

+ GetRegistryName func() string

+ type RegistryProviderConfig struct

+ ConfigMap *ConfigMapProviderConfig

+ File *FileProviderConfig

+ Type RegistryProviderType

+ func (c *RegistryProviderConfig) Validate() error

+ type RegistryProviderFactory interface

+ CreateProvider func(config *RegistryProviderConfig) (RegistryDataProvider, error)

+ func NewRegistryProviderFactory() RegistryProviderFactory

+ type RegistryProviderType string

+ const RegistryProviderTypeConfigMap

+ const RegistryProviderTypeFile

Sep 16, 2025

Changes in this version

+ const LabelRegistryName

+ const LabelRegistryNamespace

+ const LabelServerRegistryName

+ var ErrServerNotFound = errors.New("server not found")

+ type DeployedServer struct

+ EndpointURL string

+ Image string

+ Name string

+ Namespace string

+ Ready bool

+ Status string

+ Transport string

+ type DeploymentProvider interface

+ GetDeployedServer func(ctx context.Context, name string) ([]*DeployedServer, error)

+ ListDeployedServers func(ctx context.Context) ([]*DeployedServer, error)

+ type K8sDeploymentProvider struct

+ func NewK8sDeploymentProvider(config *rest.Config, registryName string) (*K8sDeploymentProvider, error)

+ func (p *K8sDeploymentProvider) GetDeployedServer(ctx context.Context, name string) ([]*DeployedServer, error)

+ func (p *K8sDeploymentProvider) ListDeployedServers(ctx context.Context) ([]*DeployedServer, error)

+ type K8sRegistryDataProvider struct

+ func NewK8sRegistryDataProvider(kubeClient kubernetes.Interface, configMapName, namespace string) *K8sRegistryDataProvider

+ func (p *K8sRegistryDataProvider) GetRegistryData(ctx context.Context) (*registry.Registry, error)

+ func (p *K8sRegistryDataProvider) GetSource() string

+ type Option func(*regSvc)

+ func WithCacheDuration(duration time.Duration) Option

+ type RegistryDataProvider interface

+ GetRegistryData func(ctx context.Context) (*registry.Registry, error)

+ GetSource func() string

+ type RegistryService interface

+ CheckReadiness func(ctx context.Context) error

+ GetDeployedServer func(ctx context.Context, name string) ([]*DeployedServer, error)

+ GetRegistry func(ctx context.Context) (*registry.Registry, string, error)

+ GetServer func(ctx context.Context, name string) (registry.ServerMetadata, error)

+ ListDeployedServers func(ctx context.Context) ([]*DeployedServer, error)

+ ListServers func(ctx context.Context) ([]registry.ServerMetadata, error)

+ func NewService(ctx context.Context, registryProvider RegistryDataProvider, ...) (RegistryService, error)