fraud

Mar 14, 2023

Changes in this version

+ var GossibSubScore = pubsub.TopicScoreParams

+ func PubsubTopicID(fraudType, networkID string) string

type ProofType

+ func Registered() []ProofType

+ func (pt ProofType) String() string

Dec 13, 2022

Changes in this version

type ProofService

+ func CreateTestService(t *testing.T, enabledSyncer bool) (*ProofService, *mockStore)

Oct 17, 2022

Changes in this version

+ func WithMetrics(store Getter)

Sep 13, 2022

Changes in this version

+ func OnProof(ctx context.Context, subscriber Subscriber, p ProofType, ...)

+ func Register(p Proof)

+ type BadEncodingProof struct

+ Axis rsmt2d.Axis

+ BlockHeight uint64

+ Index uint32

+ Shares []*ipld.ShareWithProof

+ func (p *BadEncodingProof) HeaderHash() []byte

+ func (p *BadEncodingProof) Height() uint64

+ func (p *BadEncodingProof) MarshalBinary() ([]byte, error)

+ func (p *BadEncodingProof) Type() ProofType

+ func (p *BadEncodingProof) UnmarshalBinary(data []byte) error

+ func (p *BadEncodingProof) Validate(header *header.ExtendedHeader) error

+ type Broadcaster interface

+ Broadcast func(context.Context, Proof) error

+ type DummyService struct

+ func (d *DummyService) Broadcast(context.Context, Proof) error

+ func (d *DummyService) Get(context.Context, ProofType) ([]Proof, error)

+ func (d *DummyService) Subscribe(ProofType) (Subscription, error)

+ type ErrFraudExists struct

+ Proof []Proof

+ func (e *ErrFraudExists) Error() string

+ type Getter interface

+ Get func(context.Context, ProofType) ([]Proof, error)

+ type Proof interface

+ HeaderHash func() []byte

+ Height func() uint64

+ Type func() ProofType

+ Validate func(*header.ExtendedHeader) error

+ func CreateBadEncodingProof(hash []byte, height uint64, errByzantine *ipld.ErrByzantine) Proof

+ func Unmarshal(proofType ProofType, msg []byte) (Proof, error)

+ type ProofService struct

+ func NewProofService(p *pubsub.PubSub, host host.Host, getter headerFetcher, ds datastore.Datastore, ...) *ProofService

+ func (f *ProofService) Broadcast(ctx context.Context, p Proof) error

+ func (f *ProofService) Get(ctx context.Context, proofType ProofType) ([]Proof, error)

+ func (f *ProofService) Start(context.Context) error

+ func (f *ProofService) Stop(context.Context) error

+ func (f *ProofService) Subscribe(proofType ProofType) (_ Subscription, err error)

+ type ProofType string

+ const BadEncoding

+ type ProofUnmarshaler func([]byte) (Proof, error)

+ type Service interface

+ type Subscriber interface

+ Subscribe func(ProofType) (Subscription, error)

+ type Subscription interface

+ Cancel func()

+ Proof func(context.Context) (Proof, error)