statussync

Documentation

Index

• Variables
• type StatusInformer
  • func NewManager() *StatusInformer
  • func (m *StatusInformer) Add(name string) <-chan struct{}
  • func (m *StatusInformer) Delete(name string)
  • func (m *StatusInformer) Sync(name string) error

Variables

var (
	ErrNotFound = errors.New("not Found")
)

Types

type StatusInformer

type StatusInformer struct {
	sync.Mutex
	// contains filtered or unexported fields
}

StatusInformer 状态同步通知器，当Pod状态处于Running时，通知对端

func NewManager

func NewManager() *StatusInformer

func (*StatusInformer) Add

func (m *StatusInformer) Add(name string) <-chan struct{}

func (*StatusInformer) Delete

func (m *StatusInformer) Delete(name string)

func (*StatusInformer) Sync

func (m *StatusInformer) Sync(name string) error