storage

Documentation

Index

• Constants
• func PostgreSQLConnection() (*sqlx.DB, error)
• func WalletsFromJsonToMAP(path, filename string) ([]map[string]interface{}, error)
• type NotifierService
• type OptionsSource
• type Source
  • func NewSource(sourceType string, options OptionsSource) Source
  • func (s *Source) Wallets() (wallets []Wallet, err error)
  • func (s *Source) WalletsTONotify() (wallets []Wallet, err error)
• type Sourcer
• type Wallet
  • func WalletsFromJsonToStruct(path, filename string) ([]Wallet, error)

Constants

const (
	// JSONFILE ...
	JSONFILE = "json"
	// POSTGRESQL ...
	POSTGRESQL = "postgresql"
)

Functions

func PostgreSQLConnection

func PostgreSQLConnection() (*sqlx.DB, error)

PostgreSQLConnection func for connection to PostgreSQL database.

func WalletsFromJsonToMAP

func WalletsFromJsonToMAP(path, filename string) ([]map[string]interface{}, error)

WalletsFromJsonToMAP read json filename and path

Types

type NotifierService

type NotifierService struct {
	Name   string `json:"name"`
	UserID string `json:"user_id"`
}

type OptionsSource

type OptionsSource struct {
	FileName string
	PathName string
}

type Source

type Source struct {
	SourceType string
	Options    OptionsSource
}

func NewSource

func NewSource(sourceType string, options OptionsSource) Source

func (*Source) Wallets

func (s *Source) Wallets() (wallets []Wallet, err error)

func (*Source) WalletsTONotify

func (s *Source) WalletsTONotify() (wallets []Wallet, err error)

type Sourcer

type Sourcer interface {
	Wallets() (wallets []Wallet, err error)
	WalletsTONotify() (wallets []Wallet, err error)
}

Sourcer ...

type Wallet

type Wallet struct {
	Address         string            `json:"address"`
	Symbol          string            `json:"symbol"`
	IsActive        bool              `json:"is_active"`
	NotifierService []NotifierService `json:"notifier_service"`
	NetworkType     string            `json:"network_type"`
}

func WalletsFromJsonToStruct

func WalletsFromJsonToStruct(path, filename string) ([]Wallet, error)

WalletsFromJsonToStruct read json filename and path