broker

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

type Closer interface {
	Close() error
}

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

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

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

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

type Options struct {
	NetAddrUp   string
	NetAddrDown string
}