calc

Documentation

Index

• type SyncerCallbacksDecoupler
  • func NewSyncerCallbacksDecoupler() *SyncerCallbacksDecoupler
  • func (a *SyncerCallbacksDecoupler) OnStatusUpdated(status api.SyncStatus)
  • func (a *SyncerCallbacksDecoupler) OnUpdates(updates []api.Update)
  • func (a *SyncerCallbacksDecoupler) SendTo(sink api.SyncerCallbacks)
  • func (a *SyncerCallbacksDecoupler) SendToContext(cxt context.Context, sink api.SyncerCallbacks)
• type ValidationFilter
  • func NewValidationFilter(sink api.SyncerCallbacks) *ValidationFilter
  • func (v *ValidationFilter) OnStatusUpdated(status api.SyncStatus)
  • func (v *ValidationFilter) OnUpdates(updates []api.Update)

Types

type SyncerCallbacksDecoupler

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

func NewSyncerCallbacksDecoupler

func NewSyncerCallbacksDecoupler() *SyncerCallbacksDecoupler

func (*SyncerCallbacksDecoupler) OnStatusUpdated

func (a *SyncerCallbacksDecoupler) OnStatusUpdated(status api.SyncStatus)

func (*SyncerCallbacksDecoupler) OnUpdates

func (a *SyncerCallbacksDecoupler) OnUpdates(updates []api.Update)

func (*SyncerCallbacksDecoupler) SendTo

func (a *SyncerCallbacksDecoupler) SendTo(sink api.SyncerCallbacks)

func (*SyncerCallbacksDecoupler) SendToContext

func (a *SyncerCallbacksDecoupler) SendToContext(cxt context.Context, sink api.SyncerCallbacks)

type ValidationFilter

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

func NewValidationFilter

func NewValidationFilter(sink api.SyncerCallbacks) *ValidationFilter

func (*ValidationFilter) OnStatusUpdated

func (v *ValidationFilter) OnStatusUpdated(status api.SyncStatus)

func (*ValidationFilter) OnUpdates

func (v *ValidationFilter) OnUpdates(updates []api.Update)