v2

Feb 12, 2024

Changes in this version

+ const PluginConfigEnv

+ var HandshakeConfig = plugin.HandshakeConfig

+ type ClientHook struct

+ APIVersion string

+ Kind string

+ Types []string

+ type GRPCProviderPlugin struct

+ func (p *GRPCProviderPlugin) Client(*plugin.MuxBroker, *rpc.Client) (interface{}, error)

+ func (p *GRPCProviderPlugin) GRPCClient(_ context.Context, _ *plugin.GRPCBroker, clientConn *grpc.ClientConn) (interface{}, error)

+ func (p *GRPCProviderPlugin) GRPCServer(_ *plugin.GRPCBroker, _ *grpc.Server) error

+ func (p *GRPCProviderPlugin) Server(*plugin.MuxBroker) (interface{}, error)

+ type InitConfig struct

+ CurrentNamespace string

+ Options []byte

+ PhysicalClusterConfig []byte

+ Pro InitConfigPro

+ SyncerConfig []byte

+ WorkingDir string

+ type InitConfigPro struct

+ Enabled bool

+ Features map[string]bool

+ type Manager struct

+ ClientHooks map[plugintypes.VersionKindType][]*vClusterPlugin

+ PluginFolder string

+ Plugins []*vClusterPlugin

+ ProFeatures map[string]bool

+ func NewManager() *Manager

+ func (m *Manager) HasClientHooks() bool

+ func (m *Manager) HasClientHooksForType(versionKindType plugintypes.VersionKindType) bool

+ func (m *Manager) HasPlugins() bool

+ func (m *Manager) MutateObject(ctx context.Context, obj client.Object, hookType string, ...) error

+ func (m *Manager) SetLeader(ctx context.Context) error

+ func (m *Manager) Start(ctx context.Context, currentNamespace string, physicalKubeConfig *rest.Config, ...) error

+ type Plugin interface

+ HasClientHooks func() bool

+ HasClientHooksForType func(versionKindType plugintypes.VersionKindType) bool

+ MutateObject func(ctx context.Context, obj client.Object, hookType string, ...) error

+ SetLeader func() error

+ Start func(ctx context.Context, currentNamespace, targetNamespace string, ...) error

+ type PluginConfig struct

+ ClientHooks []*ClientHook