core

package

Go to main page

Versions in this module

v0

v0.8.7

Apr 23, 2019

v0.8.6

Mar 22, 2019

v0.8.5

Mar 12, 2019

v0.8.4

Feb 26, 2019

v0.8.3

Feb 22, 2019

Changes in this version

type Certificate

+ GetMajorityRule func() int

+ GetMinRoles func() (virtual uint, heavyMaterial uint, lightMaterial uint)

v0.8.2

Feb 21, 2019

v0.8.1

Feb 21, 2019

v0.8.0

Feb 20, 2019

Changes in this version

+ const JetPrefixSize

+ const JetSize

+ var ErrNoNodes = errors.New("no matching nodes")

+ var ErrNoPendingRequest = errors.New("no pending requests are available")

+ var ErrNotFound = errors.New("Not found")

+ var ErrTooManyPendingRequests = errors.New("the limit of pending requests count has been reached")

type ArtifactManager

+ GetPendingRequest func(ctx context.Context, objectID RecordID) (Parcel, error)

type JetCoordinator

+ IsBeyondLimit func(ctx context.Context, currentPN, targetPN PulseNumber) (bool, error)

+ NodeForJet func(ctx context.Context, jetID RecordID, rootPN, targetPN PulseNumber) (*RecordRef, error)

+ NodeForObject func(ctx context.Context, objectID RecordID, rootPN, targetPN PulseNumber) (*RecordRef, error)

type MessageType

+ const TypeGetPendingRequestID

+ const TypeGetRequest

type Node

+ ConsensusAddress func() string

+ GetState func() NodeState

+ IsWorking func() bool

+ Leaving func() bool

+ LeavingETA func() PulseNumber

type NodeNetwork

+ GetState func() NodeNetworkState

+ GetWorkingNode func(ref RecordRef) Node

+ GetWorkingNodes func() []Node

+ GetWorkingNodesByRole func(role DynamicRole) []RecordRef

+ type NodeNetworkState uint8

+ const ReadyNodeNetworkState

+ const UndefinedNodeNetworkState

+ const WaitingNodeNetworkState

+ func (i NodeNetworkState) String() string

type NodeState

+ const NodeDiscovery

+ const NodeJoining

+ const NodeReady

+ func (i NodeState) String() string

+ type TerminationHandler interface

+ Abort func()

+ func NewTerminationHandler() TerminationHandler

v0.7.6

Jan 29, 2019

v0.7.5

Jan 29, 2019

Changes in this version

+ const PulseNumberCurrent

+ const PulseNumberJet

+ const RecordRefIDSeparator

+ var DomainID = *NewRecordID(0, nil)

+ var ErrHotDataTimeout = errors.New("requests were abandoned due to hot-data timeout")

+ var TODOJetID = *NewRecordID(PulseNumberJet, nil)

+ func KVSize(kvs []KV) (amount int64)

type Arguments

+ func (args *Arguments) MarshalJSON() ([]byte, error)

type ArtifactManager

+ HasPendingRequests func(ctx context.Context, object RecordRef) (bool, error)

+ type ArtifactManagerMessageHandler interface

+ CloseEarlyRequestCircuitBreakerForJet func(context.Context, RecordID)

+ ResetEarlyRequestCircuitBreaker func(context.Context)

+ type AuthorizationCertificate interface

+ GetDiscoverySigns func() map[*RecordRef][]byte

+ GetRole func() StaticRole

+ SerializeNodePart func() []byte

+ type CertificateManager interface

+ GetCertificate func() Certificate

+ NewUnsignedCertificate func(pKey string, role string, nodeRef string) (Certificate, error)

+ VerifyAuthorizationCertificate func(authCert AuthorizationCertificate) (bool, error)

type ContractRequester

+ CallConstructor func(ctx context.Context, base Message, async bool, prototype *RecordRef, ...) (*RecordRef, error)

+ CallMethod func(ctx context.Context, base Message, async bool, ref *RecordRef, method string, ...) (Reply, error)

type DynamicRole

+ func (r DynamicRole) IsVirtualRole() bool

type HeavySync

+ Reset func(ctx context.Context, jet RecordID, pn PulseNumber) error

type JetCoordinator

+ Heavy func(ctx context.Context, pulse PulseNumber) (*RecordRef, error)

+ LightExecutorForJet func(ctx context.Context, jetID RecordID, pulse PulseNumber) (*RecordRef, error)

