crdttest

type ITestBroadcaster interface {
	crdt.Broadcaster

	AddPeer(t *testing.T, peer interface{})
}

type ITestStore interface {
	crdt.Store

	Events(context.Context) ([]*types.Event, error)
	Heads(context.Context) ([]multihash.Multihash, error)
	InsertNewEvents(context.Context, []*types.Event) error

	Close() error
}

type ITestSyncer interface {
	crdt.Syncer

	AddPeer(peer interface{})
	AddStoreEvents(context.Context, []*types.Event) error
}

type TestBroadcaster struct {
	ITestBroadcaster
	// contains filtered or unexported fields
}

type TestBroadcasterMaker func(t *testing.T) *TestBroadcaster

type TestStore struct {
	ITestStore
	// contains filtered or unexported fields
}

type TestStoreMaker func(t *testing.T) *TestStore

type TestSyncer struct {
	ITestSyncer
	// contains filtered or unexported fields
}

type TestSyncerMaker func(t *testing.T) *TestSyncer