Versions in this module Expand all Collapse all v0 v0.11.3 Jun 5, 2020 v0.11.2 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)