Versions in this module Expand all Collapse all v0 v0.1.3 Jun 14, 2016 Changes in this version type InstanceID + func (i *InstanceID) MarshalYAML() (interface{}, error) type LocalDevices + func (l *LocalDevices) MarshalYAML() (interface{}, error) type VersionInfo + func (v *VersionInfo) MarshalYAML() (interface{}, error) v0.1.2 Jun 13, 2016 v0.1.1 Jun 11, 2016 Changes in this version + const ConfigClientType + const ConfigLogging + const ConfigServerAutoEndpointMode + const Etc + const Home + const LSXCmdInstanceID + const LSXCmdLocalDevices + const LSXCmdNextDevice + const LSXCmdWaitForDevice + const Lib + const Log + const Run + var Debug = strconv.ParseBool(os.Getenv("LIBSTORAGE_DEBUG")) + type ClientType int + const ControllerClient + const IntegrationClient + const UnknownClientType + func ParseClientType(str string) ClientType + func (t ClientType) String() string type ConfigKey + func (k ConfigKey) String() string + type EndpointType int + const TCPEndpoint + const UnixEndpoint + const UnknownEndpointType + func ParseEndpointType(str string) EndpointType + func (t EndpointType) String() string + type ErrBadAdminToken struct + type ErrUnsupportedForClientType struct + type VersionInfo struct + Arch string + Branch string + BuildTimestamp time.Time + SemVer string + ShaLong string + func (v *VersionInfo) MarshalJSON() ([]byte, error) + func (v *VersionInfo) String() string v0.1.1-rc3 Jun 10, 2016 v0.1.1-rc2 Jun 8, 2016 v0.1.1-rc1 May 27, 2016 v0.1.0 May 17, 2016 Changes in this version + const ConfigClient + const ConfigClientCacheInstanceID + const ConfigDeviceAttachTimeout + const ConfigDeviceScanType + const ConfigEmbedded + const ConfigEndpoints + const ConfigExecutorNoDownload + const ConfigExecutorPath + const ConfigHTTPDisableKeepAlive + const ConfigHTTPReadTimeout + const ConfigHTTPWriteTimeout + const ConfigHost + const ConfigIg + const ConfigIgVol + const ConfigIgVolOps + const ConfigIgVolOpsCreate + const ConfigIgVolOpsCreateDefault + const ConfigIgVolOpsCreateDefaultAZ + const ConfigIgVolOpsCreateDefaultFsType + const ConfigIgVolOpsCreateDefaultIOPS + const ConfigIgVolOpsCreateDefaultSize + const ConfigIgVolOpsCreateDefaultType + const ConfigIgVolOpsCreateDisable + const ConfigIgVolOpsCreateImplicit + const ConfigIgVolOpsMount + const ConfigIgVolOpsMountPath + const ConfigIgVolOpsMountPreempt + const ConfigIgVolOpsMountRootPath + const ConfigIgVolOpsPath + const ConfigIgVolOpsPathCache + const ConfigIgVolOpsRemove + const ConfigIgVolOpsRemoveDisable + const ConfigIgVolOpsUnmount + const ConfigIgVolOpsUnmountIgnoreUsed + const ConfigIntegrationDriver + const ConfigLogHTTPRequests + const ConfigLogHTTPResponses + const ConfigLogLevel + const ConfigLogStderr + const ConfigLogStdout + const ConfigOSDriver + const ConfigOldDocker + const ConfigOldDockerAvailabilityZone + const ConfigOldDockerFsType + const ConfigOldDockerIOPS + const ConfigOldDockerLinuxVolumeRootPath + const ConfigOldDockerMountDirPath + const ConfigOldDockerSize + const ConfigOldDockerVolumeType + const ConfigOldIntegrationVolCreateDisable + const ConfigOldIntegrationVolMountPreempt + const ConfigOldIntegrationVolPathCache + const ConfigOldIntegrationVolRemoveDisable + const ConfigOldIntegrationVolUnmountIgnoreUsed + const ConfigOldRoot + const ConfigRoot + const ConfigServer + const ConfigService + const ConfigServices + const ConfigStorageDriver + const ConfigTLS + const ConfigTLSCertFile + const ConfigTLSClientCertRequired + const ConfigTLSDisabled + const ConfigTLSKeyFile + const ConfigTLSServerName + const ConfigTLSTrustedCertsFile + const InstanceIDHeader + const LibStorageDriverName + const LocalDevicesHeader + const ServerNameHeader + const TaskStateError + const TaskStateQueued + const TaskStateRunning + const TaskStateSuccess + const TransactionHeader + var ErrIIDMetadataNil = goof.New("cannot unmarshal nil metadata") + var ErrIIDMetadataNilData = goof.New("cannot marshal nil metadata") + var ErrIIDMetadataNilDest = goof.New("cannot unmarshal into nil receiver") + var ErrNotImplemented = goof.New("not implemented") + var LSX string + func BackCompat(config gofig.Config) + type APIClient interface + ExecutorGet func(ctx Context, name string) (io.ReadCloser, error) + ExecutorHead func(ctx Context, name string) (*ExecutorInfo, error) + Executors func(ctx Context) (map[string]*ExecutorInfo, error) + InstanceInspect func(ctx Context, service string) (*Instance, error) + Instances func(ctx Context) (map[string]*Instance, error) + LogRequests func(enabled bool) + LogResponses func(enabled bool) + Root func(ctx Context) ([]string, error) + ServerName func() string + ServiceInspect func(ctx Context, name string) (*ServiceInfo, error) + Services func(ctx Context) (map[string]*ServiceInfo, error) + SnapshotCopy func(ctx Context, service, snapshotID string, request *SnapshotCopyRequest) (*Snapshot, error) + SnapshotInspect func(ctx Context, service, snapshotID string) (*Snapshot, error) + SnapshotRemove func(ctx Context, service, snapshotID string) error + Snapshots func(ctx Context) (ServiceSnapshotMap, error) + SnapshotsByService func(ctx Context, service string) (SnapshotMap, error) + VolumeAttach func(ctx Context, service string, volumeID string, request *VolumeAttachRequest) (*Volume, string, error) + VolumeCopy func(ctx Context, service, volumeID string, request *VolumeCopyRequest) (*Volume, error) + VolumeCreate func(ctx Context, service string, request *VolumeCreateRequest) (*Volume, error) + VolumeCreateFromSnapshot func(ctx Context, service, snapshotID string, request *VolumeCreateRequest) (*Volume, error) + VolumeDetach func(ctx Context, service string, volumeID string, request *VolumeDetachRequest) (*Volume, error) + VolumeDetachAll func(ctx Context, request *VolumeDetachRequest) (ServiceVolumeMap, error) + VolumeDetachAllForService func(ctx Context, service string, request *VolumeDetachRequest) (VolumeMap, error) + VolumeInspect func(ctx Context, service, volumeID string, attachments bool) (*Volume, error) + VolumeRemove func(ctx Context, service, volumeID string) error + VolumeSnapshot func(ctx Context, service string, volumeID string, request *VolumeSnapshotRequest) (*Snapshot, error) + Volumes func(ctx Context, attachments bool) (ServiceVolumeMap, error) + VolumesByService func(ctx Context, service string, attachments bool) (VolumeMap, error) + type APIFunc func(ctx Context, w http.ResponseWriter, r *http.Request, store Store) error + type Client interface + API func() APIClient + Executor func() StorageExecutorCLI + Integration func() IntegrationDriver + OS func() OSDriver + Storage func() StorageDriver + type ClientDriver interface + InstanceInspectAfter func(ctx Context, result *Instance) + InstanceInspectBefore func(ctx *Context) error + SnapshotCopyAfter func(ctx Context, result *Snapshot) + SnapshotCopyBefore func(ctx *Context, service, snapshotID, string, request *SnapshotCopyRequest) error + SnapshotInspectAfter func(ctx Context, result *Volume) + SnapshotInspectBefore func(ctx *Context, service, snapshotID string) error + SnapshotRemoveAfter func(ctx Context, snapshotID string) + SnapshotRemoveBefore func(ctx *Context, service, snapshotID string) error + SnapshotsAfter func(ctx Context, result *ServiceSnapshotMap) + SnapshotsBefore func(ctx *Context) error + SnapshotsByServiceAfter func(ctx Context, service string, result *SnapshotMap) + SnapshotsByServiceBefore func(ctx *Context, service string) error + VolumeAttachAfter func(ctx Context, result *Volume) + VolumeAttachBefore func(ctx *Context, service, volumeID string, request *VolumeAttachRequest) error + VolumeCopyAfter func(ctx Context, result *Volume) + VolumeCopyBefore func(ctx *Context, service, volumeID string, request *VolumeCopyRequest) error + VolumeCreateAfter func(ctx Context, result *Volume) + VolumeCreateBefore func(ctx *Context, service string, request *VolumeCreateRequest) error + VolumeCreateFromSnapshotAfter func(ctx Context, result *Volume) + VolumeCreateFromSnapshotBefore func(ctx *Context, service, snapshotID string, request *VolumeCreateRequest) error + VolumeDetachAfter func(ctx Context, result *Volume) + VolumeDetachBefore func(ctx *Context, service, volumeID string, request *VolumeDetachRequest) error + VolumeInspectAfter func(ctx Context, result *Volume) + VolumeInspectBefore func(ctx *Context, service, volumeID string, attachments bool) error + VolumeRemoveAfter func(ctx Context, service, volumeID string) + VolumeRemoveBefore func(ctx *Context, service, volumeID string) error + VolumeSnapshotAfter func(ctx Context, result *Snapshot) + VolumeSnapshotBefore func(ctx *Context, service, volumeID string, request *VolumeSnapshotRequest) error + VolumesAfter func(ctx Context, result *ServiceVolumeMap) + VolumesBefore func(ctx *Context) error + VolumesByServiceAfter func(ctx Context, service string, result *VolumeMap) + VolumesByServiceBefore func(ctx *Context, service string) error + type ConfigKey string + type Context interface + Join func(ctx context.Context) Context + WithValue func(key, value interface{}) Context + type ContextLoggerFieldAware interface + ContextLoggerField func() (string, interface{}) + type ContextLoggerFieldsAware interface + ContextLoggerFields func() map[string]interface{} + type DeviceFormatOpts struct + NewFSType string + Opts Store + OverwriteFS bool + type DeviceMountOpts struct + MountLabel string + MountOptions string + Opts Store + type DeviceScanType int + const DeviceScanDeep + const DeviceScanQuick + func ParseDeviceScanType(i interface{}) DeviceScanType + func (st DeviceScanType) String() string + type Driver interface + Init func(ctx Context, config gofig.Config) error + Name func() string + type DriverInfo struct + Name string + NextDevice *NextDeviceInfo + Type StorageType + type ErrBadFilter struct + type ErrBatchProcess struct + type ErrContextKey struct + type ErrContextType struct + type ErrDriverTypeErr struct + type ErrMissingInstanceID struct + type ErrNotFound struct + type ErrStoreKey struct + type ExecutorInfo struct + LastModified int64 + MD5Checksum string + Name string + Size int64 + type ExecutorsMap map[string]*ExecutorInfo + type Filter struct + Children []*Filter + Left string + Op FilterOperator + Right string + type FilterOperator int + const FilterAnd + const FilterApproxMatch + const FilterEqualityMatch + const FilterGreaterOrEqual + const FilterLessOrEqual + const FilterNot + const FilterOr + const FilterPresent + const FilterSubstrings + const FilterSubstringsPostfix + const FilterSubstringsPrefix + type Instance struct + Fields map[string]string + InstanceID *InstanceID + Name string + ProviderName string + Region string + type InstanceID struct + Driver string + ID string + func (i *InstanceID) DeleteMetadata() + func (i *InstanceID) MarshalJSON() ([]byte, error) + func (i *InstanceID) MarshalMetadata(data interface{}) error + func (i *InstanceID) MarshalText() ([]byte, error) + func (i *InstanceID) String() string + func (i *InstanceID) UnmarshalJSON(data []byte) error + func (i *InstanceID) UnmarshalMetadata(dest interface{}) error + func (i *InstanceID) UnmarshalText(value []byte) error + type InstanceIDMap map[string]*InstanceID + type IntegrationDriver interface + Attach func(ctx Context, volumeName string, opts *VolumeAttachOpts) (string, error) + Create func(ctx Context, volumeName string, opts *VolumeCreateOpts) (*Volume, error) + Detach func(ctx Context, volumeName string, opts *VolumeDetachOpts) error + Inspect func(ctx Context, volumeName string, opts Store) (VolumeMapping, error) + List func(ctx Context, opts Store) ([]VolumeMapping, error) + Mount func(ctx Context, volumeID, volumeName string, opts *VolumeMountOpts) (string, *Volume, error) + Path func(ctx Context, volumeID, volumeName string, opts Store) (string, error) + Remove func(ctx Context, volumeName string, opts Store) error + Unmount func(ctx Context, volumeID, volumeName string, opts Store) error + type IntegrationDriverManager interface + Driver func() IntegrationDriver + type Level log.Level + const DebugLevel + const ErrorLevel + const FatalLevel + const InfoLevel + const PanicLevel + const TraceLevel + const WarnLevel + type LocalDevices struct + DeviceMap map[string]string + Driver string + func (l *LocalDevices) MarshalJSON() ([]byte, error) + func (l *LocalDevices) MarshalText() ([]byte, error) + func (l *LocalDevices) String() string + func (l *LocalDevices) UnmarshalJSON(data []byte) error + func (l *LocalDevices) UnmarshalText(value []byte) error + type LocalDevicesMap map[string]*LocalDevices + type LocalDevicesOpts struct + Opts Store + ScanType DeviceScanType + type Middleware interface + Handle func(ctx Context, w http.ResponseWriter, r *http.Request, store Store) error + Handler func(handler APIFunc) APIFunc + Name func() string + type MiddlewareFunc func(handler APIFunc) APIFunc + type MountInfo struct + FSType string + Fields map[string]string + ID int + Major int + Minor int + MountPoint string + Optional string + Opts string + Parent int + Root string + Source string + VFSOpts string + type NewClientDriver func() ClientDriver + type NewIntegrationDriver func() IntegrationDriver + type NewOSDriver func() OSDriver + type NewRequestObjFunc func() interface + type NewRouteFunc func(config gofig.Config) Route + type NewStorageDriver func() StorageDriver + type NewStorageExecutor func() StorageExecutor + type NextDeviceInfo struct + Ignore bool + Pattern string + Prefix string + type OSDriver interface + Format func(ctx Context, deviceName string, opts *DeviceFormatOpts) error + IsMounted func(ctx Context, mountPoint string, opts Store) (bool, error) + Mount func(ctx Context, deviceName, mountPoint string, opts *DeviceMountOpts) error + Mounts func(ctx Context, deviceName, mountPoint string, opts Store) ([]*MountInfo, error) + Unmount func(ctx Context, mountPoint string, opts Store) error + type OSDriverManager interface + Driver func() OSDriver + type ProvidesAPIClient interface + API func() APIClient + type ProvidesStorageExecutorCLI interface + XCLI func() StorageExecutorCLI + type Route interface + GetHandler func() APIFunc + GetMethod func() string + GetMiddlewares func() []Middleware + GetName func() string + GetPath func() string + GetQueries func() []string + Middlewares func(middlewares ...Middleware) Route + Queries func(queries ...string) Route + type Router interface + Init func(config gofig.Config) + Name func() string + Routes func() []Route + type Server interface + Addrs func() []string + Name func() string + type Service interface + type ServiceInfo struct + Driver *DriverInfo + Instance *Instance + Name string + type ServiceSnapshotMap map[string]SnapshotMap + type ServiceVolumeMap map[string]VolumeMap + type Services interface + Storage func() StorageService + Tasks func() TaskTrackingService + type ServicesMap map[string]*ServiceInfo + type Snapshot struct + Description string + Fields map[string]string + ID string + Name string + StartTime int64 + Status string + VolumeID string + VolumeSize int64 + type SnapshotCopyRequest struct + DestinationID string + Opts map[string]interface{} + SnapshotName string + type SnapshotMap map[string]*Snapshot + type SnapshotRemoveRequest struct + Opts map[string]interface{} + type StorageDriver interface + InstanceInspect func(ctx Context, opts Store) (*Instance, error) + NextDeviceInfo func(ctx Context) (*NextDeviceInfo, error) + SnapshotCopy func(ctx Context, snapshotID, snapshotName, destinationID string, opts Store) (*Snapshot, error) + SnapshotInspect func(ctx Context, snapshotID string, opts Store) (*Snapshot, error) + SnapshotRemove func(ctx Context, snapshotID string, opts Store) error + Snapshots func(ctx Context, opts Store) ([]*Snapshot, error) + Type func(ctx Context) (StorageType, error) + VolumeAttach func(ctx Context, volumeID string, opts *VolumeAttachOpts) (*Volume, string, error) + VolumeCopy func(ctx Context, volumeID, volumeName string, opts Store) (*Volume, error) + VolumeCreate func(ctx Context, name string, opts *VolumeCreateOpts) (*Volume, error) + VolumeCreateFromSnapshot func(ctx Context, snapshotID, volumeName string, opts *VolumeCreateOpts) (*Volume, error) + VolumeDetach func(ctx Context, volumeID string, opts *VolumeDetachOpts) (*Volume, error) + VolumeInspect func(ctx Context, volumeID string, opts *VolumeInspectOpts) (*Volume, error) + VolumeRemove func(ctx Context, volumeID string, opts Store) error + VolumeSnapshot func(ctx Context, volumeID, snapshotName string, opts Store) (*Snapshot, error) + Volumes func(ctx Context, opts *VolumesOpts) ([]*Volume, error) + type StorageDriverManager interface + Driver func() StorageDriver + type StorageExecutor interface + type StorageExecutorCLI interface + WaitForDevice func(ctx Context, opts *WaitForDeviceOpts) (bool, *LocalDevices, error) + type StorageExecutorFunctions interface + InstanceID func(ctx Context, opts Store) (*InstanceID, error) + LocalDevices func(ctx Context, opts *LocalDevicesOpts) (*LocalDevices, error) + NextDevice func(ctx Context, opts Store) (string, error) + type StorageService interface + Driver func() StorageDriver + TaskExecute func(ctx Context, run StorageTaskRunFunc, schema []byte) *Task + type StorageTaskRunFunc func(ctx Context, service StorageService) (interface{}, error) + type StorageType string + const Block + const NAS + const Object + type Store interface + Delete func(k string) interface{} + Get func(k string) interface{} + GetBool func(k string) bool + GetBoolPtr func(k string) *bool + GetBoolSlice func(k string) []bool + GetInstanceID func(k string) *InstanceID + GetInt func(k string) int + GetInt64 func(k string) int64 + GetInt64Ptr func(k string) *int64 + GetIntPtr func(k string) *int + GetIntSlice func(k string) []int + GetMap func(k string) map[string]interface{} + GetStore func(k string) Store + GetString func(k string) string + GetStringPtr func(k string) *string + GetStringSlice func(k string) []string + IsSet func(k string) bool + Keys func() []string + Map func() map[string]interface{} + Set func(k string, v interface{}) + type Task struct + CompleteTime int64 + Error error + ID int + QueueTime int64 + Result interface{} + StartTime int64 + State TaskState + User string + type TaskExecutionService interface + TaskExecute func(ctx Context, run TaskRunFunc, schema []byte) *Task + type TaskRunFunc func(ctx Context) (interface{}, error) + type TaskState string + type TaskTrackingService interface + TaskExecute func(ctx Context, run TaskRunFunc, schema []byte) *Task + TaskInspect func(taskID int) *Task + TaskTrack func(ctx Context) *Task + TaskWait func(taskID int) <-chan int + TaskWaitAll func(taskIDs ...int) <-chan int + TaskWaitAllC func(taskIDs ...int) <-chan int + TaskWaitC func(taskID int) <-chan int + Tasks func() <-chan *Task + type Transaction struct + Created TxTimestamp + ID *UUID + func NewTransaction() (*Transaction, error) + func (t *Transaction) ContextLoggerFields() map[string]interface{} + func (t *Transaction) MarshalText() ([]byte, error) + func (t *Transaction) String() string + func (t *Transaction) UnmarshalText(text []byte) error + type TxTimestamp time.Time + func (t *TxTimestamp) UnmarshalText(text []byte) error + func (t TxTimestamp) MarshalText() ([]byte, error) + func (t TxTimestamp) String() string + type UUID [16]byte + func MustNewUUID() *UUID + func NewUUID() (*UUID, error) + func ParseUUID(s string) (*UUID, error) + func (u *UUID) MarshalText() ([]byte, error) + func (u *UUID) String() string + func (u *UUID) UnmarshalText(text []byte) error + type Volume struct + Attachments []*VolumeAttachment + AvailabilityZone string + Fields map[string]string + ID string + IOPS int64 + Name string + NetworkName string + Size int64 + Status string + Type string + func (v *Volume) MountPoint() string + func (v *Volume) VolumeName() string + type VolumeAttachOpts struct + Force bool + NextDevice *string + Opts Store + type VolumeAttachRequest struct + Force bool + NextDeviceName *string + Opts map[string]interface{} + type VolumeAttachResponse struct + AttachToken string + Volume *Volume + type VolumeAttachment struct + DeviceName string + Fields map[string]string + InstanceID *InstanceID + MountPoint string + Status string + VolumeID string + type VolumeCopyRequest struct + Opts map[string]interface{} + VolumeName string + type VolumeCreateOpts struct + AvailabilityZone *string + IOPS *int64 + Opts Store + Size *int64 + Type *string + type VolumeCreateRequest struct + AvailabilityZone *string + IOPS *int64 + Name string + Opts map[string]interface{} + Size *int64 + Type *string + type VolumeDetachOpts struct + Force bool + Opts Store + type VolumeDetachRequest struct + Force bool + Opts map[string]interface{} + type VolumeDevice struct + Fields map[string]string + InstanceID *InstanceID + Name string + NetworkName string + ProviderName string + Region string + Status string + VolumeID string + type VolumeInspectOpts struct + Attachments bool + Opts Store + type VolumeMap map[string]*Volume + type VolumeMapping interface + MountPoint func() string + Status func() map[string]interface{} + VolumeName func() string + type VolumeMountOpts struct + NewFSType string + Opts Store + OverwriteFS bool + Preempt bool + type VolumeSnapshotRequest struct + Opts map[string]interface{} + SnapshotName string + type VolumesOpts struct + Attachments bool + Opts Store + type WaitForDeviceOpts struct + Timeout time.Duration + Token string v0.1.0-rc2 May 10, 2016 v0.1.0-rc1 May 9, 2016 v0.1.0-docs May 20, 2016