Documentation
¶
Overview ¶
Package watchmanager is a generated GoMock package.
Index ¶
- func AddCluster(cachedClient kubernetes.Client, clusterID string) error
- func GetWatchChannel(resource string) (<-chan event.GenericEvent, error)
- func Initialize(kubeConfig *rest.Config, scheme *runtime.Scheme, mapper meta.RESTMapper) error
- func RemoveCluster(clusterID string) error
- type MockwatchManagerInterface
- type MockwatchManagerInterfaceMockRecorder
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func AddCluster ¶
func AddCluster(cachedClient kubernetes.Client, clusterID string) error
AddCluster add a cluster if not already exist to watch for sfserviceinstance and sfservicebinding
func GetWatchChannel ¶
func GetWatchChannel(resource string) (<-chan event.GenericEvent, error)
GetWatchChannel returns the channel for a resource to watch on Supported resource names are : sfserviceinstances and sfservicebindings
func Initialize ¶
Initialize initializes the watch manager
func RemoveCluster ¶
RemoveCluster stops watching on a cluster if already watching
Types ¶
type MockwatchManagerInterface ¶
type MockwatchManagerInterface struct {
// contains filtered or unexported fields
}
MockwatchManagerInterface is a mock of watchManagerInterface interface.
func NewMockwatchManagerInterface ¶
func NewMockwatchManagerInterface(ctrl *gomock.Controller) *MockwatchManagerInterface
NewMockwatchManagerInterface creates a new mock instance.
func (*MockwatchManagerInterface) EXPECT ¶
func (m *MockwatchManagerInterface) EXPECT() *MockwatchManagerInterfaceMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
type MockwatchManagerInterfaceMockRecorder ¶
type MockwatchManagerInterfaceMockRecorder struct {
// contains filtered or unexported fields
}
MockwatchManagerInterfaceMockRecorder is the mock recorder for MockwatchManagerInterface.