Versions in this module Expand all Collapse all v0 v0.0.1 Mar 15, 2022 Changes in this version + type RdbInputLifetimer struct + func NewRdbLifetimerForInputData(inputRdbSpec *lifetimesapi.InputRdbSpec, dataClient coreclientset.Interface, ...) *RdbInputLifetimer + func (ril *RdbInputLifetimer) Delete(deletePolicy lifetimesapi.DeletePolicy) error + func (ril *RdbInputLifetimer) FirstUpdate(ctx context.Context, offsetAfter time.Time) (bool, error) + func (ril *RdbInputLifetimer) Start(ctx context.Context) (time.Time, error) + func (ril *RdbInputLifetimer) Stop() error + func (ril *RdbInputLifetimer) Update(ctx context.Context) (bool, error) + type RdbOutputLifetimer struct + func NewRdbLifetimerForOutputData(outputRdbSpec *lifetimesapi.OutputRdbSpec) *RdbOutputLifetimer + func (ril *RdbOutputLifetimer) Delete(deletePolicy lifetimesapi.DeletePolicy) error + func (rol *RdbOutputLifetimer) FirstUpdate(ctx context.Context, offsetAfter time.Time) (bool, error) + func (rol *RdbOutputLifetimer) Start(ctx context.Context) error + func (rol *RdbOutputLifetimer) Stop() error + func (rol *RdbOutputLifetimer) Update(ctx context.Context) (bool, error)
Go to main page