broker

package

v0.0.0-...-9a529fd Latest Latest Go to latest Published: Jan 26, 2017 License: MIT Imports: 18 Imported by: 1

Details

This section is empty.

This section is empty.

func NewClient(netAddr string) (core.AuthBrokerClient, error)

NewClient instantiates a new core.Broker client

type AppStorage interface {
	// contains filtered or unexported methods
}

AppStorage gives a facade for manipulating the broker applications infos

func NewAppStorage(name string) (AppStorage, error)

NewAppStorage constructs a new broker controller

type Closer interface {
	Close() error
}

Closer is returned by a Dialer to give a hand on closing the dialed connection

type Components struct {
	NetworkController NetworkController
	AppStorage        AppStorage
	Ctx               log.Interface
}

Components defines a structure to make the instantiation easier to read

type Dialer interface {
	MarshalSafely() []byte
	Dial() (core.HandlerClient, Closer, error) // Dial actually attempts to dial a connection
}

Dialer abstracts the connection to grpc, or anything else

func NewDialer(netAddr []byte) Dialer

NewDialer constructs a new dialer from a given net address

type Interface interface {
	core.BrokerServer
	core.BrokerManagerServer
	Start() error
}

Interface defines the Broker interface

func New(c Components, o Options) Interface

New construct a new Broker component

type NetworkController interface {
	// contains filtered or unexported methods
}

NetworkController gives a facade for manipulating the broker databases and devices

func NewNetworkController(name string) (NetworkController, error)

NewNetworkController constructs a new broker controller

type Options struct {
	NetAddrUp   string
	NetAddrDown string
}

Options defines a structure to make the instantiation easier to read