jobs

package

v0.32.0 Latest Latest Go to latest Published: May 14, 2021 License: Apache-2.0 Imports: 23 Imported by: 2

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/hyperledger/burrow

Links

Open Source Insights

Documentation ¶

Index ¶

func AssertJob(assertion *def.Assert, logger *logging.Logger) (string, error)
func BondJob(tx *payload.BondTx, client *def.Client, logger *logging.Logger) (string, error)
func BuildJob(build *def.Build, deployScript *def.Playbook, resp *compilers.Response, ...) (result string, err error)
func CallJob(call *def.Call, tx *payload.CallTx, playbook *def.Playbook, client *def.Client, ...) (string, []*abi.Variable, error)
func DeployJob(deploy *def.Deploy, script *def.Playbook, client *def.Client, ...) (result string, err error)
func DumpStateJob(dump *def.DumpState) (string, error)
func ExecutePlaybook(args *def.DeployArgs, playbook *def.Playbook, client *def.Client, ...) error
func FirstOf(inputs ...string) string
func FormulateBondJob(bond *def.Bond, account string, client *def.Client, logger *logging.Logger) (*payload.BondTx, error)
func FormulateCallJob(call *def.Call, do *def.DeployArgs, deployScript *def.Playbook, ...) (tx *payload.CallTx, err error)
func FormulateDeployJob(deploy *def.Deploy, do *def.DeployArgs, deployScript *def.Playbook, ...) (txs []*payload.CallTx, contracts []*compilers.ResponseItem, err error)
func FormulateIdentifyJob(id *def.Identify, account string, client *def.Client, logger *logging.Logger) (*payload.IdentifyTx, error)
func FormulatePermissionJob(perm *def.Permission, account string, client *def.Client, ...) (*payload.PermsTx, error)
func FormulateRegisterNameJob(name *def.RegisterName, do *def.DeployArgs, playbook *def.Playbook, ...) ([]*payload.NameTx, error)
func FormulateSendJob(send *def.Send, account string, client *def.Client, logger *logging.Logger) (*payload.SendTx, error)
func FormulateUnbondJob(unbond *def.Unbond, account string, client *def.Client, logger *logging.Logger) (*payload.UnbondTx, error)
func FormulateUpdateAccountJob(gov *def.UpdateAccount, account string, client *def.Client, ...) (*payload.GovTx, []*abi.Variable, error)
func IdentifyJob(tx *payload.IdentifyTx, client *def.Client, logger *logging.Logger) (string, error)
func LogTxExecution(txe *exec.TxExecution, logger *logging.Logger)
func PermissionJob(tx *payload.PermsTx, client *def.Client, logger *logging.Logger) (string, error)
func ProposalJob(prop *def.Proposal, do *def.DeployArgs, parentScript *def.Playbook, ...) (string, error)
func QueryAccountJob(query *def.QueryAccount, client *def.Client, logger *logging.Logger) (string, error)
func QueryContractJob(query *def.QueryContract, do *def.DeployArgs, script *def.Playbook, ...) (string, []*abi.Variable, error)
func QueryNameJob(query *def.QueryName, client *def.Client, logger *logging.Logger) (string, error)
func QueryValsJob(query *def.QueryVals, client *def.Client, logger *logging.Logger) (interface{}, error)
func RegisterNameJob(txs []*payload.NameTx, client *def.Client, logger *logging.Logger) (string, error)
func RestoreStateJob(restore *def.RestoreState) (string, error)
func SendJob(tx *payload.SendTx, client *def.Client, logger *logging.Logger) (string, error)
func SetAccountJob(account *def.Account, script *def.Playbook, logger *logging.Logger) (string, error)
func SetValJob(set *def.Set, do *def.DeployArgs, logger *logging.Logger) (string, error)
func UnbondJob(tx *payload.UnbondTx, client *def.Client, logger *logging.Logger) (string, error)
func UpdateAccountJob(tx *payload.GovTx, client *def.Client, logger *logging.Logger) error
func WriteJobResultCSV(name, result string) error
func WriteJobResultJSON(results map[string]interface{}, logFile string) error

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func AssertJob ¶

func AssertJob(assertion *def.Assert, logger *logging.Logger) (string, error)

func BondJob ¶ added in v0.28.0

func BondJob(tx *payload.BondTx, client *def.Client, logger *logging.Logger) (string, error)

func BuildJob ¶

func BuildJob(build *def.Build, deployScript *def.Playbook, resp *compilers.Response, logger *logging.Logger) (result string, err error)

func CallJob ¶

func CallJob(call *def.Call, tx *payload.CallTx, playbook *def.Playbook, client *def.Client, logger *logging.Logger) (string, []*abi.Variable, error)

func DeployJob ¶

func DeployJob(deploy *def.Deploy, script *def.Playbook, client *def.Client, txs []*payload.CallTx, contracts []*compilers.ResponseItem, logger *logging.Logger) (result string, err error)

func DumpStateJob ¶

