v2

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
  • func NewRestoreItemActionPlugin(options ...common.PluginOption) *RestoreItemActionPlugin
  • func (p *RestoreItemActionPlugin) GRPCClient(_ context.Context, _ *plugin.GRPCBroker, clientConn *grpc.ClientConn) (interface{}, error)
  • func (p *RestoreItemActionPlugin) GRPCServer(_ *plugin.GRPCBroker, server *grpc.Server) error

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.