storage

Documentation

Index

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

Constants

const (
	// JSONFILE ...
	JSONFILE = "json"
	// DB ...
	DB = "db"
)

Functions

func PostgreSQLConnection

func PostgreSQLConnection(ctx context.Context) (*sqlx.DB, error)

PostgreSQLConnection func for connection to PostgreSQL database.

func WalletsFromJsonToMAP

func WalletsFromJsonToMAP(ctx context.Context, 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"`
}

NotifierService ...

type OptionsSource

type OptionsSource struct {
	FileName string
	PathName string
	Pgx      *sqlx.DB
}

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(ctx context.Context) (wallets []Wallet, err error)

func (*Source) WalletsTONotify

func (s *Source) WalletsTONotify(ctx context.Context) (wallets []Wallet, err error)

type Sourcer

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

Sourcer ...

type Wallet

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

Wallet ...

func WalletFromPostgreSQL

func WalletFromPostgreSQL(ctx context.Context, pgx *sqlx.DB) ([]Wallet, error)

func WalletsFromJsonToStruct

func WalletsFromJsonToStruct(ctx context.Context, path, filename string) ([]Wallet, error)

WalletsFromJsonToStruct read json filename and path

func (*Wallet) ToJSON

func (w *Wallet) ToJSON() string