rdb

Documentation

Index

• type RdbInputLifetimer
  • 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
  • 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)

Types

type RdbInputLifetimer

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

func NewRdbLifetimerForInputData

func NewRdbLifetimerForInputData(
	inputRdbSpec *lifetimesapi.InputRdbSpec,
	dataClient coreclientset.Interface, kubeClient kubernetes.Interface,
	messageQueueSpec *lifetimesapi.MessageQueueSpec) *RdbInputLifetimer

func (*RdbInputLifetimer) Delete

func (ril *RdbInputLifetimer) Delete(
	deletePolicy lifetimesapi.DeletePolicy) error

[TODO]

func (*RdbInputLifetimer) FirstUpdate

func (ril *RdbInputLifetimer) FirstUpdate(
	ctx context.Context, offsetAfter time.Time) (bool, error)

[TODO]

func (*RdbInputLifetimer) Start

func (ril *RdbInputLifetimer) Start(ctx context.Context) (time.Time, error)

[TODO]

func (*RdbInputLifetimer) Stop

func (ril *RdbInputLifetimer) Stop() error

[TODO]

func (*RdbInputLifetimer) Update

func (ril *RdbInputLifetimer) Update(ctx context.Context) (bool, error)

[TODO]

type RdbOutputLifetimer

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

func NewRdbLifetimerForOutputData

func NewRdbLifetimerForOutputData(
	outputRdbSpec *lifetimesapi.OutputRdbSpec) *RdbOutputLifetimer

func (*RdbOutputLifetimer) Delete

func (ril *RdbOutputLifetimer) Delete(
	deletePolicy lifetimesapi.DeletePolicy) error

[TODO]

func (*RdbOutputLifetimer) FirstUpdate

func (rol *RdbOutputLifetimer) FirstUpdate(
	ctx context.Context, offsetAfter time.Time) (bool, error)

[TODO]

func (*RdbOutputLifetimer) Start

func (rol *RdbOutputLifetimer) Start(ctx context.Context) error

[TODO]

func (*RdbOutputLifetimer) Stop

func (rol *RdbOutputLifetimer) Stop() error

[TODO]

func (*RdbOutputLifetimer) Update

func (rol *RdbOutputLifetimer) Update(ctx context.Context) (bool, error)

[TODO]