Documentation
¶
Index ¶
- func ConnectTo(host string, destPort uint32, datalistener common.DatatListener, ...) (common.Port, error)
- type PortImpl
- func (port *PortImpl) Addr() string
- func (port *PortImpl) CreatedAt() int64
- func (port *PortImpl) Do(action model.Action, dest string, pb proto.Message) error
- func (port *PortImpl) Name() string
- func (port *PortImpl) Send(data []byte) error
- func (port *PortImpl) Shutdown()
- func (port *PortImpl) Start()
- func (port *PortImpl) Uuid() string
- func (port *PortImpl) ZSide() string
- type ReconnectInfo
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type PortImpl ¶
type PortImpl struct {
// contains filtered or unexported fields
}
func NewPortImpl ¶
func NewPortImpl(incomingConnection bool, con net.Conn, uid string, dataListener common.DatatListener, registry common.IRegistry, servicePoints common.IServicePoints) *PortImpl
Instantiate a new port with a connection
func (*PortImpl) Addr ¶
Addr The address of this port, either remote addr or local depending on if this is the initiator of the connection
type ReconnectInfo ¶
type ReconnectInfo struct {
// contains filtered or unexported fields
}
Source Files
Click to show internal directories.
Click to hide internal directories.