Documentation
¶
Overview ¶
Code generated by MockGen. DO NOT EDIT. Source: bucket_processor.go
Generated by this command:
mockgen -source=bucket_processor.go -destination=mock_bucket_processor.go -package=app -write_package_comment=false
Code generated by MockGen. DO NOT EDIT. Source: bucket_selector.go
Generated by this command:
mockgen -source=bucket_selector.go -destination=mock_bucket_selector.go -package=app -write_package_comment=false
Code generated by MockGen. DO NOT EDIT. Source: clearing_state.go
Generated by this command:
mockgen -source=clearing_state.go -destination=mock_clearing_state.go -package=app -write_package_comment=false
Code generated by MockGen. DO NOT EDIT. Source: display_manager.go
Generated by this command:
mockgen -source=display_manager.go -destination=mock_display_manager.go -package=app -write_package_comment=false
Index ¶
- Constants
- type App
- type BucketProcessor
- type BucketProcessorConfig
- type BucketSelector
- type ClearingState
- type DisplayManager
- type IBucketProcessor
- type IBucketSelector
- type IClearingState
- type IDisplayManager
- type MockIBucketProcessor
- type MockIBucketProcessorMockRecorder
- type MockIBucketSelector
- type MockIBucketSelectorMockRecorder
- type MockIClearingState
- func (m *MockIClearingState) EXPECT() *MockIClearingStateMockRecorder
- func (m *MockIClearingState) GetChannelsForBucket(bucket string) (chan int64, chan bool)
- func (m *MockIClearingState) OutputFinalMessages(targetBuckets []string) error
- func (m *MockIClearingState) StartDisplayRoutines(targetBuckets []string, writer *io.Writer) *errgroup.Group
- type MockIClearingStateMockRecorder
- type MockIDisplayManager
- type MockIDisplayManagerMockRecorder
Constants ¶
const (
UnspecifiedConcurrencyNumber = 0
)
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type App ¶
type BucketProcessor ¶ added in v0.25.0
type BucketProcessor struct {
// contains filtered or unexported fields
}
BucketProcessor handles all bucket processing operations
func NewBucketProcessor ¶ added in v0.25.0
func NewBucketProcessor( config BucketProcessorConfig, s3Wrapper wrapper.IWrapper, ) *BucketProcessor
NewBucketProcessor creates a new BucketProcessor instance
type BucketProcessorConfig ¶ added in v0.25.0
type BucketProcessorConfig struct { TargetBuckets []string QuietMode bool ConcurrentMode bool ConcurrencyNumber int ForceMode bool OldVersionsOnly bool }
BucketProcessorConfig contains all configuration parameters for bucket processing operations
type BucketSelector ¶ added in v0.25.0
type BucketSelector struct {
// contains filtered or unexported fields
}
BucketSelector handles the selection of buckets through either interactive mode or command line arguments
func NewBucketSelector ¶ added in v0.25.0
func NewBucketSelector(interactiveMode bool, bucketNames *cli.StringSlice, s3Wrapper wrapper.IWrapper) *BucketSelector
NewBucketSelector creates a new BucketSelector instance
func (*BucketSelector) SelectBuckets ¶ added in v0.25.0
SelectBuckets selects buckets based on the mode (interactive or command line) Returns the selected buckets, a continuation flag, and any error that occurred
type ClearingState ¶ added in v0.25.0
type ClearingState struct {
// contains filtered or unexported fields
}
ClearingState manages the state of bucket clearing operations
func NewClearingState ¶ added in v0.25.0
func NewClearingState(targetBuckets []string, s3Wrapper wrapper.IWrapper, forceMode bool) *ClearingState
NewClearingState initializes a new ClearingState instance
func (*ClearingState) GetChannelsForBucket ¶ added in v0.25.0
func (s *ClearingState) GetChannelsForBucket(bucket string) (chan int64, chan bool)
GetChannelsForBucket returns the channels associated with a specific bucket
func (*ClearingState) OutputFinalMessages ¶ added in v0.25.0
func (s *ClearingState) OutputFinalMessages(targetBuckets []string) error
OutputFinalMessages displays the final status messages for all buckets
func (*ClearingState) StartDisplayRoutines ¶ added in v0.25.0
func (s *ClearingState) StartDisplayRoutines(targetBuckets []string, writer *io.Writer) *errgroup.Group
StartDisplayRoutines initializes and starts the display monitoring routines
type DisplayManager ¶ added in v0.25.0
type DisplayManager struct {
// contains filtered or unexported fields
}
DisplayManager handles the lifecycle of display operations
func NewDisplayManager ¶ added in v0.25.0
func NewDisplayManager(state IClearingState, quietMode bool) *DisplayManager
NewDisplayManager creates a new DisplayManager instance
func (*DisplayManager) Finish ¶ added in v0.25.0
func (d *DisplayManager) Finish(targetBuckets []string) error
Finish waits for display operations to complete and performs cleanup
func (*DisplayManager) Start ¶ added in v0.25.0
func (d *DisplayManager) Start(targetBuckets []string)
Start initializes and starts the display operations
type IBucketProcessor ¶ added in v0.25.0
type IBucketSelector ¶ added in v0.25.0
type IClearingState ¶ added in v0.25.0
type IDisplayManager ¶ added in v0.25.0
type MockIBucketProcessor ¶ added in v0.25.0
type MockIBucketProcessor struct {
// contains filtered or unexported fields
}
MockIBucketProcessor is a mock of IBucketProcessor interface.
func NewMockIBucketProcessor ¶ added in v0.25.0
func NewMockIBucketProcessor(ctrl *gomock.Controller) *MockIBucketProcessor
NewMockIBucketProcessor creates a new mock instance.
func (*MockIBucketProcessor) EXPECT ¶ added in v0.25.0
func (m *MockIBucketProcessor) EXPECT() *MockIBucketProcessorMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
type MockIBucketProcessorMockRecorder ¶ added in v0.25.0
type MockIBucketProcessorMockRecorder struct {
// contains filtered or unexported fields
}
MockIBucketProcessorMockRecorder is the mock recorder for MockIBucketProcessor.
type MockIBucketSelector ¶ added in v0.25.0
type MockIBucketSelector struct {
// contains filtered or unexported fields
}
MockIBucketSelector is a mock of IBucketSelector interface.
func NewMockIBucketSelector ¶ added in v0.25.0
func NewMockIBucketSelector(ctrl *gomock.Controller) *MockIBucketSelector
NewMockIBucketSelector creates a new mock instance.
func (*MockIBucketSelector) EXPECT ¶ added in v0.25.0
func (m *MockIBucketSelector) EXPECT() *MockIBucketSelectorMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockIBucketSelector) SelectBuckets ¶ added in v0.25.0
SelectBuckets mocks base method.
type MockIBucketSelectorMockRecorder ¶ added in v0.25.0
type MockIBucketSelectorMockRecorder struct {
// contains filtered or unexported fields
}
MockIBucketSelectorMockRecorder is the mock recorder for MockIBucketSelector.
func (*MockIBucketSelectorMockRecorder) SelectBuckets ¶ added in v0.25.0
func (mr *MockIBucketSelectorMockRecorder) SelectBuckets(ctx any) *gomock.Call
SelectBuckets indicates an expected call of SelectBuckets.
type MockIClearingState ¶ added in v0.25.0
type MockIClearingState struct {
// contains filtered or unexported fields
}
MockIClearingState is a mock of IClearingState interface.
func NewMockIClearingState ¶ added in v0.25.0
func NewMockIClearingState(ctrl *gomock.Controller) *MockIClearingState
NewMockIClearingState creates a new mock instance.
func (*MockIClearingState) EXPECT ¶ added in v0.25.0
func (m *MockIClearingState) EXPECT() *MockIClearingStateMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockIClearingState) GetChannelsForBucket ¶ added in v0.25.0
func (m *MockIClearingState) GetChannelsForBucket(bucket string) (chan int64, chan bool)
GetChannelsForBucket mocks base method.
func (*MockIClearingState) OutputFinalMessages ¶ added in v0.25.0
func (m *MockIClearingState) OutputFinalMessages(targetBuckets []string) error
OutputFinalMessages mocks base method.
func (*MockIClearingState) StartDisplayRoutines ¶ added in v0.25.0
func (m *MockIClearingState) StartDisplayRoutines(targetBuckets []string, writer *io.Writer) *errgroup.Group
StartDisplayRoutines mocks base method.
type MockIClearingStateMockRecorder ¶ added in v0.25.0
type MockIClearingStateMockRecorder struct {
// contains filtered or unexported fields
}
MockIClearingStateMockRecorder is the mock recorder for MockIClearingState.
func (*MockIClearingStateMockRecorder) GetChannelsForBucket ¶ added in v0.25.0
func (mr *MockIClearingStateMockRecorder) GetChannelsForBucket(bucket any) *gomock.Call
GetChannelsForBucket indicates an expected call of GetChannelsForBucket.
func (*MockIClearingStateMockRecorder) OutputFinalMessages ¶ added in v0.25.0
func (mr *MockIClearingStateMockRecorder) OutputFinalMessages(targetBuckets any) *gomock.Call
OutputFinalMessages indicates an expected call of OutputFinalMessages.
func (*MockIClearingStateMockRecorder) StartDisplayRoutines ¶ added in v0.25.0
func (mr *MockIClearingStateMockRecorder) StartDisplayRoutines(targetBuckets, writer any) *gomock.Call
StartDisplayRoutines indicates an expected call of StartDisplayRoutines.
type MockIDisplayManager ¶ added in v0.25.0
type MockIDisplayManager struct {
// contains filtered or unexported fields
}
MockIDisplayManager is a mock of IDisplayManager interface.
func NewMockIDisplayManager ¶ added in v0.25.0
func NewMockIDisplayManager(ctrl *gomock.Controller) *MockIDisplayManager
NewMockIDisplayManager creates a new mock instance.
func (*MockIDisplayManager) EXPECT ¶ added in v0.25.0
func (m *MockIDisplayManager) EXPECT() *MockIDisplayManagerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockIDisplayManager) Finish ¶ added in v0.25.0
func (m *MockIDisplayManager) Finish(targetBuckets []string) error
Finish mocks base method.
func (*MockIDisplayManager) Start ¶ added in v0.25.0
func (m *MockIDisplayManager) Start(targetBuckets []string)
Start mocks base method.
type MockIDisplayManagerMockRecorder ¶ added in v0.25.0
type MockIDisplayManagerMockRecorder struct {
// contains filtered or unexported fields
}
MockIDisplayManagerMockRecorder is the mock recorder for MockIDisplayManager.