astrolabe

package

Go to main page

Versions in this module

v0

v0.8.1

Mar 8, 2020

v0.8.0

Mar 8, 2020

v0.6.0

Feb 23, 2023

v0.5.1

May 19, 2022

v0.5.0

Mar 13, 2022

Changes in this version

+ func StringFromCopyCreateOption(options CopyCreateOptions) string

type CopyCreateOptions

+ func CopyCreateOptionFromString(optionStr string) CopyCreateOptions

type ProtectedEntityID

+ func (this ProtectedEntityID) GetBaseID() ProtectedEntityID

v0.4.0

Jun 30, 2021

Changes in this version

+ func UnzipFileToProtectedEntity(ctx context.Context, zipFileReader io.ReaderAt, zipFileSize int64, ...) error

+ func ZipProtectedEntityToFile(ctx context.Context, srcPE ProtectedEntity, zipFileWriter io.WriteCloser) (bytesWritten int64, err error)

+ func ZipProtectedEntityToWriter(ctx context.Context, pe ProtectedEntity, writer io.Writer) error

type ProtectedEntity

+ func GetPEFromZipStream(ctx context.Context, reader io.ReaderAt, size int64) (ProtectedEntity, error)

type ProtectedEntityInfo

+ GetSize func() int64

type ProtectedEntityInfoImpl

+ func (this ProtectedEntityInfoImpl) GetSize() int64

type ZipProtectedEntity

+ func (recv ZipProtectedEntity) DeleteSnapshot(ctx context.Context, snapshotToDelete ProtectedEntitySnapshotID, ...) (bool, error)

+ func (recv ZipProtectedEntity) GetCombinedInfo(ctx context.Context) ([]ProtectedEntityInfo, error)

+ func (recv ZipProtectedEntity) GetComponents(ctx context.Context) ([]ProtectedEntity, error)

+ func (recv ZipProtectedEntity) GetDataReader(ctx context.Context) (io.ReadCloser, error)

+ func (recv ZipProtectedEntity) GetID() ProtectedEntityID

+ func (recv ZipProtectedEntity) GetInfo(ctx context.Context) (ProtectedEntityInfo, error)

+ func (recv ZipProtectedEntity) GetInfoForSnapshot(ctx context.Context, snapshotID ProtectedEntitySnapshotID) (*ProtectedEntityInfo, error)

+ func (recv ZipProtectedEntity) GetMetadataReader(ctx context.Context) (io.ReadCloser, error)

+ func (recv ZipProtectedEntity) ListSnapshots(ctx context.Context) ([]ProtectedEntitySnapshotID, error)

+ func (recv ZipProtectedEntity) Overwrite(ctx context.Context, sourcePE ProtectedEntity, ...) error

+ func (recv ZipProtectedEntity) Snapshot(ctx context.Context, params map[string]map[string]interface{}) (ProtectedEntitySnapshotID, error)

v0.3.0

Mar 4, 2021

v0.2.0

Dec 16, 2020

Changes in this version

+ const CombinedExt

+ const DataExt

+ const IvdPEType

+ const MDExt

+ const PEInfoExt

+ const ParaVirtPvPEType

+ const PvcPEType

+ const S3BucketParam

+ const S3HostParam

+ const S3KeyParam

+ const S3TransportType

+ const S3URLParam

+ const S3UseHTTPParam

+ func GetNamespaceAndNameFromPEID(peid ProtectedEntityID) (namespace string, name string, err error)

type DataTransport

+ func NewS3CombinedTransportForPEID(peid ProtectedEntityID, s3Config S3Config) (DataTransport, error)

+ func NewS3DataTransportForPEID(peid ProtectedEntityID, s3Config S3Config) (DataTransport, error)

+ func NewS3MDTransportForPEID(peid ProtectedEntityID, s3Config S3Config) (DataTransport, error)

+ func NewS3PEInfoTransportForPEID(peid ProtectedEntityID, s3Config S3Config) (DataTransport, error)

+ func NewS3TransportForPEID(peid ProtectedEntityID, ext string, s3Config S3Config) (DataTransport, error)

type ProtectedEntity

+ Overwrite func(ctx context.Context, sourcePE ProtectedEntity, ...) error

type ProtectedEntityID

+ func NewProtectedEntityIDWithNamespace(peType string, name string, namespace string) ProtectedEntityID

+ func NewProtectedEntityIDWithNamespaceAndSnapshot(peType string, name string, namespace string, snapshotID string) ProtectedEntityID

+ func (this ProtectedEntityID) IDWithSnapshot(snapshotID ProtectedEntitySnapshotID) ProtectedEntityID

type ProtectedEntitySnapshotID

+ func NewProtectedEntitySnapshotIDFromModel(mpei models.ProtectedEntitySnapshotID) ProtectedEntitySnapshotID

+ type S3Config struct

+ AccessKey string

+ Host net.IP

+ Port int

+ Prefix string

+ Region string

+ Secret string

+ URLBase string

+ UseHttp bool

v0.1.2

Sep 1, 2020

v0.1.1

May 19, 2020

v0.1.0

Apr 10, 2020

Changes in this version

+ func ZipProtectedEntity(ctx context.Context, entity ProtectedEntity, writer io.Writer) error

+ type CopyCreateOptions int

+ const AllocateNewObject

+ const AllocateObjectWithID

+ const UpdateExistingObject

+ type DataTransport struct

+ func NewDataTransport(transportType string, params map[string]string) DataTransport

+ func NewDataTransportForS3(host string, bucket string, key string) DataTransport

+ func NewDataTransportForS3URL(url string) DataTransport

+ func (this *DataTransport) UnmarshalJSON(data []byte) error

+ func (this DataTransport) GetParam(key string) (string, bool)

+ func (this DataTransport) GetTransportType() string

+ func (this DataTransport) MarshalJSON() ([]byte, error)

+ type GenericTask struct

+ Completed bool

+ Details string

+ FinishedTime time.Time

+ ID TaskID

+ Progress float64

+ Result interface{}

+ StartedTime time.Time

+ TaskStatus TaskStatus

+ func NewGenericTask() GenericTask

+ func (this GenericTask) Cancel() error

+ func (this GenericTask) GetDetails() string

+ func (this GenericTask) GetFinishedTime() time.Time

+ func (this GenericTask) GetModelTaskInfo() models.TaskInfo

+ func (this GenericTask) GetProgress() float64

+ func (this GenericTask) GetResult() interface{}

+ func (this GenericTask) GetStartedTime() time.Time

+ func (this GenericTask) GetStatus() TaskStatus

+ func (this GenericTask) GetTaskID() TaskID

+ func (this GenericTask) GetTaskStatus() TaskStatus

+ type ProtectedEntity interface

+ DeleteSnapshot func(ctx context.Context, snapshotToDelete ProtectedEntitySnapshotID) (bool, error)

+ GetCombinedInfo func(ctx context.Context) ([]ProtectedEntityInfo, error)

+ GetComponents func(ctx context.Context) ([]ProtectedEntity, error)

+ GetDataReader func(ctx context.Context) (io.ReadCloser, error)

+ GetID func() ProtectedEntityID

+ GetInfo func(ctx context.Context) (ProtectedEntityInfo, error)

+ GetInfoForSnapshot func(ctx context.Context, snapshotID ProtectedEntitySnapshotID) (*ProtectedEntityInfo, error)

+ GetMetadataReader func(ctx context.Context) (io.Reader, error)

+ ListSnapshots func(ctx context.Context) ([]ProtectedEntitySnapshotID, error)

+ Snapshot func(ctx context.Context) (ProtectedEntitySnapshotID, error)

+ type ProtectedEntityID struct

+ func NewProtectedEntityID(peType string, id string) ProtectedEntityID

+ func NewProtectedEntityIDFromModel(mpei models.ProtectedEntityID) (ProtectedEntityID, error)

+ func NewProtectedEntityIDFromString(peiString string) (returnPEI ProtectedEntityID, returnError error)

+ func NewProtectedEntityIDWithSnapshotID(peType string, id string, snapshotID ProtectedEntitySnapshotID) ProtectedEntityID

+ func (this *ProtectedEntityID) UnmarshalJSON(b []byte) error

+ func (this ProtectedEntityID) GetID() string

+ func (this ProtectedEntityID) GetModelProtectedEntityID() models.ProtectedEntityID

+ func (this ProtectedEntityID) GetPeType() string

+ func (this ProtectedEntityID) GetSnapshotID() ProtectedEntitySnapshotID

+ func (this ProtectedEntityID) HasSnapshot() bool

+ func (this ProtectedEntityID) MarshalJSON() ([]byte, error)

+ func (this ProtectedEntityID) String() string

+ type ProtectedEntityInfo interface

+ GetCombinedTransports func() []DataTransport

+ GetComponentIDs func() []ProtectedEntityID

+ GetDataTransports func() []DataTransport

+ GetID func() ProtectedEntityID

+ GetMetadataTransports func() []DataTransport

+ GetModelProtectedEntityInfo func() models.ProtectedEntityInfo

+ GetName func() string

+ func NewProtectedEntityInfo(id ProtectedEntityID, name string, dataTransports []DataTransport, ...) ProtectedEntityInfo

+ func NewProtectedEntityInfoFromModel(mpei models.ProtectedEntityInfo) (ProtectedEntityInfo, error)

+ type ProtectedEntityInfoImpl struct

+ func (this *ProtectedEntityInfoImpl) FillFromModel(jsonStruct models.ProtectedEntityInfo) error

+ func (this *ProtectedEntityInfoImpl) UnmarshalJSON(data []byte) error

+ func (this ProtectedEntityInfoImpl) GetCombinedTransports() []DataTransport

+ func (this ProtectedEntityInfoImpl) GetComponentIDs() []ProtectedEntityID

+ func (this ProtectedEntityInfoImpl) GetDataTransports() []DataTransport

+ func (this ProtectedEntityInfoImpl) GetID() ProtectedEntityID

+ func (this ProtectedEntityInfoImpl) GetMetadataTransports() []DataTransport

+ func (this ProtectedEntityInfoImpl) GetModelProtectedEntityInfo() models.ProtectedEntityInfo

+ func (this ProtectedEntityInfoImpl) GetName() string

+ func (this ProtectedEntityInfoImpl) MarshalJSON() ([]byte, error)

+ type ProtectedEntityManager interface

+ GetProtectedEntity func(ctx context.Context, id ProtectedEntityID) (ProtectedEntity, error)

+ GetProtectedEntityTypeManager func(peType string) ProtectedEntityTypeManager

+ ListEntityTypeManagers func() []ProtectedEntityTypeManager

+ type ProtectedEntitySnapshotID struct

+ func NewProtectedEntitySnapshotID(pesiString string) ProtectedEntitySnapshotID

+ func (this ProtectedEntitySnapshotID) GetID() string

+ func (this ProtectedEntitySnapshotID) GetModelProtectedEntitySnapshotID() models.ProtectedEntitySnapshotID

+ func (this ProtectedEntitySnapshotID) String() string

+ type ProtectedEntityTypeManager interface

+ Copy func(ctx context.Context, pe ProtectedEntity, options CopyCreateOptions) (ProtectedEntity, error)

+ CopyFromInfo func(ctx context.Context, info ProtectedEntityInfo, options CopyCreateOptions) (ProtectedEntity, error)

+ GetProtectedEntities func(ctx context.Context) ([]ProtectedEntityID, error)

+ GetProtectedEntity func(ctx context.Context, id ProtectedEntityID) (ProtectedEntity, error)

+ GetTypeName func() string

+ type Task interface

+ Cancel func() error

+ GetDetails func() string

+ GetFinishedTime func() time.Time

+ GetID func() TaskID

+ GetModelTaskInfo func() models.TaskInfo

+ GetProgress func() float64

+ GetResult func() interface{}

+ GetStartedTime func() time.Time

+ type TaskID struct

+ func GenerateTaskID() TaskID

+ func (this TaskID) GetModelTaskID() models.TaskID

+ type TaskStatus int

+ const Cancelled

+ const Failed

+ const Running

+ const Success

+ func (this TaskStatus) String() string

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL