maint

package

v0.3.0 Latest Latest Go to latest Published: May 23, 2024 License: Apache-2.0 Imports: 21 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type CheckFollows struct {
	Delete     bool
	Processed  int
	BadFollows int
}

func NewCheckFollows(delete bool) *CheckFollows

func (c *CheckFollows) Check() error

type PopulateAddr struct {
	Checked int64
	Saved   int64
	Inputs  bool
	// contains filtered or unexported fields
}

func NewPopulateAddr(inputs bool) *PopulateAddr

func (p *PopulateAddr) GetHasError() bool

func (p *PopulateAddr) GetShardStatus(shard uint32) *item.ProcessStatus

func (p *PopulateAddr) GetStatusName() string

func (p *PopulateAddr) Populate(newRun bool) error

func (p *PopulateAddr) SetHasError(hasError bool)

func (p *PopulateAddr) SetShardStatus(shard uint32, status []byte)

type PopulateP2sh struct {
	BlocksProcessed int
	Ctx             context.Context
}

func NewPopulateP2sh(ctx context.Context) *PopulateP2sh

func (p *PopulateP2sh) Populate(startHeight int64) error

type PopulateP2shDirect struct {
	Checked int64
	Saved   int64
	Ctx     context.Context
	// contains filtered or unexported fields
}

func NewPopulateP2shDirect(ctx context.Context) *PopulateP2shDirect

func (p *PopulateP2shDirect) GetHasError() bool

func (p *PopulateP2shDirect) GetShardStatus(shard uint32) *item.ProcessStatus

func (p *PopulateP2shDirect) Populate(newRun bool) error

func (p *PopulateP2shDirect) SetHasError(hasError bool)

func (p *PopulateP2shDirect) SetShardStatus(shard uint32, status []byte)

type PopulateSeenPost struct {
	Posts int
	Ctx   context.Context
}

func NewPopulateSeenPost(ctx context.Context) *PopulateSeenPost

func (p *PopulateSeenPost) Populate() error

type ShardProcess struct {
	Errors []error
	Mutex  sync.Mutex
	Wg     sync.WaitGroup
}

func (p *ShardProcess) AddError(shard uint32, err error)