pusher

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

type Pusher interface {
	component.Component
	// AddCallback add callback for target resource type using id
	// for example, id is a unique id for every client, when resource changed for target resourceType, it will invoke callback
	AddCallback(resourceType core_model.ResourceType, id string, callback ResourceChangedCallbackFn, filters ...ResourceChangedEventFilter)
	// RemoveCallback remove callback
	RemoveCallback(resourceType core_model.ResourceType, id string)
	// InvokeCallback invoke a target callback
	// for example, for a push request from client, invoke this function to push resource.
	InvokeCallback(resourceType core_model.ResourceType, id string, request interface{}, requestFilter ResourceRequestFilter)
}

type ResourceChangedCallback struct {
	Callback ResourceChangedCallbackFn
	Filters  []ResourceChangedEventFilter
	// contains filtered or unexported fields
}

type ResourceChangedCallbackFn func(items PushedItems)

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

type ResourceChangedEventFilter func(resourceList core_model.ResourceList) core_model.ResourceList

type ResourceRequestFilter func(request interface{}, resourceList core_model.ResourceList) core_model.ResourceList