mbootstrap

type BalancePort ¶

type BalancePort interface {
	// CreateBalanceSync creates a balance synchronously and returns the created balance.
	// Named "Sync" to distinguish from the async queue-based CreateBalance in transaction module.
	CreateBalanceSync(ctx context.Context, input mmodel.CreateBalanceInput) (*mmodel.Balance, error)

	// DeleteAllBalancesByAccountID deletes all balances for a given account.
	DeleteAllBalancesByAccountID(ctx context.Context, organizationID, ledgerID, accountID uuid.UUID, requestID string) error

	// CheckHealth verifies the balance service is available.
	// In unified mode (in-process), returns nil immediately.
	// In microservices mode (gRPC), checks gRPC connection health.
	CheckHealth(ctx context.Context) error
}

BalancePort defines the interface for balance operations. This is a transport-agnostic "port" that abstracts how the onboarding module communicates with the transaction module.

This interface is implemented by:

• transaction.UseCase: Direct implementation (unified ledger mode)
• GRPCBalanceAdapter: Network calls via gRPC (separate services mode)

The onboarding module's UseCase depends on this port, allowing it to work with either implementation without knowing the underlying transport mechanism.

In unified ledger mode, the transaction.UseCase is passed directly to onboarding, eliminating the need for intermediate adapters and enabling zero-overhead in-process calls.

type MetadataIndexRepository ¶

type MetadataIndexRepository interface {
	// CreateIndex creates a new index on a metadata field in the specified collection.
	// The collection parameter is the entity name (e.g., "transaction", "account").
	CreateIndex(ctx context.Context, collection string, input *mmodel.CreateMetadataIndexInput) (*mmodel.MetadataIndex, error)

	// FindAllIndexes retrieves all indexes from the specified collection.
	// Returns metadata indexes with their configuration (unique, sparse, etc.).
	FindAllIndexes(ctx context.Context, collection string) ([]*mmodel.MetadataIndex, error)

	// DeleteIndex removes an index from the specified collection.
	// The indexName should be the full MongoDB index name (e.g., "metadata.tier_1").
	DeleteIndex(ctx context.Context, collection, indexName string) error
}

MetadataIndexRepository defines the interface for metadata index operations on MongoDB. This interface is implemented by the MongoDB metadata repositories in both onboarding and transaction components, allowing direct access in unified ledger mode.

Implementations:

• onboarding/internal/adapters/mongodb.MetadataMongoDBRepository
• transaction/internal/adapters/mongodb.MetadataMongoDBRepository

type MockBalancePort ¶

type MockBalancePort struct {
	// contains filtered or unexported fields
}

MockBalancePort is a mock of BalancePort interface.

func NewMockBalancePort(ctrl *gomock.Controller) *MockBalancePort

func (m *MockBalancePort) CheckHealth(arg0 context.Context) error

func (m *MockBalancePort) CreateBalanceSync(arg0 context.Context, arg1 mmodel.CreateBalanceInput) (*mmodel.Balance, error)

func (m *MockBalancePort) DeleteAllBalancesByAccountID(arg0 context.Context, arg1, arg2, arg3 uuid.UUID, arg4 string) error

func (m *MockBalancePort) EXPECT() *MockBalancePortMockRecorder

type MockBalancePortMockRecorder ¶

type MockBalancePortMockRecorder struct {
	// contains filtered or unexported fields
}

MockBalancePortMockRecorder is the mock recorder for MockBalancePort.

func (mr *MockBalancePortMockRecorder) CheckHealth(arg0 any) *gomock.Call

func (mr *MockBalancePortMockRecorder) CreateBalanceSync(arg0, arg1 any) *gomock.Call

func (mr *MockBalancePortMockRecorder) DeleteAllBalancesByAccountID(arg0, arg1, arg2, arg3, arg4 any) *gomock.Call

type MockMetadataIndexRepository ¶

type MockMetadataIndexRepository struct {
	// contains filtered or unexported fields
}

MockMetadataIndexRepository is a mock of MetadataIndexRepository interface.

func NewMockMetadataIndexRepository(ctrl *gomock.Controller) *MockMetadataIndexRepository

func (m *MockMetadataIndexRepository) CreateIndex(arg0 context.Context, arg1 string, arg2 *mmodel.CreateMetadataIndexInput) (*mmodel.MetadataIndex, error)

func (m *MockMetadataIndexRepository) DeleteIndex(arg0 context.Context, arg1, arg2 string) error

func (m *MockMetadataIndexRepository) EXPECT() *MockMetadataIndexRepositoryMockRecorder

func (m *MockMetadataIndexRepository) FindAllIndexes(arg0 context.Context, arg1 string) ([]*mmodel.MetadataIndex, error)

type MockMetadataIndexRepositoryMockRecorder ¶

type MockMetadataIndexRepositoryMockRecorder struct {
	// contains filtered or unexported fields
}

MockMetadataIndexRepositoryMockRecorder is the mock recorder for MockMetadataIndexRepository.

func (mr *MockMetadataIndexRepositoryMockRecorder) CreateIndex(arg0, arg1, arg2 any) *gomock.Call

func (mr *MockMetadataIndexRepositoryMockRecorder) DeleteIndex(arg0, arg1, arg2 any) *gomock.Call

func (mr *MockMetadataIndexRepositoryMockRecorder) FindAllIndexes(arg0, arg1 any) *gomock.Call

type Runnable ¶

type Runnable interface {
	Run(l *libCommons.Launcher) error
}

Runnable represents a component that can be run by the launcher. This interface is compatible with libCommons.NewLauncher's RunApp function.

type RunnableConfig ¶

type RunnableConfig struct {
	Name     string
	Runnable Runnable
}

RunnableConfig pairs a runnable with its name for the launcher.

type Service ¶

type Service interface {
	// GetRunnables returns all runnable components of this service.
	// These will be passed to libCommons.NewLauncher for execution.
	GetRunnables() []RunnableConfig
}

Service represents a bootstrapped service that can be composed into a unified deployment. Each component (onboarding, transaction) implements this interface to expose its runnable components for composition.