util

Documentation

Overview

Licensed under the Apache License, Version 2.0 (the "License"); you may not use p file except in compliance with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Index

• func InitializeBroadcast(servingOptions *broadcast.ServingOptions, rootPath string)
• func NewBroadcast(options *broadcast.ServingOptions) broadcast.Broadcast
• func Notify(objectPath string, action string, obj models.Model)
• func RegisterObserver(obs broadcast.Observer, path string)

Functions

func InitializeBroadcast

func InitializeBroadcast(servingOptions *broadcast.ServingOptions, rootPath string)

InitializeBroadcast initialize the global broadcast with a service based path

func NewBroadcast

func NewBroadcast(options *broadcast.ServingOptions) broadcast.Broadcast

NewSynchronizer will create broadcastizer according to environment's setting

func Notify

func Notify(objectPath string, action string, obj models.Model)

Notify fire the global broadcast

func RegisterObserver

func RegisterObserver(obs broadcast.Observer, path string)

RegisterObserver register an observer on the global broadcast