utils

Documentation

Index

• type DataFeed
  • func NewDataFeed(c client.Interface) *DataFeed
  • func (d *DataFeed) OnStatusUpdated(status bapi.SyncStatus)
  • func (c *DataFeed) OnUpdates(updates []bapi.Update)
  • func (d *DataFeed) RegisterForNotification(key model.Key, h UpdateHandler)
  • func (d *DataFeed) RegisterForSyncStatus(h StatusHandler)
  • func (d *DataFeed) Start()
• type StatusHandler
• type UpdateHandler

Types

type DataFeed

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

func NewDataFeed

func NewDataFeed(c client.Interface) *DataFeed

func (*DataFeed) OnStatusUpdated

func (d *DataFeed) OnStatusUpdated(status bapi.SyncStatus)

func (*DataFeed) OnUpdates

func (c *DataFeed) OnUpdates(updates []bapi.Update)

func (*DataFeed) RegisterForNotification

func (d *DataFeed) RegisterForNotification(key model.Key, h UpdateHandler)

RegisterForNotification registers a channel to receive an update when the given kind receives an update. kind should be a pointer to the struct type received over the syncer.

func (*DataFeed) RegisterForSyncStatus

func (d *DataFeed) RegisterForSyncStatus(h StatusHandler)

func (*DataFeed) Start

func (d *DataFeed) Start()

type StatusHandler

type StatusHandler func(bapi.SyncStatus)

type UpdateHandler

type UpdateHandler func(bapi.Update)