컨테이너 오케스트레이션이 정적 종속성 체인보다 유연하고 Kubernetes보다 단순할 수 있기를 바란 적이 있습니까? PnR(Prompt and Response)을 만나보세요. Go의 강력한 플랫폼 추상화 기능을 활용하여 단순한 종속성이 아닌 실제 준비 상태를 기반으로 컨테이너를 조정하는 구성 중심 접근 방식입니다.
PnR에 대해 알아보기 전에 Go가 특히 크로스 플랫폼 컨테이너 오케스트레이션에 적합한 이유를 살펴보겠습니다.
통합 Docker API 인터페이스: Go의 Docker 클라이언트 라이브러리는 플랫폼별 소켓 연결을 통해 Windows, Linux 및 macOS 전반에 걸쳐 일관된 인터페이스를 제공합니다.
기본 동시성 지원: Go의 고루틴과 채널을 통해 효율적인 컨테이너 모니터링이 가능합니다.
교차 플랫폼 네트워크 처리: Go의 넷 패키지는 플랫폼별 네트워크 세부 정보를 추상화합니다.
PnR은 세 가지 주요 구성 요소를 통해 컨테이너를 조정합니다.
MongoDB, API 서버, 웹 클라이언트 등 일반적인 웹 스택을 사용하여 이를 실제로 살펴보겠습니다.
{ "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 이상) 설치:
도커 설치
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: Gos 플랫폼 추상화를 통한 구성 의도 기반 컨테이너 오케스트레이션의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!