resourcewatcher

Documentation

Index

• Constants
• type LastResourceVersions
• type Service
  • func NewService(client clientset.Interface) *Service
  • func (s *Service) ListWatch(ctx context.Context, stream sw.ResponseStream, ...) error
• type StreamWriter

Constants

const (
	Pods       sw.ResourceKind = "pods"
	Nodes      sw.ResourceKind = "nodes"
	Pvs        sw.ResourceKind = "persistentvolumes"
	Pvcs       sw.ResourceKind = "persistentvolumeclaims"
	Scs        sw.ResourceKind = "storageclasses"
	Pcs        sw.ResourceKind = "priorityclasses"
	Namespaces sw.ResourceKind = "namespaces"
)

Types

type LastResourceVersions

type LastResourceVersions struct {
	Pods       string
	Nodes      string
	Pvs        string
	Pvcs       string
	Scs        string
	Pcs        string
	Namespaces string
}

LastResourceVersions includes each resource's LastResourceVersions.

type Service

type Service struct {
	// contains filtered or unexported fields
}

Service watches simulator's resources.

func NewService

func NewService(client clientset.Interface) *Service

NewService initializes Service.

func (*Service) ListWatch

func (s *Service) ListWatch(ctx context.Context, stream sw.ResponseStream, lrVersions *LastResourceVersions) error

ListWatch watches each simulator's resources and send notified events to the frontend continuously.

type StreamWriter

type StreamWriter interface {
	Write(we *sw.WatchEvent) error
}

StreamWriter is an interface that allows send a received WatchEvent to the frontend.