zedagent

func IsMyAddress ¶

func IsMyAddress(clientIP net.IP) bool

IsMyAddress checks the IP address against the local IPs. Returns True if there is a match.

func PublishAppInfoToZedCloud ¶

func PublishAppInfoToZedCloud(ctx *zedagentContext, uuid string,
	aiStatus *types.AppInstanceStatus,
	aa *types.AssignableAdapters, iteration int, dest destinationBitset)

This function is called per change, hence needs to try over all management ports When aiStatus is nil it means a delete and we send a message containing only the UUID to inform zedcloud about the delete.

func PublishAppInstMetaDataToZedCloud ¶

func PublishAppInstMetaDataToZedCloud(ctx *zedagentContext,
	appInstMetadata *types.AppInstMetaData, isDelete bool,
	dest destinationBitset)

PublishAppInstMetaDataToZedCloud is called when an appInst reports its Metadata to EVE. AppInst metadata is relayed to the controller to be processed further.

func PublishBlobInfoToZedCloud ¶

func PublishBlobInfoToZedCloud(ctx *zedagentContext, blobSha string,
	blobStatus *types.BlobStatus, iteration int, dest destinationBitset)

PublishBlobInfoToZedCloud is called per change, hence needs to try over all management ports When blob Status is nil it means a delete and we send a message containing only the UUID to inform zedcloud about the delete.

func PublishContentInfoToZedCloud ¶

func PublishContentInfoToZedCloud(ctx *zedagentContext, uuid string,
	ctStatus *types.ContentTreeStatus, iteration int, dest destinationBitset)

PublishContentInfoToZedCloud is called per change, hence needs to try over all management ports When content tree Status is nil it means a delete and we send a message containing only the UUID to inform zedcloud about the delete.

func PublishDeviceInfoToZedCloud ¶

func PublishDeviceInfoToZedCloud(ctx *zedagentContext, dest destinationBitset)

PublishDeviceInfoToZedCloud This function is called per change, hence needs to try over all management ports

func PublishEdgeviewToZedCloud ¶

func PublishEdgeviewToZedCloud(ctx *zedagentContext,
	evStatus *types.EdgeviewStatus, dest destinationBitset)

PublishEdgeviewToZedCloud - publish Edgeview info to controller

func PublishHardwareInfoToZedCloud ¶

func PublishHardwareInfoToZedCloud(ctx *zedagentContext, dest destinationBitset)

PublishHardwareInfoToZedCloud send ZInfoHardware message

func PublishVolumeToZedCloud ¶

func PublishVolumeToZedCloud(ctx *zedagentContext, uuid string,
	volStatus *types.VolumeStatus, iteration int, dest destinationBitset)

PublishVolumeToZedCloud is called per change, hence needs to try over all management ports When volume status is nil it means a delete and we send a message containing only the UUID to inform zedcloud about the delete.

func Run ¶

func Run(ps *pubsub.PubSub, loggerArg *logrus.Logger, logArg *base.LogObject, arguments []string) int

func SendProtobuf ¶

func SendProtobuf(url string, buf *bytes.Buffer, size int64,
	iteration int) error

This function is called per change, hence needs to try over all management ports For each port we try different source IPs until we find a working one. For the HTTP errors indicating the object is gone we ignore the error so the caller does not defer and retry