type Event struct {TypestringPort        *PortDiscoveryIDstring}

type PluggableDiscovery struct {// contains filtered or unexported fields}

funcNew¶

func New(idstring, args ...string) *PluggableDiscovery

New create and connect to the given pluggable discovery

func (*PluggableDiscovery)GetID¶

func (disc *PluggableDiscovery) GetID()string

GetID returns the identifier for this discovery

func (*PluggableDiscovery)List¶

func (disc *PluggableDiscovery) List() ([]*Port,error)

List executes an enumeration of the ports and returns a list of the availableports at the moment of the call.

func (*PluggableDiscovery)Quit¶

func (disc *PluggableDiscovery) Quit()

Quit terminates the discovery. No more commands can be accepted by the discovery.

func (*PluggableDiscovery)Run¶

func (disc *PluggableDiscovery) Run() (errerror)

Run starts the discovery executable process and sends the HELLO command to the discovery to agree on thepluggable discovery protocol. This must be the first command to run in the communication with the discovery.If the process is started but the HELLO command fails the process is killed.

func (*PluggableDiscovery)Start¶

func (disc *PluggableDiscovery) Start()error

Start initializes and start the discovery internal subroutines. This command must becalled before List or StartSync.

func (*PluggableDiscovery)StartSync¶

func (disc *PluggableDiscovery) StartSync(sizeint) (<-chan *Event,error)

StartSync puts the discovery in "events" mode: the discovery will send "add"and "remove" events each time a new port is detected or removed respectively.After calling StartSync an initial burst of "add" events may be generated toreport all the ports available at the moment of the start.It also creates a channel used to receive events from the pluggable discovery.The event channel must be consumed as quickly as possible since it may block thediscovery if it becomes full. The channel size is configurable.

func (*PluggableDiscovery)State¶

func (disc *PluggableDiscovery) State()int

State returns the current state of this PluggableDiscovery

func (*PluggableDiscovery)Stop¶

func (disc *PluggableDiscovery) Stop()error

Stop stops the discovery internal subroutines and possibly free the internallyused resources. This command should be called if the client wants to pause thediscovery for a while.

func (*PluggableDiscovery)String¶

func (disc *PluggableDiscovery) String()string

type Port struct {Addressstring          `json:"address"`AddressLabelstring          `json:"label"`Protocolstring          `json:"protocol"`ProtocolLabelstring          `json:"protocolLabel"`HardwareIDstring          `json:"hardwareId,omitempty"`Properties    *properties.Map `json:"properties"`}

funcPortFromRPCPort¶

func PortFromRPCPort(o *rpc.Port) (p *Port)

PortFromRPCPort converts an *rpc.Port to a *Port

func (*Port)Clone¶

func (p *Port) Clone() *Port

Clone creates a copy of this Port

func (*Port)Equals¶

func (p *Port) Equals(o *Port)bool

Equals returns true if the given port has the same address and protocolof the current port.

func (*Port)String¶

func (p *Port) String()string

func (*Port)ToRPC¶

func (p *Port) ToRPC() *rpc.Port

ToRPC converts Port into rpc.Port