manager

package

v0.1.18 Latest Latest Go to latest Published: Sep 7, 2025 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation ¶

Index ¶

type ClusterManager
type SchemaWatcher
type Service
- func NewGateway(ctx context.Context, log *logger.Logger, appCfg appConfig.Config) (*Service, error)
- func (g *Service) Close() error
- func (g *Service) ServeHTTP(w http.ResponseWriter, r *http.Request)

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type ClusterManager ¶

type ClusterManager interface {
	LoadCluster(schemaFilePath string) error
	UpdateCluster(schemaFilePath string) error
	RemoveCluster(schemaFilePath string) error
	GetCluster(name string) (*targetcluster.TargetCluster, bool)
	ServeHTTP(w http.ResponseWriter, r *http.Request)
	Close() error
}

ClusterManager manages target clusters and their lifecycle

type SchemaWatcher ¶

type SchemaWatcher interface {
	Initialize(ctx context.Context, watchPath string) error
}

SchemaWatcher monitors schema files and manages cluster connections

type Service ¶

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

Service orchestrates the domain-driven architecture with target clusters

func NewGateway ¶

func NewGateway(ctx context.Context, log *logger.Logger, appCfg appConfig.Config) (*Service, error)

NewGateway creates a new domain-driven Gateway instance

func (*Service) Close ¶

func (g *Service) Close() error

Close gracefully shuts down the gateway and all its services

func (*Service) ServeHTTP ¶

func (g *Service) ServeHTTP(w http.ResponseWriter, r *http.Request)

ServeHTTP delegates HTTP requests to the cluster registry

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
mocks
roundtripper
targetcluster
watcher

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