rpc

Documentation

Index

• type RPC
  • func (cc *RPC) AddStrategy(client *rpc2.Client, req *strategy.Strategy, reply *[]byte) (err error)
  • func (cc *RPC) CheckIsReady()
  • func (cc *RPC) Create(callback func())
  • func (cc *RPC) DeleteStrategy(client *rpc2.Client, req *strategy.Strategy, reply *[]byte) (err error)
  • func (cc *RPC) GetAssets(client *rpc2.Client, req *[]byte, reply *[]database.Assets) error
  • func (cc *RPC) GetAssetsProvider(client *rpc2.Client, req *[]byte, reply *[]database.Assets) error
  • func (cc *RPC) GetBrokersProvider(client *rpc2.Client, req *[]byte, reply *[]database.BrokersProvider) error
  • func (cc *RPC) GetComponentList(client *rpc2.Client, req *[]byte, reply *[]components.Components) error
  • func (cc *RPC) GetIndicatorList(client *rpc2.Client, req *[]byte, reply *[]indicator.Indicator) error
  • func (cc *RPC) GetProfile(client *rpc2.Client, req *[]byte, reply *controllers.UserLoginResponse) (err error)
  • func (cc *RPC) GetRatesProvider(client *rpc2.Client, req *[]byte, reply *[]database.RatesProvider) error
  • func (cc *RPC) GetStrategy(client *rpc2.Client, req *[]byte, reply *[]strategy.Strategy) error
  • func (cc *RPC) GetUserAgent(client *rpc2.Client, req *[]byte, reply *map[string]string) error
  • func (cc *RPC) SetAssetsProvider(client *rpc2.Client, reqData *database.AssetProvider, reply *[]byte) error
  • func (cc *RPC) SetComponentsActive(client *rpc2.Client, reqData *controllers.SetComponentsActive, reply *[]byte) error
  • func (cc *RPC) SetRatesActive(client *rpc2.Client, reqData *controllers.SetRatesActive, reply *[]byte) error
  • func (cc *RPC) SetRatesAsset(client *rpc2.Client, reqData *controllers.SetRatesAsset, reply *[]byte) error
  • func (cc *RPC) SetRatesProviderConfig(client *rpc2.Client, reqData *database.ProviderConfig, reply *[]byte) error
  • func (cc *RPC) Start()
  • func (cc *RPC) SubMessage(client *rpc2.Client, reqData *[]rpc.SubMessage, reply *[]byte) error
  • func (cc *RPC) TerminatedBefore()
  • func (cc *RPC) UserLogin(client *rpc2.Client, reqData *controllers.UserLogin, ...) error

Types

type RPC

type RPC struct {
	Logger     *logger.Logger
	Port       int
	Host       string
	Database   *maindb.Database
	Rates      *rates.Rates
	Brokers    *brokers.Brokers
	Strategy   *strategy.Strategy
	Components *components.Components
	Server     *rpc2.Server
	Client     sync.Map
	TLS        bool
	Key        []byte
	Crt        []byte
}

RPC - implement rpc for client communication

func (*RPC) AddStrategy

func (cc *RPC) AddStrategy(client *rpc2.Client, req *strategy.Strategy, reply *[]byte) (err error)

AddStrategy -

func (*RPC) CheckIsReady

func (cc *RPC) CheckIsReady()

CheckIsReady -

func (*RPC) Create

func (cc *RPC) Create(callback func())

Create -

func (*RPC) DeleteStrategy

func (cc *RPC) DeleteStrategy(client *rpc2.Client, req *strategy.Strategy, reply *[]byte) (err error)

DeleteStrategy -

func (*RPC) GetAssets

func (cc *RPC) GetAssets(client *rpc2.Client, req *[]byte, reply *[]database.Assets) error

GetAssets -

func (*RPC) GetAssetsProvider

func (cc *RPC) GetAssetsProvider(client *rpc2.Client, req *[]byte, reply *[]database.Assets) error

GetAssetsProvider -

func (*RPC) GetBrokersProvider

func (cc *RPC) GetBrokersProvider(client *rpc2.Client, req *[]byte, reply *[]database.BrokersProvider) error

GetBrokersProvider -

func (*RPC) GetComponentList

func (cc *RPC) GetComponentList(client *rpc2.Client, req *[]byte, reply *[]components.Components) error

GetComponentList -

func (*RPC) GetIndicatorList

func (cc *RPC) GetIndicatorList(client *rpc2.Client, req *[]byte, reply *[]indicator.Indicator) error

GetIndicatorList -

func (*RPC) GetProfile

func (cc *RPC) GetProfile(client *rpc2.Client, req *[]byte, reply *controllers.UserLoginResponse) (err error)

GetProfile -

func (*RPC) GetRatesProvider

func (cc *RPC) GetRatesProvider(client *rpc2.Client, req *[]byte, reply *[]database.RatesProvider) error

GetRatesProvider -

func (*RPC) GetStrategy

func (cc *RPC) GetStrategy(client *rpc2.Client, req *[]byte, reply *[]strategy.Strategy) error

GetStrategy -

func (*RPC) GetUserAgent

func (cc *RPC) GetUserAgent(client *rpc2.Client, req *[]byte, reply *map[string]string) error

GetUserAgent -

func (*RPC) SetAssetsProvider

func (cc *RPC) SetAssetsProvider(client *rpc2.Client, reqData *database.AssetProvider, reply *[]byte) error

SetAssetsProvider -

func (*RPC) SetComponentsActive

func (cc *RPC) SetComponentsActive(client *rpc2.Client, reqData *controllers.SetComponentsActive, reply *[]byte) error

SetComponentsActive -

func (*RPC) SetRatesActive

func (cc *RPC) SetRatesActive(client *rpc2.Client, reqData *controllers.SetRatesActive, reply *[]byte) error

SetRatesActive -

func (*RPC) SetRatesAsset

func (cc *RPC) SetRatesAsset(client *rpc2.Client, reqData *controllers.SetRatesAsset, reply *[]byte) error

SetRatesAsset -

func (*RPC) SetRatesProviderConfig

func (cc *RPC) SetRatesProviderConfig(client *rpc2.Client, reqData *database.ProviderConfig, reply *[]byte) error

SetRatesProviderConfig -

func (*RPC) Start

func (cc *RPC) Start()

Start -

func (*RPC) SubMessage

func (cc *RPC) SubMessage(client *rpc2.Client, reqData *[]rpc.SubMessage, reply *[]byte) error

SubMessage -

func (*RPC) TerminatedBefore

func (cc *RPC) TerminatedBefore()

TerminatedBefore -

func (*RPC) UserLogin

func (cc *RPC) UserLogin(client *rpc2.Client, reqData *controllers.UserLogin, reply *controllers.UserLoginResponse) error

UserLogin -