calc

Documentation

Index

• type NodeCounter
  • func NewNodeCounter(sink api.SyncerCallbacks) *NodeCounter
  • func (c *NodeCounter) GetNumNodes() (int, error)
  • func (c *NodeCounter) OnStatusUpdated(status api.SyncStatus)
  • func (c *NodeCounter) OnUpdates(updates []api.Update)
• 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 NodeCounter

type NodeCounter struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewNodeCounter

func NewNodeCounter(sink api.SyncerCallbacks) *NodeCounter

func (*NodeCounter) GetNumNodes

func (c *NodeCounter) GetNumNodes() (int, error)

func (*NodeCounter) OnStatusUpdated

func (c *NodeCounter) OnStatusUpdated(status api.SyncStatus)

func (*NodeCounter) OnUpdates

func (c *NodeCounter) OnUpdates(updates []api.Update)

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)