service

Documentation

Index

• func NewKubernetesClient() (*kubernetes.Clientset, error)
• func SplitImageNameAndTag(image string) (string, string)
• type ResourceKey
• type WatcherService
  • func NewWatcherService() *WatcherService
  • func (ws *WatcherService) StartWatcher()

Functions

func NewKubernetesClient

func NewKubernetesClient() (*kubernetes.Clientset, error)

NewKubernetesClient 创建一个新的 Kubernetes 客户端

func SplitImageNameAndTag

func SplitImageNameAndTag(image string) (string, string)

SplitImageNameAndTag 根据最后一个':'分隔符分割镜像字符串，返回镜像名称和标签。

Types

type ResourceKey

type ResourceKey struct {
	Namespace     string
	ResourceName  string
	ResourceType  string
	ContainerName string
	ImageName     string
	ImageTag      string
}

type WatcherService

type WatcherService struct {
	ImageCache map[string][]ResourceKey

	UpdateHandlerChan chan model.PushEvent
	// 定义信号管道，UpdateHandlerChan处理完就置传入true
	UpdateHandlerDone chan bool
	// contains filtered or unexported fields
}

func NewWatcherService

func NewWatcherService() *WatcherService

func (*WatcherService) StartWatcher

func (ws *WatcherService) StartWatcher()