v2

package
v1.13.2 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 11, 2024 License: Apache-2.0 Imports: 16 Imported by: 2

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type BackupItemActionGRPCClient 

type BackupItemActionGRPCClient struct {
	*common.ClientBase
	// contains filtered or unexported fields
}

BackupItemActionGRPCClient implements the backup/ItemAction interface and uses a gRPC client to make calls to the plugin server.

func (*BackupItemActionGRPCClient) AppliesTo 

func (c *BackupItemActionGRPCClient) AppliesTo() (velero.ResourceSelector, error)

func (*BackupItemActionGRPCClient) Cancel 

func (c *BackupItemActionGRPCClient) Cancel(operationID string, backup *api.Backup) error

func (*BackupItemActionGRPCClient) Execute 

func (c *BackupItemActionGRPCClient) Execute(item runtime.Unstructured, backup *api.Backup) (runtime.Unstructured, []velero.ResourceIdentifier, string, []velero.ResourceIdentifier, error)

func (*BackupItemActionGRPCClient) Name 

func (c *BackupItemActionGRPCClient) Name() string

This shouldn't be called on the GRPC client since the RestartableBackupItemAction won't delegate this method

func (*BackupItemActionGRPCClient) Progress 

func (c *BackupItemActionGRPCClient) Progress(operationID string, backup *api.Backup) (velero.OperationProgress, error)

type BackupItemActionGRPCServer 

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

BackupItemActionGRPCServer implements the proto-generated BackupItemAction interface, and accepts gRPC calls and forwards them to an implementation of the pluggable interface.

func (*BackupItemActionGRPCServer) AppliesTo 

func (s *BackupItemActionGRPCServer) AppliesTo(
	ctx context.Context, req *protobiav2.BackupItemActionAppliesToRequest) (
	response *protobiav2.BackupItemActionAppliesToResponse, err error)

func (*BackupItemActionGRPCServer) Cancel 

func (s *BackupItemActionGRPCServer) Cancel(
	ctx context.Context, req *protobiav2.BackupItemActionCancelRequest) (
	response *emptypb.Empty, err error)

func (*BackupItemActionGRPCServer) Execute 

func (s *BackupItemActionGRPCServer) Execute(
	ctx context.Context, req *protobiav2.ExecuteRequest) (response *protobiav2.ExecuteResponse, err error)

func (*BackupItemActionGRPCServer) Name 

func (s *BackupItemActionGRPCServer) Name() string

This shouldn't be called on the GRPC server since the server won't ever receive this request, as the RestartableBackupItemAction in Velero won't delegate this to the server

func (*BackupItemActionGRPCServer) Progress 

func (s *BackupItemActionGRPCServer) Progress(
	ctx context.Context, req *protobiav2.BackupItemActionProgressRequest) (
	response *protobiav2.BackupItemActionProgressResponse, err error)

type BackupItemActionPlugin 

type BackupItemActionPlugin struct {
	plugin.NetRPCUnsupportedPlugin
	*common.PluginBase
}

BackupItemActionPlugin is an implementation of go-plugin's Plugin interface with support for gRPC for the backup/ItemAction interface.

func NewBackupItemActionPlugin 

func NewBackupItemActionPlugin(options ...common.PluginOption) *BackupItemActionPlugin

NewBackupItemActionPlugin constructs a BackupItemActionPlugin.

func (*BackupItemActionPlugin) GRPCClient 

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

GRPCClient returns a clientDispenser for BackupItemAction gRPC clients.

func (*BackupItemActionPlugin) GRPCServer 

func (p *BackupItemActionPlugin) GRPCServer(_ *plugin.GRPCBroker, server *grpc.Server) error

GRPCServer registers a BackupItemAction gRPC server.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.