v2

Documentation

Index

• type BackupItemActionGRPCClient
  • func (c *BackupItemActionGRPCClient) AppliesTo() (velero.ResourceSelector, error)
  • func (c *BackupItemActionGRPCClient) Cancel(operationID string, backup *api.Backup) error
  • func (c *BackupItemActionGRPCClient) Execute(item runtime.Unstructured, backup *api.Backup) (runtime.Unstructured, []velero.ResourceIdentifier, string, ...)
  • func (c *BackupItemActionGRPCClient) Name() string
  • func (c *BackupItemActionGRPCClient) Progress(operationID string, backup *api.Backup) (velero.OperationProgress, error)
• type BackupItemActionGRPCServer
  • func (s *BackupItemActionGRPCServer) AppliesTo(ctx context.Context, req *protobiav2.BackupItemActionAppliesToRequest) (response *protobiav2.BackupItemActionAppliesToResponse, err error)
  • func (s *BackupItemActionGRPCServer) Cancel(ctx context.Context, req *protobiav2.BackupItemActionCancelRequest) (response *emptypb.Empty, err error)
  • func (s *BackupItemActionGRPCServer) Execute(ctx context.Context, req *protobiav2.ExecuteRequest) (response *protobiav2.ExecuteResponse, err error)
  • func (c *BackupItemActionGRPCServer) Name() string
  • func (s *BackupItemActionGRPCServer) Progress(ctx context.Context, req *protobiav2.BackupItemActionProgressRequest) (response *protobiav2.BackupItemActionProgressResponse, err error)
• type BackupItemActionPlugin
  • func NewBackupItemActionPlugin(options ...common.PluginOption) *BackupItemActionPlugin
  • func (p *BackupItemActionPlugin) GRPCClient(_ context.Context, _ *plugin.GRPCBroker, clientConn *grpc.ClientConn) (interface{}, error)
  • func (p *BackupItemActionPlugin) GRPCServer(_ *plugin.GRPCBroker, server *grpc.Server) error

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 (c *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.