event

Documentation

Index

• type Address
  • 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
• type Listener
• type Package

Types

type Address

type Address struct {
	ID        string `json:"id"`
	MachineID string `json:"machineId"`
	LocalID   string `json:"localId"`
}

func NewAddressFromID

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

func (*Address) Equal

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

func (*Address) GetMachineID

func (a *Address) GetMachineID() string

func (*Address) MarshalJSON

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

func (*Address) ToString

func (a *Address) ToString() string

func (*Address) UnmarshalJSON

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

type EventEmitter

type EventEmitter interface {
	Emit(ctx context.Context, address *Address, pkg *Package) error
	EmitLocal(ctx context.Context, address *Address, pkg *Package) error
	Listen(address *Address, listener Listener)
	RemoveListener(address *Address, listener Listener)
	Close() error
}

type Listener

type Listener interface {
	Listen(ctx context.Context, pkg *Package)
	IsClose() bool
	Close(ctx context.Context, code string) error
}

type Package

type Package struct {
	From       *Address        `json:"from"`
	CreatedAt  int64           `json:"createdAt"`
	RequestId  string          `json:"requestId"`
	RoutingKey string          `json:"routingKey"`
	Content    json.RawMessage `json:"content"`
}