K8S ingress YAML 配置示例

apiVersion: networking.k8s.io/v1
kind: Ingress
metadata:
  name: minimal-ingress
  annotations:
    nginx.ingress.kubernetes.io/rewrite-target: /
spec:
  rules:
  - http:
      paths:
      - path: /testpath
        pathType: Prefix
        backend:
          service:
            name: test
            port:
              number: 80

reference
02/27 posted in  K8S配置示例

K8S Service YAML 配置示例

apiVersion: apps/v1
kind: Deployment
metadata:
  name: my-nginx
spec:
  selector:
    matchLabels:
      run: my-nginx
  replicas: 2
  template:
    metadata:
      labels:
        run: my-nginx
    spec:
      containers:
      - name: my-nginx
        image: nginx
        ports:
        - containerPort: 80
---
apiVersion: v1
kind: Service
metadata:
  name: my-nginx
  labels:
    run: my-nginx
spec:
  ports:
  - port: 80
    protocol: TCP
  selector:
    run: my-nginx

reference
02/27 posted in  K8S配置示例

K8S StatefulSets YAML 配置示例

apiVersion: v1
kind: Service
metadata:
  name: nginx
  labels:
    app: nginx
spec:
  ports:
  - port: 80
    name: web
  clusterIP: None
  selector:
    app: nginx
---
apiVersion: apps/v1
kind: StatefulSet
metadata:
  name: web
spec:
  selector:
    matchLabels:
      app: nginx # has to match .spec.template.metadata.labels
  serviceName: "nginx"
  replicas: 3 # by default is 1
  template:
    metadata:
      labels:
        app: nginx # has to match .spec.selector.matchLabels
    spec:
      terminationGracePeriodSeconds: 10
      containers:
      - name: nginx
        image: k8s.gcr.io/nginx-slim:0.8
        ports:
        - containerPort: 80
          name: web
        volumeMounts:
        - name: www
          mountPath: /usr/share/nginx/html
  volumeClaimTemplates:
  - metadata:
      name: www
    spec:
      accessModes: [ "ReadWriteOnce" ]
      storageClassName: "my-storage-class"
      resources:
        requests:
          storage: 1Gi

reference
02/27 posted in  K8S配置示例

K8S Deployment YAML 配置示例

apiVersion: apps/v1
kind: Deployment
metadata:
  name: nginx-deployment
spec:
  selector:
    matchLabels:
      app: nginx
  replicas: 2 # tells deployment to run 2 pods matching the template
  template:
    metadata:
      labels:
        app: nginx
    spec:
      containers:
      - name: nginx
        image: nginx:alpine
        ports:
        - containerPort: 80

reference
02/27 posted in  K8S配置示例

istio: Gateway 、VirtualService 配置示例

Gateway

apiVersion: networking.istio.io/v1alpha3
kind: Gateway
metadata:
  name: bookinfo-gateway
spec:
  selector:
    istio: ingressgateway # use istio default controller
  servers:
  - port:
      number: 80
      name: http
      protocol: HTTP
    hosts:
    - "*"

VirtualService

apiVersion: networking.istio.io/v1alpha3
kind: VirtualService
metadata:
  name: bookinfo
spec:
  hosts:
  - "*"
  gateways:
  - bookinfo-gateway
  http:
  - match:
    - uri:
        exact: /productpage
    - uri:
        prefix: /static
    - uri:
        exact: /login
    - uri:
        exact: /logout
    - uri:
        prefix: /api/v1/products
    route:
    - destination:
        host: productpage
        port:
          number: 9080
02/27 posted in  Istio配置示例

Golang 读取 YAML 配置文件

1. 从配置文件中获取

  • ./config/query-ip.yaml
influxdb: 
  server: <Your_Influxdb_Host>
  port: 8086
  • 代表示例

从配置文件中读取 influxdb 的 IP 和端口，然后将访问日志写入 DB

func initConfig() {

    viper.SetConfigName("query-ip") // YAML 文件名 (不带后缀)
    viper.AddConfigPath("./conf/")  //添加配置文件所在的路径
    // viper.SetConfigType("yaml")          //设置配置文件类型
    err3 := viper.ReadInConfig()
    if err3 != nil {
        fmt.Printf("config file error: %s\n", err3)
        os.Exit(1)
    }

    influxdbServer := viper.Get("influxdb.server")
    influxdbPort := viper.Get("influxdb.port")

    writeInfludbURL = fmt.Sprintf("http://%s:%d/write?db=<your_database>", influxdbServer, influxdbPort)

}

2. 从 HTTP Response 中获取 YAML

解析 cURL 命令获取本机外网 IP 中返回的 YAML 格式数据。

# dhcp.cn/?ip=134.175.159.160

IP: 134.175.159.160
Address:
  Country: 中国
  Province: 广东省
  City: 广州市
ISP: 电信

代码示例

package main

import (
    "bytes"
    "fmt"
    "io/ioutil"
    "log"
    "net"
    "net/http"
    "strconv"
    "strings"
    "github.com/spf13/viper"
)

func getIP(w http.ResponseWriter, req *http.Request, _ httprouter.Params) {

    clientIP := fmt.Sprintf("%s", req.Header.Get("X-Real-IP"))

    queryURL := fmt.Sprintf("http://api.dhcp.cn/?ip=%s", clientIP)

    responseClient, errClient := http.Get(queryURL) // 获取外网 IP
    if errClient != nil {
        fmt.Printf("获取外网 IP 失败，请检查网络\n")
        panic(errClient)
    }
    // 程序在使用完 response 后必须关闭 response 的主体。
    defer responseClient.Body.Close()

    IPBody, _ := ioutil.ReadAll(responseClient.Body)

    fmt.Fprintf(w, "%s", string(IPBody))

  // 从 []byte 中解析 YAML 
    viper.SetConfigType("yaml")
    viper.ReadConfig(bytes.NewBuffer(IPBody))

    IP := fmt.Sprintf("%s", viper.Get("IP"))
    Country := fmt.Sprintf("%s", viper.Get("Address.Country"))
    Province := fmt.Sprintf("%s", viper.Get("Address.Province"))
    City := fmt.Sprintf("%s", viper.Get("Address.City"))
    ISP := fmt.Sprintf("%s", viper.Get("ISP"))
}

reference

02/27 posted in  程序读取YAML文件

Copyright © YAML在线编辑器