collecting

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: 20 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ActivateCollector

type ActivateCollector struct {
	// contains filtered or unexported fields
}

func NewActivateCollector

func NewActivateCollector(properRequest, properActivate observer.Predicate) *ActivateCollector

func (*ActivateCollector) Collect

type BalanceCollector

type BalanceCollector struct {
	// contains filtered or unexported fields
}

func NewBalanceCollector

func NewBalanceCollector(log *logrus.Logger) *BalanceCollector

func (*BalanceCollector) Collect

func (c *BalanceCollector) Collect(rec *observer.Record) *observer.Balance

type BoundCollector

type BoundCollector struct {
	// contains filtered or unexported fields
}

func NewBoundCollector

func NewBoundCollector(originRequest, properResult, directRequest, properActivate observer.Predicate) *BoundCollector

func (*BoundCollector) Collect

func (c *BoundCollector) Collect(rec *observer.Record) *BoundCouple

type BoundCouple

type BoundCouple struct {
	Result   *observer.Result
	Activate *observer.Activate
}

type ChainCollector

type ChainCollector struct {
	// contains filtered or unexported fields
}

func NewChainCollector

func NewChainCollector(
	parent *RelationDesc, child *RelationDesc,
) *ChainCollector

func (*ChainCollector) Collect

func (c *ChainCollector) Collect(chain interface{}) *observer.Chain

type DepositCollector

type DepositCollector struct {
	// contains filtered or unexported fields
}

func NewDepositCollector

func NewDepositCollector(log *logrus.Logger) *DepositCollector

func (*DepositCollector) Collect

func (c *DepositCollector) Collect(rec *observer.Record) *observer.Deposit

type DepositUpdateCollector

type DepositUpdateCollector struct {
	// contains filtered or unexported fields
}

func NewDepositUpdateCollector

func NewDepositUpdateCollector(log *logrus.Logger) *DepositUpdateCollector

func (*DepositUpdateCollector) Collect

type ExtendedTransferCollector

type ExtendedTransferCollector struct {
	// contains filtered or unexported fields
}

func NewExtendedTransferCollector

func NewExtendedTransferCollector(log *logrus.Logger) *ExtendedTransferCollector

func (*ExtendedTransferCollector) Collect

type MemberCollector

type MemberCollector struct {
	// contains filtered or unexported fields
}

func NewMemberCollector

func NewMemberCollector() *MemberCollector

func (*MemberCollector) Collect

func (c *MemberCollector) Collect(rec *observer.Record) *observer.Member

type MigrationAddressCollector

type MigrationAddressCollector struct {
	// contains filtered or unexported fields
}

func NewMigrationAddressesCollector

func NewMigrationAddressesCollector() *MigrationAddressCollector

func (*MigrationAddressCollector) Collect

type RelationDesc

type RelationDesc struct {
	Is     observer.Predicate
	Origin observer.OriginFunc
	Proper observer.Predicate
}

type ResultCollector

type ResultCollector struct {
	// contains filtered or unexported fields
}

func NewResultCollector

func NewResultCollector(properRequest, properResult observer.Predicate) *ResultCollector

func (*ResultCollector) Collect

func (c *ResultCollector) Collect(record *observer.Record) *observer.CoupledResult

type TransferCollector

type TransferCollector struct {
	// contains filtered or unexported fields
}

func NewTransferCollector

func NewTransferCollector(log *logrus.Logger) *TransferCollector

func (*TransferCollector) Collect

type WastingCollector

type WastingCollector struct {
	// contains filtered or unexported fields
}

func NewWastingCollector

func NewWastingCollector() *WastingCollector

func (*WastingCollector) Collect

func (c *WastingCollector) Collect(rec *observer.Record) *observer.Wasting

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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