cluster

Documentation

Index

• Constants
• type AgentListWatcher
  • func NewAgentListWatcher(token string, config *config.ListWatcherConfig) AgentListWatcher

Constants

const ClusterAgentWatchKey = "kubespace:cluster:agent:%s"

Types

type AgentListWatcher

type AgentListWatcher interface {
	listwatcher.Interface
	Watched() (bool, error)
	NotifyResult(req *kubetypes.Request, timeout int) *utils.Response
	NotifyWatch(traceId string, stopCh <-chan struct{}) <-chan []byte
	NotifyResponse(resp *kubetypes.Response) error
}

func NewAgentListWatcher

func NewAgentListWatcher(token string, config *config.ListWatcherConfig) AgentListWatcher