volumewatcher

May 14, 2020

Changes in this version

+ const CrossVolumeUpdateBatchDuration

+ const LimitStateQueriesPerSecond

+ type BatchFuture struct

+ func NewBatchFuture() *BatchFuture

+ func (f *BatchFuture) Results() (uint64, error)

+ func (f *BatchFuture) Set(index uint64, err error)

+ type ClientRPC interface

+ ControllerDetachVolume func(args *cstructs.ClientCSIControllerDetachVolumeRequest, ...) error

+ NodeDetachVolume func(args *cstructs.ClientCSINodeDetachVolumeRequest, ...) error

+ type VolumeRaftEndpoints interface

+ UpsertVolumeClaims func(*structs.CSIVolumeClaimBatchRequest) (uint64, error)

+ type VolumeUpdateBatcher struct

+ func NewVolumeUpdateBatcher(batchDuration time.Duration, raft VolumeRaftEndpoints, ctx context.Context) *VolumeUpdateBatcher

+ func (b *VolumeUpdateBatcher) CreateUpdate(claims []structs.CSIVolumeClaimRequest) *BatchFuture

+ type Watcher struct

+ func NewVolumesWatcher(logger log.Logger, raft VolumeRaftEndpoints, rpc ClientRPC, ...) *Watcher

+ func (w *Watcher) SetEnabled(enabled bool, state *state.StateStore)