+ LightExecutorForObject func(ctx context.Context, objID RecordID, pulse PulseNumber) (*RecordRef, error)

+ LightValidatorsForJet func(ctx context.Context, jetID RecordID, pulse PulseNumber) ([]RecordRef, error)

+ LightValidatorsForObject func(ctx context.Context, objID RecordID, pulse PulseNumber) ([]RecordRef, error)

+ Me func() RecordRef

+ VirtualExecutorForObject func(ctx context.Context, objID RecordID, pulse PulseNumber) (*RecordRef, error)

+ VirtualValidatorsForObject func(ctx context.Context, objID RecordID, pulse PulseNumber) ([]RecordRef, error)

type KeyProcessor

+ ExportPrivateKeyPEM func(crypto.PrivateKey) ([]byte, error)

+ ExportPublicKeyBinary func(crypto.PublicKey) ([]byte, error)

+ ExportPublicKeyPEM func(crypto.PublicKey) ([]byte, error)

+ ImportPrivateKeyPEM func([]byte) (crypto.PrivateKey, error)

+ ImportPublicKeyBinary func([]byte) (crypto.PublicKey, error)

+ ImportPublicKeyPEM func([]byte) (crypto.PublicKey, error)

type LogicCallContext

+ Mode string

type LogicRunner

+ HandleExecutorResultsMessage func(context.Context, Parcel) (res Reply, err error)

+ HandleValidateCaseBindMessage func(context.Context, Parcel) (res Reply, err error)

+ HandleValidationResultsMessage func(context.Context, Parcel) (res Reply, err error)

type Message

+ AllowedSenderObjectAndRole func() (*RecordRef, DynamicRole)

+ DefaultRole func() DynamicRole

+ DefaultTarget func() *RecordRef

type MessageBus

+ OnPulse func(context.Context, Pulse) error

type MessageType

+ const TypeAbandonedRequestsNotification

+ const TypeGetJet

+ const TypeGetPendingRequests

+ const TypeHeavyReset

+ const TypeHotRecords

+ const TypeNodeSignRequest

+ const TypePendingFinished

+ const TypeReturnResults

+ const TypeStillExecuting

+ const TypeValidationCheck

type NetworkCoordinator

+ IsStarted func() bool

type Node

+ GetGlobuleID func() GlobuleID

type Parcel

+ Pulse func() PulseNumber

type PlatformCryptographyScheme

+ PublicKeySize func() int

+ SignatureSIze func() int

+ type PulseDistributor interface

+ Distribute func(context.Context, Pulse)

+ type PulseStorage interface

+ Current func(ctx context.Context) (*Pulse, error)

type RecordID

+ func NewIDFromBase58(str string) (*RecordID, error)

+ func (id *RecordID) DebugString() string

type StaticRole

+ func (nr StaticRole) String() string

type SwitcherWorkAround

+ SetIsBootstrapped func(isBootstrap bool)

+ type TapeWriter interface

+ WriteTape func(ctx context.Context, writer io.Writer) error

v0.7.4-alpha

Jan 28, 2019

v0.7.3-alpha

Jan 24, 2019

v0.7.2-alpha

Jan 22, 2019

v0.7.1-alpha

Jan 21, 2019

v0.7.0-alpha

Jan 21, 2019

v0.6.3

Nov 30, 2018

Changes in this version

+ const DynamicRoleHeavyExecutor

+ const DynamicRoleLightExecutor

+ const DynamicRoleLightValidator

+ const DynamicRoleUndefined

+ const DynamicRoleVirtualExecutor

+ const DynamicRoleVirtualValidator

+ const OriginIDSize

+ const StaticRoleHeavyMaterial

+ const StaticRoleLightMaterial

+ const StaticRoleUnknown

+ const StaticRoleVirtual

+ var AllStaticRoles = []StaticRole

+ func ContextWithMessageBus(ctx context.Context, bus MessageBus) context.Context

+ func Deserialize(data []byte, to interface{}) error

+ func Serialize(o interface{}) ([]byte, error)

+ type APIRunner interface

+ IsAPIRunner func() bool

type ArtifactManager

+ State func() ([]byte, error)

type CaseBind

+ Requests []CaseRequest

type CaseBindReplay

+ CaseBind CaseBind

+ Record int

+ Request int

+ Steps int

+ func (r *CaseBindReplay) NextStep() (*CaseRecord, int)

type CaseRecordType

+ const CaseRecordTypeTraceID

+ type CaseRequest struct

+ Records []CaseRecord

