bertyreplication

Documentation

Index

• func DBForTests(t testing.TB, logger *zap.Logger) *gorm.DB
• func TestHelperNewReplicationService(ctx context.Context, t *testing.T, logger *zap.Logger, mn mocknet.Mocknet, ...) (*replicationService, ipfsutil.CoreAPIMock)
• func TestReplicateMessage(t *testing.T)
• 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

Functions

func DBForTests

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

func TestHelperNewReplicationService

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

func TestReplicateMessage

func TestReplicateMessage(t *testing.T)

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 {
	CoreAPI ipfsutil.CoreAPIMock
	Service ReplicationService
}

func NewReplicationMockedPeer

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