handler

Documentation

Index

• type FakeHandler
  • func NewFakeNoOpHandler(clusterID string, sleep time.Duration) *FakeHandler
  • func NewFakeNoOpHandlerWithChildEvent(clusterID string, ...) *FakeHandler
  • func NewFakeNoOpHandlerWithStatus(clusterID string, eventStatus *controller.EventProcessStatus) *FakeHandler
  • func (d *FakeHandler) Added(ctx context.Context, _ interface{}, ...) controller.EventStatus
  • func (d *FakeHandler) Deleted(ctx context.Context, _ interface{}, ...) controller.EventStatus
  • func (d *FakeHandler) OnStatus(_ context.Context, _ controller.EventProcessStatus)
  • func (d *FakeHandler) Updated(ctx context.Context, _ interface{}, _ interface{}, ...) controller.EventStatus

Types

type FakeHandler

type FakeHandler struct {
	handler.Handler

	AddCalled      atomic.Int64
	UpdateCalled   atomic.Int64
	DeleteCalled   atomic.Int64
	OnStatusCalled atomic.Int64
	// contains filtered or unexported fields
}

Mock Handler.

func NewFakeNoOpHandler

func NewFakeNoOpHandler(clusterID string, sleep time.Duration) *FakeHandler

func NewFakeNoOpHandlerWithChildEvent

func NewFakeNoOpHandlerWithChildEvent(clusterID string, childOnStatus func(ctx context.Context, status controller.EventProcessStatus)) *FakeHandler

func NewFakeNoOpHandlerWithStatus

func NewFakeNoOpHandlerWithStatus(clusterID string, eventStatus *controller.EventProcessStatus) *FakeHandler

func (*FakeHandler) Added

func (d *FakeHandler) Added(ctx context.Context, _ interface{}, statusChan chan controller.EventProcessStatus) controller.EventStatus

func (*FakeHandler) Deleted

func (d *FakeHandler) Deleted(ctx context.Context, _ interface{}, statusChan chan controller.EventProcessStatus) controller.EventStatus

func (*FakeHandler) OnStatus

func (d *FakeHandler) OnStatus(_ context.Context, _ controller.EventProcessStatus)

func (*FakeHandler) Updated

func (d *FakeHandler) Updated(ctx context.Context, _ interface{}, _ interface{}, statusChan chan controller.EventProcessStatus) controller.EventStatus