aggregator

package
v1.0.1 Latest Latest
Warning

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

Go to latest
Published: Apr 29, 2022 License: AGPL-3.0 Imports: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Aggregator

type Aggregator struct {
	HashItems    goconcurrentqueue.Queue //In
	Logger       log.Logger
	LatestTime   string
	Aggregations goconcurrentqueue.Queue //Out
	AggMutex     sync.Mutex
	RestartMutex sync.Mutex
	QueueMutex   sync.Mutex
	TempStop     chan struct{}
	WaitGroup    sync.WaitGroup
	UlidGen      *threadsafe_ulid.ThreadSafeUlid
}

Aggregator : object includes rabbitURI and Logger

func (*Aggregator) AddHashItem

func (aggregator *Aggregator) AddHashItem(item types.HashItem)

func (*Aggregator) AggregateAndReset

func (aggregator *Aggregator) AggregateAndReset() []types.Aggregation

func (*Aggregator) HeadHashItem

func (aggregator *Aggregator) HeadHashItem() types.HashItem

func (*Aggregator) ProcessAggregation

func (aggregator *Aggregator) ProcessAggregation(msgStructSlice []types.HashItem, drand string) types.Aggregation

ProcessAggregation creates merkle trees of received hashes a la https://github.com/chainpoint/chainpoint-services/blob/develop/node-aggregator-service/server.js#L66

func (*Aggregator) StartAggregation

func (aggregator *Aggregator) StartAggregation() error

ReceiveCalRMQ : Continually consume the calendar work queue and process any resulting messages from the tx and monitor services

Jump to

Keyboard shortcuts

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