🐹 Go로 만든 채널 기반 실시간 데이터 통합 시스템

// Go 실시간 데이터 통합 시스템 예제
package main

import (
	"fmt"
	"time"
)

// 데이터 타입 정의
type Data struct {
	Value string
}

func main() {
	// 채널 생성
	dataChan := make(chan Data)
	logChan := make(chan string)

	// 데이터 소스 시뮬레이션 (예: 5초 간격으로 데이터 전송)
	done := make(chan bool)
	go func() {
		for {
			dataChan <- Data{Value: "Data" + time.Now().String()}
			time.Sleep(5 * time.Second)
			if done != nil {
				break
			}
		}
	}()

	// 데이터 처리 로직 (필터링 및 변환)
	go func() {
		for data := range dataChan {
			filteredData := Data{Value: "Filtered: " + data.Value}
			logChan <- fmt.Sprintf("Processed: %s", filteredData.Value)
		}
	}()

	// 로그 출력 루프
	go func() {
		for log := range logChan {
			fmt.Println(log)
		}
	}()

	// 프로그램 종료 대기
	select {
		done <- true:
		case <-time.After(30 * time.Second):
			fmt.Println("Timeout: Exiting...")
			break
	}
}