Documentation
¶
Index ¶
- Constants
- Variables
- func GetEvent(nodeName, apiAddr, resource string) (aEvent exports.StoredEvent, aType string, err error)
- func GetOutboundIP(aURL string) net.IP
- func InitPubSub()
- func IsEventValid(aEvent *event.Event) bool
- func PushInitialEvent(resource string)
- func StartListening(...) (err error)
- func SubscribeAllEvents(supportedResource, apiAddr, localAPIAddr string, timeoutPost time.Duration) (err error)
- func SubscribeAnWaitForAllEvents(kubernetesHost, nodeName, apiAddr string, localHTTPServerPort int, ...) (err error)
- func UnsubscribeAllEvents(nodeName string)
- type ListenerConfig
Constants ¶
View Source
const ( SubscriptionPath = "/api/ocloudNotifications/v1/subscriptions" EventsPath = "/api/ocloudNotifications/v1" LocalEventPath = "/event" LocalHealthPath = "/health" LocalAckEventPath = "/ack/event" HTTP200 = 200 )
Variables ¶
View Source
var ( Ps *chanpubsub.Pubsub CurrentSubscriptionIDPerType = map[string]string{} )
Functions ¶
func GetEvent ¶ added in v0.1.4
func GetEvent(nodeName, apiAddr, resource string) (aEvent exports.StoredEvent, aType string, err error)
func GetOutboundIP ¶
Get preferred outbound ip of this machine
func InitPubSub ¶
func InitPubSub()
func IsEventValid ¶ added in v0.1.4
func PushInitialEvent ¶ added in v0.1.4
func PushInitialEvent(resource string)
sends a fake events to indicate the initial state at the time of registering events via channel-pubsub
func StartListening ¶
func SubscribeAllEvents ¶
func UnsubscribeAllEvents ¶
func UnsubscribeAllEvents(nodeName string)
Types ¶
type ListenerConfig ¶ added in v0.1.4
type ListenerConfig struct {
// contains filtered or unexported fields
}
Click to show internal directories.
Click to hide internal directories.