util

package

v4.2.4-rc2 Latest Latest Go to latest Published: Jul 12, 2023 License: AGPL-3.0 Imports: 13 Imported by: 0

Details

This section is empty.

This section is empty.

func CreateAddress(addr string, meta map[string]string) registry.Generic

func CreateEndpoint(name string, meta map[string]string) registry.Generic

func CreateNode() registry.Node

func DetectType(i registry.Item) pb.ItemType

func NewChanStatusWatcher(item registry.Item, input chan map[string]interface{}) registry.StatusWatcher

func NewIntervalStatsWatcher(item registry.Item, interval time.Duration, callback func() map[string]interface{}) registry.StatusWatcher

func NewIntervalStatusWatcher(item registry.Item, interval time.Duration, callback func() (registry.Item, bool)) registry.StatusWatcher

func ToDao(i *pb.Item, d *pb.Dao) registry.Dao

func ToEdge(i *pb.Item, e *pb.Edge) registry.Edge

func ToGeneric(i *pb.Item, e *pb.Generic) registry.Generic

func ToItem(s *pb.Item) registry.Item

ToItem wraps a protobuf item in a registry.Item interface

func ToNode(i *pb.Item, d *pb.Node) registry.Node

func ToOptions(s *pb.Options) (oo []registry.Option)

ToOptions parses a protobuf pb.Options to a slice of registry.Option

func ToProtoDao(d registry.Dao) *pb.Dao

func ToProtoEdge(e registry.Edge) *pb.Edge

func ToProtoGeneric(e registry.Generic) *pb.Generic

func ToProtoItem(i registry.Item) *pb.Item

ToProtoItem transforms a registry.Item to its protobuf counterpart

func ToProtoItems(ii []registry.Item) []*pb.Item

ToProtoItems transforms a list of interfaces to protobuf for serialization

func ToProtoNode(d registry.Node) *pb.Node

func ToProtoServer(s registry.Server) *pb.Server

func ToProtoService(s registry.Service) *pb.Service

func ToServer(i *pb.Item, s *pb.Server) registry.Server

func ToService(i *pb.Item, s *pb.Service) registry.Service

This section is empty.