event

Documentation

Index

• func NewLocalEventEmitter(addressManager *rpc.AddressManager, rpcManager *rpc.RpcManager) event.EventEmitter
• type LocalEventEmitter
  • func (e *LocalEventEmitter) Close() error
  • func (e *LocalEventEmitter) Emit(ctx context.Context, address *event.Address, msg *event.Package) error
  • func (e *LocalEventEmitter) EmitLocal(ctx context.Context, address *event.Address, pkg *event.Package) error
  • func (e *LocalEventEmitter) Listen(address *event.Address, listener event.Listener)
  • func (e *LocalEventEmitter) RemoveListener(address *event.Address, listener event.Listener)
• type RpcEventEmitter
  • func NewRpcEventEmitter(localEventEmitter event.EventEmitter, rpcManager *rpc.RpcManager) (*RpcEventEmitter, error)
  • func (e *RpcEventEmitter) Emit(r *http.Request, req *RpcEventEmitterRequest, res *RpcEventEmitterResponse) error
• type RpcEventEmitterRequest
  • func NewRpcEventEmitterRequest() *RpcEventEmitterRequest
• type RpcEventEmitterResponse
  • func NewRpcEventEmitterResponse() *RpcEventEmitterResponse

Functions

func NewLocalEventEmitter

func NewLocalEventEmitter(addressManager *rpc.AddressManager, rpcManager *rpc.RpcManager) event.EventEmitter

Types

type LocalEventEmitter

type LocalEventEmitter struct {
	// contains filtered or unexported fields
}

func (*LocalEventEmitter) Close

func (e *LocalEventEmitter) Close() error

func (*LocalEventEmitter) Emit

func (e *LocalEventEmitter) Emit(ctx context.Context, address *event.Address, msg *event.Package) error

func (*LocalEventEmitter) EmitLocal

func (e *LocalEventEmitter) EmitLocal(ctx context.Context, address *event.Address, pkg *event.Package) error

func (*LocalEventEmitter) Listen

func (e *LocalEventEmitter) Listen(address *event.Address, listener event.Listener)

func (*LocalEventEmitter) RemoveListener

func (e *LocalEventEmitter) RemoveListener(address *event.Address, listener event.Listener)

type RpcEventEmitter

type RpcEventEmitter struct {
	// contains filtered or unexported fields
}

func NewRpcEventEmitter

func NewRpcEventEmitter(localEventEmitter event.EventEmitter, rpcManager *rpc.RpcManager) (*RpcEventEmitter, error)

func (*RpcEventEmitter) Emit

func (e *RpcEventEmitter) Emit(r *http.Request, req *RpcEventEmitterRequest, res *RpcEventEmitterResponse) error

type RpcEventEmitterRequest

type RpcEventEmitterRequest struct {
	ContextTimeout int
	Address        *event.Address
	Package        *event.Package
}

func NewRpcEventEmitterRequest

func NewRpcEventEmitterRequest() *RpcEventEmitterRequest

type RpcEventEmitterResponse

type RpcEventEmitterResponse struct {
	room.BasicRpcResponse
}

func NewRpcEventEmitterResponse

func NewRpcEventEmitterResponse() *RpcEventEmitterResponse