objects

Documentation

Index

• Constants
• type WatchHandler
  • func NewWatchHandler(clientPool *kubeclient.ClientPool) *WatchHandler
  • func (h *WatchHandler) Handle(ctx context.Context, call rpc.Call, reply chan<- stream.Message) error

Constants

const Watch rpc.CallMethod = "kubeObjects.watch"

Types

type WatchHandler

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

func NewWatchHandler

func NewWatchHandler(clientPool *kubeclient.ClientPool) *WatchHandler

func (*WatchHandler) Handle

func (h *WatchHandler) Handle(ctx context.Context, call rpc.Call, reply chan<- stream.Message) error