chainsync

package

v0.32.5 Latest Latest Go to latest Published: Sep 24, 2025 License: Apache-2.0 Imports: 9 Imported by: 2

Details

This section is empty.

This section is empty.

func NewFromCmdlineOptions() plugin.Plugin

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

func New(options ...ChainSyncOptionFunc) *ChainSync

New returns a new ChainSync object with the specified options applied

func (c *ChainSync) ErrorChan() chan error

ErrorChan returns the filter error channel

func (c *ChainSync) InputChan() chan<- event.Event

InputChan returns the input event channel

func (c *ChainSync) OutputChan() <-chan event.Event

OutputChan returns the output event channel

func (c *ChainSync) Start() error

Start the chain sync filter

func (c *ChainSync) Stop() error

Stop the chain sync filter

type ChainSyncOptionFunc func(*ChainSync)

func WithAddresses(addresses []string) ChainSyncOptionFunc

WithAddresses specfies the address to filter on

func WithAssetFingerprints(assetFingerprints []string) ChainSyncOptionFunc

WithAssetFingerprints specifies the asset fingerprint (asset1xxx) to filter on

func WithLogger(logger plugin.Logger) ChainSyncOptionFunc

WithLogger specifies the logger object to use for logging messages

func WithPolicies(policyIds []string) ChainSyncOptionFunc

WithPolicies specfies the address to filter on

func WithPoolIds(poolIds []string) ChainSyncOptionFunc

WithPoolIds specifies the pool to filter on