63 Star 181 Fork 3

Gitee 极速下载 / hyperledger-fabric

加入 Gitee
与超过 1200万 开发者一起发现、参与优秀开源项目,私有仓库也完全免费 :)
免费加入
此仓库是为了提升国内下载速度的镜像仓库,每日同步一次。 原始仓库: https://github.com/hyperledger/fabric
克隆/下载
peer.go 14.72 KB
一键复制 编辑 原始数据 按行查看 历史
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756
/*
Copyright IBM Corp. All Rights Reserved.
SPDX-License-Identifier: Apache-2.0
*/
package commands
import "strconv"
type NodeStart struct {
PeerID string
}
func (n NodeStart) SessionName() string {
return n.PeerID
}
func (n NodeStart) Args() []string {
return []string{
"node", "start",
}
}
type NodeReset struct {
}
func (n NodeReset) SessionName() string {
return "peer-node-reset"
}
func (n NodeReset) Args() []string {
return []string{
"node", "reset",
}
}
type NodeRollback struct {
ChannelID string
BlockNumber int
}
func (n NodeRollback) SessionName() string {
return "peer-node-rollback"
}
func (n NodeRollback) Args() []string {
return []string{
"node", "rollback",
"--channelID", n.ChannelID,
"--blockNumber", strconv.Itoa(n.BlockNumber),
}
}
type NodePause struct {
ChannelID string
}
func (n NodePause) SessionName() string {
return "peer-node-pause"
}
func (n NodePause) Args() []string {
return []string{
"node", "pause",
"--channelID", n.ChannelID,
}
}
type NodeResume struct {
ChannelID string
}
func (n NodeResume) SessionName() string {
return "peer-node-resume"
}
func (n NodeResume) Args() []string {
return []string{
"node", "resume",
"--channelID", n.ChannelID,
}
}
type ChannelCreate struct {
ChannelID string
Orderer string
File string
OutputBlock string
ClientAuth bool
}
func (c ChannelCreate) SessionName() string {
return "peer-channel-create"
}
func (c ChannelCreate) Args() []string {
args := []string{
"channel", "create",
"--channelID", c.ChannelID,
"--orderer", c.Orderer,
"--file", c.File,
"--outputBlock", c.OutputBlock,
"--timeout", "15s",
}
if c.ClientAuth {
args = append(args, "--clientauth")
}
return args
}
type ChannelJoin struct {
BlockPath string
ClientAuth bool
}
func (c ChannelJoin) SessionName() string {
return "peer-channel-join"
}
func (c ChannelJoin) Args() []string {
args := []string{
"channel", "join",
"-b", c.BlockPath,
}
if c.ClientAuth {
args = append(args, "--clientauth")
}
return args
}
type ChannelFetch struct {
ChannelID string
Block string
Orderer string
OutputFile string
ClientAuth bool
}
func (c ChannelFetch) SessionName() string {
return "peer-channel-fetch"
}
func (c ChannelFetch) Args() []string {
args := []string{
"channel", "fetch", c.Block,
}
if c.ChannelID != "" {
args = append(args, "--channelID", c.ChannelID)
}
if c.Orderer != "" {
args = append(args, "--orderer", c.Orderer)
}
if c.OutputFile != "" {
args = append(args, c.OutputFile)
}
if c.ClientAuth {
args = append(args, "--clientauth")
}
return args
}
type ChaincodePackage struct {
Path string
Lang string
Label string
OutputFile string
ClientAuth bool
}
func (c ChaincodePackage) SessionName() string {
return "peer-lifecycle-chaincode-package"
}
func (c ChaincodePackage) Args() []string {
args := []string{
"lifecycle", "chaincode", "package",
"--path", c.Path,
"--lang", c.Lang,
"--label", c.Label,
c.OutputFile,
}
if c.ClientAuth {
args = append(args, "--clientauth")
}
return args
}
type ChaincodePackageLegacy struct {
Name string
Version string
Path string
Lang string
OutputFile string
ClientAuth bool
}
func (c ChaincodePackageLegacy) SessionName() string {
return "peer-chaincode-package"
}
func (c ChaincodePackageLegacy) Args() []string {
args := []string{
"chaincode", "package",
"--name", c.Name,
"--version", c.Version,
"--path", c.Path,
c.OutputFile,
}
if c.ClientAuth {
args = append(args, "--clientauth")
}
if c.Lang != "" {
args = append(args, "--lang", c.Lang)
}
return args
}
type ChaincodeInstall struct {
PackageFile string
PeerAddresses []string
ClientAuth bool
}
func (c ChaincodeInstall) SessionName() string {
return "peer-lifecycle-chaincode-install"
}
func (c ChaincodeInstall) Args() []string {
args := []string{
"lifecycle", "chaincode", "install",
c.PackageFile,
}
for _, p := range c.PeerAddresses {
args = append(args, "--peerAddresses", p)
}
if c.ClientAuth {
args = append(args, "--clientauth")
}
return args
}
type ChaincodeGetInstalledPackage struct {
PackageID string
OutputDirectory string
ClientAuth bool
}
func (c ChaincodeGetInstalledPackage) SessionName() string {
return "peer-lifecycle-chaincode-getinstalledpackage"
}
func (c ChaincodeGetInstalledPackage) Args() []string {
args := []string{
"lifecycle", "chaincode", "getinstalledpackage",
"--package-id", c.PackageID,
"--output-directory", c.OutputDirectory,
}
if c.ClientAuth {
args = append(args, "--clientauth")
}
return args
}
type ChaincodeInstallLegacy struct {
Name string
Version string
Path string
Lang string
PackageFile string
ClientAuth bool
}
func (c ChaincodeInstallLegacy) SessionName() string {
return "peer-chaincode-install"
}
func (c ChaincodeInstallLegacy) Args() []string {
args := []string{
"chaincode", "install",
}
if c.PackageFile != "" {
args = append(args, c.PackageFile)
}
if c.Name != "" {
args = append(args, "--name", c.Name)
}
if c.Version != "" {
args = append(args, "--version", c.Version)
}
if c.Path != "" {
args = append(args, "--path", c.Path)
}
if c.Lang != "" {
args = append(args, "--lang", c.Lang)
}
if c.ClientAuth {
args = append(args, "--clientauth")
}
return args
}
type ChaincodeApproveForMyOrg struct {
ChannelID string
Orderer string
Name string
Version string
PackageID string
Sequence string
EndorsementPlugin string
ValidationPlugin string
SignaturePolicy string
ChannelConfigPolicy string
InitRequired bool
CollectionsConfig string
PeerAddresses []string
WaitForEvent bool
ClientAuth bool
}
func (c ChaincodeApproveForMyOrg) SessionName() string {
return "peer-lifecycle-chaincode-approveformyorg"
}
func (c ChaincodeApproveForMyOrg) Args() []string {
args := []string{
"lifecycle", "chaincode", "approveformyorg",
"--channelID", c.ChannelID,
"--orderer", c.Orderer,
"--name", c.Name,
"--version", c.Version,
"--package-id", c.PackageID,
"--sequence", c.Sequence,
"--endorsement-plugin", c.EndorsementPlugin,
"--validation-plugin", c.ValidationPlugin,
"--signature-policy", c.SignaturePolicy,
"--channel-config-policy", c.ChannelConfigPolicy,
}
if c.InitRequired {
args = append(args, "--init-required")
}
if c.CollectionsConfig != "" {
args = append(args, "--collections-config", c.CollectionsConfig)
}
if c.ClientAuth {
args = append(args, "--clientauth")
}
for _, p := range c.PeerAddresses {
args = append(args, "--peerAddresses", p)
}
return args
}
type ChaincodeCheckCommitReadiness struct {
ChannelID string
Name string
Version string
Sequence string
EndorsementPlugin string
ValidationPlugin string
SignaturePolicy string
ChannelConfigPolicy string
InitRequired bool
CollectionsConfig string
PeerAddresses []string
ClientAuth bool
}
func (c ChaincodeCheckCommitReadiness) SessionName() string {
return "peer-lifecycle-chaincode-checkcommitreadiness"
}
func (c ChaincodeCheckCommitReadiness) Args() []string {
args := []string{
"lifecycle", "chaincode", "checkcommitreadiness",
"--channelID", c.ChannelID,
"--name", c.Name,
"--version", c.Version,
"--sequence", c.Sequence,
"--endorsement-plugin", c.EndorsementPlugin,
"--validation-plugin", c.ValidationPlugin,
"--signature-policy", c.SignaturePolicy,
"--channel-config-policy", c.ChannelConfigPolicy,
"--output", "json",
}
if c.InitRequired {
args = append(args, "--init-required")
}
if c.CollectionsConfig != "" {
args = append(args, "--collections-config", c.CollectionsConfig)
}
for _, p := range c.PeerAddresses {
args = append(args, "--peerAddresses", p)
}
if c.ClientAuth {
args = append(args, "--clientauth")
}
return args
}
type ChaincodeCommit struct {
ChannelID string
Orderer string
Name string
Version string
Sequence string
EndorsementPlugin string
ValidationPlugin string
SignaturePolicy string
ChannelConfigPolicy string
InitRequired bool
CollectionsConfig string
PeerAddresses []string
WaitForEvent bool
ClientAuth bool
}
func (c ChaincodeCommit) SessionName() string {
return "peer-lifecycle-chaincode-commit"
}
func (c ChaincodeCommit) Args() []string {
args := []string{
"lifecycle", "chaincode", "commit",
"--channelID", c.ChannelID,
"--orderer", c.Orderer,
"--name", c.Name,
"--version", c.Version,
"--sequence", c.Sequence,
"--endorsement-plugin", c.EndorsementPlugin,
"--validation-plugin", c.ValidationPlugin,
"--signature-policy", c.SignaturePolicy,
"--channel-config-policy", c.ChannelConfigPolicy,
}
if c.InitRequired {
args = append(args, "--init-required")
}
for _, p := range c.PeerAddresses {
args = append(args, "--peerAddresses", p)
}
if c.CollectionsConfig != "" {
args = append(args, "--collections-config", c.CollectionsConfig)
}
if c.ClientAuth {
args = append(args, "--clientauth")
}
return args
}
type ChaincodeInstantiateLegacy struct {
ChannelID string
Orderer string
Name string
Version string
Ctor string
Policy string
Lang string
CollectionsConfig string
ClientAuth bool
}
func (c ChaincodeInstantiateLegacy) SessionName() string {
return "peer-chaincode-instantiate"
}
func (c ChaincodeInstantiateLegacy) Args() []string {
args := []string{
"chaincode", "instantiate",
"--channelID", c.ChannelID,
"--orderer", c.Orderer,
"--name", c.Name,
"--version", c.Version,
"--ctor", c.Ctor,
"--policy", c.Policy,
}
if c.CollectionsConfig != "" {
args = append(args, "--collections-config", c.CollectionsConfig)
}
if c.Lang != "" {
args = append(args, "--lang", c.Lang)
}
if c.ClientAuth {
args = append(args, "--clientauth")
}
return args
}
type ChaincodeQueryInstalled struct {
ClientAuth bool
}
func (c ChaincodeQueryInstalled) SessionName() string {
return "peer-lifecycle-chaincode-queryinstalled"
}
func (c ChaincodeQueryInstalled) Args() []string {
args := []string{
"lifecycle", "chaincode", "queryinstalled",
"--output", "json",
}
if c.ClientAuth {
args = append(args, "--clientauth")
}
return args
}
type ChaincodeListInstalledLegacy struct {
ClientAuth bool
}
func (c ChaincodeListInstalledLegacy) SessionName() string {
return "peer-chaincode-list-installed"
}
func (c ChaincodeListInstalledLegacy) Args() []string {
args := []string{
"chaincode", "list", "--installed",
}
if c.ClientAuth {
args = append(args, "--clientauth")
}
return args
}
type ChaincodeListCommitted struct {
ChannelID string
Name string
ClientAuth bool
}
func (c ChaincodeListCommitted) SessionName() string {
return "peer-lifecycle-chaincode-querycommitted"
}
func (c ChaincodeListCommitted) Args() []string {
args := []string{
"lifecycle", "chaincode", "querycommitted",
"--channelID", c.ChannelID,
"--name", c.Name,
"--output", "json",
}
if c.ClientAuth {
args = append(args, "--clientauth")
}
return args
}
type ChaincodeListInstantiatedLegacy struct {
ChannelID string
ClientAuth bool
}
func (c ChaincodeListInstantiatedLegacy) SessionName() string {
return "peer-chaincode-list-instantiated"
}
func (c ChaincodeListInstantiatedLegacy) Args() []string {
args := []string{
"chaincode", "list", "--instantiated",
"--channelID", c.ChannelID,
}
if c.ClientAuth {
args = append(args, "--clientauth")
}
return args
}
type ChaincodeQuery struct {
ChannelID string
Name string
Ctor string
ClientAuth bool
}
func (c ChaincodeQuery) SessionName() string {
return "peer-chaincode-query"
}
func (c ChaincodeQuery) Args() []string {
args := []string{
"chaincode", "query",
"--channelID", c.ChannelID,
"--name", c.Name,
"--ctor", c.Ctor,
}
if c.ClientAuth {
args = append(args, "--clientauth")
}
return args
}
type ChaincodeInvoke struct {
ChannelID string
Orderer string
Name string
Ctor string
Transient string
PeerAddresses []string
WaitForEvent bool
IsInit bool
ClientAuth bool
}
func (c ChaincodeInvoke) SessionName() string {
return "peer-chaincode-invoke"
}
func (c ChaincodeInvoke) Args() []string {
args := []string{
"chaincode", "invoke",
"--channelID", c.ChannelID,
"--orderer", c.Orderer,
"--name", c.Name,
"--ctor", c.Ctor,
}
if c.Transient != "" {
args = append(args, "--transient", c.Transient)
}
for _, p := range c.PeerAddresses {
args = append(args, "--peerAddresses", p)
}
if c.WaitForEvent {
args = append(args, "--waitForEvent")
}
if c.IsInit {
args = append(args, "--isInit")
}
if c.ClientAuth {
args = append(args, "--clientauth")
}
return args
}
type ChaincodeUpgradeLegacy struct {
Name string
Version string
Path string // optional
ChannelID string
Orderer string
Ctor string
Policy string
CollectionsConfig string // optional
ClientAuth bool
}
func (c ChaincodeUpgradeLegacy) SessionName() string {
return "peer-chaincode-upgrade"
}
func (c ChaincodeUpgradeLegacy) Args() []string {
args := []string{
"chaincode", "upgrade",
"--name", c.Name,
"--version", c.Version,
"--channelID", c.ChannelID,
"--orderer", c.Orderer,
"--ctor", c.Ctor,
"--policy", c.Policy,
}
if c.Path != "" {
args = append(args, "--path", c.Path)
}
if c.CollectionsConfig != "" {
args = append(args, "--collections-config", c.CollectionsConfig)
}
if c.ClientAuth {
args = append(args, "--clientauth")
}
return args
}
type SignConfigTx struct {
File string
ClientAuth bool
}
func (s SignConfigTx) SessionName() string {
return "peer-channel-signconfigtx"
}
func (s SignConfigTx) Args() []string {
args := []string{
"channel", "signconfigtx",
"--file", s.File,
}
if s.ClientAuth {
args = append(args, "--clientauth")
}
return args
}
type ChannelUpdate struct {
ChannelID string
Orderer string
File string
ClientAuth bool
}
func (c ChannelUpdate) SessionName() string {
return "peer-channel-update"
}
func (c ChannelUpdate) Args() []string {
args := []string{
"channel", "update",
"--channelID", c.ChannelID,
"--orderer", c.Orderer,
"--file", c.File,
}
if c.ClientAuth {
args = append(args, "--clientauth")
}
return args
}
type ChannelInfo struct {
ChannelID string
ClientAuth bool
}
func (c ChannelInfo) SessionName() string {
return "peer-channel-info"
}
func (c ChannelInfo) Args() []string {
args := []string{
"channel", "getinfo",
"-c", c.ChannelID,
}
if c.ClientAuth {
args = append(args, "--clientauth")
}
return args
}
Go
1
https://gitee.com/mirrors/hyperledger-fabric.git
git@gitee.com:mirrors/hyperledger-fabric.git
mirrors
hyperledger-fabric
hyperledger-fabric
v2.1.1

搜索帮助