appfactory

Documentation

Index

• func CreateDefaultAppMetadata(notificationOptions domain.NotificationOptions, ...) (*domain.Application, error)
• func FindOrCreateAppMetaData(env domain.Env, applicationsRepository domain.ApplicationRepository, ...) (*domain.Application, error)
• func GetBroker(appEnv string, krakenAPI *krakenapi.KrakenAPI) domain.Broker
• func NotificationJob(notificationsService domain.NotificationsService, ...) func(ohlc *domain.OHLC)
• func SaveApplicationState(ID primitive.ObjectID, application *app.App, ...) domain.OnNewAssetPrice
• func SaveAssetPrice(asset string, assetsPricesService domain.AssetsPricesService) domain.OnNewAssetPrice
• func SetupApplication(appMetaData *domain.Application, mongoDatabase *mongo.Database, ...) (*app.App, error)

Functions

func CreateDefaultAppMetadata

func CreateDefaultAppMetadata(notificationOptions domain.NotificationOptions, repository domain.ApplicationRepository, accountsRepository domain.AccountsRepository) (*domain.Application, error)

func FindOrCreateAppMetaData

func FindOrCreateAppMetaData(env domain.Env, applicationsRepository domain.ApplicationRepository, accountsRepository domain.AccountsRepository) (*domain.Application, error)

func GetBroker

func GetBroker(appEnv string, krakenAPI *krakenapi.KrakenAPI) domain.Broker

func NotificationJob

func NotificationJob(
	notificationsService domain.NotificationsService,
	eventLogsRepository domain.EventsLog,
	accountService domain.AccountService,
) func(ohlc *domain.OHLC)

func SaveApplicationState

func SaveApplicationState(ID primitive.ObjectID, application *app.App, applicationExecutionStateRepository domain.Repository) domain.OnNewAssetPrice

func SaveAssetPrice

func SaveAssetPrice(asset string, assetsPricesService domain.AssetsPricesService) domain.OnNewAssetPrice

func SetupApplication

func SetupApplication(appMetaData *domain.Application, mongoDatabase *mongo.Database, broker domain.Broker, collector domain.Collector) (*app.App, error)