lib

Documentation

Index

• Variables
• type Brokers
  • func (cc *Brokers) AddTasks(opt controllers.AddTasks) (err error)
  • func (cc *Brokers) Create(opt *core.IBrokersCallback) (err error)
  • func (cc *Brokers) CreateAccounts(opt controllers.CreateAccounts) error
  • func (cc *Brokers) DeleteAccount(opt controllers.DeleteAccount) error
  • func (cc *Brokers) DeleteTasks(opt controllers.DeleteTasks) (err error)
  • func (cc *Brokers) DeleteTestTasks(opt tasks.TestTasks) (err error)
  • func (cc *Brokers) EditAccounts(opt controllers.CreateAccounts) error
  • func (cc *Brokers) EditTasks(opt controllers.EditTasks) (err error)
  • func (cc *Brokers) GetAccounts(id string) (data []accounts.Accounts, err error)
  • func (cc *Brokers) GetStatsTasksTransactions(opt controllers.GetTasksTransactions) (data tasks.StatsTask, err error)
  • func (cc *Brokers) GetTasks() (data []tasks.Tasks, err error)
  • func (cc *Brokers) GetTasksTest(opt controllers.GetTasksTestOption) (data []tasks.TestTasks, err error)
  • func (cc *Brokers) GetTasksTransactions(opt controllers.GetTasksTransactions) (data []brokers.Transactions, err error)
  • func (cc *Brokers) Name() string
  • func (cc *Brokers) RegisterOnSignal() func(strategy.SendingSignal)
  • func (cc *Brokers) ResetTasks(opt controllers.ResetTasks) (err error)
  • func (cc *Brokers) ResetTestTasks(opt tasks.TestTasks) (err error)
  • func (cc *Brokers) Run() bool
  • func (cc *Brokers) RunTestTasks(opt tasks.TestTasks) (err error)
  • func (cc *Brokers) SetAccountActive(opt controllers.SetAccountActive) error
  • func (cc *Brokers) TestTasks(opt tasks.TestTasks) (err error)
  • func (cc *Brokers) Validator(opt interface{}, ignores map[string]bool) (err error)
  • func (cc *Brokers) Version() string
• type Database
  • func (cc *Database) Del(bucket, key string) (err error)
  • func (cc *Database) Get(bucket, key string, autocreateBucket bool) (value []byte, err error)
  • func (cc *Database) GetAll(bucket string) (res interface{})
  • func (cc *Database) Init() (err error)
  • func (cc *Database) Set(bucket, key string, value []byte, autocreateBucket bool) (err error)
  • func (cc *Database) Sync()
• type Stores

Variables

var Validate *validator.Validate

Validate -

Types

type Brokers

type Brokers struct {
	Brokers  *core.IBrokersCallback
	Config   *database.BrokersProviderConfig
	Database *Database
	Apps     core.Apps
	sync.Mutex
}

Brokers -

func (*Brokers) AddTasks

func (cc *Brokers) AddTasks(opt controllers.AddTasks) (err error)

AddTasks -

func (*Brokers) Create

func (cc *Brokers) Create(opt *core.IBrokersCallback) (err error)

Create -

func (*Brokers) CreateAccounts

func (cc *Brokers) CreateAccounts(opt controllers.CreateAccounts) error

CreateAccounts -

func (*Brokers) DeleteAccount

func (cc *Brokers) DeleteAccount(opt controllers.DeleteAccount) error

DeleteAccount -

func (*Brokers) DeleteTasks

func (cc *Brokers) DeleteTasks(opt controllers.DeleteTasks) (err error)

DeleteTasks -

func (*Brokers) DeleteTestTasks

func (cc *Brokers) DeleteTestTasks(opt tasks.TestTasks) (err error)

DeleteTestTasks -

func (*Brokers) EditAccounts

func (cc *Brokers) EditAccounts(opt controllers.CreateAccounts) error

EditAccounts -

func (*Brokers) EditTasks

func (cc *Brokers) EditTasks(opt controllers.EditTasks) (err error)

EditTasks -

func (*Brokers) GetAccounts

func (cc *Brokers) GetAccounts(id string) (data []accounts.Accounts, err error)

GetAccounts -

func (*Brokers) GetStatsTasksTransactions

func (cc *Brokers) GetStatsTasksTransactions(opt controllers.GetTasksTransactions) (data tasks.StatsTask, err error)

GetStatsTasksTransactions -

func (*Brokers) GetTasks

func (cc *Brokers) GetTasks() (data []tasks.Tasks, err error)

GetTasks -

func (*Brokers) GetTasksTest

func (cc *Brokers) GetTasksTest(opt controllers.GetTasksTestOption) (data []tasks.TestTasks, err error)

GetTasksTest -

func (*Brokers) GetTasksTransactions

func (cc *Brokers) GetTasksTransactions(opt controllers.GetTasksTransactions) (data []brokers.Transactions, err error)

GetTasksTransactions -

func (*Brokers) Name

func (cc *Brokers) Name() string

Name -

func (*Brokers) RegisterOnSignal

func (cc *Brokers) RegisterOnSignal() func(strategy.SendingSignal)

RegisterOnSignal -

func (*Brokers) ResetTasks

func (cc *Brokers) ResetTasks(opt controllers.ResetTasks) (err error)

ResetTasks -

func (*Brokers) ResetTestTasks

func (cc *Brokers) ResetTestTasks(opt tasks.TestTasks) (err error)

ResetTestTasks -

func (*Brokers) Run

func (cc *Brokers) Run() bool

Run -

func (*Brokers) RunTestTasks

func (cc *Brokers) RunTestTasks(opt tasks.TestTasks) (err error)

RunTestTasks -

func (*Brokers) SetAccountActive

func (cc *Brokers) SetAccountActive(opt controllers.SetAccountActive) error

SetAccountActive -

func (*Brokers) TestTasks

func (cc *Brokers) TestTasks(opt tasks.TestTasks) (err error)

TestTasks -

func (*Brokers) Validator

func (cc *Brokers) Validator(opt interface{}, ignores map[string]bool) (err error)

Validator -

func (*Brokers) Version

func (cc *Brokers) Version() string

Version -

type Database

type Database struct {
	Logger     *logging.Logger
	DB         *nutsdb.DB
	Stores     Stores
	DBLocation string
}

Database -

func (*Database) Del

func (cc *Database) Del(bucket, key string) (err error)

Del -

func (*Database) Get

func (cc *Database) Get(bucket, key string, autocreateBucket bool) (value []byte, err error)

Get -

func (*Database) GetAll

func (cc *Database) GetAll(bucket string) (res interface{})

GetAll -

func (*Database) Init

func (cc *Database) Init() (err error)

Init -

func (*Database) Set

func (cc *Database) Set(bucket, key string, value []byte, autocreateBucket bool) (err error)

Set -

func (*Database) Sync

func (cc *Database) Sync()

Sync -

type Stores

type Stores struct {
	Accounts sync.Map
	Tasks    sync.Map
}

Stores -