retentionMgr

Documentation

Index

• type Options
• type RetentionManager
  • func New(opts *Options, metadata metadata.TChanMetadataService, ...) *RetentionManager
  • func (t *RetentionManager) Run()
  • func (t *RetentionManager) Start()
  • func (t *RetentionManager) Stop()

Types

type Options

type Options struct {
	RetentionInterval                time.Duration
	DLQRetentionInterval             time.Duration
	SingleCGVisibleExtentGracePeriod time.Duration
	ExtentDeleteDeferPeriod          time.Duration
	NumWorkers                       int
	LocalZone                        string
}

Options are the options used to initialize RetentionManager

type RetentionManager

type RetentionManager struct {
	*Options

	sync.Mutex
	// contains filtered or unexported fields
}

RetentionManager context

func New

func New(opts *Options, metadata metadata.TChanMetadataService, clientFactory common.ClientFactory, m3Client metrics.Client, logger bark.Logger) *RetentionManager

New initializes context for a new instance of retention manager

func (*RetentionManager) Run

func (t *RetentionManager) Run()

Run does a 'one-shot' run of retention manager

func (*RetentionManager) Start

func (t *RetentionManager) Start()

Start starts the various go-routines asynchronously

func (*RetentionManager) Stop

func (t *RetentionManager) Stop()

Stop stops the retention manager