Documentation ¶
Overview ¶
Package message represents message that messagebus can route
Index ¶
- func Deserialize(buff io.Reader) (core.Message, error)
- func DeserializeParcel(buff io.Reader) (core.Parcel, error)
- func MustSerializeBytes(msg core.Message) []byte
- func ParcelToBytes(msg core.Parcel) []byte
- func Serialize(msg core.Message) (io.Reader, error)
- func SerializeParcel(parcel core.Parcel) (io.Reader, error)
- func ToBytes(msg core.Message) []byte
- type AbandonedRequestsNotification
- func (m *AbandonedRequestsNotification) AllowedSenderObjectAndRole() (*core.RecordRef, core.DynamicRole)
- func (*AbandonedRequestsNotification) DefaultRole() core.DynamicRole
- func (m *AbandonedRequestsNotification) DefaultTarget() *core.RecordRef
- func (AbandonedRequestsNotification) GetCaller() *core.RecordRef
- func (*AbandonedRequestsNotification) Type() core.MessageType
- type BaseLogicMessage
- func (m *BaseLogicMessage) AllowedSenderObjectAndRole() (*core.RecordRef, core.DynamicRole)
- func (m *BaseLogicMessage) DefaultRole() core.DynamicRole
- func (m *BaseLogicMessage) DefaultTarget() *core.RecordRef
- func (m *BaseLogicMessage) GetBaseLogicMessage() *BaseLogicMessage
- func (m *BaseLogicMessage) GetCaller() *core.RecordRef
- func (m *BaseLogicMessage) GetCallerPrototype() *core.RecordRef
- func (m *BaseLogicMessage) GetReference() core.RecordRef
- func (m *BaseLogicMessage) GetRequest() core.RecordRef
- func (m *BaseLogicMessage) Type() core.MessageType
- type CallConstructor
- func (cc *CallConstructor) AllowedSenderObjectAndRole() (*core.RecordRef, core.DynamicRole)
- func (*CallConstructor) DefaultRole() core.DynamicRole
- func (cc *CallConstructor) DefaultTarget() *core.RecordRef
- func (cc *CallConstructor) GetReference() core.RecordRef
- func (cc *CallConstructor) ToMap() (map[string]interface{}, error)
- func (cc *CallConstructor) Type() core.MessageType
- type CallMethod
- func (cm *CallMethod) AllowedSenderObjectAndRole() (*core.RecordRef, core.DynamicRole)
- func (*CallMethod) DefaultRole() core.DynamicRole
- func (cm *CallMethod) DefaultTarget() *core.RecordRef
- func (cm *CallMethod) GetReference() core.RecordRef
- func (cm *CallMethod) ToMap() (map[string]interface{}, error)
- func (cm *CallMethod) Type() core.MessageType
- type CaseBindRequest
- type ExecutionQueueElement
- type ExecutorResults
- func (er *ExecutorResults) AllowedSenderObjectAndRole() (*core.RecordRef, core.DynamicRole)
- func (er *ExecutorResults) DefaultRole() core.DynamicRole
- func (er *ExecutorResults) DefaultTarget() *core.RecordRef
- func (er *ExecutorResults) GetCaller() *core.RecordRef
- func (er *ExecutorResults) GetReference() core.RecordRef
- func (er *ExecutorResults) Type() core.MessageType
- type GenesisRequest
- type GetChildren
- type GetCode
- type GetDelegate
- type GetJet
- type GetObject
- type GetObjectIndex
- type GetPendingRequestID
- func (m *GetPendingRequestID) AllowedSenderObjectAndRole() (*core.RecordRef, core.DynamicRole)
- func (*GetPendingRequestID) DefaultRole() core.DynamicRole
- func (m *GetPendingRequestID) DefaultTarget() *core.RecordRef
- func (GetPendingRequestID) GetCaller() *core.RecordRef
- func (*GetPendingRequestID) Type() core.MessageType
- type GetPendingRequests
- func (m *GetPendingRequests) AllowedSenderObjectAndRole() (*core.RecordRef, core.DynamicRole)
- func (*GetPendingRequests) DefaultRole() core.DynamicRole
- func (m *GetPendingRequests) DefaultTarget() *core.RecordRef
- func (GetPendingRequests) GetCaller() *core.RecordRef
- func (*GetPendingRequests) Type() core.MessageType
- type GetRequest
- type HeavyPayload
- type HeavyReset
- type HeavyStartStop
- type HotData
- type HotIndex
- type IBaseLogicMessage
- type JetDrop
- type MethodReturnMode
- type NodeSignPayload
- func (nsp *NodeSignPayload) AllowedSenderObjectAndRole() (*core.RecordRef, core.DynamicRole)
- func (nsp *NodeSignPayload) DefaultRole() core.DynamicRole
- func (nsp *NodeSignPayload) DefaultTarget() *core.RecordRef
- func (NodeSignPayload) GetCaller() *core.RecordRef
- func (nsp *NodeSignPayload) GetNodeRef() *core.RecordRef
- func (nsp *NodeSignPayload) Type() core.MessageType
- type NodeSignPayloadInt
- type Parcel
- func (p *Parcel) AddDelegationToken(token core.DelegationToken)
- func (p *Parcel) AllowedSenderObjectAndRole() (*core.RecordRef, core.DynamicRole)
- func (p *Parcel) Context(ctx context.Context) context.Context
- func (p *Parcel) DefaultRole() core.DynamicRole
- func (p *Parcel) DefaultTarget() *core.RecordRef
- func (p *Parcel) DelegationToken() core.DelegationToken
- func (p *Parcel) GetCaller() *core.RecordRef
- func (p *Parcel) GetSender() core.RecordRef
- func (p *Parcel) GetSign() []byte
- func (p *Parcel) Message() core.Message
- func (p *Parcel) Pulse() core.PulseNumber
- func (p *Parcel) Type() core.MessageType
- type ParcelFactory
- type PendingFinished
- func (pf *PendingFinished) AllowedSenderObjectAndRole() (*core.RecordRef, core.DynamicRole)
- func (pf *PendingFinished) DefaultRole() core.DynamicRole
- func (pf *PendingFinished) DefaultTarget() *core.RecordRef
- func (pf *PendingFinished) GetCaller() *core.RecordRef
- func (pf *PendingFinished) Type() core.MessageType
- type PendingState
- type RegisterChild
- type ReturnResults
- func (rr *ReturnResults) AllowedSenderObjectAndRole() (*core.RecordRef, core.DynamicRole)
- func (rr *ReturnResults) DefaultRole() core.DynamicRole
- func (rr *ReturnResults) DefaultTarget() *core.RecordRef
- func (rr *ReturnResults) GetCaller() *core.RecordRef
- func (rr *ReturnResults) Type() core.MessageType
- type SaveAs
- type SetBlob
- type SetRecord
- type StillExecuting
- func (se *StillExecuting) AllowedSenderObjectAndRole() (*core.RecordRef, core.DynamicRole)
- func (se *StillExecuting) DefaultRole() core.DynamicRole
- func (se *StillExecuting) DefaultTarget() *core.RecordRef
- func (se *StillExecuting) GetCaller() *core.RecordRef
- func (se *StillExecuting) Type() core.MessageType
- type UpdateObject
- type ValidateCaseBind
- func (vcb *ValidateCaseBind) AllowedSenderObjectAndRole() (*core.RecordRef, core.DynamicRole)
- func (*ValidateCaseBind) DefaultRole() core.DynamicRole
- func (vcb *ValidateCaseBind) DefaultTarget() *core.RecordRef
- func (vcb *ValidateCaseBind) GetCaller() *core.RecordRef
- func (vcb *ValidateCaseBind) GetPulse() core.Pulse
- func (vcb *ValidateCaseBind) GetReference() core.RecordRef
- func (vcb *ValidateCaseBind) Type() core.MessageType
- type ValidateRecord
- type ValidationCheck
- func (m *ValidationCheck) AllowedSenderObjectAndRole() (*core.RecordRef, core.DynamicRole)
- func (m *ValidationCheck) DefaultRole() core.DynamicRole
- func (m *ValidationCheck) DefaultTarget() *core.RecordRef
- func (ValidationCheck) GetCaller() *core.RecordRef
- func (*ValidationCheck) Type() core.MessageType
- type ValidationResults
- func (vr *ValidationResults) AllowedSenderObjectAndRole() (*core.RecordRef, core.DynamicRole)
- func (*ValidationResults) DefaultRole() core.DynamicRole
- func (vr *ValidationResults) DefaultTarget() *core.RecordRef
- func (vr *ValidationResults) GetCaller() *core.RecordRef
- func (vr *ValidationResults) GetReference() core.RecordRef
- func (vr *ValidationResults) Type() core.MessageType
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func Deserialize ¶
Deserialize returns decoded message.
func DeserializeParcel ¶ added in v0.6.3
DeserializeParcel returns decoded signed message.
func MustSerializeBytes ¶ added in v0.5.0
MustSerializeBytes returns encoded core.Message, panics on error.
func ParcelToBytes ¶ added in v0.6.3
ParcelToBytes deserialize a core.Parcel to bytes.
func SerializeParcel ¶ added in v0.6.3
SerializeParcel returns io.Reader on buffer with encoded core.Parcel.
Types ¶
type AbandonedRequestsNotification ¶ added in v0.7.5
type AbandonedRequestsNotification struct { Object core.RecordID // contains filtered or unexported fields }
AbandonedRequestsNotification informs virtual node about unclosed requests.
func (*AbandonedRequestsNotification) AllowedSenderObjectAndRole ¶ added in v0.7.5
func (m *AbandonedRequestsNotification) AllowedSenderObjectAndRole() (*core.RecordRef, core.DynamicRole)
AllowedSenderObjectAndRole implements interface method
func (*AbandonedRequestsNotification) DefaultRole ¶ added in v0.7.5
func (*AbandonedRequestsNotification) DefaultRole() core.DynamicRole
DefaultRole returns role for this event
func (*AbandonedRequestsNotification) DefaultTarget ¶ added in v0.7.5
func (m *AbandonedRequestsNotification) DefaultTarget() *core.RecordRef
DefaultTarget returns of target of this event.
func (AbandonedRequestsNotification) GetCaller ¶ added in v0.7.5
GetCaller implementation of Message interface.
func (*AbandonedRequestsNotification) Type ¶ added in v0.7.5
func (*AbandonedRequestsNotification) Type() core.MessageType
Type implementation of Message interface.
type BaseLogicMessage ¶ added in v0.5.0
type BaseLogicMessage struct { Caller core.RecordRef Request core.RecordRef CallerPrototype core.RecordRef Nonce uint64 Sequence uint64 }
BaseLogicMessage base of event class family, do not use it standalone
func (*BaseLogicMessage) AllowedSenderObjectAndRole ¶ added in v0.7.5
func (m *BaseLogicMessage) AllowedSenderObjectAndRole() (*core.RecordRef, core.DynamicRole)
func (*BaseLogicMessage) DefaultRole ¶ added in v0.7.5
func (m *BaseLogicMessage) DefaultRole() core.DynamicRole
func (*BaseLogicMessage) DefaultTarget ¶ added in v0.7.5
func (m *BaseLogicMessage) DefaultTarget() *core.RecordRef
func (*BaseLogicMessage) GetBaseLogicMessage ¶ added in v0.7.5
func (m *BaseLogicMessage) GetBaseLogicMessage() *BaseLogicMessage
func (*BaseLogicMessage) GetCaller ¶ added in v0.5.0
func (m *BaseLogicMessage) GetCaller() *core.RecordRef
func (*BaseLogicMessage) GetCallerPrototype ¶ added in v0.6.3
func (m *BaseLogicMessage) GetCallerPrototype() *core.RecordRef
func (*BaseLogicMessage) GetReference ¶ added in v0.7.5
func (m *BaseLogicMessage) GetReference() core.RecordRef
func (*BaseLogicMessage) GetRequest ¶ added in v0.6.1
func (m *BaseLogicMessage) GetRequest() core.RecordRef
GetRequest returns DynamicRoleVirtualExecutor as routing target role.
func (*BaseLogicMessage) Type ¶ added in v0.7.5
func (m *BaseLogicMessage) Type() core.MessageType
type CallConstructor ¶
type CallConstructor struct { BaseLogicMessage ParentRef core.RecordRef SaveAs SaveAs PrototypeRef core.RecordRef Method string Arguments core.Arguments PulseNum core.PulseNumber }
CallConstructor is a message for calling constructor and obtain its reply
func (*CallConstructor) AllowedSenderObjectAndRole ¶ added in v0.7.5
func (cc *CallConstructor) AllowedSenderObjectAndRole() (*core.RecordRef, core.DynamicRole)
func (*CallConstructor) DefaultRole ¶ added in v0.7.5
func (*CallConstructor) DefaultRole() core.DynamicRole
DefaultRole returns role for this event
func (*CallConstructor) DefaultTarget ¶ added in v0.7.5
func (cc *CallConstructor) DefaultTarget() *core.RecordRef
DefaultTarget returns of target of this event.
func (*CallConstructor) GetReference ¶ added in v0.5.0
func (cc *CallConstructor) GetReference() core.RecordRef
func (*CallConstructor) ToMap ¶ added in v0.7.5
func (cc *CallConstructor) ToMap() (map[string]interface{}, error)
ToMap returns map representation of CallConstructor. Temporary until ledger.exporter api response reorganization
func (*CallConstructor) Type ¶
func (cc *CallConstructor) Type() core.MessageType
Type returns TypeCallConstructor.
type CallMethod ¶
type CallMethod struct { BaseLogicMessage ReturnMode MethodReturnMode ObjectRef core.RecordRef Method string Arguments core.Arguments ProxyPrototype core.RecordRef }
CallMethod - Simply call method and return result
func (*CallMethod) AllowedSenderObjectAndRole ¶ added in v0.7.5
func (cm *CallMethod) AllowedSenderObjectAndRole() (*core.RecordRef, core.DynamicRole)
AllowedSenderObjectAndRole implements interface method
func (*CallMethod) DefaultRole ¶ added in v0.7.5
func (*CallMethod) DefaultRole() core.DynamicRole
DefaultRole returns role for this event
func (*CallMethod) DefaultTarget ¶ added in v0.7.5
func (cm *CallMethod) DefaultTarget() *core.RecordRef
DefaultTarget returns of target of this event.
func (*CallMethod) GetReference ¶ added in v0.5.0
func (cm *CallMethod) GetReference() core.RecordRef
func (*CallMethod) ToMap ¶ added in v0.7.5
func (cm *CallMethod) ToMap() (map[string]interface{}, error)
ToMap returns map representation of CallMethod. Temporary until ledger.exporter api response reorganization
func (*CallMethod) Type ¶
func (cm *CallMethod) Type() core.MessageType
Type returns TypeCallMethod.
type CaseBindRequest ¶ added in v0.7.5
type ExecutionQueueElement ¶ added in v0.7.5
type ExecutorResults ¶ added in v0.6.0
type ExecutorResults struct { Caller core.RecordRef RecordRef core.RecordRef Requests []CaseBindRequest Queue []ExecutionQueueElement LedgerHasMoreRequests bool Pending PendingState }
TODO rename to executorObjectResult (results?)
func (*ExecutorResults) AllowedSenderObjectAndRole ¶ added in v0.7.5
func (er *ExecutorResults) AllowedSenderObjectAndRole() (*core.RecordRef, core.DynamicRole)
AllowedSenderObjectAndRole implements interface method
func (*ExecutorResults) DefaultRole ¶ added in v0.7.5
func (er *ExecutorResults) DefaultRole() core.DynamicRole
DefaultRole returns role for this event
func (*ExecutorResults) DefaultTarget ¶ added in v0.7.5
func (er *ExecutorResults) DefaultTarget() *core.RecordRef
DefaultTarget returns of target of this event.
func (*ExecutorResults) GetCaller ¶ added in v0.6.0
func (er *ExecutorResults) GetCaller() *core.RecordRef
TODO change after changing pulsar
func (*ExecutorResults) GetReference ¶ added in v0.6.0
func (er *ExecutorResults) GetReference() core.RecordRef
func (*ExecutorResults) Type ¶ added in v0.6.0
func (er *ExecutorResults) Type() core.MessageType
type GenesisRequest ¶ added in v0.6.3
type GenesisRequest struct { // Name should be unique for each genesis record. Name string }
GenesisRequest is used for genesis records generation.
func (*GenesisRequest) AllowedSenderObjectAndRole ¶ added in v0.7.5
func (*GenesisRequest) AllowedSenderObjectAndRole() (*core.RecordRef, core.DynamicRole)
AllowedSenderObjectAndRole implements interface method
func (*GenesisRequest) DefaultRole ¶ added in v0.7.5
func (*GenesisRequest) DefaultRole() core.DynamicRole
DefaultRole returns role for this event
func (*GenesisRequest) DefaultTarget ¶ added in v0.7.5
func (gr *GenesisRequest) DefaultTarget() *core.RecordRef
DefaultTarget returns of target of this event.
func (*GenesisRequest) GetCaller ¶ added in v0.6.3
func (*GenesisRequest) GetCaller() *core.RecordRef
GetCaller implementation for genesis request.
func (*GenesisRequest) Type ¶ added in v0.6.3
func (*GenesisRequest) Type() core.MessageType
Type implementation for genesis request.
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) AllowedSenderObjectAndRole ¶ added in v0.7.5
func (m *GetChildren) AllowedSenderObjectAndRole() (*core.RecordRef, core.DynamicRole)
AllowedSenderObjectAndRole implements interface method
func (*GetChildren) DefaultRole ¶ added in v0.7.5
func (*GetChildren) DefaultRole() core.DynamicRole
DefaultRole returns role for this event
func (*GetChildren) DefaultTarget ¶ added in v0.7.5
func (m *GetChildren) DefaultTarget() *core.RecordRef
DefaultTarget returns of target of this event.
func (*GetChildren) Type ¶ added in v0.5.0
func (*GetChildren) Type() core.MessageType
Type implementation of Message interface.
type GetCode ¶
GetCode retrieves code From storage.
func (*GetCode) AllowedSenderObjectAndRole ¶ added in v0.7.5
func (m *GetCode) AllowedSenderObjectAndRole() (*core.RecordRef, core.DynamicRole)
AllowedSenderObjectAndRole implements interface method
func (*GetCode) DefaultRole ¶ added in v0.7.5
func (*GetCode) DefaultRole() core.DynamicRole
DefaultRole returns role for this event
func (*GetCode) DefaultTarget ¶ added in v0.7.5
DefaultTarget returns of target of this event.
func (*GetCode) Type ¶
func (*GetCode) Type() core.MessageType
Type implementation of Message interface.
type GetDelegate ¶
type GetDelegate struct { Head core.RecordRef AsType core.RecordRef // contains filtered or unexported fields }
GetDelegate retrieves object represented as provided type.
func (*GetDelegate) AllowedSenderObjectAndRole ¶ added in v0.7.5
func (m *GetDelegate) AllowedSenderObjectAndRole() (*core.RecordRef, core.DynamicRole)
AllowedSenderObjectAndRole implements interface method
func (*GetDelegate) DefaultRole ¶ added in v0.7.5
func (*GetDelegate) DefaultRole() core.DynamicRole
DefaultRole returns role for this event
func (*GetDelegate) DefaultTarget ¶ added in v0.7.5
func (m *GetDelegate) DefaultTarget() *core.RecordRef
DefaultTarget returns of target of this event.
func (*GetDelegate) Type ¶
func (*GetDelegate) Type() core.MessageType
Type implementation of Message interface.
type GetJet ¶ added in v0.7.5
type GetJet struct { Object core.RecordID Pulse core.PulseNumber // contains filtered or unexported fields }
GetJet requests to calculate a jet for provided object.
func (*GetJet) AllowedSenderObjectAndRole ¶ added in v0.7.5
func (m *GetJet) AllowedSenderObjectAndRole() (*core.RecordRef, core.DynamicRole)
AllowedSenderObjectAndRole implements interface method
func (*GetJet) DefaultRole ¶ added in v0.7.5
func (*GetJet) DefaultRole() core.DynamicRole
DefaultRole returns role for this event
func (*GetJet) DefaultTarget ¶ added in v0.7.5
DefaultTarget returns of target of this event.
func (*GetJet) Type ¶ added in v0.7.5
func (*GetJet) Type() core.MessageType
Type implementation of Message interface.
type GetObject ¶
type GetObject struct { Head core.RecordRef State *core.RecordID // If nil, will fetch the latest state. Approved bool // contains filtered or unexported fields }
GetObject retrieves object From storage.
func (*GetObject) AllowedSenderObjectAndRole ¶ added in v0.7.5
func (m *GetObject) AllowedSenderObjectAndRole() (*core.RecordRef, core.DynamicRole)
AllowedSenderObjectAndRole implements interface method
func (*GetObject) DefaultRole ¶ added in v0.7.5
func (*GetObject) DefaultRole() core.DynamicRole
DefaultRole returns role for this event
func (*GetObject) DefaultTarget ¶ added in v0.7.5
DefaultTarget returns of target of this event.
func (*GetObject) Type ¶
func (*GetObject) Type() core.MessageType
Type implementation of Message interface.
type GetObjectIndex ¶ added in v0.6.3
GetObjectIndex fetches objects index.
func (*GetObjectIndex) AllowedSenderObjectAndRole ¶ added in v0.7.5
func (m *GetObjectIndex) AllowedSenderObjectAndRole() (*core.RecordRef, core.DynamicRole)
AllowedSenderObjectAndRole implements interface method
func (*GetObjectIndex) DefaultRole ¶ added in v0.7.5
func (*GetObjectIndex) DefaultRole() core.DynamicRole
DefaultRole returns role for this event
func (*GetObjectIndex) DefaultTarget ¶ added in v0.7.5
func (m *GetObjectIndex) DefaultTarget() *core.RecordRef
DefaultTarget returns of target of this event.
func (*GetObjectIndex) Type ¶ added in v0.6.3
func (*GetObjectIndex) Type() core.MessageType
Type implementation of Message interface.
type GetPendingRequestID ¶ added in v0.8.0
type GetPendingRequestID struct { ObjectID core.RecordID // contains filtered or unexported fields }
GetPendingRequestID fetches a pending request id for an object from current LME
func (*GetPendingRequestID) AllowedSenderObjectAndRole ¶ added in v0.8.0
func (m *GetPendingRequestID) AllowedSenderObjectAndRole() (*core.RecordRef, core.DynamicRole)
AllowedSenderObjectAndRole implements interface method
func (*GetPendingRequestID) DefaultRole ¶ added in v0.8.0
func (*GetPendingRequestID) DefaultRole() core.DynamicRole
DefaultRole returns role for this event
func (*GetPendingRequestID) DefaultTarget ¶ added in v0.8.0
func (m *GetPendingRequestID) DefaultTarget() *core.RecordRef
DefaultTarget returns of target of this event.
func (GetPendingRequestID) GetCaller ¶ added in v0.8.0
GetCaller implementation of Message interface.
func (*GetPendingRequestID) Type ¶ added in v0.8.0
func (*GetPendingRequestID) Type() core.MessageType
Type implementation of Message interface.
type GetPendingRequests ¶ added in v0.7.5
GetPendingRequests fetches pending requests for object.
func (*GetPendingRequests) AllowedSenderObjectAndRole ¶ added in v0.7.5
func (m *GetPendingRequests) AllowedSenderObjectAndRole() (*core.RecordRef, core.DynamicRole)
AllowedSenderObjectAndRole implements interface method
func (*GetPendingRequests) DefaultRole ¶ added in v0.7.5
func (*GetPendingRequests) DefaultRole() core.DynamicRole
DefaultRole returns role for this event
func (*GetPendingRequests) DefaultTarget ¶ added in v0.7.5
func (m *GetPendingRequests) DefaultTarget() *core.RecordRef
DefaultTarget returns of target of this event.
func (GetPendingRequests) GetCaller ¶ added in v0.7.5
GetCaller implementation of Message interface.
func (*GetPendingRequests) Type ¶ added in v0.7.5
func (*GetPendingRequests) Type() core.MessageType
Type implementation of Message interface.
type GetRequest ¶ added in v0.8.0
GetRequest fetches request from ledger.
func (*GetRequest) AllowedSenderObjectAndRole ¶ added in v0.8.0
func (m *GetRequest) AllowedSenderObjectAndRole() (*core.RecordRef, core.DynamicRole)
AllowedSenderObjectAndRole implements interface method
func (*GetRequest) DefaultRole ¶ added in v0.8.0
func (*GetRequest) DefaultRole() core.DynamicRole
DefaultRole returns role for this event
func (*GetRequest) DefaultTarget ¶ added in v0.8.0
func (m *GetRequest) DefaultTarget() *core.RecordRef
DefaultTarget returns of target of this event.
func (*GetRequest) Type ¶ added in v0.8.0
func (*GetRequest) Type() core.MessageType
Type implementation of Message interface.
type HeavyPayload ¶ added in v0.6.3
HeavyPayload carries Key/Value records and pulse number that replicates to Heavy Material node.
func (*HeavyPayload) AllowedSenderObjectAndRole ¶ added in v0.7.5
func (*HeavyPayload) AllowedSenderObjectAndRole() (*core.RecordRef, core.DynamicRole)
AllowedSenderObjectAndRole implements interface method
func (*HeavyPayload) DefaultRole ¶ added in v0.7.5
func (*HeavyPayload) DefaultRole() core.DynamicRole
DefaultRole returns role for this event
func (*HeavyPayload) DefaultTarget ¶ added in v0.7.5
func (hp *HeavyPayload) DefaultTarget() *core.RecordRef
DefaultTarget returns of target of this event.
func (HeavyPayload) GetCaller ¶ added in v0.6.3
func (HeavyPayload) GetCaller() *core.RecordRef
GetCaller implementation of Message interface.
func (*HeavyPayload) Type ¶ added in v0.6.3
func (hp *HeavyPayload) Type() core.MessageType
Type implementation of Message interface.
type HeavyReset ¶ added in v0.7.5
type HeavyReset struct { JetID core.RecordID PulseNum core.PulseNumber }
HeavyReset carries heavy replication start/stop signal with pulse number.
func (*HeavyReset) AllowedSenderObjectAndRole ¶ added in v0.7.5
func (*HeavyReset) AllowedSenderObjectAndRole() (*core.RecordRef, core.DynamicRole)
AllowedSenderObjectAndRole implements interface method
func (*HeavyReset) DefaultRole ¶ added in v0.7.5
func (*HeavyReset) DefaultRole() core.DynamicRole
DefaultRole returns role for this event
func (*HeavyReset) DefaultTarget ¶ added in v0.7.5
func (*HeavyReset) DefaultTarget() *core.RecordRef
DefaultTarget returns of target of this event.
func (HeavyReset) GetCaller ¶ added in v0.7.5
func (HeavyReset) GetCaller() *core.RecordRef
GetCaller implementation of Message interface.
func (*HeavyReset) Type ¶ added in v0.7.5
func (e *HeavyReset) Type() core.MessageType
Type implementation of Message interface.
type HeavyStartStop ¶ added in v0.6.3
type HeavyStartStop struct { JetID core.RecordID PulseNum core.PulseNumber Finished bool }
HeavyStartStop carries heavy replication start/stop signal with pulse number.
func (*HeavyStartStop) AllowedSenderObjectAndRole ¶ added in v0.7.5
func (*HeavyStartStop) AllowedSenderObjectAndRole() (*core.RecordRef, core.DynamicRole)
AllowedSenderObjectAndRole implements interface method
func (*HeavyStartStop) DefaultRole ¶ added in v0.7.5
func (*HeavyStartStop) DefaultRole() core.DynamicRole
DefaultRole returns role for this event
func (*HeavyStartStop) DefaultTarget ¶ added in v0.7.5
func (*HeavyStartStop) DefaultTarget() *core.RecordRef
DefaultTarget returns of target of this event.
func (HeavyStartStop) GetCaller ¶ added in v0.6.3
func (HeavyStartStop) GetCaller() *core.RecordRef
GetCaller implementation of Message interface.
func (*HeavyStartStop) Type ¶ added in v0.6.3
func (e *HeavyStartStop) Type() core.MessageType
Type implementation of Message interface.
type HotData ¶ added in v0.7.5
type HotData struct { Jet core.RecordRef DropJet core.RecordID // If will be different in case of split. Drop jet.JetDrop RecentObjects map[core.RecordID]HotIndex PendingRequests map[core.RecordID]recentstorage.PendingObjectContext PulseNumber core.PulseNumber JetDropSizeHistory jet.DropSizeHistory // contains filtered or unexported fields }
HotData contains hot-data
func (*HotData) AllowedSenderObjectAndRole ¶ added in v0.7.5
func (m *HotData) AllowedSenderObjectAndRole() (*core.RecordRef, core.DynamicRole)
AllowedSenderObjectAndRole implements interface method
func (*HotData) DefaultRole ¶ added in v0.7.5
func (*HotData) DefaultRole() core.DynamicRole
DefaultRole returns role for this event
func (*HotData) DefaultTarget ¶ added in v0.7.5
DefaultTarget returns of target of this event.
func (*HotData) Type ¶ added in v0.7.5
func (*HotData) 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 { JetID core.RecordID Drop []byte Messages [][]byte PulseNumber core.PulseNumber // contains filtered or unexported fields }
JetDrop spreads jet drop
func (*JetDrop) AllowedSenderObjectAndRole ¶ added in v0.7.5
func (m *JetDrop) AllowedSenderObjectAndRole() (*core.RecordRef, core.DynamicRole)
AllowedSenderObjectAndRole implements interface method
func (*JetDrop) DefaultRole ¶ added in v0.7.5
func (*JetDrop) DefaultRole() core.DynamicRole
DefaultRole returns role for this event
func (*JetDrop) DefaultTarget ¶ added in v0.7.5
DefaultTarget returns of target of this event.
func (*JetDrop) Type ¶ added in v0.6.0
func (*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 NodeSignPayload ¶ added in v0.7.5
func (*NodeSignPayload) AllowedSenderObjectAndRole ¶ added in v0.7.5
func (nsp *NodeSignPayload) AllowedSenderObjectAndRole() (*core.RecordRef, core.DynamicRole)
AllowedSenderObjectAndRole implements interface method
func (*NodeSignPayload) DefaultRole ¶ added in v0.7.5
func (nsp *NodeSignPayload) DefaultRole() core.DynamicRole
DefaultRole returns role for this event
func (*NodeSignPayload) DefaultTarget ¶ added in v0.7.5
func (nsp *NodeSignPayload) DefaultTarget() *core.RecordRef
DefaultTarget returns of target of this event.
func (NodeSignPayload) GetCaller ¶ added in v0.7.5
func (NodeSignPayload) GetCaller() *core.RecordRef
GetCaller implementation of Message interface.
func (*NodeSignPayload) GetNodeRef ¶ added in v0.7.5
func (nsp *NodeSignPayload) GetNodeRef() *core.RecordRef
func (*NodeSignPayload) Type ¶ added in v0.7.5
func (nsp *NodeSignPayload) Type() core.MessageType
Type implementation of Message interface.
type NodeSignPayloadInt ¶ added in v0.7.5
type Parcel ¶ added in v0.6.3
type Parcel struct { Sender core.RecordRef Msg core.Message Signature []byte LogTraceID string TraceSpanData []byte Token core.DelegationToken PulseNumber core.PulseNumber }
Parcel is a message signed by senders private key.
func (*Parcel) AddDelegationToken ¶ added in v0.6.3
func (p *Parcel) AddDelegationToken(token core.DelegationToken)
func (*Parcel) AllowedSenderObjectAndRole ¶ added in v0.7.5
func (p *Parcel) AllowedSenderObjectAndRole() (*core.RecordRef, core.DynamicRole)
AllowedSenderObjectAndRole implements interface method
func (*Parcel) Context ¶ added in v0.6.3
Context returns initialized context with propagated data with ctx as parent.
func (*Parcel) DefaultRole ¶ added in v0.7.5
func (p *Parcel) DefaultRole() core.DynamicRole
DefaultRole returns role for this event
func (*Parcel) DefaultTarget ¶ added in v0.7.5
DefaultTarget returns of target of this event.
func (*Parcel) DelegationToken ¶ added in v0.6.3
func (p *Parcel) DelegationToken() core.DelegationToken
func (*Parcel) Pulse ¶ added in v0.7.5
func (p *Parcel) Pulse() core.PulseNumber
Pulse returns pulse, when parcel was sent
func (*Parcel) Type ¶ added in v0.6.3
func (p *Parcel) Type() core.MessageType
Type returns message type.
type ParcelFactory ¶ added in v0.6.3
type ParcelFactory interface { Create(context.Context, core.Message, core.RecordRef, core.DelegationToken, core.Pulse) (core.Parcel, error) Validate(crypto.PublicKey, core.Parcel) error }
ParcelFactory is used for creating parcels
type PendingFinished ¶ added in v0.7.5
PendingFinished is sent by the old executor to the current executor when pending execution finishes.
func (*PendingFinished) AllowedSenderObjectAndRole ¶ added in v0.7.5
func (pf *PendingFinished) AllowedSenderObjectAndRole() (*core.RecordRef, core.DynamicRole)
func (*PendingFinished) DefaultRole ¶ added in v0.7.5
func (pf *PendingFinished) DefaultRole() core.DynamicRole
func (*PendingFinished) DefaultTarget ¶ added in v0.7.5
func (pf *PendingFinished) DefaultTarget() *core.RecordRef
func (*PendingFinished) GetCaller ¶ added in v0.7.5
func (pf *PendingFinished) GetCaller() *core.RecordRef
func (*PendingFinished) Type ¶ added in v0.7.5
func (pf *PendingFinished) Type() core.MessageType
type PendingState ¶ added in v0.7.5
type PendingState int
const ( PendingUnknown PendingState = iota NotPending InPending )
type RegisterChild ¶ added in v0.5.0
type RegisterChild struct { Record []byte Parent core.RecordRef Child core.RecordRef AsType *core.RecordRef // If not nil, considered as delegate. // contains filtered or unexported fields }
RegisterChild amends object.
func (*RegisterChild) AllowedSenderObjectAndRole ¶ added in v0.7.5
func (m *RegisterChild) AllowedSenderObjectAndRole() (*core.RecordRef, core.DynamicRole)
AllowedSenderObjectAndRole implements interface method
func (*RegisterChild) DefaultRole ¶ added in v0.7.5
func (*RegisterChild) DefaultRole() core.DynamicRole
DefaultRole returns role for this event
func (*RegisterChild) DefaultTarget ¶ added in v0.7.5
func (m *RegisterChild) DefaultTarget() *core.RecordRef
DefaultTarget returns of target of this event.
func (*RegisterChild) Type ¶ added in v0.5.0
func (*RegisterChild) Type() core.MessageType
Type implementation of Message interface.
type ReturnResults ¶ added in v0.7.5
type ReturnResults struct { Target core.RecordRef Caller core.RecordRef Sequence uint64 Reply core.Reply Error string }
ReturnResults - push results of methods
func (*ReturnResults) AllowedSenderObjectAndRole ¶ added in v0.7.5
func (rr *ReturnResults) AllowedSenderObjectAndRole() (*core.RecordRef, core.DynamicRole)
func (*ReturnResults) DefaultRole ¶ added in v0.7.5
func (rr *ReturnResults) DefaultRole() core.DynamicRole
func (*ReturnResults) DefaultTarget ¶ added in v0.7.5
func (rr *ReturnResults) DefaultTarget() *core.RecordRef
func (*ReturnResults) GetCaller ¶ added in v0.7.5
func (rr *ReturnResults) GetCaller() *core.RecordRef
func (*ReturnResults) Type ¶ added in v0.7.5
func (rr *ReturnResults) Type() core.MessageType
type SetBlob ¶ added in v0.6.2
type SetBlob struct { TargetRef core.RecordRef Memory []byte // contains filtered or unexported fields }
SetBlob saves blob in storage.
func (*SetBlob) AllowedSenderObjectAndRole ¶ added in v0.7.5
func (m *SetBlob) AllowedSenderObjectAndRole() (*core.RecordRef, core.DynamicRole)
AllowedSenderObjectAndRole implements interface method
func (*SetBlob) DefaultRole ¶ added in v0.7.5
func (*SetBlob) DefaultRole() core.DynamicRole
DefaultRole returns role for this event
func (*SetBlob) DefaultTarget ¶ added in v0.7.5
DefaultTarget returns of target of this event.
func (*SetBlob) Type ¶ added in v0.6.2
func (*SetBlob) Type() core.MessageType
Type implementation of Message interface.
type SetRecord ¶ added in v0.6.1
type SetRecord struct { Record []byte TargetRef core.RecordRef // contains filtered or unexported fields }
SetRecord saves record in storage.
func (*SetRecord) AllowedSenderObjectAndRole ¶ added in v0.7.5
func (m *SetRecord) AllowedSenderObjectAndRole() (*core.RecordRef, core.DynamicRole)
AllowedSenderObjectAndRole implements interface method
func (*SetRecord) DefaultRole ¶ added in v0.7.5
func (*SetRecord) DefaultRole() core.DynamicRole
DefaultRole returns role for this event
func (*SetRecord) DefaultTarget ¶ added in v0.7.5
DefaultTarget returns of target of this event.
func (*SetRecord) Type ¶ added in v0.6.1
func (m *SetRecord) Type() core.MessageType
Type implementation of Message interface.
type StillExecuting ¶ added in v0.7.5
StillExecuting
func (*StillExecuting) AllowedSenderObjectAndRole ¶ added in v0.7.5
func (se *StillExecuting) AllowedSenderObjectAndRole() (*core.RecordRef, core.DynamicRole)
func (*StillExecuting) DefaultRole ¶ added in v0.7.5
func (se *StillExecuting) DefaultRole() core.DynamicRole
func (*StillExecuting) DefaultTarget ¶ added in v0.7.5
func (se *StillExecuting) DefaultTarget() *core.RecordRef
func (*StillExecuting) GetCaller ¶ added in v0.7.5
func (se *StillExecuting) GetCaller() *core.RecordRef
func (*StillExecuting) Type ¶ added in v0.7.5
func (se *StillExecuting) Type() core.MessageType
type UpdateObject ¶
type UpdateObject struct { Record []byte Object core.RecordRef Memory []byte // contains filtered or unexported fields }
UpdateObject amends object.
func (*UpdateObject) AllowedSenderObjectAndRole ¶ added in v0.7.5
func (m *UpdateObject) AllowedSenderObjectAndRole() (*core.RecordRef, core.DynamicRole)
AllowedSenderObjectAndRole implements interface method
func (*UpdateObject) DefaultRole ¶ added in v0.7.5
func (*UpdateObject) DefaultRole() core.DynamicRole
DefaultRole returns role for this event
func (*UpdateObject) DefaultTarget ¶ added in v0.7.5
func (m *UpdateObject) DefaultTarget() *core.RecordRef
DefaultTarget returns of target of this event.
func (*UpdateObject) Type ¶
func (*UpdateObject) Type() core.MessageType
Type implementation of Message interface.
type ValidateCaseBind ¶ added in v0.6.0
type ValidateCaseBind struct { Caller core.RecordRef RecordRef core.RecordRef Requests []CaseBindRequest Pulse core.Pulse }
func (*ValidateCaseBind) AllowedSenderObjectAndRole ¶ added in v0.7.5
func (vcb *ValidateCaseBind) AllowedSenderObjectAndRole() (*core.RecordRef, core.DynamicRole)
AllowedSenderObjectAndRole implements interface method
func (*ValidateCaseBind) DefaultRole ¶ added in v0.7.5
func (*ValidateCaseBind) DefaultRole() core.DynamicRole
DefaultRole returns role for this event
func (*ValidateCaseBind) DefaultTarget ¶ added in v0.7.5
func (vcb *ValidateCaseBind) DefaultTarget() *core.RecordRef
DefaultTarget returns of target of this event.
func (*ValidateCaseBind) GetCaller ¶ added in v0.6.0
func (vcb *ValidateCaseBind) GetCaller() *core.RecordRef
TODO change after changing pulsar
func (*ValidateCaseBind) GetPulse ¶ added in v0.6.0
func (vcb *ValidateCaseBind) GetPulse() core.Pulse
func (*ValidateCaseBind) GetReference ¶ added in v0.6.0
func (vcb *ValidateCaseBind) GetReference() core.RecordRef
func (*ValidateCaseBind) Type ¶ added in v0.6.0
func (vcb *ValidateCaseBind) Type() core.MessageType
type ValidateRecord ¶ added in v0.6.2
type ValidateRecord struct { Object core.RecordRef State core.RecordID IsValid bool ValidationMessages []core.Message // contains filtered or unexported fields }
ValidateRecord creates VM validation for specific object record.
func (*ValidateRecord) AllowedSenderObjectAndRole ¶ added in v0.7.5
func (m *ValidateRecord) AllowedSenderObjectAndRole() (*core.RecordRef, core.DynamicRole)
AllowedSenderObjectAndRole implements interface method
func (*ValidateRecord) DefaultRole ¶ added in v0.7.5
func (*ValidateRecord) DefaultRole() core.DynamicRole
DefaultRole returns role for this event
func (*ValidateRecord) DefaultTarget ¶ added in v0.7.5
func (m *ValidateRecord) DefaultTarget() *core.RecordRef
DefaultTarget returns of target of this event.
func (*ValidateRecord) Type ¶ added in v0.6.2
func (*ValidateRecord) Type() core.MessageType
Type implementation of Message interface.
type ValidationCheck ¶ added in v0.7.5
type ValidationCheck struct { Object core.RecordRef ValidatedState core.RecordID LatestStateApproved *core.RecordID // contains filtered or unexported fields }
ValidationCheck checks if validation of a particular record can be performed.
func (*ValidationCheck) AllowedSenderObjectAndRole ¶ added in v0.7.5
func (m *ValidationCheck) AllowedSenderObjectAndRole() (*core.RecordRef, core.DynamicRole)
AllowedSenderObjectAndRole implements interface method
func (*ValidationCheck) DefaultRole ¶ added in v0.7.5
func (m *ValidationCheck) DefaultRole() core.DynamicRole
DefaultRole returns role for this event
func (*ValidationCheck) DefaultTarget ¶ added in v0.7.5
func (m *ValidationCheck) DefaultTarget() *core.RecordRef
DefaultTarget returns of target of this event.
func (*ValidationCheck) Type ¶ added in v0.7.5
func (*ValidationCheck) Type() core.MessageType
Type implementation of Message interface.
type ValidationResults ¶ added in v0.6.0
type ValidationResults struct { Caller core.RecordRef RecordRef core.RecordRef PassedStepsCount int Error string }
func (*ValidationResults) AllowedSenderObjectAndRole ¶ added in v0.7.5
func (vr *ValidationResults) AllowedSenderObjectAndRole() (*core.RecordRef, core.DynamicRole)
AllowedSenderObjectAndRole implements interface method
func (*ValidationResults) DefaultRole ¶ added in v0.7.5
func (*ValidationResults) DefaultRole() core.DynamicRole
DefaultRole returns role for this event
func (*ValidationResults) DefaultTarget ¶ added in v0.7.5
func (vr *ValidationResults) DefaultTarget() *core.RecordRef
DefaultTarget returns of target of this event.
func (*ValidationResults) GetCaller ¶ added in v0.6.0
func (vr *ValidationResults) GetCaller() *core.RecordRef
TODO change after changing pulsar
func (*ValidationResults) GetReference ¶ added in v0.6.0
func (vr *ValidationResults) GetReference() core.RecordRef
func (*ValidationResults) Type ¶ added in v0.6.0
func (vr *ValidationResults) Type() core.MessageType