+ Request interface{}

type Certificate

+ GetDiscoveryNodes func() []DiscoveryNode

+ GetRole func() StaticRole

+ GetRootDomainReference func() *RecordRef

+ SetRootDomainReference func(ref *RecordRef)

+ type ContractRequester interface

+ SendRequest func(ctx context.Context, ref *RecordRef, method string, argsIn []interface{}) (Reply, error)

+ type CryptographyService interface

+ GetPublicKey func() (crypto.PublicKey, error)

+ Sign func([]byte) (*Signature, error)

+ Verify func(crypto.PublicKey, Signature, []byte) bool

+ type DelegationToken interface

+ Type func() DelegationTokenType

+ Verify func(parcel Parcel) (bool, error)

+ type DelegationTokenFactory interface

+ IssueGetChildrenRedirect func(sender *RecordRef, redirectedMessage Message) (DelegationToken, error)

+ IssueGetCodeRedirect func(sender *RecordRef, redirectedMessage Message) (DelegationToken, error)

+ IssueGetObjectRedirect func(sender *RecordRef, redirectedMessage Message) (DelegationToken, error)

+ IssuePendingExecution func(msg Message, pulse PulseNumber) (DelegationToken, error)

+ Verify func(parcel Parcel) (bool, error)

+ type DelegationTokenType byte

+ const DTTypeGetChildrenRedirect

+ const DTTypeGetCodeRedirect

+ const DTTypeGetObjectRedirect

+ const DTTypePendingExecution

+ func (i DelegationTokenType) String() string

+ type DiscoveryNode interface

+ GetHost func() string

+ type DynamicRole int

+ type Genesis interface

+ type GenesisDataProvider interface

+ GetNodeDomain func(ctx context.Context) (*RecordRef, error)

+ GetRootDomain func(ctx context.Context) *RecordRef

+ GetRootMember func(ctx context.Context) (*RecordRef, error)

+ type GlobalInsolarLock interface

+ Acquire func(context.Context)

+ Release func(context.Context)

+ type GlobuleID uint32

+ type Hasher interface

+ Hash func([]byte) []byte

+ type HeavySync interface

+ Start func(ctx context.Context, pn PulseNumber) error

+ Stop func(ctx context.Context, pn PulseNumber) error

+ Store func(ctx context.Context, pn PulseNumber, kvs []KV) error

type JetCoordinator

+ GetActiveNodes func(pulse PulseNumber) ([]Node, error)

+ type KV struct

+ K []byte

+ V []byte

+ type KeyProcessor interface

+ ExportPrivateKey func(crypto.PrivateKey) ([]byte, error)

+ ExportPublicKey func(crypto.PublicKey) ([]byte, error)

+ ExtractPublicKey func(crypto.PrivateKey) crypto.PublicKey

+ GeneratePrivateKey func() (crypto.PrivateKey, error)

+ ImportPrivateKey func([]byte) (crypto.PrivateKey, error)

+ ImportPublicKey func([]byte) (crypto.PublicKey, error)

+ type KeyStore interface

+ GetPrivateKey func(string) (crypto.PrivateKey, error)

type Ledger

+ GetLocalStorage func() LocalStorage

+ type LocalStorage interface

+ Get func(ctx context.Context, pulse PulseNumber, key []byte) ([]byte, error)

+ Iterate func(ctx context.Context, pulse PulseNumber, prefix []byte, ...) error

+ Set func(ctx context.Context, pulse PulseNumber, key []byte, data []byte) error

type LogicCallContext

+ CallerPrototype *RecordRef

+ Code *RecordRef

type MessageBus

+ func MessageBusFromContext(ctx context.Context, fallback MessageBus) MessageBus

+ NewPlayer func(ctx context.Context, reader io.Reader) (MessageBus, error)

+ NewRecorder func(ctx context.Context) (MessageBus, error)

+ WriteTape func(ctx context.Context, writer io.Writer) error

+ type MessageSendOptions struct

+ Receiver *RecordRef

+ Token DelegationToken

+ func (o *MessageSendOptions) Safe() *MessageSendOptions

+ type MessageSignature interface

+ GetSender func() RecordRef

+ GetSign func() []byte

type MessageType

+ const TypeGetObjectIndex

+ const TypeHeavyPayload

+ const TypeHeavyStartStop

type Network

+ GetGlobuleID func() GlobuleID

type NetworkCoordinator

+ GetCert func(context.Context, RecordRef) (Certificate, error)

+ SetPulse func(ctx context.Context, pulse Pulse) error

+ ValidateCert func(context.Context, Certificate) (bool, error)

+ type NetworkState int

+ const AuthorizationNetworkState

+ const CompleteNetworkState

+ const JetlessNetworkState

+ const NoNetworkState

+ const VoidNetworkState

+ func (i NetworkState) String() string

+ type NetworkSwitcher interface

+ GetState func() NetworkState

+ OnPulse func(context.Context, Pulse) error

type Node

+ ID func() RecordRef

+ PhysicalAddress func() string

+ Pulse func() PulseNumber

+ Role func() StaticRole

+ ShortID func() ShortNodeID

+ type NodeMeta interface

+ GetNodeRef func() *RecordRef

+ GetPublicKey func() crypto.PublicKey

type NodeNetwork

+ GetCloudHash func() []byte

+ type Parcel interface

+ Context func(context.Context) context.Context

+ DelegationToken func() DelegationToken

+ Message func() Message

+ type PlatformCryptographyScheme interface

+ IntegrityHasher func() Hasher

+ ReferenceHasher func() Hasher

+ Signer func(crypto.PrivateKey) Signer

+ Verifier func(crypto.PublicKey) Verifier

type Pulse

+ EpochPulseNumber int

+ OriginID [OriginIDSize]byte

+ PrevPulseNumber PulseNumber

+ PulseTimestamp int64

type PulseNumber

+ func NewPulseNumber(buf []byte) PulseNumber

+ type PulseRange struct

+ Begin PulseNumber

+ End PulseNumber

+ func (pr *PulseRange) String() string

type RecordID

+ func (id *RecordID) Hash() []byte

+ func (id *RecordID) MarshalJSON() ([]byte, error)

+ func (id *RecordID) String() string

type RecordRef

+ func (ref *RecordRef) MarshalJSON() ([]byte, error)

+ func (ref RecordRef) Bytes() []byte

+ func (ref RecordRef) Compare(other RecordRef) int

+ func (ref RecordRef) FromSlice(from []byte) RecordRef

+ func (ref RecordRef) IsEmpty() bool

+ type RedirectReply interface

+ GetReceiver func() *RecordRef

+ GetToken func() DelegationToken

+ Redirected func(genericMsg Message) Message

+ type ShortNodeID uint32

type Signature

+ func SignatureFromBytes(raw []byte) Signature

+ func (s *Signature) Bytes() []byte

+ type Signer interface

+ Sign func([]byte) (*Signature, error)

+ type StaticRole int

+ func GetStaticRoleFromString(role string) StaticRole

+ type StorageExportResult struct

+ Data map[string]interface{}

+ NextFrom *PulseNumber

+ Size int

+ type StorageExporter interface

+ Export func(ctx context.Context, fromPulse PulseNumber, size int) (*StorageExportResult, error)

+ type SwitcherWorkAround interface

+ IsBootstrapped func() bool

+ type Verifier interface

+ Verify func(Signature, []byte) bool

v0.6.2

Nov 1, 2018

Changes in this version

+ var ErrStateNotAvailable = errors.New("object state is not available")

type ArtifactManager

+ ActivatePrototype func(ctx context.Context, domain, request, parent, code RecordRef, memory []byte) (ObjectDescriptor, error)

+ RegisterResult func(ctx context.Context, request RecordRef, payload []byte) (*RecordID, error)

+ RegisterValidation func(ctx context.Context, object RecordRef, state RecordID, isValid bool, ...) error

+ UpdatePrototype func(ctx context.Context, domain, request RecordRef, obj ObjectDescriptor, ...) (ObjectDescriptor, error)

type CaseRecordType

+ const CaseRecordTypeSignObject

type Components

+ NodeNetwork NodeNetwork

type LogicCallContext

+ Prototype *RecordRef

+ TraceID string

type MessageType

+ const TypeSetBlob

+ const TypeValidateRecord

+ type Node struct

+ Address string

+ NodeID RecordRef

+ PublicKey *ecdsa.PublicKey

+ PulseNum PulseNumber

+ Roles []NodeRole

+ State NodeState

+ Version string

+ type NodeNetwork interface

+ GetActiveNode func(ref RecordRef) *Node

+ GetActiveNodes func() []*Node

+ GetActiveNodesByRole func(role JetRole) []RecordRef

+ GetOrigin func() *Node

type ObjectDescriptor

+ ChildPointer func() *RecordID

+ Code func() (*RecordRef, error)

+ IsPrototype func() bool

+ Parent func() *RecordRef

+ Prototype func() (*RecordRef, error)

type RecordID

+ func NewRecordID(pulse PulseNumber, hash []byte) *RecordID

+ func (id *RecordID) Equal(other *RecordID) bool

+ func (id *RecordID) Pulse() PulseNumber

type RecordRef

+ func NewRecordRef(domain RecordID, record RecordID) *RecordRef

+ func (ref *RecordRef) Record() *RecordID

type SignedMessage

+ Context func(context.Context) context.Context

v0.6.1

Oct 23, 2018

Changes in this version

type ActiveNode

+ Address string

+ Roles []NodeRole

+ Version string

+ type ActiveNodeComponent interface

+ GetActiveNode func(ref RecordRef) *ActiveNode

+ GetActiveNodes func() []*ActiveNode

+ GetActiveNodesByRole func(role JetRole) []RecordRef

+ GetSelf func() *ActiveNode

type CaseRecordType

+ const CaseRecordTypeRequest

+ type Certificate interface

+ GetEcdsaPrivateKey func() *ecdsa.PrivateKey

+ GetPrivateKey func() (string, error)

+ GetPublicKey func() (string, error)

type Components

+ ActiveNodeComponent ActiveNodeComponent

+ Certificate Certificate

+ type Context interface

+ Log func() Logger

+ TraceID func() string

type Logger

+ WithField func(string, interface{}) Logger

+ WithFields func(map[string]interface{}) Logger

type LogicCallContext

+ Request *RecordRef

type MessageType

+ const TypeSetRecord

type Network

+ GetPrivateKey func() *ecdsa.PrivateKey

+ type Signature interface

+ GetSender func() RecordRef

+ GetSign func() []byte

+ IsValid func(key *ecdsa.PublicKey) bool

+ type SignedMessage interface

+ Message func() Message

v0.6.0

Oct 16, 2018

Changes in this version

+ const RoleHeavyMaterial

+ const RoleLightMaterial

+ const RoleUnknown

+ const RoleVirtual

+ var ErrDeactivated = errors.New("object is deactivated")

+ var ErrUnknown = errors.New("unknown error")

+ func UnMarshalResponse(resp []byte, typeHolders []interface{}) ([]interface{}, error)

type ActiveNode

+ Role NodeRole

type Arguments

+ func MarshalArgs(args ...interface{}) (Arguments, error)

type ArtifactManager

+ GenesisRef func() *RecordRef

type Bootstrapper

+ GetNodeDomainRef func() *RecordRef

+ Info func() ([]byte, error)

type CaseRecordType

+ const CaseRecordTypeDeactivateObject

+ const CaseRecordTypeGetObject

type Components

+ NetworkCoordinator NetworkCoordinator

type LogicRunner

+ ExecutorResults func(Message) (res Reply, err error)

+ ProcessValidationResults func(Message) (res Reply, err error)

+ ValidateCaseBind func(Message) (res Reply, err error)

type Message

+ GetSign func() []byte

+ SetSign func([]byte)

type MessageType

+ const TypeBootstrapRequest

+ const TypeExecutorResults

+ const TypeJetDrop

+ const TypeValidateCaseBind

+ const TypeValidationResults

+ type NetworkCoordinator interface

+ Authorize func(nodeRef RecordRef, seed []byte, signatureRaw []byte) (string, NodeRole, error)

+ RegisterNode func(publicKey string, role string) (*RecordRef, error)

+ WriteActiveNodes func(number PulseNumber, activeNodes []*ActiveNode) error

+ type NodeRole int

+ func GetRoleFromString(role string) NodeRole

type PulseSenderConfirmation

+ Entropy Entropy

+ PulseNumber PulseNumber

v0.5.0

Oct 9, 2018

Changes in this version

+ var GenesisPulse = &Pulse

type ArtifactManager

+ GetChildren func(parent RecordRef, pulse *PulseNumber) (RefIterator, error)

+ RegisterRequest func(message Message) (*RecordRef, error)

+ type CaseBind struct

+ Pulse Pulse

+ Records map[RecordRef][]CaseRecord

+ type CaseBindReplay struct

+ Fail int

+ Pulse Pulse

+ Records []CaseRecord

+ RecordsLen int

+ Step int

+ type CaseRecord struct

+ ReqSig []byte

+ Resp interface{}

+ Type CaseRecordType

+ type CaseRecordType int

+ const CaseRecordTypeGetDelegate

+ const CaseRecordTypeGetObjChildren

+ const CaseRecordTypeResult

+ const CaseRecordTypeRouteCall

+ const CaseRecordTypeSaveAsChild

+ const CaseRecordTypeSaveAsDelegate

+ const CaseRecordTypeStart

type ClassDescriptor

+ StateID func() *RecordID

type LogicRunner

+ Validate func(ref RecordRef, p Pulse, cr []CaseRecord) (int, error)

type MessageBus

+ MustRegister func(p MessageType, handler MessageHandler)

type MessageType

+ const TypeActivateClass

+ const TypeActivateObject

+ const TypeActivateObjectDelegate

+ const TypeCallConstructor

+ const TypeCallMethod

+ const TypeDeactivateClass

+ const TypeDeactivateObject

+ const TypeDeclareType

+ const TypeDeployCode

+ const TypeGetChildren

+ const TypeGetClass

+ const TypeGetCode

+ const TypeGetDelegate

+ const TypeGetObject

+ const TypeRegisterChild

+ const TypeRequestCall

+ const TypeUpdateClass

+ const TypeUpdateObject

+ func (i MessageType) String() string

type ObjectDescriptor

+ StateID func() *RecordID

type RecordID

+ func GenRecordID(pn PulseNumber, h []byte) (recid RecordID)

+ func (id *RecordID) Bytes() []byte

type RecordRef

+ func ComposeRecordRef(domain RecordID, record RecordID) (ref RecordRef)

+ func GenRequest(pn PulseNumber, payload []byte) *RecordRef

+ func (ref *RecordRef) GetDomainID() (id RecordID)

+ func (ref *RecordRef) GetRecordID() (id RecordID)

+ func (ref *RecordRef) SetDomain(recID RecordID)

+ func (ref *RecordRef) SetRecord(recID RecordID)

v0.4.1

Oct 3, 2018

v0.4.0

Oct 3, 2018

Changes in this version

+ const FirstPulseDate

+ const FirstPulseNumber

+ const NodeActive

+ const NodeJoined

+ const NodeLeaved

+ const NodePrepared

+ const NodeSuspended

+ func CalculateMsToNextPulse(previousPulse PulseNumber, now time.Time) time.Duration

+ type ActiveNode struct

+ JetRoles JetRoleMask

+ NodeID RecordRef

+ PublicKey []byte

+ PulseNum PulseNumber

+ State NodeState

type Components

+ MessageBus MessageBus

+ type JetRoleMask uint64

+ func (mask *JetRoleMask) Set(role JetRole)

+ func (mask *JetRoleMask) Unset(role JetRole)

+ func (mask JetRoleMask) IsSet(role JetRole) bool

type LogicRunner

+ OnPulse func(Pulse) error

type Message

+ GetCaller func() *RecordRef

+ Target func() *RecordRef

+ TargetRole func() JetRole

+ Type func() MessageType

+ type MessageBus interface

+ Register func(p MessageType, handler MessageHandler) error

+ Send func(Message) (Reply, error)

+ SendAsync func(Message)

+ type MessageHandler func(Message) (Reply, error)

+ type MessageType byte

+ type NodeState uint8

type Pulse

+ NextPulseNumber PulseNumber

+ Signs map[string]PulseSenderConfirmation

+ func (p *Pulse) PulseDuration() time.Duration

type PulseNumber

+ func CalculatePulseNumber(now time.Time) PulseNumber

+ type PulseSenderConfirmation struct

+ ChosenPublicKey string

+ Signature []byte

+ type RecordID [RecordIDSize]byte

type RecordRef

+ func RandomRef() RecordRef

+ type Reply interface

+ Type func() ReplyType

+ type ReplyType byte

v0.3.0

Sep 25, 2018

Changes in this version

type ArtifactManager

+ ActivateObject func(domain, request, class, parent RecordRef, memory []byte) (*RecordRef, error)

+ ActivateObjectDelegate func(domain, request, class, parent RecordRef, memory []byte) (*RecordRef, error)

+ DeactivateObject func(domain, request, obj RecordRef) (*RecordRef, error)

+ GetClass func(head RecordRef, state *RecordRef) (ClassDescriptor, error)

+ GetDelegate func(head, asClass RecordRef) (*RecordRef, error)

+ GetObject func(head RecordRef, state *RecordRef) (ObjectDescriptor, error)

+ UpdateObject func(domain, request, obj RecordRef, memory []byte) (*RecordRef, error)

type Components

+ APIRunner Component

+ Bootstrapper Bootstrapper

+ EventBus EventBus

+ Ledger Ledger

+ LogicRunner LogicRunner

+ Metrics Component

+ Network Network

+ type Event interface

+ GetOperatingRole func() JetRole

+ GetReference func() RecordRef

+ React func(Components) (Reaction, error)

+ Serialize func() (io.Reader, error)

+ type EventBus interface

+ Dispatch func(Event) (Reaction, error)

+ DispatchAsync func(Event)

type Ledger

+ HandleEvent func(Event) (Reaction, error)

type Logger

+ GetLevel func() string

+ SetOutput func(w io.Writer)

type Network

+ SendCascadeEvent func(data Cascade, method string, event Event) error

+ SendEvent func(nodeID RecordRef, method string, event Event) ([]byte, error)

type ObjectDescriptor

+ Children func() RefIterator

+ type Reaction interface

+ Serialize func() (io.Reader, error)

v0.2.0

Sep 18, 2018

Changes in this version

+ const EntropySize

+ const PulseNumberSize

+ const RecordHashSize

+ const RoleHeavyExecutor

+ const RoleLightExecutor

+ const RoleLightValidator

+ const RoleVirtualExecutor

+ const RoleVirtualValidator

+ type Bootstrapper interface

+ GetRootDomainRef func() *RecordRef

+ type Cascade struct

+ Entropy Entropy

+ NodeIds []RecordRef

+ ReplicationFactor uint

+ type Entropy [EntropySize]byte

type JetCoordinator

+ IsAuthorized func(role JetRole, obj RecordRef, pulse PulseNumber, node RecordRef) (bool, error)

+ QueryRole func(role JetRole, obj RecordRef, pulse PulseNumber) ([]RecordRef, error)

type Ledger

+ GetArtifactManager func() ArtifactManager

+ GetJetCoordinator func() JetCoordinator

+ GetPulseManager func() PulseManager

type Logger

+ Debugf func(string, ...interface{})

+ Errorf func(string, ...interface{})

+ Fatalf func(string, ...interface{})

+ Infof func(string, ...interface{})

+ Panicf func(string, ...interface{})

+ Warnf func(string, ...interface{})

type Message

+ GetOperatingRole func() JetRole

+ type Metrics interface

+ AddCounter func(name, componentName, help string) (prometheus.Counter, error)

+ AddGauge func(name, componentName, help string) (prometheus.Gauge, error)

type Network

+ GetNodeID func() RecordRef

+ SendCascadeMessage func(data Cascade, method string, msg Message) error

+ type Pulse struct

+ Entropy Entropy

+ PulseNumber PulseNumber

+ type PulseManager interface

+ Current func() (*Pulse, error)

+ Set func(pulse Pulse) error

type PulseNumber

+ func Bytes2PulseNumber(buf []byte) PulseNumber

+ func (pn PulseNumber) Bytes() []byte

type RecordRef

+ func NewRefFromBase58(str string) RecordRef

type Response

+ Serialize func() (io.Reader, error)

v0.0.6

Sep 13, 2018

Changes in this version

+ const HeavyExecutor

+ const LightExecutor

+ const LightValidator

+ const NoRole

+ const VirtualExecutor

+ const VirtualValidator

type ArtifactManager

+ ActivateObjDelegate func(domain, request, class, parent RecordRef, memory []byte) (*RecordRef, error)

+ GetLatestClass func(head RecordRef) (ClassDescriptor, error)

+ GetObjChildren func(head RecordRef) (RefIterator, error)

+ GetObjDelegate func(head, asClass RecordRef) (*RecordRef, error)

+ RootRef func() *RecordRef

type CodeDescriptor

+ MachineType func() (MachineType, error)

+ type JetCoordinator interface

+ AmI func(role JetRole, ref RecordRef, number PulseNumber) bool

+ GetHeavyExecutor func(pulse PulseNumber, ref RecordRef) NetworkAddress

+ GetLightExecutor func(pulse PulseNumber, ref RecordRef) NetworkAddress

+ GetLightValidators func(pulse PulseNumber, ref RecordRef) []NetworkAddress

+ GetVirtualExecutor func(pulse PulseNumber, ref RecordRef) NetworkAddress

+ GetVirtualValidators func(pulse PulseNumber, ref RecordRef) []NetworkAddress

+ IsIt func(role JetRole, ref RecordRef, number PulseNumber) bool

