reply

package
v0.8.7 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 23, 2019 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Overview

Package reply represents responses to messages of the messagebus

Index

Constants

View Source 
const (

	// TypeError is reply with error.
	TypeError = core.ReplyType(iota + 1)
	// TypeOK is a generic reply for signaling a positive result.
	TypeOK
	// TypeNotOK is a generic reply for signaling a negative result.
	TypeNotOK

	// TypeGetCodeRedirect is a redirect reply for code-call
	TypeGetCodeRedirect
	// TypeGetObjectRedirect is a redirect reply for object-call
	TypeGetObjectRedirect
	// TypeGetChildrenRedirect is a redirect reply for children-call
	TypeGetChildrenRedirect

	// TypeCallMethod - two binary fields: data and results.
	TypeCallMethod
	// TypeCallConstructor - reference on created object
	TypeCallConstructor
	// TypeRegisterRequest - request for execution was registered
	TypeRegisterRequest

	// TypeCode is code from storage.
	TypeCode
	// TypeObject is object from storage.
	TypeObject
	// TypeDelegate is delegate reference from storage.
	TypeDelegate
	// TypeID is common reply for methods returning id to lifeline states.
	TypeID
	// TypeChildren is a reply for fetching objects children in chunks.
	TypeChildren
	// TypeObjectIndex contains serialized object index. It can be stored in DB without processing.
	TypeObjectIndex
	// TypeJetMiss is returned for miscalculated jets due to incomplete jet tree.
	TypeJetMiss
	// TypePendingRequests contains unclosed requests for an object.
	TypePendingRequests
	// TypeJet contains jet.
	TypeJet
	// TypeRequest contains request.
	TypeRequest
	// TypeHeavyError carries heavy record sync
	TypeHeavyError

	TypeNodeSign
)
View Source 
const (
	// ErrDeactivated returned when requested object is deactivated.
	ErrDeactivated = iota + 1
	// ErrStateNotAvailable is returned when requested object is deactivated.
	ErrStateNotAvailable
	// ErrHotDataTimeout is returned when no hot data received for a specific jet
	ErrHotDataTimeout
	// ErrNoPendingRequests is returned when there are no pending requests on current LME
	ErrNoPendingRequests
	// ErrTooManyPendingRequests is returned when a limit of pending requests has been reached
	ErrTooManyPendingRequests
)

Variables

This section is empty.

Functions

func Deserialize 

func Deserialize(buff io.Reader) (core.Reply, error)

Deserialize returns decoded reply.

func Serialize 

func Serialize(reply core.Reply) (io.Reader, error)

Serialize returns encoded reply.

func ToBytes added in v0.6.3 

func ToBytes(rep core.Reply) []byte

ToBytes deserializes reply to bytes.

Types

type CallConstructor added in v0.5.0 

type CallConstructor struct {
	Object *core.RecordRef
}

func (*CallConstructor) Type added in v0.5.0 

func (r *CallConstructor) Type() core.ReplyType

Type returns type of the reply

type CallMethod added in v0.5.0 

type CallMethod struct {
	Request core.RecordRef
	Result  []byte
}

CallMethod - the most common reply

func (*CallMethod) Type added in v0.5.0 

func (r *CallMethod) Type() core.ReplyType

Type returns type of the reply

type Children added in v0.5.0 

type Children struct {
	Refs     []core.RecordRef
	NextFrom *core.RecordID
}

Children is common reaction for methods returning id to lifeline states.

func (*Children) Type added in v0.5.0 

func (e *Children) Type() core.ReplyType

Type implementation of Reply interface.

type Code 

type Code struct {
	Code        []byte
	MachineType core.MachineType
}

Code is code from storage.

func (*Code) Type 

func (e *Code) Type() core.ReplyType

Type implementation of Reply interface.

type Delegate 

type Delegate struct {
	Head core.RecordRef
}

Delegate is delegate reference from storage.

func (*Delegate) Type 

func (e *Delegate) Type() core.ReplyType

Type implementation of Reply interface.

type ErrType added in v0.6.0 

type ErrType int

ErrType is used to determine and compare reply errors. 

const (
	ErrHeavySyncInProgress ErrType = iota + 1
)

ErrHeavySyncInProgress returned when heavy sync in progress.

