core

Documentation

Index

• Constants
• type Application
  • func NewApplication(acct *sdk.Account) Application
• type CreateOracleRequestParam
• type OracleApplication
  • func (app *OracleApplication) AddJob(job *models.JobSpec)
  • func (app *OracleApplication) AddUndoRequests() error
  • func (app *OracleApplication) JobRunner()
  • func (app *OracleApplication) OntScanner()
  • func (app *OracleApplication) RunJob(job *models.JobSpec)
  • func (app *OracleApplication) Start()
  • func (app *OracleApplication) Stop()
• type UndoRequests

Constants

const DB_PATH = "./Store"

Types

type Application

type Application interface {
	Start()
	Stop()
}

Application implements the common functions used in the core node.

func NewApplication

func NewApplication(acct *sdk.Account) Application

type CreateOracleRequestParam

type CreateOracleRequestParam struct {
	Request    string `json:"request"`
	OracleNode string `json:"oracleNode"`
	Address    string `json:"address"`
}

type OracleApplication

type OracleApplication struct {
	Account *sdk.Account
	JobList chan *models.JobSpec
	Store   *leveldb.DB
	Ont     *sdk.OntologySdk
	Exiter  func(int)
}

func (*OracleApplication) AddJob

func (app *OracleApplication) AddJob(job *models.JobSpec)

func (*OracleApplication) AddUndoRequests

func (app *OracleApplication) AddUndoRequests() error

func (*OracleApplication) JobRunner

func (app *OracleApplication) JobRunner()

func (*OracleApplication) OntScanner

func (app *OracleApplication) OntScanner()

func (*OracleApplication) RunJob

func (app *OracleApplication) RunJob(job *models.JobSpec)

func (*OracleApplication) Start

func (app *OracleApplication) Start()

func (*OracleApplication) Stop

func (app *OracleApplication) Stop()

type UndoRequests

type UndoRequests struct {
	Requests map[string]interface{} `json:"requests"`
}