segment

Documentation

Index

• type Updater
  • func NewSegmentFetcher(splitStorage storage.SplitStorage, segmentStorage storage.SegmentStorage, ...) Updater
• type UpdaterImpl
  • func (s *UpdaterImpl) IsSegmentCached(segmentName string) bool
  • func (s *UpdaterImpl) SegmentNames() []interface{}
  • func (s *UpdaterImpl) SynchronizeSegment(name string, till *int64, requestNoCache bool) error
  • func (s *UpdaterImpl) SynchronizeSegments(requestNoCache bool) error

Types

type Updater

type Updater interface {
	SynchronizeSegment(name string, till *int64, requestNoCache bool) error
	SynchronizeSegments(requestNoCache bool) error
	SegmentNames() []interface{}
	IsSegmentCached(segmentName string) bool
}

Updater interface

func NewSegmentFetcher

func NewSegmentFetcher(
	splitStorage storage.SplitStorage,
	segmentStorage storage.SegmentStorage,
	segmentFetcher service.SegmentFetcher,
	logger logging.LoggerInterface,
	runtimeTelemetry storage.TelemetryRuntimeProducer,
) Updater

NewSegmentFetcher creates new segment synchronizer for processing segment updates

type UpdaterImpl

type UpdaterImpl struct {
	// contains filtered or unexported fields
}

UpdaterImpl struct for segment sync

func (*UpdaterImpl) IsSegmentCached

func (s *UpdaterImpl) IsSegmentCached(segmentName string) bool

IsSegmentCached returns true if a segment exists

func (*UpdaterImpl) SegmentNames

func (s *UpdaterImpl) SegmentNames() []interface{}

SegmentNames returns all segments

func (*UpdaterImpl) SynchronizeSegment

func (s *UpdaterImpl) SynchronizeSegment(name string, till *int64, requestNoCache bool) error

SynchronizeSegment syncs segment

func (*UpdaterImpl) SynchronizeSegments

func (s *UpdaterImpl) SynchronizeSegments(requestNoCache bool) error

SynchronizeSegments syncs segments at once