Documentation
¶
Index ¶
- type ConnectFunc
- type ConnectOptions
- type RemoteBroker
- func (broker *RemoteBroker) Connect(opts ConnectOptions, connect ConnectFunc) wrapper.Conn
- func (broker *RemoteBroker) Receive(conn wrapper.Conn) (model.Message, error)
- func (broker *RemoteBroker) Send(conn wrapper.Conn, message model.Message) error
- func (broker *RemoteBroker) SendSync(conn wrapper.Conn, message model.Message, timeout time.Duration) (model.Message, error)
- func (broker *RemoteBroker) SendSyncInternal(conn wrapper.Conn, message model.Message, timeout time.Duration) (model.Message, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ConnectFunc ¶
type ConnectFunc func(ConnectOptions) (interface{}, error)
ConnectFunc connect func
type ConnectOptions ¶
type ConnectOptions struct {
Address string
MessageType string
BufferSize int
Cert tls.Certificate
// for websocket/http
RequestHeader http.Header
}
ConnectOptions connect options
type RemoteBroker ¶
type RemoteBroker struct {
// contains filtered or unexported fields
}
RemoteBroker remote broker
func (*RemoteBroker) Connect ¶
func (broker *RemoteBroker) Connect(opts ConnectOptions, connect ConnectFunc) wrapper.Conn
Connect connect
Source Files
Click to show internal directories.
Click to hide internal directories.