Documentation ¶
Index ¶
- type SubHandler
- func (e *SubHandler) AddSub(name types.EventType, id client.SubscriptionID, hd handler)
- func (e *SubHandler) Close() error
- func (e *SubHandler) HandleBalanceChange(ctx context.Context, er *types.EventResult, ed interface{}) error
- func (e *SubHandler) HandleDeleteObject(ctx context.Context, er *types.EventResult, ed interface{}) error
- func (e *SubHandler) HandleMove(_ context.Context, er *types.EventResult, ed interface{}) error
- func (e *SubHandler) HandleMutateObject(_ context.Context, er *types.EventResult, ed interface{}) error
- func (e *SubHandler) HandleNewObject(_ context.Context, er *types.EventResult, ed interface{}) error
- func (e *SubHandler) HandlePublish(_ context.Context, er *types.EventResult, ed interface{}) error
- func (e *SubHandler) HandleTransferObject(_ context.Context, er *types.EventResult, ed interface{}) error
- func (e *SubHandler) RemoveSub(id client.SubscriptionID)
- func (e *SubHandler) SubscribeEvent(ctx context.Context, r jsonrpc.RawParams) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type SubHandler ¶
type SubHandler struct {
// contains filtered or unexported fields
}
func NewSubHandler ¶
func (*SubHandler) AddSub ¶
func (e *SubHandler) AddSub(name types.EventType, id client.SubscriptionID, hd handler)
func (*SubHandler) Close ¶
func (e *SubHandler) Close() error
func (*SubHandler) HandleBalanceChange ¶
func (e *SubHandler) HandleBalanceChange(ctx context.Context, er *types.EventResult, ed interface{}) error
HandleBalanceChange handle the balance change events.
func (*SubHandler) HandleDeleteObject ¶
func (e *SubHandler) HandleDeleteObject(ctx context.Context, er *types.EventResult, ed interface{}) error
HandleDeleteObject handle delete object events
func (*SubHandler) HandleMove ¶
func (e *SubHandler) HandleMove(_ context.Context, er *types.EventResult, ed interface{}) error
HandleMove handle delete object events
func (*SubHandler) HandleMutateObject ¶
func (e *SubHandler) HandleMutateObject(_ context.Context, er *types.EventResult, ed interface{}) error
HandleMutateObject handle mutate object events
func (*SubHandler) HandleNewObject ¶
func (e *SubHandler) HandleNewObject(_ context.Context, er *types.EventResult, ed interface{}) error
HandleNewObject handle delete object events
func (*SubHandler) HandlePublish ¶
func (e *SubHandler) HandlePublish(_ context.Context, er *types.EventResult, ed interface{}) error
HandlePublish handle publish event
func (*SubHandler) HandleTransferObject ¶
func (e *SubHandler) HandleTransferObject(_ context.Context, er *types.EventResult, ed interface{}) error
HandleTransferObject handle transfer object event
func (*SubHandler) RemoveSub ¶
func (e *SubHandler) RemoveSub(id client.SubscriptionID)
func (*SubHandler) SubscribeEvent ¶
func (e *SubHandler) SubscribeEvent(ctx context.Context, r jsonrpc.RawParams) error
Click to show internal directories.
Click to hide internal directories.