Documentation ¶
Overview ¶
Package message represents message that messagebus can route
Index ¶
- func Deserialize(buff io.Reader) (core.Message, error)
- func MustSerializeBytes(msg core.Message) []byte
- func Serialize(msg core.Message) (io.Reader, error)
- func SignIsCorrect(msg core.Message, key *ecdsa.PrivateKey) bool
- func SignMessage(msg core.Message, key *ecdsa.PrivateKey) error
- func ToBytes(msg core.Message) ([]byte, error)
- type ActivateClass
- type ActivateObject
- type ActivateObjectDelegate
- func (ActivateObjectDelegate) GetCaller() *core.RecordRef
- func (l *ActivateObjectDelegate) GetSign() []byte
- func (l *ActivateObjectDelegate) SetSign(sign []byte)
- func (e *ActivateObjectDelegate) Target() *core.RecordRef
- func (ActivateObjectDelegate) TargetRole() core.JetRole
- func (e *ActivateObjectDelegate) Type() core.MessageType
- type BaseLogicMessage
- type BootstrapRequest
- type CallConstructor
- type CallMethod
- type DeactivateClass
- type DeactivateObject
- type DeclareType
- type DeployCode
- type ExecutorResults
- func (e *ExecutorResults) GetCaller() *core.RecordRef
- func (e *ExecutorResults) GetReference() core.RecordRef
- func (e *ExecutorResults) GetSign() []byte
- func (e *ExecutorResults) SetSign(sign []byte)
- func (e *ExecutorResults) Target() *core.RecordRef
- func (e *ExecutorResults) TargetRole() core.JetRole
- func (e *ExecutorResults) Type() core.MessageType
- type GetChildren
- type GetClass
- type GetCode
- type GetDelegate
- type GetObject
- type IBaseLogicMessage
- type JetDrop
- type MethodReturnMode
- type RegisterChild
- type RequestCall
- type SaveAs
- type UpdateClass
- type UpdateObject
- type ValidateCaseBind
- func (e *ValidateCaseBind) GetCaller() *core.RecordRef
- func (e *ValidateCaseBind) GetCaseRecords() []core.CaseRecord
- func (e *ValidateCaseBind) GetPulse() core.Pulse
- func (e *ValidateCaseBind) GetReference() core.RecordRef
- func (e *ValidateCaseBind) GetSign() []byte
- func (e *ValidateCaseBind) SetSign(sign []byte)
- func (e *ValidateCaseBind) Target() *core.RecordRef
- func (e *ValidateCaseBind) TargetRole() core.JetRole
- func (e *ValidateCaseBind) Type() core.MessageType
- type ValidationResults
- func (e *ValidationResults) GetCaller() *core.RecordRef
- func (e *ValidationResults) GetReference() core.RecordRef
- func (e *ValidationResults) GetSign() []byte
- func (e *ValidationResults) SetSign(sign []byte)
- func (e *ValidationResults) Target() *core.RecordRef
- func (e ValidationResults) TargetRole() core.JetRole
- func (e *ValidationResults) Type() core.MessageType
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func Deserialize ¶
Deserialize returns decoded message.
func MustSerializeBytes ¶ added in v0.5.0
MustSerializeBytes returns encoded core.Message, panics on error.
func SignIsCorrect ¶ added in v0.6.0
func SignIsCorrect(msg core.Message, key *ecdsa.PrivateKey) bool
SignIsCorrect checks if a sign is correct.
func SignMessage ¶ added in v0.6.0
func SignMessage(msg core.Message, key *ecdsa.PrivateKey) error
SignMessage tries to sign a core.Message.
Types ¶
type ActivateClass ¶
type ActivateClass struct { Domain core.RecordRef Request core.RecordRef Code core.RecordRef // contains filtered or unexported fields }
ActivateClass activates class.
func (*ActivateClass) GetSign ¶ added in v0.6.0
func (l *ActivateClass) GetSign() []byte
GetSign returns a sign.
func (*ActivateClass) SetSign ¶ added in v0.6.0
func (l *ActivateClass) SetSign(sign []byte)
SetSign sets a signature to message.
func (*ActivateClass) Target ¶
func (e *ActivateClass) Target() *core.RecordRef
Target implementation of Message interface.
func (ActivateClass) TargetRole ¶
TargetRole implementation of Message interface.
func (*ActivateClass) Type ¶
func (e *ActivateClass) Type() core.MessageType
Type implementation of Message interface.
type ActivateObject ¶
type ActivateObject struct { Domain core.RecordRef Request core.RecordRef Class core.RecordRef Parent core.RecordRef Memory []byte // contains filtered or unexported fields }
ActivateObject activates object.
func (*ActivateObject) GetSign ¶ added in v0.6.0
func (l *ActivateObject) GetSign() []byte
GetSign returns a sign.
func (*ActivateObject) SetSign ¶ added in v0.6.0
func (l *ActivateObject) SetSign(sign []byte)
SetSign sets a signature to message.
func (*ActivateObject) Target ¶
func (e *ActivateObject) Target() *core.RecordRef
Target implementation of Message interface.
func (ActivateObject) TargetRole ¶
TargetRole implementation of Message interface.
func (*ActivateObject) Type ¶
func (e *ActivateObject) Type() core.MessageType
Type implementation of Message interface.
type ActivateObjectDelegate ¶
type ActivateObjectDelegate struct { Domain core.RecordRef Request core.RecordRef Class core.RecordRef Parent core.RecordRef Memory []byte // contains filtered or unexported fields }
ActivateObjectDelegate similar to ActivateObjType but it creates object as parent's delegate of provided class.
func (*ActivateObjectDelegate) GetSign ¶ added in v0.6.0
func (l *ActivateObjectDelegate) GetSign() []byte
GetSign returns a sign.
func (*ActivateObjectDelegate) SetSign ¶ added in v0.6.0
func (l *ActivateObjectDelegate) SetSign(sign []byte)
SetSign sets a signature to message.
func (*ActivateObjectDelegate) Target ¶
func (e *ActivateObjectDelegate) Target() *core.RecordRef
Target implementation of Message interface.
func (ActivateObjectDelegate) TargetRole ¶
TargetRole implementation of Message interface.
func (*ActivateObjectDelegate) Type ¶
func (e *ActivateObjectDelegate) Type() core.MessageType
Type implementation of Message interface.
type BaseLogicMessage ¶ added in v0.5.0
type BaseLogicMessage struct { Caller core.RecordRef Nonce uint64 // contains filtered or unexported fields }
BaseLogicMessage base of event class family, do not use it standalone
func (*BaseLogicMessage) GetCaller ¶ added in v0.5.0
func (e *BaseLogicMessage) GetCaller() *core.RecordRef
func (*BaseLogicMessage) GetSign ¶ added in v0.6.0
func (b *BaseLogicMessage) GetSign() []byte
GetSign returns a sign.
func (*BaseLogicMessage) SetSign ¶ added in v0.6.0
func (b *BaseLogicMessage) SetSign(sign []byte)
SetSign sets a signature to message.
func (*BaseLogicMessage) TargetRole ¶ added in v0.5.0
func (e *BaseLogicMessage) TargetRole() core.JetRole
TargetRole returns RoleVirtualExecutor as routing target role.
type BootstrapRequest ¶ added in v0.6.0
type BootstrapRequest struct { // Name should be unique for each bootstrap record. Name string // contains filtered or unexported fields }
BootstrapRequest is used for bootstrap records generation.
func (*BootstrapRequest) GetCaller ¶ added in v0.6.0
func (*BootstrapRequest) GetCaller() *core.RecordRef
GetCaller implementation for bootstrap request.
func (*BootstrapRequest) GetSign ¶ added in v0.6.0
func (m *BootstrapRequest) GetSign() []byte
GetSign returns a sign.
func (*BootstrapRequest) SetSign ¶ added in v0.6.0
func (m *BootstrapRequest) SetSign(sign []byte)
SetSign sets a signature to message.
func (*BootstrapRequest) Target ¶ added in v0.6.0
func (m *BootstrapRequest) Target() *core.RecordRef
Target implementation for bootstrap request.
func (*BootstrapRequest) TargetRole ¶ added in v0.6.0
func (*BootstrapRequest) TargetRole() core.JetRole
TargetRole implementation for bootstrap request.
func (*BootstrapRequest) Type ¶ added in v0.6.0
func (*BootstrapRequest) Type() core.MessageType
Type implementation for bootstrap request.
type CallConstructor ¶
type CallConstructor struct { BaseLogicMessage ParentRef core.RecordRef SaveAs SaveAs ClassRef core.RecordRef Name string Arguments core.Arguments PulseNum core.PulseNumber }
CallConstructor is a message for calling constructor and obtain its reply
func (*CallConstructor) GetReference ¶ added in v0.5.0
func (e *CallConstructor) GetReference() core.RecordRef
func (*CallConstructor) Target ¶
func (e *CallConstructor) Target() *core.RecordRef
Target returns request ref as routing target.
func (*CallConstructor) Type ¶
func (e *CallConstructor) Type() core.MessageType
Type returns TypeCallConstructor.
type CallMethod ¶
type CallMethod struct { BaseLogicMessage ReturnMode MethodReturnMode ObjectRef core.RecordRef Method string Arguments core.Arguments }
CallMethod - Simply call method and return result
func (*CallMethod) GetReference ¶ added in v0.5.0
func (e *CallMethod) GetReference() core.RecordRef
func (*CallMethod) Target ¶
func (e *CallMethod) Target() *core.RecordRef
Target returns ObjectRef as routing target.
type DeactivateClass ¶
type DeactivateClass struct { Domain core.RecordRef Request core.RecordRef Class core.RecordRef // contains filtered or unexported fields }
DeactivateClass deactivates class.
func (*DeactivateClass) GetSign ¶ added in v0.6.0
func (l *DeactivateClass) GetSign() []byte
GetSign returns a sign.
func (*DeactivateClass) SetSign ¶ added in v0.6.0
func (l *DeactivateClass) SetSign(sign []byte)
SetSign sets a signature to message.
func (*DeactivateClass) Target ¶
func (e *DeactivateClass) Target() *core.RecordRef
Target implementation of Message interface.
func (DeactivateClass) TargetRole ¶
TargetRole implementation of Message interface.
func (*DeactivateClass) Type ¶
func (e *DeactivateClass) Type() core.MessageType
Type implementation of Message interface.
type DeactivateObject ¶
type DeactivateObject struct { Domain core.RecordRef Request core.RecordRef Object core.RecordRef // contains filtered or unexported fields }
DeactivateObject deactivates object.
func (*DeactivateObject) GetSign ¶ added in v0.6.0
func (l *DeactivateObject) GetSign() []byte
GetSign returns a sign.
func (*DeactivateObject) SetSign ¶ added in v0.6.0
func (l *DeactivateObject) SetSign(sign []byte)
SetSign sets a signature to message.
func (*DeactivateObject) Target ¶
func (e *DeactivateObject) Target() *core.RecordRef
Target implementation of Message interface.
func (DeactivateObject) TargetRole ¶
TargetRole implementation of Message interface.
func (*DeactivateObject) Type ¶
func (e *DeactivateObject) Type() core.MessageType
Type implementation of Message interface.
type DeclareType ¶
type DeclareType struct { Domain core.RecordRef Request core.RecordRef TypeDec []byte // contains filtered or unexported fields }
DeclareType creates new type.
func (*DeclareType) GetSign ¶ added in v0.6.0
func (l *DeclareType) GetSign() []byte
GetSign returns a sign.
func (*DeclareType) SetSign ¶ added in v0.6.0
func (l *DeclareType) SetSign(sign []byte)
SetSign sets a signature to message.
func (*DeclareType) Target ¶
func (e *DeclareType) Target() *core.RecordRef
Target implementation of Message interface.
func (DeclareType) TargetRole ¶
TargetRole implementation of Message interface.
func (*DeclareType) Type ¶
func (e *DeclareType) Type() core.MessageType
Type implementation of Message interface.
type DeployCode ¶
type DeployCode struct { Domain core.RecordRef Request core.RecordRef CodeMap map[core.MachineType][]byte // contains filtered or unexported fields }
DeployCode creates new code.
func (*DeployCode) GetSign ¶ added in v0.6.0
func (l *DeployCode) GetSign() []byte
GetSign returns a sign.
func (*DeployCode) SetSign ¶ added in v0.6.0
func (l *DeployCode) SetSign(sign []byte)
SetSign sets a signature to message.
func (*DeployCode) Target ¶
func (e *DeployCode) Target() *core.RecordRef
Target implementation of Message interface.
func (DeployCode) TargetRole ¶
TargetRole implementation of Message interface.
func (*DeployCode) Type ¶
func (e *DeployCode) Type() core.MessageType
Type implementation of Message interface.
type ExecutorResults ¶ added in v0.6.0
type ExecutorResults struct { RecordRef core.RecordRef CaseRecords []core.CaseRecord // contains filtered or unexported fields }
func (*ExecutorResults) GetCaller ¶ added in v0.6.0
func (e *ExecutorResults) GetCaller() *core.RecordRef
TODO change after changing pulsar
func (*ExecutorResults) GetReference ¶ added in v0.6.0
func (e *ExecutorResults) GetReference() core.RecordRef
func (*ExecutorResults) GetSign ¶ added in v0.6.0
func (e *ExecutorResults) GetSign() []byte
func (*ExecutorResults) SetSign ¶ added in v0.6.0
func (e *ExecutorResults) SetSign(sign []byte)
func (*ExecutorResults) Target ¶ added in v0.6.0
func (e *ExecutorResults) Target() *core.RecordRef
func (*ExecutorResults) TargetRole ¶ added in v0.6.0
func (e *ExecutorResults) TargetRole() core.JetRole
func (*ExecutorResults) Type ¶ added in v0.6.0
func (e *ExecutorResults) Type() core.MessageType
type GetChildren ¶ added in v0.5.0
type GetChildren struct { Parent core.RecordRef FromChild *core.RecordID FromPulse *core.PulseNumber Amount int // contains filtered or unexported fields }
GetChildren retrieves a chunk of children references.
func (*GetChildren) GetSign ¶ added in v0.6.0
func (l *GetChildren) GetSign() []byte
GetSign returns a sign.
func (*GetChildren) SetSign ¶ added in v0.6.0
func (l *GetChildren) SetSign(sign []byte)
SetSign sets a signature to message.
func (*GetChildren) Target ¶ added in v0.5.0
func (e *GetChildren) Target() *core.RecordRef
Target implementation of Message interface.
func (GetChildren) TargetRole ¶ added in v0.5.0
TargetRole implementation of Message interface.
func (*GetChildren) Type ¶ added in v0.5.0
func (e *GetChildren) Type() core.MessageType
Type implementation of Message interface.
type GetClass ¶
type GetClass struct { Head core.RecordRef State *core.RecordRef // If nil, will fetch the latest state. // contains filtered or unexported fields }
GetClass retrieves class from storage.
func (*GetClass) GetSign ¶ added in v0.6.0
func (l *GetClass) GetSign() []byte
GetSign returns a sign.
func (*GetClass) SetSign ¶ added in v0.6.0
func (l *GetClass) SetSign(sign []byte)
SetSign sets a signature to message.
func (GetClass) TargetRole ¶
TargetRole implementation of Message interface.
func (*GetClass) Type ¶
func (e *GetClass) Type() core.MessageType
Type implementation of Message interface.
type GetCode ¶
type GetCode struct { Code core.RecordRef MachinePref []core.MachineType // contains filtered or unexported fields }
GetCode retrieves code from storage.
func (*GetCode) GetSign ¶ added in v0.6.0
func (l *GetCode) GetSign() []byte
GetSign returns a sign.
func (*GetCode) SetSign ¶ added in v0.6.0
func (l *GetCode) SetSign(sign []byte)
SetSign sets a signature to message.
func (GetCode) TargetRole ¶
TargetRole implementation of Message interface.
func (*GetCode) Type ¶
func (e *GetCode) Type() core.MessageType
Type implementation of Message interface.
type GetDelegate ¶
type GetDelegate struct { Head core.RecordRef AsClass core.RecordRef // contains filtered or unexported fields }
GetDelegate retrieves object represented as provided class.
func (*GetDelegate) GetSign ¶ added in v0.6.0
func (l *GetDelegate) GetSign() []byte
GetSign returns a sign.
func (*GetDelegate) SetSign ¶ added in v0.6.0
func (l *GetDelegate) SetSign(sign []byte)
SetSign sets a signature to message.
func (*GetDelegate) Target ¶
func (e *GetDelegate) Target() *core.RecordRef
Target implementation of Message interface.
func (GetDelegate) TargetRole ¶
TargetRole implementation of Message interface.
func (*GetDelegate) Type ¶
func (e *GetDelegate) Type() core.MessageType
Type implementation of Message interface.
type GetObject ¶
type GetObject struct { Head core.RecordRef State *core.RecordRef // If nil, will fetch the latest state. // contains filtered or unexported fields }
GetObject retrieves object from storage.
func (*GetObject) GetSign ¶ added in v0.6.0
func (l *GetObject) GetSign() []byte
GetSign returns a sign.
func (*GetObject) SetSign ¶ added in v0.6.0
func (l *GetObject) SetSign(sign []byte)
SetSign sets a signature to message.
func (GetObject) TargetRole ¶
TargetRole implementation of Message interface.
func (*GetObject) Type ¶
func (e *GetObject) Type() core.MessageType
Type implementation of Message interface.
type IBaseLogicMessage ¶ added in v0.5.0
type JetDrop ¶ added in v0.6.0
type JetDrop struct { Jet core.RecordRef Drop []byte Records [][2][]byte // contains filtered or unexported fields }
JetDrop spreads jet drop
func (*JetDrop) GetSign ¶ added in v0.6.0
func (l *JetDrop) GetSign() []byte
GetSign returns a sign.
func (*JetDrop) SetSign ¶ added in v0.6.0
func (l *JetDrop) SetSign(sign []byte)
SetSign sets a signature to message.
func (JetDrop) TargetRole ¶ added in v0.6.0
TargetRole implementation of Message interface.
func (*JetDrop) Type ¶ added in v0.6.0
func (e *JetDrop) Type() core.MessageType
Type implementation of Message interface.
type MethodReturnMode ¶
type MethodReturnMode int
MethodReturnMode ENUM to set when method returns its result
const ( // ReturnResult - return result as soon as it is ready ReturnResult MethodReturnMode = iota // ReturnNoWait - call method and return without results ReturnNoWait )
type RegisterChild ¶ added in v0.5.0
type RegisterChild struct { Parent core.RecordRef Child core.RecordRef // contains filtered or unexported fields }
RegisterChild amends object.
func (*RegisterChild) GetSign ¶ added in v0.6.0
func (l *RegisterChild) GetSign() []byte
GetSign returns a sign.
func (*RegisterChild) SetSign ¶ added in v0.6.0
func (l *RegisterChild) SetSign(sign []byte)
SetSign sets a signature to message.
func (*RegisterChild) Target ¶ added in v0.5.0
func (e *RegisterChild) Target() *core.RecordRef
Target implementation of Message interface.
func (RegisterChild) TargetRole ¶ added in v0.5.0
TargetRole implementation of Message interface.
func (*RegisterChild) Type ¶ added in v0.5.0
func (e *RegisterChild) Type() core.MessageType
Type implementation of Message interface.
type RequestCall ¶ added in v0.5.0
RequestCall is a Ledger's message wrapping logicrunner's Call messages.
func (*RequestCall) TargetRole ¶ added in v0.5.0
func (*RequestCall) TargetRole() core.JetRole
TargetRole implementation of Message interface.
func (*RequestCall) Type ¶ added in v0.5.0
func (*RequestCall) Type() core.MessageType
Type implementation of Message interface.
type UpdateClass ¶
type UpdateClass struct { Domain core.RecordRef Request core.RecordRef Class core.RecordRef Code core.RecordRef Migrations []core.RecordRef // contains filtered or unexported fields }
UpdateClass amends class.
func (*UpdateClass) GetSign ¶ added in v0.6.0
func (l *UpdateClass) GetSign() []byte
GetSign returns a sign.
func (*UpdateClass) SetSign ¶ added in v0.6.0
func (l *UpdateClass) SetSign(sign []byte)
SetSign sets a signature to message.
func (*UpdateClass) Target ¶
func (e *UpdateClass) Target() *core.RecordRef
Target implementation of Message interface.
func (UpdateClass) TargetRole ¶
TargetRole implementation of Message interface.
func (*UpdateClass) Type ¶
func (e *UpdateClass) Type() core.MessageType
Type implementation of Message interface.
type UpdateObject ¶
type UpdateObject struct { Domain core.RecordRef Request core.RecordRef Object core.RecordRef Memory []byte // contains filtered or unexported fields }
UpdateObject amends object.
func (*UpdateObject) GetSign ¶ added in v0.6.0
func (l *UpdateObject) GetSign() []byte
GetSign returns a sign.
func (*UpdateObject) SetSign ¶ added in v0.6.0
func (l *UpdateObject) SetSign(sign []byte)
SetSign sets a signature to message.
func (*UpdateObject) Target ¶
func (e *UpdateObject) Target() *core.RecordRef
Target implementation of Message interface.
func (UpdateObject) TargetRole ¶
TargetRole implementation of Message interface.
func (*UpdateObject) Type ¶
func (e *UpdateObject) Type() core.MessageType
Type implementation of Message interface.
type ValidateCaseBind ¶ added in v0.6.0
type ValidateCaseBind struct { RecordRef core.RecordRef CaseRecords []core.CaseRecord Pulse core.Pulse // contains filtered or unexported fields }
func (*ValidateCaseBind) GetCaller ¶ added in v0.6.0
func (e *ValidateCaseBind) GetCaller() *core.RecordRef
TODO change after changing pulsar
func (*ValidateCaseBind) GetCaseRecords ¶ added in v0.6.0
func (e *ValidateCaseBind) GetCaseRecords() []core.CaseRecord
func (*ValidateCaseBind) GetPulse ¶ added in v0.6.0
func (e *ValidateCaseBind) GetPulse() core.Pulse
func (*ValidateCaseBind) GetReference ¶ added in v0.6.0
func (e *ValidateCaseBind) GetReference() core.RecordRef
func (*ValidateCaseBind) GetSign ¶ added in v0.6.0
func (e *ValidateCaseBind) GetSign() []byte
func (*ValidateCaseBind) SetSign ¶ added in v0.6.0
func (e *ValidateCaseBind) SetSign(sign []byte)
func (*ValidateCaseBind) Target ¶ added in v0.6.0
func (e *ValidateCaseBind) Target() *core.RecordRef
func (*ValidateCaseBind) TargetRole ¶ added in v0.6.0
func (e *ValidateCaseBind) TargetRole() core.JetRole
func (*ValidateCaseBind) Type ¶ added in v0.6.0
func (e *ValidateCaseBind) Type() core.MessageType
type ValidationResults ¶ added in v0.6.0
type ValidationResults struct { RecordRef core.RecordRef PassedStepsCount int Error error // contains filtered or unexported fields }
func (*ValidationResults) GetCaller ¶ added in v0.6.0
func (e *ValidationResults) GetCaller() *core.RecordRef
TODO change after changing pulsar
func (*ValidationResults) GetReference ¶ added in v0.6.0
func (e *ValidationResults) GetReference() core.RecordRef
func (*ValidationResults) GetSign ¶ added in v0.6.0
func (e *ValidationResults) GetSign() []byte
func (*ValidationResults) SetSign ¶ added in v0.6.0
func (e *ValidationResults) SetSign(sign []byte)
func (*ValidationResults) Target ¶ added in v0.6.0
func (e *ValidationResults) Target() *core.RecordRef
func (ValidationResults) TargetRole ¶ added in v0.6.0
func (e ValidationResults) TargetRole() core.JetRole
func (*ValidationResults) Type ¶ added in v0.6.0
func (e *ValidationResults) Type() core.MessageType