type Error added in v0.6.0 

type Error struct {
	ErrType ErrType
}

Error is common error reaction.

func (*Error) Error added in v0.6.0 

func (e *Error) Error() error

Error returns concrete error for stored type.

func (*Error) Type added in v0.6.0 

func (e *Error) Type() core.ReplyType

Type implementation of Reply interface.

type GetChildrenRedirectReply added in v0.7.5 

type GetChildrenRedirectReply struct {
	Receiver *core.RecordRef
	Token    core.DelegationToken

	FromChild core.RecordID
}

GetChildrenRedirectReply is a redirect reply for get children.

func NewGetChildrenRedirect added in v0.6.3 

func NewGetChildrenRedirect(
	factory core.DelegationTokenFactory, parcel core.Parcel, receiver *core.RecordRef, fromChild core.RecordID,
) (*GetChildrenRedirectReply, error)

NewGetChildrenRedirect creates a new instance of GetChildrenRedirectReply.

func (*GetChildrenRedirectReply) GetReceiver added in v0.7.5 

func (r *GetChildrenRedirectReply) GetReceiver() *core.RecordRef

GetReceiver returns node reference to send message to.

func (*GetChildrenRedirectReply) GetToken added in v0.7.5 

func (r *GetChildrenRedirectReply) GetToken() core.DelegationToken

GetToken returns delegation token.

func (*GetChildrenRedirectReply) Redirected added in v0.7.5 

func (r *GetChildrenRedirectReply) Redirected(genericMsg core.Message) core.Message

Redirected creates redirected message from redirect data.

func (*GetChildrenRedirectReply) Type added in v0.7.5 

func (r *GetChildrenRedirectReply) Type() core.ReplyType

Type returns type of the reply

type GetCodeRedirectReply added in v0.7.5 

type GetCodeRedirectReply struct {
	Receiver *core.RecordRef
	Token    core.DelegationToken
}

GetCodeRedirectReply is a redirect reply for get children.

func NewGetCodeRedirect added in v0.6.3 

func NewGetCodeRedirect(
	factory core.DelegationTokenFactory, parcel core.Parcel, receiver *core.RecordRef,
) (*GetCodeRedirectReply, error)

NewGetCodeRedirect creates a new instance of GetChildrenRedirectReply.

func (*GetCodeRedirectReply) GetReceiver added in v0.7.5 

func (r *GetCodeRedirectReply) GetReceiver() *core.RecordRef

GetReceiver returns node reference to send message to.

func (*GetCodeRedirectReply) GetToken added in v0.7.5 

func (r *GetCodeRedirectReply) GetToken() core.DelegationToken

GetToken returns delegation token.

func (*GetCodeRedirectReply) Redirected added in v0.7.5 

func (r *GetCodeRedirectReply) Redirected(genericMsg core.Message) core.Message

Redirected creates redirected message from redirect data.

func (*GetCodeRedirectReply) Type added in v0.7.5 

func (r *GetCodeRedirectReply) Type() core.ReplyType

Type returns type of the reply

type GetObjectRedirectReply added in v0.7.5 

type GetObjectRedirectReply struct {
	Receiver *core.RecordRef
	Token    core.DelegationToken

	StateID *core.RecordID
}

GetObjectRedirectReply is a redirect-reply for get object

func NewGetObjectRedirectReply added in v0.6.3 

func NewGetObjectRedirectReply(
	factory core.DelegationTokenFactory, parcel core.Parcel, receiver *core.RecordRef, state *core.RecordID,
) (*GetObjectRedirectReply, error)

NewGetObjectRedirectReply return new GetObjectRedirectReply

func (*GetObjectRedirectReply) GetReceiver added in v0.7.5 

func (r *GetObjectRedirectReply) GetReceiver() *core.RecordRef

GetReceiver returns node reference to send message to.

func (*GetObjectRedirectReply) GetToken added in v0.7.5 

func (r *GetObjectRedirectReply) GetToken() core.DelegationToken

GetToken returns delegation token.

func (*GetObjectRedirectReply) Redirected added in v0.7.5 

func (r *GetObjectRedirectReply) Redirected(genericMsg core.Message) core.Message

Redirected creates redirected message from redirect data.