func DumpStateJob(dump *def.DumpState) (string, error)

func ExecutePlaybook ¶ added in v0.24.0

func ExecutePlaybook(args *def.DeployArgs, playbook *def.Playbook, client *def.Client, logger *logging.Logger) error

func FirstOf ¶ added in v0.26.0

func FirstOf(inputs ...string) string

func FormulateBondJob ¶ added in v0.28.0

func FormulateBondJob(bond *def.Bond, account string, client *def.Client, logger *logging.Logger) (*payload.BondTx, error)

func FormulateCallJob ¶ added in v0.23.0

func FormulateCallJob(call *def.Call, do *def.DeployArgs, deployScript *def.Playbook, client *def.Client, logger *logging.Logger) (tx *payload.CallTx, err error)

func FormulateDeployJob ¶ added in v0.24.0

func FormulateDeployJob(deploy *def.Deploy, do *def.DeployArgs, deployScript *def.Playbook, client *def.Client, intermediate interface{}, logger *logging.Logger) (txs []*payload.CallTx, contracts []*compilers.ResponseItem, err error)

func FormulateIdentifyJob ¶ added in v0.29.0

func FormulateIdentifyJob(id *def.Identify, account string, client *def.Client, logger *logging.Logger) (*payload.IdentifyTx, error)

func FormulatePermissionJob ¶ added in v0.24.0

func FormulatePermissionJob(perm *def.Permission, account string, client *def.Client, logger *logging.Logger) (*payload.PermsTx, error)

func FormulateRegisterNameJob ¶ added in v0.24.0

func FormulateRegisterNameJob(name *def.RegisterName, do *def.DeployArgs, playbook *def.Playbook, client *def.Client, logger *logging.Logger) ([]*payload.NameTx, error)

func FormulateSendJob ¶ added in v0.24.0

func FormulateSendJob(send *def.Send, account string, client *def.Client, logger *logging.Logger) (*payload.SendTx, error)

func FormulateUnbondJob ¶ added in v0.28.0

func FormulateUnbondJob(unbond *def.Unbond, account string, client *def.Client, logger *logging.Logger) (*payload.UnbondTx, error)

func FormulateUpdateAccountJob ¶ added in v0.24.0

func FormulateUpdateAccountJob(gov *def.UpdateAccount, account string, client *def.Client, logger *logging.Logger) (*payload.GovTx, []*abi.Variable, error)

func IdentifyJob ¶ added in v0.29.0

func IdentifyJob(tx *payload.IdentifyTx, client *def.Client, logger *logging.Logger) (string, error)

func LogTxExecution ¶ added in v0.30.5

func LogTxExecution(txe *exec.TxExecution, logger *logging.Logger)

func PermissionJob ¶

func PermissionJob(tx *payload.PermsTx, client *def.Client, logger *logging.Logger) (string, error)

func ProposalJob ¶ added in v0.23.0

func ProposalJob(prop *def.Proposal, do *def.DeployArgs, parentScript *def.Playbook, client *def.Client, logger *logging.Logger) (string, error)

func QueryAccountJob ¶

func QueryAccountJob(query *def.QueryAccount, client *def.Client, logger *logging.Logger) (string, error)

func QueryContractJob ¶

func QueryContractJob(query *def.QueryContract, do *def.DeployArgs, script *def.Playbook, client *def.Client, logger *logging.Logger) (string, []*abi.Variable, error)

func QueryNameJob ¶

func QueryNameJob(query *def.QueryName, client *def.Client, logger *logging.Logger) (string, error)

func QueryValsJob ¶

func QueryValsJob(query *def.QueryVals, client *def.Client, logger *logging.Logger) (interface{}, error)

func RegisterNameJob ¶

func RegisterNameJob(txs []*payload.NameTx, client *def.Client, logger *logging.Logger) (string, error)

func RestoreStateJob ¶

func RestoreStateJob(restore *def.RestoreState) (string, error)

func SendJob ¶

func SendJob(tx *payload.SendTx, client *def.Client, logger *logging.Logger) (string, error)

func SetAccountJob ¶

func SetAccountJob(account *def.Account, script *def.Playbook, logger *logging.Logger) (string, error)

func SetValJob ¶

func SetValJob(set *def.Set, do *def.DeployArgs, logger *logging.Logger) (string, error)

func UnbondJob ¶ added in v0.28.0

func UnbondJob(tx *payload.UnbondTx, client *def.Client, logger *logging.Logger) (string, error)

func UpdateAccountJob ¶

func UpdateAccountJob(tx *payload.GovTx, client *def.Client, logger *logging.Logger) error

func WriteJobResultCSV ¶

func WriteJobResultCSV(name, result string) error

[zr] this should go (currently used by the nameReg writer) WriteJobResultCSV takes two strings and writes those to the delineated log file, which is currently deploy.log in the same directory as the deploy.yaml

func WriteJobResultJSON ¶

func WriteJobResultJSON(results map[string]interface{}, logFile string) error

Types ¶

This section is empty.

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL