observer

package
v2.0.4+incompatible Latest Latest
Warning

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

 Go to latest Published: Oct 16, 2019 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Activate 

type Activate record.Material

func CastToActivate 

func CastToActivate(r interface{}) *Activate

func (*Activate) IsActivate 

func (a *Activate) IsActivate() bool

func (*Activate) Request 

func (a *Activate) Request() insolar.ID

type ActivateCollector 

type ActivateCollector interface {
	Collect(*Record) *CoupledActivate
}

type Amend 

type Amend record.Material

func CastToAmend 

func CastToAmend(r interface{}) *Amend

func (*Amend) IsAmend 

func (a *Amend) IsAmend() bool

type Balance 

type Balance struct {
	PrevState    insolar.ID
	AccountState insolar.ID
	Balance      string
}

type BalanceCollector 

type BalanceCollector interface {
	Collect(*Record) *Balance
}

type BalanceFilter 

type BalanceFilter interface {
	Filter(map[insolar.ID]*Balance, map[insolar.ID]*Member)
}

type Cache 

type Cache interface {
	Set(insolar.ID, interface{})
	Get(insolar.ID) interface{}
	Has(insolar.ID) bool
	Delete(insolar.ID)
}

type Chain 

type Chain struct {
	Parent interface{}
	Child  interface{}
}

type ChainCollector 

type ChainCollector interface {
	Collect(interface{}) *Chain
}

type CoupledActivate 

type CoupledActivate struct {
	Request  *Request
	Activate *Activate
}

type CoupledResult 

type CoupledResult struct {
	Request *Request
	Result  *Result
}

type Deactivate 

type Deactivate record.Material

func CastToDeactivate 

func CastToDeactivate(r interface{}) *Deactivate

func (*Deactivate) IsDeactivate 

func (a *Deactivate) IsDeactivate() bool

type Deposit 

type Deposit struct {
	EthHash         string
	Ref             insolar.ID
	Member          insolar.ID
	Timestamp       int64
	HoldReleaseDate int64
	Amount          string
	Balance         string
	DepositState    insolar.ID
}

type DepositCollector 

type DepositCollector interface {
	Collect(*Record) *Deposit
}

type DepositTransfer 

type DepositTransfer struct {
	Transfer
	EthHash string
}

DepositTransfer describes token moving from deposit account to the insolar member account.

type DepositUpdate 

type DepositUpdate struct {
	ID              insolar.ID
	HoldReleaseDate int64
	Amount          string
	Balance         string
	// Prev state record ID
	PrevState insolar.ID
}

type DepositUpdateCollector 

type DepositUpdateCollector interface {
	Collect(*Record) *DepositUpdate
}

type ExtendedTransfer 

type ExtendedTransfer struct {
	DepositTransfer
	TransferRequestMember  insolar.ID
	TransferRequestWallet  insolar.ID
	TransferRequestAccount insolar.ID
	AcceptRequestMember    insolar.ID
	AcceptRequestWallet    insolar.ID
	AcceptRequestAccount   insolar.ID
	CalcFeeRequest         insolar.ID
	FeeMemberRequest       insolar.ID
	CostCenterRef          insolar.ID
	FeeMemberRef           insolar.ID
}

type Member 

type Member struct {
	MemberRef        insolar.ID
	Balance          string
	MigrationAddress string
	AccountState     insolar.ID
	Status           string
}

Member describes insolar member.

type MemberCollector 

type MemberCollector interface {
	Collect(*Record) *Member
}

type MemberStorage 

type MemberStorage interface {
	Insert(*Member) error
	Update(*Balance) error
}

type MigrationAddress 

type MigrationAddress struct {
	Addr   string
	Pulse  insolar.PulseNumber
	Wasted bool
}

type MigrationAddressCollector 

type MigrationAddressCollector interface {
	Collect(*Record) []*MigrationAddress
}

type OriginFunc 

type OriginFunc func(interface{}) insolar.ID

type Predicate 

type Predicate func(interface{}) bool

type Pulse 

type Pulse struct {
	Number    insolar.PulseNumber
	Entropy   insolar.Entropy
	Timestamp int64
	Nodes     []insolar.Node
}

type PulseFetcher 

type PulseFetcher interface {
	Fetch(insolar.PulseNumber) (*Pulse, error)
}

type PulseStorage 

type PulseStorage interface {
	Insert(*Pulse) error
	Last() *Pulse
}

type Record 

type Record record.Material

func (*Record) Marshal 

func (r *Record) Marshal() ([]byte, error)

func (*Record) Unmarshal 

func (r *Record) Unmarshal(data []byte) error

type RecordFetcher 

type RecordFetcher interface {
	Fetch(insolar.PulseNumber) ([]*Record, error)
}

type RecordStorage 

type RecordStorage interface {
	Last() *Record
	Count(insolar.PulseNumber) uint32
	Insert(*Record) error
}

type Request 

type Request record.Material

func CastToRequest 

func CastToRequest(r interface{}) *Request

func (*Request) IsIncoming 

func (r *Request) IsIncoming() bool

func (*Request) IsMemberCall 

func (r *Request) IsMemberCall() bool

func (*Request) IsOutgoing 

func (r *Request) IsOutgoing() bool

func (*Request) ParseMemberCallArguments 

func (r *Request) ParseMemberCallArguments() member.Request

func (*Request) ParseMemberContractCallParams 

func (r *Request) ParseMemberContractCallParams(v interface{})

func (*Request) Reason 

func (r *Request) Reason() insolar.ID

type RequestCollector 

type RequestCollector interface {
	Collect(*Record)
}

type Result 

type Result record.Material

func CastToResult 

func CastToResult(r interface{}) *Result

func (*Result) IsResult 

func (r *Result) IsResult() bool

func (*Result) IsSuccess 

func (r *Result) IsSuccess() bool

func (*Result) ParseFirstPayloadValue 

func (r *Result) ParseFirstPayloadValue(v interface{})

func (*Result) ParsePayload 

func (r *Result) ParsePayload() (foundation.Result, error)

func (*Result) Request 

func (r *Result) Request() insolar.ID

type ResultCollector 

type ResultCollector interface {
	Collect(*Record) *CoupledResult
}

type Statistic 

type Statistic struct {
	Pulse              insolar.PulseNumber
	Transfers          int
	TotalTransfers     int
	TotalMembers       int
	MaxTransfers       int
	LastMonthTransfers int
	Nodes              int
}

type Status 

type Status string
const (
	PENDING  Status = "PENDING"
	SUCCESS  Status = "SUCCESS"
	CANCELED Status = "CANCELED"
)

type Transfer 

type Transfer struct {
	TxID      insolar.ID
	From      insolar.ID
	To        insolar.ID
	Amount    string
	Fee       string
	Timestamp int64
	Pulse     insolar.PulseNumber
}

Transfer describes token moving between the insolar members.

type TransferCollector 

type TransferCollector interface {
	Collect(*Record) *DepositTransfer
}

type TransferStorage 

type TransferStorage interface {
	Insert(*Transfer) error
}

type Wasting 

type Wasting struct {
	Addr string
}

type WastingCollector 

type WastingCollector interface {
	Collect(*Record) []*Wasting
}

Source Files

View all Source files

Directories

Path Synopsis
cache

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.