Documentation
¶
Index ¶
Constants ¶
View Source
const ( BatchSizeConfigEnvName = envConfigPrefix + "WORKER_BATCH_SIZE" ClientTimeoutToFundConfigEnvName = envConfigPrefix + "CLIENT_TIMEOUT_TO_FUND" ExternalWalletFinalizationTimeoutConfigEnvName = envConfigPrefix + "EXTERNAL_WALLET_FINALIZATION_TIMEOUT" )
Variables ¶
This section is empty.
Functions ¶
func New ¶
func New(log *zap.Logger, data ocp_data.Provider, vmIndexerClient indexerpb.IndexerClient, integration Integration, configProvider ConfigProvider) worker.Runtime
Types ¶
type ConfigProvider ¶
type ConfigProvider func() *conf
ConfigProvider defines how config values are pulled
func WithEnvConfigs ¶
func WithEnvConfigs() ConfigProvider
WithEnvConfigs returns configuration pulled from environment variables
type Integration ¶
type Integration interface {
OnSwapFinalized(ctx context.Context, owner *common.Account, isBuy bool, mint *common.Account, currencyName string, region currency.Code, valueReceived float64, isMintInit bool) error
}
Integration allows for notifications based on events processed by the swap worker
Click to show internal directories.
Click to hide internal directories.