Knative Serving 进阶: Knative Serving SDK 开发实践

Knative Serving SDK 简介

Knative Serving SDK 是一个 Golang 库，它提供了用于与 Knative Serving 交互的 API。使用 Knative Serving SDK，我们可以轻松地开发 Knative Serving 应用程序，并将其部署到 Knative Serving 集群中。

Knative Serving SDK 的安装

Knative Serving SDK 可以通过以下命令安装：

go get -u github.com/knative/serving/pkg/client/clientset/versioned

Knative Serving SDK 的使用

Knative Serving SDK 提供了多种 API，用于与 Knative Serving 交互。这些 API 可以分为两大类：

• client ：用于创建、获取、更新和删除 Knative Serving 资源。
• Informer ：用于监视 Knative Serving 资源的变化。

client

client 是一个用于与 Knative Serving API 服务器通信的接口。我们可以使用 client 来创建、获取、更新和删除 Knative Serving 资源。例如，我们可以使用以下代码来创建 Deployment。

import (
	"context"

	servingv1 "k8s.io/api/serving/v1"
	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
	"k8s.io/client-go/kubernetes"
)

func createDeployment(clientset *kubernetes.Clientset, namespace string) error {
	deployment := &servingv1.Deployment{
		ObjectMeta: metav1.ObjectMeta{
			Name:      "my-deployment",
			Namespace: namespace,
		},
		Spec: servingv1.DeploymentSpec{
			RevisionTemplate: servingv1.RevisionTemplateSpec{
				Spec: servingv1.RevisionSpec{
					PodSpec: corev1.PodSpec{
						Containers: []corev1.Container{
							{
								Name:  "my-container",
								Image: "gcr.io/my-project/my-image",
							},
						},
					},
				},
			},
		},
	}

	_, err := clientset.ServingV1().Deployments(namespace).Create(context.TODO(), deployment, metav1.CreateOptions{})
	return err
}

Informer

Informer 是一个用于监视 Knative Serving 资源变化的接口。我们可以使用 Informer 来监视 Deployment、Service、Revision 等资源的变化。例如，我们可以使用以下代码来监视 Deployment 的变化。

import (
	"context"

	servingv1 "k8s.io/api/serving/v1"
	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
	"k8s.io/client-go/kubernetes"
	"k8s.io/client-go/tools/cache"
)

func watchDeployments(clientset *kubernetes.Clientset, namespace string) error {
	informer := cache.NewSharedIndexInformer(
		&cache.ListWatch{
			ListFunc: func(options metav1.ListOptions) (interface{}, error) {
				return clientset.ServingV1().Deployments(namespace).List(context.TODO(), options)
			},
			WatchFunc: func(options metav1.ListOptions) (watch.Interface, error) {
				return clientset.ServingV1().Deployments(namespace).Watch(context.TODO(), options)
			},
		},
		&servingv1.Deployment{},
		0, // resync period
		cache.Indexers{},
	)

	informer.AddEventHandler(cache.ResourceEventHandlerFuncs{
		AddFunc: func(obj interface{}) {
			deployment := obj.(*servingv1.Deployment)
			fmt.Println("Deployment created:", deployment.Name)
		},
		UpdateFunc: func(oldObj, newObj interface{}) {
			oldDeployment := oldObj.(*servingv1.Deployment)
			newDeployment := newObj.(*servingv1.Deployment)
			fmt.Println("Deployment updated:", oldDeployment.Name, newDeployment.Name)
		},
		DeleteFunc: func(obj interface{}) {
			deployment := obj.(*servingv1.Deployment)
			fmt.Println("Deployment deleted:", deployment.Name)
		},
	})

	stop := make(chan struct{})
	go informer.Run(stop)

	// Wait for informer to sync
	if !cache.WaitForCacheSync(context.TODO(), informer.HasSynced) {
		return fmt.Errorf("failed to wait for cache to sync")
	}

	// Wait for a while to receive events
	time.Sleep(30 * time.Second)

	close(stop)

	return nil
}

Knative Serving SDK 的调试和监控

Knative Serving SDK 提供了多种工具，用于调试和监控 Knative Serving 应用程序。这些工具包括：

• knative-serving-debug ：用于调试 Knative Serving 应用程序。
• knative-serving-metrics ：用于监控 Knative Serving 应用程序的指标。

knative-serving-debug

knative-serving-debug 是一个命令行工具，用于调试 Knative Serving 应用程序。它可以帮助我们检查 Knative Serving 应用程序的配置，并跟踪 Knative Serving 应用程序的日志。例如，我们可以使用以下命令来检查 Deployment 的配置。

knative-serving-debug deployment my-deployment -n my-namespace

knative-serving-metrics

knative-serving-metrics 是一个命令行工具，用于监控 Knative Serving 应用程序的指标。它可以帮助我们查看 Knative Serving 应用程序的请求量、延迟、错误率等指标。例如，我们可以使用以下命令来查看 Deployment 的请求量。

knative-serving-metrics deployment my-deployment -n my-namespace --metric requests_per_second

结论

本文介绍了 Knative Serving SDK 的使用，以及如何使用它来开发 Knative Serving 应用程序。还讨论了如何使用 Knative Serving SDK 来调试和监控应用程序。希望本文能够帮助读者更好地掌握 Knative Serving SDK 的使用。