コンテナ オーケストレーションが静的依存関係チェーンよりも柔軟で、Kubernetes よりもシンプルであればいいのにと思ったことはありませんか? PnR (プロンプト アンド レスポンス) をご紹介します。これは、Go の強力なプラットフォーム抽象化機能を活用して、単純な依存関係ではなく実際の準備状態に基づいてコンテナを調整する構成主導のアプローチです。
PnR について説明する前に、Go がクロスプラットフォームのコンテナ オーケストレーションに特に適している理由を理解しましょう。
統合 Docker API インターフェイス: Go の Docker クライアント ライブラリは、プラットフォーム固有のソケット接続を通じて、Windows、Linux、macOS 全体で一貫したインターフェイスを提供します。
ネイティブ同時実行サポート: Go の goroutine とチャネルにより、効率的なコンテナ監視が可能になります:
クロスプラットフォーム ネットワーク処理: Go の net パッケージは、プラットフォーム固有のネットワークの詳細を抽象化します:
PnR は、次の 3 つの主要なコンポーネントを通じてコンテナを調整します。
これを典型的な Web スタック (MongoDB、API サーバー、Web クライアント) で実際に動作させてみます。
{
"name": "dev_stack",
"cpuxs": {
"stack_startup": {
"design_chunks": [
{
"name": "mongodb",
"gatekeeper": {
"system_ready": {
"prompt": "Is system ready?",
"response": ["yes"],
"tv": "Y"
}
},
"flowout": {
"mongodb_ready": {
"prompt": "Is MongoDB ready?",
"response": ["yes"],
"tv": "Y"
}
},
"health_check": {
"type": "tcp",
"port_key": "27017",
"timeout_seconds": 2,
"status_mapping": {
"success": {
"key": "mongodb_ready",
"response": ["yes"],
"tv": "Y"
},
"failure": {
"key": "mongodb_ready",
"response": ["no"],
"tv": "N"
}
}
},
"container": {
"name": "pnr_mongodb",
"image": "mongo:latest",
"ports": {
"27017": "27017"
}
}
}
]
}
}
}
PnR の核心は、プラットフォームに依存しないコンテナ管理です。仕組みは次のとおりです:
func (il *ContainerIntentionLoop) Execute() error {
// Create platform-specific network
_, err := il.dockerClient.NetworkCreate(il.ctx, "pnr_network", types.NetworkCreate{})
if err != nil {
return fmt.Errorf("failed to create network: %v", err)
}
for {
// Update runtime state
if err := il.updateRTStateFromRuntime(); err != nil {
return err
}
allCompleted := true
anyExecuting := false
// Process each container
for i := range il.cpux.DesignChunks {
chunk := &il.cpux.DesignChunks[i]
// Container state machine
switch chunk.Status {
case "completed":
continue
case "executing":
anyExecuting = true
allCompleted = false
if il.checkChunkCompletion(chunk) {
chunk.Status = "completed"
}
case "", "ready":
allCompleted = false
if il.checkGatekeeper(chunk) {
if err := il.startContainer(chunk); err != nil {
return err
}
chunk.Status = "executing"
anyExecuting = true
}
}
}
// Check termination conditions
if allCompleted {
return nil
}
if !anyExecuting && !allCompleted {
return fmt.Errorf("no progress possible - execution stalled")
}
time.Sleep(5 * time.Second)
}
}
PnR は、Go の標準ライブラリを使用してプラットフォームに依存しないヘルスチェックを実装します。
{
"name": "dev_stack",
"cpuxs": {
"stack_startup": {
"design_chunks": [
{
"name": "mongodb",
"gatekeeper": {
"system_ready": {
"prompt": "Is system ready?",
"response": ["yes"],
"tv": "Y"
}
},
"flowout": {
"mongodb_ready": {
"prompt": "Is MongoDB ready?",
"response": ["yes"],
"tv": "Y"
}
},
"health_check": {
"type": "tcp",
"port_key": "27017",
"timeout_seconds": 2,
"status_mapping": {
"success": {
"key": "mongodb_ready",
"response": ["yes"],
"tv": "Y"
},
"failure": {
"key": "mongodb_ready",
"response": ["no"],
"tv": "N"
}
}
},
"container": {
"name": "pnr_mongodb",
"image": "mongo:latest",
"ports": {
"27017": "27017"
}
}
}
]
}
}
}
Go (1.19 以降) をインストールします:
Docker をインストールします
func (il *ContainerIntentionLoop) Execute() error {
// Create platform-specific network
_, err := il.dockerClient.NetworkCreate(il.ctx, "pnr_network", types.NetworkCreate{})
if err != nil {
return fmt.Errorf("failed to create network: %v", err)
}
for {
// Update runtime state
if err := il.updateRTStateFromRuntime(); err != nil {
return err
}
allCompleted := true
anyExecuting := false
// Process each container
for i := range il.cpux.DesignChunks {
chunk := &il.cpux.DesignChunks[i]
// Container state machine
switch chunk.Status {
case "completed":
continue
case "executing":
anyExecuting = true
allCompleted = false
if il.checkChunkCompletion(chunk) {
chunk.Status = "completed"
}
case "", "ready":
allCompleted = false
if il.checkGatekeeper(chunk) {
if err := il.startContainer(chunk); err != nil {
return err
}
chunk.Status = "executing"
anyExecuting = true
}
}
}
// Check termination conditions
if allCompleted {
return nil
}
if !anyExecuting && !allCompleted {
return fmt.Errorf("no progress possible - execution stalled")
}
time.Sleep(5 * time.Second)
}
}
func (il *ContainerIntentionLoop) checkChunkCompletion(chunk *DesignChunk) bool {
// Platform-agnostic container status check
isRunning, err := il.isContainerRunning(chunk.Container.Name)
if !isRunning {
il.updateChunkStatus(chunk, false)
return false
}
// Health check based on configuration
status := false
switch chunk.HealthCheck.Type {
case "tcp":
addr := fmt.Sprintf("localhost:%s", chunk.Container.Ports[chunk.HealthCheck.PortKey])
conn, err := net.DialTimeout("tcp", addr, timeout)
if err == nil {
conn.Close()
status = true
}
case "http":
url := fmt.Sprintf("http://localhost:%s%s",
chunk.Container.Ports[chunk.HealthCheck.PortKey],
chunk.HealthCheck.Path)
resp, err := client.Get(url)
if err == nil {
status = (resp.StatusCode == chunk.HealthCheck.ExpectedCode)
}
}
il.updateChunkStatus(chunk, status)
return status
}
pnr-orchestrator/ ├── main.go ├── containers.go ├── config/ │ └── domain.json └── runtime/ # Created automatically
従来の Docker Compose:
# Create project directory mkdir pnr-orchestrator cd pnr-orchestrator # Initialize Go module go mod init pnr-orchestrator # Install dependencies go get github.com/docker/docker/client go get github.com/docker/docker/api/types go get github.com/docker/go-connections/nat
PnR のインテリジェントなオーケストレーション:
# Option 1: Direct run go run main.go containers.go # Option 2: Build and run separately go build ./pnr-orchestrator # Unix/Linux/Mac pnr-orchestrator.exe # Windows
主な違いは何ですか? PnR は、コンテナーの起動だけでなく、あらゆるプラットフォームにわたって実際のサービスの準備を整えます。
PnR は、Go の強力なプラットフォーム抽象化機能により、シンプルさやパワーを犠牲にすることなく、堅牢なクロスプラットフォームのコンテナ オーケストレーション ツールをどのように作成できるかを示します。
さらに例を見たい場合、またはプラットフォーム固有の実装について質問がある場合は、コメントでお知らせください。
以上がPnR: Go&#s プラットフォーム抽象化による構成意図主導のコンテナ オーケストレーションの詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。
![[Web フロントエンド] Node.js クイック スタート](https://img.php.cn/upload/course/000/000/067/662b5d34ba7c0227.png)