func (*GetObjectRedirectReply) Type added in v0.7.5 

func (r *GetObjectRedirectReply) Type() core.ReplyType

Type returns type of the reply

type HasPendingRequests added in v0.7.5 

type HasPendingRequests struct {
	Has bool
}

HasPendingRequests contains unclosed requests for an object.

func (*HasPendingRequests) Type added in v0.7.5 

func (e *HasPendingRequests) Type() core.ReplyType

Type implementation of Reply interface.

type HeavyError added in v0.7.5 

type HeavyError struct {
	Message  string
	SubType  ErrType
	JetID    core.RecordID
	PulseNum core.PulseNumber
}

HeavyError carries heavy sync error information.

func (*HeavyError) ConcreteType added in v0.7.5 

func (e *HeavyError) ConcreteType() ErrType

ConcreteType returns concrete error type.

func (*HeavyError) Error added in v0.7.5 

func (e *HeavyError) Error() string

Error returns error message for stored type.

func (*HeavyError) IsRetryable added in v0.7.5 

func (e *HeavyError) IsRetryable() bool

IsRetryable returns true if retry could be performed.

func (*HeavyError) Type added in v0.7.5 

func (e *HeavyError) Type() core.ReplyType

Type implementation of Reply interface.

type ID added in v0.5.0 

type ID struct {
	ID core.RecordID
}

ID is common reaction for methods returning id to lifeline states.

func (*ID) Type added in v0.5.0 

func (e *ID) Type() core.ReplyType

Type implementation of Reply interface.

type Jet added in v0.7.5 

type Jet struct {
	ID     core.RecordID
	Actual bool
}

Jet contains jet.

func (*Jet) Type added in v0.7.5 

func (r *Jet) Type() core.ReplyType

Type implementation of Reply interface.

type JetMiss added in v0.7.5 

type JetMiss struct {
	JetID core.RecordID
	Pulse core.PulseNumber
}

JetMiss is returned for miscalculated jets due to incomplete jet tree.

func (*JetMiss) Type added in v0.7.5 

func (e *JetMiss) Type() core.ReplyType

Type implementation of Reply interface.

type NodeSign added in v0.7.5 

type NodeSign struct {
	Sign []byte
}

func (*NodeSign) GetSign added in v0.7.5 

func (e *NodeSign) GetSign() []byte

func (*NodeSign) Type added in v0.7.5 

func (e *NodeSign) Type() core.ReplyType

Type implementation of Reply interface.

type NodeSignInt added in v0.7.5 

type NodeSignInt interface {
	core.Reply
	GetSign() []byte
}

type NotOK added in v0.7.5 

type NotOK struct {
}

NotOK is a generic reply for signaling a negative result.

func (*NotOK) Type added in v0.7.5 

func (e *NotOK) Type() core.ReplyType

Type implementation of Reply interface.

type OK added in v0.6.0 

type OK struct {
}

OK is a generic reply for signaling a positive result.

func (*OK) Type added in v0.6.0 

func (e *OK) Type() core.ReplyType

Type implementation of Reply interface.

type Object 

type Object struct {
	Head         core.RecordRef
	State        core.RecordID
	Prototype    *core.RecordRef
	IsPrototype  bool
	ChildPointer *core.RecordID
	Memory       []byte
	Parent       core.RecordRef
}

Object is object from storage.

func (*Object) Type 

func (e *Object) Type() core.ReplyType

Type implementation of Reply interface.

type ObjectIndex added in v0.6.3 

type ObjectIndex struct {
	Index []byte
}

ObjectIndex contains serialized object index. It can be stored in DB without processing.

func (*ObjectIndex) Type added in v0.6.3 

func (e *ObjectIndex) Type() core.ReplyType

Type implementation of Reply interface.

type RegisterRequest added in v0.7.5 

type RegisterRequest struct {
	Request core.RecordRef
}

func (*RegisterRequest) Type added in v0.7.5 

func (r *RegisterRequest) Type() core.ReplyType

Type returns type of the reply

type Request added in v0.8.0 

type Request struct {
	ID     core.RecordID
	Record []byte
}

Request contains jet.

func (*Request) Type added in v0.8.0 

func (r *Request) Type() core.ReplyType

Type implementation of Reply interface.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.