Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrNotConsumed = errors.New("not consumed yet") ErrNotNotified = errors.New("not notified yet") ErrNotified = errors.New("notified") )
View Source
var (
Logger *zap.Logger
)
Functions ¶
This section is empty.
Types ¶
type Browser ¶
type Browser struct {
// contains filtered or unexported fields
}
func NewBrowser ¶
func NewBrowser(cnx *Connection) *Browser
type Callback ¶
type Callback struct {
// contains filtered or unexported fields
}
func NewCallback ¶
func NewCallback() *Callback
func (*Callback) WaitResult ¶
type CallbackPool ¶
type CallbackPool struct {
// contains filtered or unexported fields
}
func NewCallbackPool ¶
func NewCallbackPool() *CallbackPool
func (*CallbackPool) Get ¶
func (cp *CallbackPool) Get() *Callback
func (*CallbackPool) Put ¶
func (cp *CallbackPool) Put(cb *Callback) error
type Connection ¶
type Connection struct {
// contains filtered or unexported fields
}
func NewConnection ¶
func NewConnection(url string) (*Connection, error)
func (*Connection) CreateSession ¶
func (cnx *Connection) CreateSession(tid target.TargetID) (*Session, error)
type Receiver ¶
type Receiver struct {
// contains filtered or unexported fields
}
func NewReceiver ¶
type Session ¶
type Subscriber ¶
type Subscriber struct {
// contains filtered or unexported fields
}
func (*Subscriber) Handle ¶
func (sub *Subscriber) Handle(event string, d []byte)
func (*Subscriber) Subscribe ¶
func (sub *Subscriber) Subscribe(event string, f func([]byte))
func (*Subscriber) WaitUtilPublished ¶
func (sub *Subscriber) WaitUtilPublished() map[string]*Receiver
Source Files ¶
Click to show internal directories.
Click to hide internal directories.