bertyreplication

Documentation

Index

• func DBForTests(t testing.TB, logger *zap.Logger) (*gorm.DB, func())
• func TestHelperNewReplicationService(ctx context.Context, t *testing.T, logger *zap.Logger, ...) *replicationService
• type BertyOrbitDB
• type ReplicationClient
• type ReplicationService
  • func NewReplicationService(ctx context.Context, db *gorm.DB, odb BertyOrbitDB, logger *zap.Logger) (ReplicationService, error)
• type TestingReplicationPeer
  • func NewReplicationMockedPeer(ctx context.Context, t *testing.T, secret []byte, sk ed25519.PublicKey, ...) (*TestingReplicationPeer, func())

Functions

func DBForTests

func DBForTests(t testing.TB, logger *zap.Logger) (*gorm.DB, func())

func TestHelperNewReplicationService

func TestHelperNewReplicationService(ctx context.Context, t *testing.T, logger *zap.Logger, mn libp2p_mocknet.Mocknet, msrv *tinder.MockDriverServer, ds datastore.Batching, db *gorm.DB) *replicationService

Types

type BertyOrbitDB

type BertyOrbitDB interface {
	OpenGroupReplication(ctx context.Context, g *protocoltypes.Group, options *orbitdb.CreateDBOptions) (iface.Store, iface.Store, error)
	IsGroupLoaded(groupID string) bool
}

type ReplicationClient

type ReplicationClient interface {
	replicationtypes.ReplicationServiceClient

	Close() error
}

type ReplicationService

type ReplicationService interface {
	replicationtypes.ReplicationServiceServer

	Close() error
}

func NewReplicationService

func NewReplicationService(ctx context.Context, db *gorm.DB, odb BertyOrbitDB, logger *zap.Logger) (ReplicationService, error)

type TestingReplicationPeer

type TestingReplicationPeer struct {
	Service ReplicationService
}

func NewReplicationMockedPeer

func NewReplicationMockedPeer(ctx context.Context, t *testing.T, secret []byte, sk ed25519.PublicKey, opts *bertyprotocol.TestingOpts) (*TestingReplicationPeer, func())