+ type JetID RecordRef

+ type JetRole int

+ type Logger interface

+ Debug func(...interface{})

+ Debugln func(...interface{})

+ Error func(...interface{})

+ Errorln func(...interface{})

+ Fatal func(...interface{})

+ Fatalln func(...interface{})

+ Info func(...interface{})

+ Infoln func(...interface{})

+ Panic func(...interface{})

+ Panicln func(...interface{})

+ SetLevel func(string) error

+ Warn func(...interface{})

+ Warnln func(...interface{})

+ type LogicCallContext struct

+ Callee *RecordRef

+ Caller *RecordRef

+ Class *RecordRef

+ Parent *RecordRef

+ Pulse uint64

+ Time time.Time

type MachineType

+ const MachineTypeNotExist

type Message

+ GetReference func() RecordRef

+ Serialize func() (io.Reader, error)

+ type NetworkAddress string

+ type PulseNumber uint32

+ type RefIterator interface

+ HasNext func() bool

+ Next func() (RecordRef, error)

v0.0.5

Sep 4, 2018

Changes in this version

+ const RecordIDSize

+ const RecordRefSize

+ type Arguments []byte

+ type ArtifactManager interface

+ ActivateClass func(domain, request, code RecordRef, memory []byte) (*RecordRef, error)

+ ActivateObj func(domain, request, class RecordRef, memory []byte) (*RecordRef, error)

+ AppendObjDelegate func(domain, request, obj RecordRef, memory []byte) (*RecordRef, error)

+ DeactivateClass func(domain, request, class RecordRef) (*RecordRef, error)

+ DeactivateObj func(domain, request, obj RecordRef) (*RecordRef, error)

+ DeclareType func(domain, request RecordRef, typeDec []byte) (*RecordRef, error)

+ DeployCode func(domain, request RecordRef, types []RecordRef, codeMap map[MachineType][]byte) (*RecordRef, error)

+ GetCode func(code RecordRef) (CodeDescriptor, error)

+ GetLatestObj func(head RecordRef) (ObjectDescriptor, error)

+ SetArchPref func(pref []MachineType)

+ UpdateClass func(domain, request, class, code RecordRef, migrationRefs []RecordRef) (*RecordRef, error)

+ UpdateObj func(domain, request, obj RecordRef, memory []byte) (*RecordRef, error)

+ type ClassDescriptor interface

+ CodeDescriptor func() (CodeDescriptor, error)

+ HeadRef func() *RecordRef

+ StateRef func() *RecordRef

+ type CodeDescriptor interface

+ Code func() ([]byte, error)

+ Ref func() *RecordRef

+ type Component interface

+ Start func(components Components) error

+ Stop func() error

+ type Components map[string]Component

+ type Ledger interface

+ GetManager func() ArtifactManager

+ type LogicRunner interface

+ Execute func(msg Message) (res *Response)

+ type MachineLogicExecutor interface

+ CallConstructor func(codeRef RecordRef, name string, args Arguments) (objectState []byte, err error)

+ CallMethod func(codeRef RecordRef, data []byte, method string, args Arguments) (newObjectState []byte, methodResults Arguments, err error)

+ Stop func() error

+ type MachineType int

+ const MachineTypeBuiltin

+ const MachineTypeGoPlugin

+ const MachineTypesLastID

+ type Message struct

+ Arguments Arguments

+ Caller struct{}

+ Constructor bool

+ Method string

+ Reference RecordRef

+ type MessageRouter interface

+ Route func(msg Message) (resp Response, err error)

+ type Network interface

+ GetAddress func() string

+ RemoteProcedureRegister func(name string, method RemoteProcedure)

+ SendMessage func(method string, msg *Message) ([]byte, error)

+ type ObjectDescriptor interface

+ ClassDescriptor func() (ClassDescriptor, error)

+ CodeDescriptor func() (CodeDescriptor, error)

+ HeadRef func() *RecordRef

+ Memory func() ([]byte, error)

+ StateRef func() *RecordRef

+ type RecordRef [RecordRefSize]byte

+ func String2Ref(str string) RecordRef

+ func (ref RecordRef) Domain() [RecordIDSize]byte

+ func (ref RecordRef) Equal(other RecordRef) bool

+ func (ref RecordRef) String() string

+ type RemoteProcedure func(args [][]byte) ([]byte, error)

+ type Response struct

+ Data []byte

+ Error error

+ Result []byte

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL