event

Nov 13, 2024

Changes in this version

+ type Address struct

+ ID string

+ LocalID string

+ MachineID string

+ func NewAddressFromID(id string) (*Address, error)

+ func (a *Address) Equal(compare *Address) bool

+ func (a *Address) GetMachineID() string

+ func (a *Address) MarshalJSON() ([]byte, error)

+ func (a *Address) ToString() string

+ func (a *Address) UnmarshalJSON(data []byte) error

+ type EventEmitter interface

+ Close func() error

+ Emit func(ctx context.Context, address *Address, pkg *Package) error

+ EmitLocal func(ctx context.Context, address *Address, pkg *Package) error

+ Listen func(address *Address, listener Listener)

+ RemoveListener func(address *Address, listener Listener)

+ type Listener interface

+ Close func(ctx context.Context, code string) error

+ IsClose func() bool

+ Listen func(ctx context.Context, pkg *Package)

+ type Package struct

+ Content json.RawMessage

+ CreatedAt int64

+ From *Address

+ RequestId string

+ RoutingKey string