registry

package
v0.2.5 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 26, 2026 License: Apache-2.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ConnectionTester

type ConnectionTester interface {
	Test(ctx context.Context, in TestConnectionInput) (TestConnectionResult, error)
}

func NewConnectionTester

func NewConnectionTester(finder Finder, locator factory.ProviderLocator, logger *slog.Logger) ConnectionTester

type CreateInput

type CreateInput struct {
	GatewayID   ids.GatewayID
	Name        string
	Type        domain.Type
	Enabled     *bool
	Description string
	LLMTarget   *domain.LLMTarget
	MCPTarget   *domain.MCPTarget
}

type Creator

type Creator interface {
	Create(ctx context.Context, in CreateInput) (*domain.Registry, error)
}

func NewCreator

func NewCreator(repo domain.Repository, manager *cache.TTLMapManager, logger *slog.Logger) Creator

type Deleter

type Deleter interface {
	Delete(ctx context.Context, gatewayID ids.GatewayID, id ids.RegistryID) error
}

func NewDeleter

func NewDeleter(
	repo domain.Repository,
	manager *cache.TTLMapManager,
	publisher cache.EventPublisher,
	logger *slog.Logger,
) Deleter

type Finder

type Finder interface {
	FindByID(ctx context.Context, gatewayID ids.GatewayID, id ids.RegistryID) (*domain.Registry, error)
	List(ctx context.Context, filter domain.ListFilter) ([]*domain.Registry, int, error)
}

func NewFinder

func NewFinder(repo domain.Repository, manager *cache.TTLMapManager, logger *slog.Logger) Finder

type TestConnectionInput

type TestConnectionInput struct {
	GatewayID       ids.GatewayID
	RegistryID      *ids.RegistryID
	Provider        string
	ProviderOptions map[string]any
	Auth            *domain.TargetAuth
}

type TestConnectionResult

type TestConnectionResult struct {
	OK         bool
	Stage      string
	Provider   string
	StatusCode int
	LatencyMs  int64
	Message    string
}

type UpdateInput

type UpdateInput struct {
	ID              ids.RegistryID
	GatewayID       ids.GatewayID
	Name            *string
	Enabled         *bool
	Provider        *string
	ProviderOptions *map[string]any
	Description     *string
	Auth            *domain.TargetAuth
	HealthChecks    *domain.HealthChecks
	MCPTarget       *domain.MCPTarget
}

type Updater

type Updater interface {
	Update(ctx context.Context, in UpdateInput) (*domain.Registry, error)
}

func NewUpdater

func NewUpdater(
	repo domain.Repository,
	manager *cache.TTLMapManager,
	publisher cache.EventPublisher,
	logger *slog.Logger,
) Updater

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL