integration

package module

Go to main page

Versions in this module

v1

v1.1.4

Nov 4, 2026

Changes in this version

+ func ExporterBackends() []string

+ func ImporterBackends() []string

+ func RegisterExporter(name string, flags location.Flags, backend ExporterFn) error

+ func RegisterImporter(name string, flags location.Flags, backend ImporterFn) error

+ func RegisterStore(name string, flags location.Flags, backend StoreFn) error

+ func StoreBackends() []string

+ func UnregisterExporter(name string) error

+ func UnregisterImporter(name string) error

+ func UnregisterStore(name string) error

type MAC

+ func MACFromBytes(b []byte) (MAC, error)

+ type StorageResourceEntry struct

+ MAC MAC

+ MTime time.Time

+ Size int64

v1.1.3

Nov 3, 2026

Changes in this version

+ type Resource struct

+ MAC MAC

+ MTime time.Time

+ Size int64

v1.1.2

Oct 28, 2026

Changes in this version

+ func ParseFileInfoSortKeys(sortKeysStr string) ([]string, error)

+ func SortFileInfos(infos []FileInfo, sortKeys []string) error

+ func WithFlag(ctx context.Context, flag StorageFlag) context.Context

+ type Attribute uint8

+ const AttributeADS

+ const AttributeCustom

+ const AttributeExtended

+ type Exporter interface

+ Close func(context.Context) error

+ Export func(context.Context, <-chan *Record, chan<- *Result) error

+ Flags func() location.Flags

+ Origin func() string

+ Ping func(context.Context) error

+ Root func() string

+ Type func() string

+ type ExporterFn func(context.Context, *Options, string, map[string]string) (Exporter, error)

+ type FileInfo struct

+ Flags uint32

+ Ldev uint64

+ Lgid uint64

+ Lgroupname string

+ Lino uint64

+ LmodTime time.Time

+ Lmode fs.FileMode

+ Lname string

+ Lnlink uint16

+ Lsize int64

+ Luid uint64

+ Lusername string

+ func FileInfoFromStat(stat fs.FileInfo) FileInfo

+ func NewFileInfo(name string, size int64, mode os.FileMode, modTime time.Time, dev uint64, ...) FileInfo

+ func (f FileInfo) Dev() uint64

+ func (f FileInfo) Gid() uint64

+ func (f FileInfo) Groupname() string

+ func (f FileInfo) Ino() uint64

+ func (f FileInfo) IsDir() bool

+ func (f FileInfo) ModTime() time.Time

+ func (f FileInfo) Mode() os.FileMode

+ func (f FileInfo) Name() string

+ func (f FileInfo) Nlink() uint16

+ func (f FileInfo) Size() int64

+ func (f FileInfo) Sys() any

+ func (f FileInfo) Uid() uint64

+ func (f FileInfo) Username() string

+ func (fileinfo *FileInfo) Equal(fi *FileInfo) bool

+ func (fileinfo *FileInfo) EqualIgnoreSize(fi *FileInfo) bool

+ func (fileinfo *FileInfo) HumanSize() string

+ func (fileinfo *FileInfo) ToBytes() ([]byte, error)

+ func (fileinfo *FileInfo) Type() string

+ type Importer interface

+ Close func(context.Context) error

+ Flags func() location.Flags

+ Import func(context.Context, chan<- *Record, <-chan *Result) error

+ Origin func() string

+ Ping func(context.Context) error

+ Root func() string

+ Type func() string

+ type ImporterFn func(context.Context, *Options, string, map[string]string) (Importer, error)

+ type LazyReader struct

+ func NewLazyReader(open func() (io.ReadCloser, error)) *LazyReader

+ func (lr *LazyReader) Close() error

+ func (lr *LazyReader) Read(p []byte) (int, error)

+ type MAC [32]byte

+ var NilMac MAC

+ func RandomMAC() MAC

+ func (m *MAC) ParseHex(s string) error

+ func (m *MAC) UnmarshalJSON(data []byte) error

+ func (m MAC) FormatHex() string

+ func (m MAC) MarshalJSON() ([]byte, error)

+ type Mode uint32

+ const ModeRead

+ const ModeWrite

+ type Options struct

+ Architecture string

+ CWD string

+ Excludes []string

+ Hostname string

+ MaxConcurrency int

+ NoXattr bool

+ OperatingSystem string

+ Stderr io.Writer

+ Stdin io.Reader

+ Stdout io.Writer

+ type Range struct

+ Length uint32

+ Offset uint64

+ type Record struct

+ Err error

+ ExtendedAttributes []string

+ FileAttributes uint32

+ FileInfo FileInfo

+ ID string

+ IsXattr bool

+ Pathname string

+ Reader io.ReadCloser

+ Target string

+ XattrName string

+ XattrType Attribute

+ func NewError(pathname string, err error) *Record

+ func NewRecord(pathname, target string, fileinfo FileInfo, xattr []string, ...) *Record

+ func NewXattr(pathname, xattr string, kind Attribute, read func() (io.ReadCloser, error)) *Record

+ func (s *Record) Close() error

+ func (s *Record) Error(err error) *Result

+ func (s *Record) Ok() *Result

+ type Result struct

+ Err error

+ Record Record

+ type StorageFlag uint32

+ const StorageHot

+ func Flag(ctx context.Context) StorageFlag

+ type StorageResource uint32

+ const StorageResourceECCPackfile

+ const StorageResourceECCState

+ const StorageResourceLock

+ const StorageResourcePackfile

+ const StorageResourceState

+ const StorageResourceUndefined

+ func (s StorageResource) String() string

+ type Store interface

+ Close func(ctx context.Context) error

+ Create func(context.Context, []byte) error

+ Delete func(context.Context, StorageResource, MAC) error

+ Flags func() location.Flags

+ Get func(context.Context, StorageResource, MAC, *Range) (io.ReadCloser, error)

+ List func(context.Context, StorageResource) ([]MAC, error)

+ Mode func(context.Context) (Mode, error)

+ Open func(context.Context) ([]byte, error)

+ Origin func() string

+ Ping func(context.Context) error

+ Put func(context.Context, StorageResource, MAC, io.Reader) (int64, error)

+ Root func() string

+ Size func(context.Context) (int64, error)

+ Type func() string

+ type StoreFn func(context.Context, string, map[string]string) (Store, error)

v1.1.1

Oct 26, 2026

v1.1.0

Oct 26, 2026

Changes in this version

+ const ConnectorTypeExporter

+ const ConnectorTypeImporter

+ const ConnectorTypeInventory

+ const ConnectorTypeSecretProvider

+ const ConnectorTypeStorage

+ const ResourceClassAnalytics

+ const ResourceClassBlockStorage

+ const ResourceClassCompute

+ const ResourceClassDatabase

+ const ResourceClassFileStorage

+ const ResourceClassHypervisor

+ const ResourceClassIdentity

+ const ResourceClassMessaging

+ const ResourceClassNetwork

+ const ResourceClassObjectStorage

+ const ResourceClassObservability

+ const ResourceClassRegistry

+ const ResourceClassSecurity

+ const ResourceClassService

+ const ResourceClassUndefined

+ const ResourceClassUnknown

+ const ResourceSubClassAzBlob

+ const ResourceSubClassFTP

+ const ResourceSubClassGCS

+ const ResourceSubClassIMAP

+ const ResourceSubClassMongoDB

+ const ResourceSubClassMySQL

+ const ResourceSubClassPVC

+ const ResourceSubClassPostgreSQL

+ const ResourceSubClassProxmox

+ const ResourceSubClassRedis

+ const ResourceSubClassS3

+ const ResourceSubClassSFTP

+ const ResourceSubClassSecretManager

+ const ResourceSubClassUndefined

+ const ResourceSubClassUnknown

+ const ResourceSubClassVMware

+ var ErrConnectorMismatch = errors.New("cannot update connector type")

+ var ErrDisabledSync = errors.New("disabled sync")

+ var ErrInvalidEndpoint = errors.New("invalid endpoint")

+ var ErrUnknownEndpointType = errors.New("unknown endpoint type")

+ func GetClassTree() map[ResourceClass][]ResourceSubClass

+ type ConnectorType string

+ func (c ConnectorType) IsValid() bool

+ type Country string

+ func CountryOf(code string) Country

+ type EndpointType string

+ const EndpointHost

+ const EndpointIdentifier

+ const EndpointInet4

+ const EndpointInet6

+ const EndpointNetwork

+ const EndpointUUID

+ const EndpointUndefined

+ func EndpointTypeFromString(t string) (EndpointType, error)

+ type HostEndpoint struct

+ Attributes map[string]string

+ Endpoint string

+ Type EndpointType

+ type Inventory interface

+ Close func(context.Context) error

+ List func(context.Context, chan<- *InventoryEntry) error

+ type InventoryEntry struct

+ Class ResourceClass

+ Country Country

+ Details []byte

+ Endpoints []HostEndpoint

+ Name string

+ Region string

+ Resource string

+ Service string

+ SubClass ResourceSubClass

+ Tags []string

+ URN string

+ type ResourceClass string

+ func (c ResourceClass) IsValid() bool

+ type ResourceSubClass string

+ func (c ResourceSubClass) IsSubClassOf(parent ResourceClass) bool

+ func (c ResourceSubClass) IsValid() bool

+ type SecretProvider interface

+ Close func(ctx context.Context) error

+ Ping func(ctx context.Context) error

+ Resolve func(ctx context.Context, handle string) (secret string, err error)

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