Versions in this module Expand all Collapse all v0 v0.6.0 Nov 30, 2017 Changes in this version + var AllPluginKinds = []PluginKind + var Handshake = plugin.HandshakeConfig + func NewLogger() logrus.FieldLogger + func Serve(p Interface) + type BackupItemActionGRPCClient struct + func (c *BackupItemActionGRPCClient) AppliesTo() (arkbackup.ResourceSelector, error) + func (c *BackupItemActionGRPCClient) Execute(item runtime.Unstructured, backup *api.Backup) (runtime.Unstructured, []arkbackup.ResourceIdentifier, error) + func (c *BackupItemActionGRPCClient) SetLog(log logrus.FieldLogger) + type BackupItemActionGRPCServer struct + func (s *BackupItemActionGRPCServer) AppliesTo(ctx context.Context, req *proto.Empty) (*proto.AppliesToResponse, error) + func (s *BackupItemActionGRPCServer) Execute(ctx context.Context, req *proto.ExecuteRequest) (*proto.ExecuteResponse, error) + type BackupItemActionPlugin struct + func NewBackupItemActionPlugin(itemAction arkbackup.ItemAction) *BackupItemActionPlugin + func (p *BackupItemActionPlugin) GRPCClient(c *grpc.ClientConn) (interface{}, error) + func (p *BackupItemActionPlugin) GRPCServer(s *grpc.Server) error + func (p *BackupItemActionPlugin) Kind() PluginKind + type BlockStoreGRPCClient struct + func (c *BlockStoreGRPCClient) CreateSnapshot(volumeID, volumeAZ string, tags map[string]string) (string, error) + func (c *BlockStoreGRPCClient) CreateVolumeFromSnapshot(snapshotID, volumeType, volumeAZ string, iops *int64) (string, error) + func (c *BlockStoreGRPCClient) DeleteSnapshot(snapshotID string) error + func (c *BlockStoreGRPCClient) GetVolumeID(pv runtime.Unstructured) (string, error) + func (c *BlockStoreGRPCClient) GetVolumeInfo(volumeID, volumeAZ string) (string, *int64, error) + func (c *BlockStoreGRPCClient) Init(config map[string]string) error + func (c *BlockStoreGRPCClient) IsVolumeReady(volumeID, volumeAZ string) (bool, error) + func (c *BlockStoreGRPCClient) SetVolumeID(pv runtime.Unstructured, volumeID string) (runtime.Unstructured, error) + type BlockStoreGRPCServer struct + func (s *BlockStoreGRPCServer) CreateSnapshot(ctx context.Context, req *proto.CreateSnapshotRequest) (*proto.CreateSnapshotResponse, error) + func (s *BlockStoreGRPCServer) CreateVolumeFromSnapshot(ctx context.Context, req *proto.CreateVolumeRequest) (*proto.CreateVolumeResponse, error) + func (s *BlockStoreGRPCServer) DeleteSnapshot(ctx context.Context, req *proto.DeleteSnapshotRequest) (*proto.Empty, error) + func (s *BlockStoreGRPCServer) GetVolumeID(ctx context.Context, req *proto.GetVolumeIDRequest) (*proto.GetVolumeIDResponse, error) + func (s *BlockStoreGRPCServer) GetVolumeInfo(ctx context.Context, req *proto.GetVolumeInfoRequest) (*proto.GetVolumeInfoResponse, error) + func (s *BlockStoreGRPCServer) Init(ctx context.Context, req *proto.InitRequest) (*proto.Empty, error) + func (s *BlockStoreGRPCServer) IsVolumeReady(ctx context.Context, req *proto.IsVolumeReadyRequest) (*proto.IsVolumeReadyResponse, error) + func (s *BlockStoreGRPCServer) SetVolumeID(ctx context.Context, req *proto.SetVolumeIDRequest) (*proto.SetVolumeIDResponse, error) + type BlockStorePlugin struct + func NewBlockStorePlugin(blockStore cloudprovider.BlockStore) *BlockStorePlugin + func (p *BlockStorePlugin) GRPCClient(c *grpc.ClientConn) (interface{}, error) + func (p *BlockStorePlugin) GRPCServer(s *grpc.Server) error + func (p *BlockStorePlugin) Kind() PluginKind + type CloseFunc func() error + type Interface interface + Kind func() PluginKind + type Manager interface + CloseBackupItemActions func(backupName string) error + CloseRestoreItemActions func(restoreName string) error + GetBackupItemActions func(backupName string) ([]backup.ItemAction, error) + GetBlockStore func(name string) (cloudprovider.BlockStore, error) + GetObjectStore func(name string) (cloudprovider.ObjectStore, error) + GetRestoreItemActions func(restoreName string) ([]restore.ItemAction, error) + func NewManager(logger logrus.FieldLogger, level logrus.Level) (Manager, error) + type ObjectStoreGRPCClient struct + func (c *ObjectStoreGRPCClient) CreateSignedURL(bucket, key string, ttl time.Duration) (string, error) + func (c *ObjectStoreGRPCClient) DeleteObject(bucket, key string) error + func (c *ObjectStoreGRPCClient) GetObject(bucket, key string) (io.ReadCloser, error) + func (c *ObjectStoreGRPCClient) Init(config map[string]string) error + func (c *ObjectStoreGRPCClient) ListCommonPrefixes(bucket, delimiter string) ([]string, error) + func (c *ObjectStoreGRPCClient) ListObjects(bucket, prefix string) ([]string, error) + func (c *ObjectStoreGRPCClient) PutObject(bucket, key string, body io.Reader) error + type ObjectStoreGRPCServer struct + func (s *ObjectStoreGRPCServer) CreateSignedURL(ctx context.Context, req *proto.CreateSignedURLRequest) (*proto.CreateSignedURLResponse, error) + func (s *ObjectStoreGRPCServer) DeleteObject(ctx context.Context, req *proto.DeleteObjectRequest) (*proto.Empty, error) + func (s *ObjectStoreGRPCServer) GetObject(req *proto.GetObjectRequest, stream proto.ObjectStore_GetObjectServer) error + func (s *ObjectStoreGRPCServer) Init(ctx context.Context, req *proto.InitRequest) (*proto.Empty, error) + func (s *ObjectStoreGRPCServer) ListCommonPrefixes(ctx context.Context, req *proto.ListCommonPrefixesRequest) (*proto.ListCommonPrefixesResponse, error) + func (s *ObjectStoreGRPCServer) ListObjects(ctx context.Context, req *proto.ListObjectsRequest) (*proto.ListObjectsResponse, error) + func (s *ObjectStoreGRPCServer) PutObject(stream proto.ObjectStore_PutObjectServer) error + type ObjectStorePlugin struct + func NewObjectStorePlugin(objectStore cloudprovider.ObjectStore) *ObjectStorePlugin + func (p *ObjectStorePlugin) GRPCClient(c *grpc.ClientConn) (interface{}, error) + func (p *ObjectStorePlugin) GRPCServer(s *grpc.Server) error + func (p *ObjectStorePlugin) Kind() PluginKind + type PluginKind string + const PluginKindBackupItemAction + const PluginKindBlockStore + const PluginKindCloudProvider + const PluginKindObjectStore + const PluginKindRestoreItemAction + func (k PluginKind) String() string + type ReceiveFunc func() ([]byte, error) + type RestoreItemActionGRPCClient struct + func (c *RestoreItemActionGRPCClient) AppliesTo() (restore.ResourceSelector, error) + func (c *RestoreItemActionGRPCClient) Execute(item runtime.Unstructured, restore *api.Restore) (runtime.Unstructured, error, error) + func (c *RestoreItemActionGRPCClient) SetLog(log logrus.FieldLogger) + type RestoreItemActionGRPCServer struct + func (s *RestoreItemActionGRPCServer) AppliesTo(ctx context.Context, req *proto.Empty) (*proto.AppliesToResponse, error) + func (s *RestoreItemActionGRPCServer) Execute(ctx context.Context, req *proto.RestoreExecuteRequest) (*proto.RestoreExecuteResponse, error) + type RestoreItemActionPlugin struct + func NewRestoreItemActionPlugin(itemAction restore.ItemAction) *RestoreItemActionPlugin + func (p *RestoreItemActionPlugin) GRPCClient(c *grpc.ClientConn) (interface{}, error) + func (p *RestoreItemActionPlugin) GRPCServer(s *grpc.Server) error + func (p *RestoreItemActionPlugin) Kind() PluginKind + type StreamReadCloser struct + func (s *StreamReadCloser) Close() error + func (s *StreamReadCloser) Read(p []byte) (n int, err error)
Go to main page