Documentation ¶
Index ¶
- Variables
- func DefaultEngineOption() ofn.Option
- func NewRedisEngine(opts ...signaling.NewEngineOption) (signaling.Engine, error)
- func WithHealthCheckPeriod(d time.Duration) signaling.NewEngineOption
- func WithResolvePeriod(d time.Duration) signaling.NewEngineOption
- func WithURL(url string) signaling.NewEngineOption
- func WithWaitWiredEventTimeout(d time.Duration) signaling.NewEngineOption
- type Event
- func NewErrorEventWithSession(session int32, err error) *Event
- func NewEvent(name string, session int32, descriptor *signaling.Descriptor, err error) *Event
- func NewWireEvent(descriptor *signaling.Descriptor) *Event
- func NewWireEventWithSession(session int32, descriptor *signaling.Descriptor) *Event
- func NewWiredEventWithSession(session int32, descriptor *signaling.Descriptor) *Event
- type RedisEngine
Constants ¶
This section is empty.
Variables ¶
Functions ¶
func DefaultEngineOption ¶
func NewRedisEngine ¶
func NewRedisEngine(opts ...signaling.NewEngineOption) (signaling.Engine, error)
func WithHealthCheckPeriod ¶
func WithHealthCheckPeriod(d time.Duration) signaling.NewEngineOption
func WithResolvePeriod ¶
func WithResolvePeriod(d time.Duration) signaling.NewEngineOption
func WithURL ¶
func WithURL(url string) signaling.NewEngineOption
func WithWaitWiredEventTimeout ¶
func WithWaitWiredEventTimeout(d time.Duration) signaling.NewEngineOption
Types ¶
type Event ¶
type Event struct { Name string `json:"name"` Session int32 `json:"session"` Descriptor *signaling.Descriptor `json:"descriptor,omitempty"` Error string `json:"error,omitempty"` }
func NewWireEvent ¶
func NewWireEvent(descriptor *signaling.Descriptor) *Event
func NewWireEventWithSession ¶
func NewWireEventWithSession(session int32, descriptor *signaling.Descriptor) *Event
func NewWiredEventWithSession ¶
func NewWiredEventWithSession(session int32, descriptor *signaling.Descriptor) *Event
type RedisEngine ¶
type RedisEngine struct {
// contains filtered or unexported fields
}
func (*RedisEngine) Close ¶
func (e *RedisEngine) Close() error
func (*RedisEngine) ID ¶
func (e *RedisEngine) ID() string
func (*RedisEngine) OnWire ¶
func (e *RedisEngine) OnWire(h signaling.WireHandler)
func (*RedisEngine) Wire ¶
func (e *RedisEngine) Wire(dst, src *signaling.Descriptor) (*signaling.Descriptor, error)
Click to show internal directories.
Click to hide internal directories.