Documentation
¶
Index ¶
- Constants
- func CleanupInstanceByKey(ctx context.Context, instanceName string)
- func CleanupInstanceByValue(ctx context.Context, instance interface{})
- func ClearInstancesTestHelper(t *testing.T)
- func GetInstance(instanceName string) (interface{}, bool)
- func NewAdminDBConnectionPool(ctx context.Context, opts DBConnectionPoolOptions) (db.DBConnectionPool, error)
- func NewAnchorPlatformAPIService(anchorPlatformBasePlatformURL, anchorPlatformOutgoingJWTSecret string) (anchorplatform.AnchorPlatformAPIServiceInterface, error)
- func NewCrashTracker(ctx context.Context, opts crashtracker.CrashTrackerOptions) (crashtracker.CrashTrackerClient, error)
- func NewDistributionAccountResolver(ctx context.Context, opts signing.DistributionAccountResolverOptions) (signing.DistributionAccountResolver, error)
- func NewEmailClient(opts EmailClientOptions) (message.MessengerClient, error)
- func NewHorizonClient(ctx context.Context, horizonURL string) (horizonclient.ClientInterface, error)
- func NewLedgerNumberTracker(ctx context.Context, horizonClient horizonclient.ClientInterface) (preconditions.LedgerNumberTracker, error)
- func NewMtnDBConnectionPool(ctx context.Context, opts DBConnectionPoolOptions) (db.DBConnectionPool, error)
- func NewSMSClient(opts SMSClientOptions) (message.MessengerClient, error)
- func NewSignatureService(ctx context.Context, opts signing.SignatureServiceOptions) (signing.SignatureService, error)
- func NewTSSDBConnectionPool(ctx context.Context, opts DBConnectionPoolOptions) (db.DBConnectionPool, error)
- func NewTxSubmitterEngine(ctx context.Context, opts TxSubmitterEngineOptions) (engine.SubmitterEngine, error)
- func SetInstance(instanceName string, instance interface{})
- type DBConnectionPoolOptions
- type EmailClientOptions
- type SMSClientOptions
- type TxSubmitterEngineOptions
Constants ¶
const AdminDBConnectionPoolInstanceName = "admin_db_connection_pool_instance"
const CrashTrackerInstanceName = "crash_tracker_instance"
const DistributionAccountResolverInstanceName = "distribution_account_resolver_instance"
const EmailClientInstanceName = "email_client_instance"
const HorizonClientInstanceName = "horizon_client_instance"
const LedgerNumberTrackerInstanceName = "ledger_number_tracker_instance"
const MtnDBConnectionPoolInstanceName = "mtn_db_connection_pool_instance"
const SMSClientInstanceName = "sms_client_instance"
const SignatureServiceInstanceName = "signature_service_instance"
const TSSDBConnectionPoolInstanceName = "tss_db_connection_pool_instance"
const TxSubmitterEngineInstanceName = "tx_submitter_engine_instance"
Variables ¶
This section is empty.
Functions ¶
func CleanupInstanceByKey ¶
CleanupInstanceByKey removes a service instance from the store by key and test if it is closeable, in which case, its Close() method is called.
func CleanupInstanceByValue ¶
CleanupInstanceByValue removes a service instance from the store by value and checks if it is closeable, in which case, its Close() method is called.
func GetInstance ¶
GetInstance retrieves a service instance by name from the store.
func NewAdminDBConnectionPool ¶
func NewAdminDBConnectionPool(ctx context.Context, opts DBConnectionPoolOptions) (db.DBConnectionPool, error)
NewAdminDBConnectionPool creates a new admin db connection pool instance, or retrives an instance that was already created before.
func NewAnchorPlatformAPIService ¶
func NewAnchorPlatformAPIService(anchorPlatformBasePlatformURL, anchorPlatformOutgoingJWTSecret string) (anchorplatform.AnchorPlatformAPIServiceInterface, error)
func NewCrashTracker ¶
func NewCrashTracker(ctx context.Context, opts crashtracker.CrashTrackerOptions) (crashtracker.CrashTrackerClient, error)
NewCrashTracker creates a new crash tracker instance, or retrives a instance that was already created before.
func NewDistributionAccountResolver ¶
func NewDistributionAccountResolver(ctx context.Context, opts signing.DistributionAccountResolverOptions) (signing.DistributionAccountResolver, error)
NewDistributionAccountResolver creates a new distribution account resolver instance, or retrieves an instance that was already created before.
func NewEmailClient ¶
func NewEmailClient(opts EmailClientOptions) (message.MessengerClient, error)
NewEmailClient creates a new email client instance, or retrives a instance that was already created before.
func NewHorizonClient ¶
func NewHorizonClient(ctx context.Context, horizonURL string) (horizonclient.ClientInterface, error)
NewHorizonClient creates a new horizon client instance, or retrives an instance that was already created before.
func NewLedgerNumberTracker ¶
func NewLedgerNumberTracker(ctx context.Context, horizonClient horizonclient.ClientInterface) (preconditions.LedgerNumberTracker, error)
NewLedgerNumberTracker creates a new ledger number tracker instance, or retrives an instance that was already created before.
func NewMtnDBConnectionPool ¶
func NewMtnDBConnectionPool(ctx context.Context, opts DBConnectionPoolOptions) (db.DBConnectionPool, error)
NewMtnDBConnectionPool creates a new multitenant db connection pool instance, or retrives an instance that was already created before. The multitenant db connection pool is used to connect to the tenant's databases based on the tenant found in the context.
func NewSMSClient ¶
func NewSMSClient(opts SMSClientOptions) (message.MessengerClient, error)
NewSMSClient creates a new SMS client instance, or retrives a instance that was already created before.
func NewSignatureService ¶
func NewSignatureService(ctx context.Context, opts signing.SignatureServiceOptions) (signing.SignatureService, error)
NewSignatureService creates a new signature service instance, or retrieves an instance that was already created before.
func NewTSSDBConnectionPool ¶
func NewTSSDBConnectionPool(ctx context.Context, opts DBConnectionPoolOptions) (db.DBConnectionPool, error)
NewTSSDBConnectionPool creates a new TSS db connection pool instance, or retrives a instance that was already created before.
func NewTxSubmitterEngine ¶
func NewTxSubmitterEngine(ctx context.Context, opts TxSubmitterEngineOptions) (engine.SubmitterEngine, error)
NewTxSubmitterEngine creates a new ledger number tracker instance, or retrives an instance that was already created before.
func SetInstance ¶
func SetInstance(instanceName string, instance interface{})
SetInstance adds a new service instance to the store.
Types ¶
type DBConnectionPoolOptions ¶
type DBConnectionPoolOptions struct {
DatabaseURL string
MonitorService monitor.MonitorServiceInterface
}
type EmailClientOptions ¶
type EmailClientOptions struct {
EmailType message.MessengerType
MessengerOptions *message.MessengerOptions
}
type SMSClientOptions ¶
type SMSClientOptions struct {
SMSType message.MessengerType
MessengerOptions *message.MessengerOptions
}
type TxSubmitterEngineOptions ¶
type TxSubmitterEngineOptions struct {
HorizonURL string
SignatureServiceOptions signing.SignatureServiceOptions
MaxBaseFee int
}
Source Files
¶
- admin_db_connection_pool.go
- anchor_platform_service.go
- container.go
- crash_tracker.go
- distribution_account_resolver.go
- email_client.go
- fixtures.go
- horizon_client.go
- ledger_number_tracker.go
- mtn_db_connection_pool.go
- shared.go
- signature_service.go
- sms_client.go
- tss_db_connection_pool.go
- tx_submitter_engine.go