Documentation
¶
Index ¶
- Constants
- type Updater
- type UpdaterImpl
- func (s *UpdaterImpl) IsCached(name string) bool
- func (u *UpdaterImpl) SynchronizeLargeSegment(name string, till *int64) (*int64, error)
- func (u *UpdaterImpl) SynchronizeLargeSegmentUpdate(lsRFDResponseDTO *dtos.LargeSegmentRFDResponseDTO) (*int64, error)
- func (u *UpdaterImpl) SynchronizeLargeSegments() (map[string]*int64, error)
Constants ¶
View Source
const ( // LargeSegmentDefinitionUpdate received when a large segment definition is updated LargeSegmentNewDefinition = "LS_NEW_DEFINITION" // LargeSegmentEmpty received when a large segment has no definition LargeSegmentEmpty = "LS_EMPTY" )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Updater ¶
type Updater interface {
SynchronizeLargeSegment(name string, till *int64) (*int64, error)
SynchronizeLargeSegmentUpdate(lsRFDResponseDTO *dtos.LargeSegmentRFDResponseDTO) (*int64, error)
SynchronizeLargeSegments() (map[string]*int64, error)
IsCached(name string) bool
}
Updater interface
type UpdaterImpl ¶
type UpdaterImpl struct {
// contains filtered or unexported fields
}
UpdaterImpl struct for segment sync
func NewLargeSegmentUpdater ¶
func NewLargeSegmentUpdater( splitStorage storage.SplitStorageConsumer, largeSegmentStorage storage.LargeSegmentsStorage, largeSegmentFetcher service.LargeSegmentFetcher, logger logging.LoggerInterface, runtimeTelemetry storage.TelemetryRuntimeProducer, hcMonitor hc.MonitorProducerInterface, ) *UpdaterImpl
NewLargeSegmentUpdater creates new large segment synchronizer for processing larrge segment updates
func (*UpdaterImpl) IsCached ¶
func (s *UpdaterImpl) IsCached(name string) bool
func (*UpdaterImpl) SynchronizeLargeSegment ¶
func (u *UpdaterImpl) SynchronizeLargeSegment(name string, till *int64) (*int64, error)
func (*UpdaterImpl) SynchronizeLargeSegmentUpdate ¶
func (u *UpdaterImpl) SynchronizeLargeSegmentUpdate(lsRFDResponseDTO *dtos.LargeSegmentRFDResponseDTO) (*int64, error)
func (*UpdaterImpl) SynchronizeLargeSegments ¶
func (u *UpdaterImpl) SynchronizeLargeSegments() (map[string]*int64, error)
Source Files
Click to show internal directories.
Click to hide internal directories.