Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ( // ErrInvalidTransportDSN is returned when the Transport's DSN is invalid. ErrInvalidTransportDSN = errors.New("invalid transport DSN") // ErrClosedTransport is returned by the Transport's Dispatch and AddSubscriber methods after a call to Close. ErrClosedTransport = errors.New("hub: read/write on closed Transport") )
Functions ¶
This section is empty.
Types ¶
type BoltTransport ¶
type BoltTransport struct {
// contains filtered or unexported fields
}
BoltTransport implements the TransportInterface using the Bolt database.
func NewBoltTransport ¶
func NewBoltTransport(u *url.URL) (*BoltTransport, error)
NewBoltTransport create a new BoltTransport.
func (*BoltTransport) Count ¶
func (b *BoltTransport) Count() (int64, error)
type RedisTransport ¶
type RedisTransport struct {
// contains filtered or unexported fields
}
RedisTransport implements the TransportInterface using the Bolt database.
func NewRedisTransport ¶
func NewRedisTransport(u *url.URL) (*RedisTransport, error)
NewBoltTransport create a new RedisTransport.
func (*RedisTransport) Count ¶
func (r *RedisTransport) Count() (int64, error)
Source Files
Click to show internal directories.
Click to hide internal directories.