Documentation ¶
Index ¶
- Constants
- Variables
- type Broker
- func (b *Broker) Bind(context context.Context, instanceID string, bindingID string, ...) (_ brokerapi.Binding, e error)
- func (b *Broker) Deprovision(context context.Context, instanceID string, ...) (_ brokerapi.DeprovisionServiceSpec, e error)
- func (b *Broker) DeprovisionEvent(opState *OperationState)
- func (b *Broker) LastOperation(_ context.Context, instanceID string, operationData string) (brokerapi.LastOperation, error)
- func (b *Broker) Provision(context context.Context, instanceID string, details brokerapi.ProvisionDetails, ...) (_ brokerapi.ProvisionedServiceSpec, e error)
- func (b *Broker) ProvisionEvent(opState *OperationState)
- func (b *Broker) Services(_ context.Context) []brokerapi.Service
- func (b *Broker) Unbind(context context.Context, instanceID string, bindingID string, ...) (e error)
- func (b *Broker) Update(context context.Context, instanceID string, details brokerapi.UpdateDetails, ...) (brokerapi.UpdateServiceSpec, error)
- type Clock
- type DeprovisionOperation
- type DeprovisionOperationSpec
- type EFSInstance
- type EFSService
- type Operation
- type OperationState
- type OperationStateErr
- type ProvisionOperationStateMachine
- func (o *ProvisionOperationStateMachine) CheckFs() error
- func (o *ProvisionOperationStateMachine) CheckMountTargets() error
- func (o *ProvisionOperationStateMachine) CreateFs() error
- func (o *ProvisionOperationStateMachine) CreateMountTargets() error
- func (o *ProvisionOperationStateMachine) Execute()
- func (o *ProvisionOperationStateMachine) OpenPerms() error
- type Subnet
Constants ¶
View Source
const ( PermissionVolumeMount = brokerapi.RequiredPermission("volume_mount") DefaultContainerPath = "/var/vcap/data" RootPath = ":/" )
View Source
const (
PollingInterval = time.Second
)
Variables ¶
View Source
var ( ErrNoMountTargets = errors.New("no mount targets found") )
Functions ¶
This section is empty.
Types ¶
type Broker ¶
type Broker struct { ProvisionOperation func(logger lager.Logger, instanceID string, details brokerapi.ProvisionDetails, efsService EFSService, efsTools efsvoltools.VolTools, subnets []Subnet, clock Clock, updateCb func(*OperationState)) Operation DeprovisionOperation func(logger lager.Logger, efsService EFSService, clock Clock, spec DeprovisionOperationSpec, updateCb func(*OperationState)) Operation // contains filtered or unexported fields }
func New ¶
func New( logger lager.Logger, serviceName, serviceId, dataDir string, os osshim.Os, clock clock.Clock, store brokerstore.Store, efsService EFSService, subnets []Subnet, efsTools efsvoltools.VolTools, provisionOperation func(logger lager.Logger, instanceID string, details brokerapi.ProvisionDetails, efsService EFSService, efsTools efsvoltools.VolTools, subnets []Subnet, clock Clock, updateCb func(*OperationState)) Operation, deprovisionOperation func(logger lager.Logger, efsService EFSService, clock Clock, spec DeprovisionOperationSpec, updateCb func(*OperationState)) Operation, ) *Broker
func (*Broker) Deprovision ¶
func (b *Broker) Deprovision(context context.Context, instanceID string, details brokerapi.DeprovisionDetails, asyncAllowed bool) (_ brokerapi.DeprovisionServiceSpec, e error)
func (*Broker) DeprovisionEvent ¶
func (b *Broker) DeprovisionEvent(opState *OperationState)
func (*Broker) LastOperation ¶
func (*Broker) Provision ¶
func (b *Broker) Provision(context context.Context, instanceID string, details brokerapi.ProvisionDetails, asyncAllowed bool) (_ brokerapi.ProvisionedServiceSpec, e error)
type DeprovisionOperation ¶
type DeprovisionOperation struct {
// contains filtered or unexported fields
}
func NewTestDeprovisionOperation ¶
func NewTestDeprovisionOperation(logger lager.Logger, efsService EFSService, clock Clock, spec DeprovisionOperationSpec, updateCb func(*OperationState)) *DeprovisionOperation
func (*DeprovisionOperation) CheckFs ¶
func (o *DeprovisionOperation) CheckFs(fsID string) error
func (*DeprovisionOperation) CheckMountTarget ¶
func (o *DeprovisionOperation) CheckMountTarget(fsID string) error
func (*DeprovisionOperation) DeleteFs ¶
func (o *DeprovisionOperation) DeleteFs(fsID string) error
func (*DeprovisionOperation) DeleteMountTarget ¶
func (o *DeprovisionOperation) DeleteMountTarget(fsID string) error
func (*DeprovisionOperation) Execute ¶
func (o *DeprovisionOperation) Execute()
type EFSInstance ¶
type EFSInstance struct { brokerapi.ProvisionDetails EfsId string `json:"EfsId"` FsState string `json:"FsState"` MountId string `json:"MountId"` MountState string `json:"MountState"` MountPermsSet bool `json:"MountPermsSet"` MountIp string `json:"MountIp"` MountIds []string `json:"MountIds"` MountStates []string `json:"MountStates"` MountIps []string `json:"MountIps"` MountAZs []string `json:"MountAZs"` Err *OperationStateErr `json:"Err"` }
type EFSService ¶
type EFSService interface { CreateFileSystem(*efs.CreateFileSystemInput) (*efs.FileSystemDescription, error) CreateTags(*efs.CreateTagsInput) (*efs.CreateTagsOutput, error) DeleteFileSystem(*efs.DeleteFileSystemInput) (*efs.DeleteFileSystemOutput, error) DescribeFileSystems(*efs.DescribeFileSystemsInput) (*efs.DescribeFileSystemsOutput, error) CreateMountTarget(*efs.CreateMountTargetInput) (*efs.MountTargetDescription, error) DeleteMountTarget(*efs.DeleteMountTargetInput) (*efs.DeleteMountTargetOutput, error) DescribeMountTargets(*efs.DescribeMountTargetsInput) (*efs.DescribeMountTargetsOutput, error) }
type Operation ¶
type Operation interface {
Execute()
}
func NewDeprovisionOperation ¶
func NewDeprovisionOperation(logger lager.Logger, efsService EFSService, clock Clock, spec DeprovisionOperationSpec, updateCb func(*OperationState)) Operation
func NewProvisionOperation ¶
func NewProvisionOperation(logger lager.Logger, instanceID string, details brokerapi.ProvisionDetails, efsService EFSService, efsTools efsvoltools.VolTools, subnets []Subnet, clock Clock, updateCb func(*OperationState)) Operation
type OperationState ¶
type OperationStateErr ¶
type OperationStateErr struct {
Message string `json:"message"`
}
func NewOperationStateErr ¶
func NewOperationStateErr(format string, args ...interface{}) *OperationStateErr
func WrapOperationStateErr ¶
func WrapOperationStateErr(err error) *OperationStateErr
func (*OperationStateErr) Error ¶
func (e *OperationStateErr) Error() string
type ProvisionOperationStateMachine ¶
type ProvisionOperationStateMachine struct {
// contains filtered or unexported fields
}
func NewProvisionStateMachine ¶
func NewProvisionStateMachine(logger lager.Logger, instanceID string, details brokerapi.ProvisionDetails, efsService EFSService, efsTools efsvoltools.VolTools, subnets []Subnet, clock Clock, updateCb func(*OperationState)) *ProvisionOperationStateMachine
func (*ProvisionOperationStateMachine) CheckFs ¶
func (o *ProvisionOperationStateMachine) CheckFs() error
func (*ProvisionOperationStateMachine) CheckMountTargets ¶
func (o *ProvisionOperationStateMachine) CheckMountTargets() error
func (*ProvisionOperationStateMachine) CreateFs ¶
func (o *ProvisionOperationStateMachine) CreateFs() error
func (*ProvisionOperationStateMachine) CreateMountTargets ¶
func (o *ProvisionOperationStateMachine) CreateMountTargets() error
func (*ProvisionOperationStateMachine) Execute ¶
func (o *ProvisionOperationStateMachine) Execute()
func (*ProvisionOperationStateMachine) OpenPerms ¶
func (o *ProvisionOperationStateMachine) OpenPerms() error
Click to show internal directories.
Click to hide internal directories.