Documentation
¶
Index ¶
- type RestoreItemActionGRPCClient
- func (c *RestoreItemActionGRPCClient) AppliesTo() (velero.ResourceSelector, error)
- func (c *RestoreItemActionGRPCClient) AreAdditionalItemsReady(additionalItems []velero.ResourceIdentifier, restore *api.Restore) (bool, error)
- func (c *RestoreItemActionGRPCClient) Cancel(operationID string, restore *api.Restore) error
- func (c *RestoreItemActionGRPCClient) Execute(input *velero.RestoreItemActionExecuteInput) (*velero.RestoreItemActionExecuteOutput, error)
- func (c *RestoreItemActionGRPCClient) Name() string
- func (c *RestoreItemActionGRPCClient) Progress(operationID string, restore *api.Restore) (velero.OperationProgress, error)
- type RestoreItemActionGRPCServer
- func (s *RestoreItemActionGRPCServer) AppliesTo(ctx context.Context, req *protoriav2.RestoreItemActionAppliesToRequest) (response *protoriav2.RestoreItemActionAppliesToResponse, err error)
- func (s *RestoreItemActionGRPCServer) AreAdditionalItemsReady(ctx context.Context, req *protoriav2.RestoreItemActionItemsReadyRequest) (response *protoriav2.RestoreItemActionItemsReadyResponse, err error)
- func (s *RestoreItemActionGRPCServer) Cancel(ctx context.Context, req *protoriav2.RestoreItemActionCancelRequest) (response *emptypb.Empty, err error)
- func (s *RestoreItemActionGRPCServer) Execute(ctx context.Context, req *protoriav2.RestoreItemActionExecuteRequest) (response *protoriav2.RestoreItemActionExecuteResponse, err error)
- func (s *RestoreItemActionGRPCServer) Name() string
- func (s *RestoreItemActionGRPCServer) Progress(ctx context.Context, req *protoriav2.RestoreItemActionProgressRequest) (response *protoriav2.RestoreItemActionProgressResponse, err error)
- type RestoreItemActionPlugin
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type RestoreItemActionGRPCClient ¶
type RestoreItemActionGRPCClient struct {
*common.ClientBase
// contains filtered or unexported fields
}
RestoreItemActionGRPCClient implements the backup/ItemAction interface and uses a gRPC client to make calls to the plugin server.
func (*RestoreItemActionGRPCClient) AppliesTo ¶
func (c *RestoreItemActionGRPCClient) AppliesTo() (velero.ResourceSelector, error)
func (*RestoreItemActionGRPCClient) AreAdditionalItemsReady ¶
func (c *RestoreItemActionGRPCClient) AreAdditionalItemsReady(additionalItems []velero.ResourceIdentifier, restore *api.Restore) (bool, error)
func (*RestoreItemActionGRPCClient) Cancel ¶
func (c *RestoreItemActionGRPCClient) Cancel(operationID string, restore *api.Restore) error
func (*RestoreItemActionGRPCClient) Execute ¶
func (c *RestoreItemActionGRPCClient) Execute(input *velero.RestoreItemActionExecuteInput) (*velero.RestoreItemActionExecuteOutput, error)
func (*RestoreItemActionGRPCClient) Name ¶
func (c *RestoreItemActionGRPCClient) Name() string
This shouldn't be called on the GRPC client since the RestartableRestoreItemAction won't delegate this method
func (*RestoreItemActionGRPCClient) Progress ¶
func (c *RestoreItemActionGRPCClient) Progress(operationID string, restore *api.Restore) (velero.OperationProgress, error)
type RestoreItemActionGRPCServer ¶
type RestoreItemActionGRPCServer struct {
// contains filtered or unexported fields
}
RestoreItemActionGRPCServer implements the proto-generated RestoreItemActionServer interface, and accepts gRPC calls and forwards them to an implementation of the pluggable interface.
func (*RestoreItemActionGRPCServer) AppliesTo ¶
func (s *RestoreItemActionGRPCServer) AppliesTo(ctx context.Context, req *protoriav2.RestoreItemActionAppliesToRequest) (response *protoriav2.RestoreItemActionAppliesToResponse, err error)
func (*RestoreItemActionGRPCServer) AreAdditionalItemsReady ¶
func (s *RestoreItemActionGRPCServer) AreAdditionalItemsReady(ctx context.Context, req *protoriav2.RestoreItemActionItemsReadyRequest) ( response *protoriav2.RestoreItemActionItemsReadyResponse, err error)
func (*RestoreItemActionGRPCServer) Cancel ¶
func (s *RestoreItemActionGRPCServer) Cancel( ctx context.Context, req *protoriav2.RestoreItemActionCancelRequest) ( response *emptypb.Empty, err error)
func (*RestoreItemActionGRPCServer) Execute ¶
func (s *RestoreItemActionGRPCServer) Execute(ctx context.Context, req *protoriav2.RestoreItemActionExecuteRequest) (response *protoriav2.RestoreItemActionExecuteResponse, err error)
func (*RestoreItemActionGRPCServer) Name ¶
func (s *RestoreItemActionGRPCServer) Name() string
This shouldn't be called on the GRPC server since the server won't ever receive this request, as the RestartableRestoreItemAction in Velero won't delegate this to the server
func (*RestoreItemActionGRPCServer) Progress ¶
func (s *RestoreItemActionGRPCServer) Progress(ctx context.Context, req *protoriav2.RestoreItemActionProgressRequest) ( response *protoriav2.RestoreItemActionProgressResponse, err error)
type RestoreItemActionPlugin ¶
type RestoreItemActionPlugin struct {
plugin.NetRPCUnsupportedPlugin
*common.PluginBase
}
RestoreItemActionPlugin is an implementation of go-plugin's Plugin interface with support for gRPC for the restore/ItemAction interface.
func NewRestoreItemActionPlugin ¶
func NewRestoreItemActionPlugin(options ...common.PluginOption) *RestoreItemActionPlugin
NewRestoreItemActionPlugin constructs a RestoreItemActionPlugin.
func (*RestoreItemActionPlugin) GRPCClient ¶
func (p *RestoreItemActionPlugin) GRPCClient(_ context.Context, _ *plugin.GRPCBroker, clientConn *grpc.ClientConn) (interface{}, error)
GRPCClient returns a RestoreItemAction gRPC client.
func (*RestoreItemActionPlugin) GRPCServer ¶
func (p *RestoreItemActionPlugin) GRPCServer(_ *plugin.GRPCBroker, server *grpc.Server) error
GRPCServer registers a RestoreItemAction gRPC server.
Source Files
Click to show internal directories.
Click to hide internal directories.