common

Documentation

Overview

Package common ...

Index

• Constants
• func DeleteSubscription(publisherURL string, clientID uuid.UUID) error
• func GetCurrentState(clientID uuid.UUID, publisherURL, resourceAddress string) (*cloudevents.Event, *cneevent.Data, error)
• func GetEventData(url string) (*cloudevents.Event, *cneevent.Data, error)
• func GetResources() map[string]string
• func Post(address string, e cloudevents.Event) (int, error)
• func Print(color string, data string)
• func PrintEvent(data *cneevent.Data, eventType string, eTime time.Time)
• func PrintHeader()
• func StartServer(wg *sync.WaitGroup, clientAddress string, stopHTTPServerChan chan bool)
• func Subscribe(clientID uuid.UUID, subs []pubsub.PubSub, ...) error

Constants

const (
	// ColorRed ...
	ColorRed = "\033[31m"
	// ColorGreen ...
	ColorGreen = "\033[32m"
	// ColorYellow ...
	ColorYellow = "\033[33m"
)

const (
	// CURRENTSTATE  resource path name
	CURRENTSTATE = "CurrentState"
)

Functions

func DeleteSubscription

func DeleteSubscription(publisherURL string, clientID uuid.UUID) error

DeleteSubscription ... delete all subscription data

func GetCurrentState

func GetCurrentState(clientID uuid.UUID, publisherURL, resourceAddress string) (*cloudevents.Event, *cneevent.Data, error)

GetCurrentState ... get current ptp event state

func GetEventData

func GetEventData(url string) (*cloudevents.Event, *cneevent.Data, error)

GetEventData ... getter method

func GetResources

func GetResources() map[string]string

GetResources ... get resource types

func Post

func Post(address string, e cloudevents.Event) (int, error)

Post ...

func Print

func Print(color string, data string)

Print ...

func PrintEvent

func PrintEvent(data *cneevent.Data, eventType string, eTime time.Time)

PrintEvent ...

func PrintHeader

func PrintHeader()

PrintHeader ...

func StartServer

func StartServer(wg *sync.WaitGroup, clientAddress string, stopHTTPServerChan chan bool)

StartServer ... start event consumer application

func Subscribe

func Subscribe(clientID uuid.UUID, subs []pubsub.PubSub, nodeName, publisherURL, returnEndPoint string) error

Subscribe create subscription