protos

package
v0.6.0-preview Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 15, 2016 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation ¶

Overview ¶

Package protos is a generated protocol buffer package.

It is generated from these files:

api.proto
chaincodeevent.proto
chaincode.proto
devops.proto
events.proto
fabric.proto
server_admin.proto

It has these top-level messages:

BlockNumber
BlockCount
ChaincodeEvent
ChaincodeID
ChaincodeInput
ChaincodeSpec
ChaincodeDeploymentSpec
ChaincodeInvocationSpec
ChaincodeSecurityContext
ChaincodeMessage
PutStateInfo
RangeQueryState
RangeQueryStateNext
RangeQueryStateClose
RangeQueryStateKeyValue
RangeQueryStateResponse
Secret
SigmaInput
ExecuteWithBinding
SigmaOutput
BuildResult
TransactionRequest
ChaincodeReg
Interest
Register
Rejection
Unregister
Event
Transaction
TransactionBlock
TransactionResult
Block
BlockchainInfo
NonHashData
PeerAddress
PeerID
PeerEndpoint
PeersMessage
PeersAddresses
HelloMessage
Message
Response
BlockState
SyncBlockRange
SyncBlocks
SyncStateSnapshotRequest
SyncStateSnapshot
SyncStateDeltasRequest
SyncStateDeltas
ServerStatus

Index ¶

Constants ¶

This section is empty.

Variables ¶

View Source
var BuildResult_StatusCode_name = map[int32]string{
	0: "UNDEFINED",
	1: "SUCCESS",
	2: "FAILURE",
}
View Source
var BuildResult_StatusCode_value = map[string]int32{
	"UNDEFINED": 0,
	"SUCCESS":   1,
	"FAILURE":   2,
}
View Source
var ChaincodeDeploymentSpec_ExecutionEnvironment_name = map[int32]string{
	0: "DOCKER",
	1: "SYSTEM",
}
View Source
var ChaincodeDeploymentSpec_ExecutionEnvironment_value = map[string]int32{
	"DOCKER": 0,
	"SYSTEM": 1,
}
View Source
var ChaincodeMessage_Type_name = map[int32]string{
	0:  "UNDEFINED",
	1:  "REGISTER",
	2:  "REGISTERED",
	3:  "INIT",
	4:  "READY",
	5:  "TRANSACTION",
	6:  "COMPLETED",
	7:  "ERROR",
	8:  "GET_STATE",
	9:  "PUT_STATE",
	10: "DEL_STATE",
	11: "INVOKE_CHAINCODE",
	12: "INVOKE_QUERY",
	13: "RESPONSE",
	14: "QUERY",
	15: "QUERY_COMPLETED",
	16: "QUERY_ERROR",
	17: "RANGE_QUERY_STATE",
	18: "RANGE_QUERY_STATE_NEXT",
	19: "RANGE_QUERY_STATE_CLOSE",
	20: "KEEPALIVE",
}
View Source
var ChaincodeMessage_Type_value = map[string]int32{
	"UNDEFINED":               0,
	"REGISTER":                1,
	"REGISTERED":              2,
	"INIT":                    3,
	"READY":                   4,
	"TRANSACTION":             5,
	"COMPLETED":               6,
	"ERROR":                   7,
	"GET_STATE":               8,
	"PUT_STATE":               9,
	"DEL_STATE":               10,
	"INVOKE_CHAINCODE":        11,
	"INVOKE_QUERY":            12,
	"RESPONSE":                13,
	"QUERY":                   14,
	"QUERY_COMPLETED":         15,
	"QUERY_ERROR":             16,
	"RANGE_QUERY_STATE":       17,
	"RANGE_QUERY_STATE_NEXT":  18,
	"RANGE_QUERY_STATE_CLOSE": 19,
	"KEEPALIVE":               20,
}
View Source
var ChaincodeSpec_Type_name = map[int32]string{
	0: "UNDEFINED",
	1: "GOLANG",
	2: "NODE",
	3: "CAR",
	4: "JAVA",
}
View Source
var ChaincodeSpec_Type_value = map[string]int32{
	"UNDEFINED": 0,
	"GOLANG":    1,
	"NODE":      2,
	"CAR":       3,
	"JAVA":      4,
}
View Source
var ConfidentialityLevel_name = map[int32]string{
	0: "PUBLIC",
	1: "CONFIDENTIAL",
}
View Source
var ConfidentialityLevel_value = map[string]int32{
	"PUBLIC":       0,
	"CONFIDENTIAL": 1,
}
View Source
var EventType_name = map[int32]string{
	0: "REGISTER",
	1: "BLOCK",
	2: "CHAINCODE",
	3: "REJECTION",
}
View Source
var EventType_value = map[string]int32{
	"REGISTER":  0,
	"BLOCK":     1,
	"CHAINCODE": 2,
	"REJECTION": 3,
}
View Source
var Message_Type_name = map[int32]string{
	0:  "UNDEFINED",
	1:  "DISC_HELLO",
	2:  "DISC_DISCONNECT",
	3:  "DISC_GET_PEERS",
	4:  "DISC_PEERS",
	5:  "DISC_NEWMSG",
	6:  "CHAIN_TRANSACTION",
	11: "SYNC_GET_BLOCKS",
	12: "SYNC_BLOCKS",
	13: "SYNC_BLOCK_ADDED",
	14: "SYNC_STATE_GET_SNAPSHOT",
	15: "SYNC_STATE_SNAPSHOT",
	16: "SYNC_STATE_GET_DELTAS",
	17: "SYNC_STATE_DELTAS",
	20: "RESPONSE",
	21: "CONSENSUS",
}
View Source
var Message_Type_value = map[string]int32{
	"UNDEFINED":               0,
	"DISC_HELLO":              1,
	"DISC_DISCONNECT":         2,
	"DISC_GET_PEERS":          3,
	"DISC_PEERS":              4,
	"DISC_NEWMSG":             5,
	"CHAIN_TRANSACTION":       6,
	"SYNC_GET_BLOCKS":         11,
	"SYNC_BLOCKS":             12,
	"SYNC_BLOCK_ADDED":        13,
	"SYNC_STATE_GET_SNAPSHOT": 14,
	"SYNC_STATE_SNAPSHOT":     15,
	"SYNC_STATE_GET_DELTAS":   16,
	"SYNC_STATE_DELTAS":       17,
	"RESPONSE":                20,
	"CONSENSUS":               21,
}
View Source
var PeerEndpoint_Type_name = map[int32]string{
	0: "UNDEFINED",
	1: "VALIDATOR",
	2: "NON_VALIDATOR",
}
View Source
var PeerEndpoint_Type_value = map[string]int32{
	"UNDEFINED":     0,
	"VALIDATOR":     1,
	"NON_VALIDATOR": 2,
}
View Source
var Response_StatusCode_name = map[int32]string{
	0:   "UNDEFINED",
	200: "SUCCESS",
	500: "FAILURE",
}
View Source
var Response_StatusCode_value = map[string]int32{
	"UNDEFINED": 0,
	"SUCCESS":   200,
	"FAILURE":   500,
}
View Source
var ServerStatus_StatusCode_name = map[int32]string{
	0: "UNDEFINED",
	1: "STARTED",
	2: "STOPPED",
	3: "PAUSED",
	4: "ERROR",
	5: "UNKNOWN",
}
View Source
var ServerStatus_StatusCode_value = map[string]int32{
	"UNDEFINED": 0,
	"STARTED":   1,
	"STOPPED":   2,
	"PAUSED":    3,
	"ERROR":     4,
	"UNKNOWN":   5,
}
View Source
var Transaction_Type_name = map[int32]string{
	0: "UNDEFINED",
	1: "CHAINCODE_DEPLOY",
	2: "CHAINCODE_INVOKE",
	3: "CHAINCODE_QUERY",
	4: "CHAINCODE_TERMINATE",
}
View Source
var Transaction_Type_value = map[string]int32{
	"UNDEFINED":           0,
	"CHAINCODE_DEPLOY":    1,
	"CHAINCODE_INVOKE":    2,
	"CHAINCODE_QUERY":     3,
	"CHAINCODE_TERMINATE": 4,
}

Functions ¶

func RegisterAdminServer ¶

func RegisterAdminServer(s *grpc.Server, srv AdminServer)

func RegisterChaincodeSupportServer ¶

func RegisterChaincodeSupportServer(s *grpc.Server, srv ChaincodeSupportServer)

func RegisterDevopsServer ¶

func RegisterDevopsServer(s *grpc.Server, srv DevopsServer)

func RegisterEventsServer ¶

func RegisterEventsServer(s *grpc.Server, srv EventsServer)

func RegisterOpenchainServer ¶

func RegisterOpenchainServer(s *grpc.Server, srv OpenchainServer)

func RegisterPeerServer ¶

func RegisterPeerServer(s *grpc.Server, srv PeerServer)

Types ¶

type AdminClient ¶

type AdminClient interface {
	// Return the serve status.
	GetStatus(ctx context.Context, in *google_protobuf1.Empty, opts ...grpc.CallOption) (*ServerStatus, error)
	StartServer(ctx context.Context, in *google_protobuf1.Empty, opts ...grpc.CallOption) (*ServerStatus, error)
	StopServer(ctx context.Context, in *google_protobuf1.Empty, opts ...grpc.CallOption) (*ServerStatus, error)
}

func NewAdminClient ¶

func NewAdminClient(cc *grpc.ClientConn) AdminClient

type AdminServer ¶

type AdminServer interface {
	// Return the serve status.
	GetStatus(context.Context, *google_protobuf1.Empty) (*ServerStatus, error)
	StartServer(context.Context, *google_protobuf1.Empty) (*ServerStatus, error)
	StopServer(context.Context, *google_protobuf1.Empty) (*ServerStatus, error)
}

type Block ¶

type Block struct {
	Version           uint32                     `protobuf:"varint,1,opt,name=version" json:"version,omitempty"`
	Timestamp         *google_protobuf.Timestamp `protobuf:"bytes,2,opt,name=timestamp" json:"timestamp,omitempty"`
	Transactions      []*Transaction             `protobuf:"bytes,3,rep,name=transactions" json:"transactions,omitempty"`
	StateHash         []byte                     `protobuf:"bytes,4,opt,name=stateHash,proto3" json:"stateHash,omitempty"`
	PreviousBlockHash []byte                     `protobuf:"bytes,5,opt,name=previousBlockHash,proto3" json:"previousBlockHash,omitempty"`
	ConsensusMetadata []byte                     `protobuf:"bytes,6,opt,name=consensusMetadata,proto3" json:"consensusMetadata,omitempty"`
	NonHashData       *NonHashData               `protobuf:"bytes,7,opt,name=nonHashData" json:"nonHashData,omitempty"`
}

Block carries The data that describes a block in the blockchain. version - Version used to track any protocol changes. timestamp - The time at which the block or transaction order was proposed. This may not be used by all consensus modules. transactions - The ordered list of transactions in the block. stateHash - The state hash after running transactions in this block. previousBlockHash - The hash of the previous block in the chain. consensusMetadata - Consensus modules may optionally store any additional metadata in this field. nonHashData - Data stored with the block, but not included in the blocks hash. This allows this data to be different per peer or discarded without impacting the blockchain.

func NewBlock ¶

func NewBlock(transactions []*Transaction, metadata []byte) *Block

NewBlock creates a new Block given the input parameters.

func UnmarshallBlock ¶

func UnmarshallBlock(blockBytes []byte) (*Block, error)

UnmarshallBlock converts a byte array generated by Bytes() back to a block.

func (*Block) Bytes ¶

func (block *Block) Bytes() ([]byte, error)

Bytes returns this block as an array of bytes.

func (*Block) Descriptor ¶

func (*Block) Descriptor() ([]byte, []int)

func (*Block) GetHash ¶

func (block *Block) GetHash() ([]byte, error)

GetHash returns the hash of this block.

func (*Block) GetNonHashData ¶

func (m *Block) GetNonHashData() *NonHashData

func (*Block) GetStateHash ¶

func (block *Block) GetStateHash() []byte

GetStateHash returns the stateHash stored in this block. The stateHash is the value returned by state.GetHash() after running all transactions in the block.

func (*Block) GetTimestamp ¶

func (m *Block) GetTimestamp() *google_protobuf.Timestamp

func (*Block) GetTransactions ¶

func (m *Block) GetTransactions() []*Transaction

func (*Block) ProtoMessage ¶

func (*Block) ProtoMessage()

func (*Block) Reset ¶

func (m *Block) Reset()

func (*Block) SetPreviousBlockHash ¶

func (block *Block) SetPreviousBlockHash(previousBlockHash []byte)

SetPreviousBlockHash sets the hash of the previous block. This will be called by blockchain.AddBlock when then the block is added.

func (*Block) String ¶

func (m *Block) String() string

type BlockCount ¶

type BlockCount struct {
	Count uint64 `protobuf:"varint,1,opt,name=count" json:"count,omitempty"`
}

Specifies the current number of blocks in the blockchain.

func (*BlockCount) Descriptor ¶

func (*BlockCount) Descriptor() ([]byte, []int)

func (*BlockCount) ProtoMessage ¶

func (*BlockCount) ProtoMessage()

func (*BlockCount) Reset ¶

func (m *BlockCount) Reset()

func (*BlockCount) String ¶

func (m *BlockCount) String() string

type BlockNumber ¶

type BlockNumber struct {
	Number uint64 `protobuf:"varint,1,opt,name=number" json:"number,omitempty"`
}

Specifies the block number to be returned from the blockchain.

func (*BlockNumber) Descriptor ¶

func (*BlockNumber) Descriptor() ([]byte, []int)

func (*BlockNumber) ProtoMessage ¶

func (*BlockNumber) ProtoMessage()

func (*BlockNumber) Reset ¶

func (m *BlockNumber) Reset()

func (*BlockNumber) String ¶

func (m *BlockNumber) String() string

type BlockState ¶

type BlockState struct {
	Block      *Block `protobuf:"bytes,1,opt,name=block" json:"block,omitempty"`
	StateDelta []byte `protobuf:"bytes,2,opt,name=stateDelta,proto3" json:"stateDelta,omitempty"`
}

BlockState is the payload of Message.SYNC_BLOCK_ADDED. When a VP commits a new block to the ledger, it will notify its connected NVPs of the block and the delta state. The NVP may call the ledger APIs to apply the block and the delta state to its ledger if the block's previousBlockHash equals to the NVP's current block hash

func (*BlockState) Descriptor ¶

func (*BlockState) Descriptor() ([]byte, []int)

func (*BlockState) GetBlock ¶

func (m *BlockState) GetBlock() *Block

func (*BlockState) ProtoMessage ¶

func (*BlockState) ProtoMessage()

func (*BlockState) Reset ¶

func (m *BlockState) Reset()

func (*BlockState) String ¶

func (m *BlockState) String() string

type BlockchainInfo ¶

type BlockchainInfo struct {
	Height            uint64 `protobuf:"varint,1,opt,name=height" json:"height,omitempty"`
	CurrentBlockHash  []byte `protobuf:"bytes,2,opt,name=currentBlockHash,proto3" json:"currentBlockHash,omitempty"`
	PreviousBlockHash []byte `protobuf:"bytes,3,opt,name=previousBlockHash,proto3" json:"previousBlockHash,omitempty"`
}

Contains information about the blockchain ledger such as height, current block hash, and previous block hash.

func (*BlockchainInfo) Descriptor ¶

func (*BlockchainInfo) Descriptor() ([]byte, []int)

func (*BlockchainInfo) ProtoMessage ¶

func (*BlockchainInfo) ProtoMessage()

func (*BlockchainInfo) Reset ¶

func (m *BlockchainInfo) Reset()

func (*BlockchainInfo) String ¶

func (m *BlockchainInfo) String() string

type BuildResult ¶

type BuildResult struct {
	Status         BuildResult_StatusCode   `protobuf:"varint,1,opt,name=status,enum=protos.BuildResult_StatusCode" json:"status,omitempty"`
	Msg            string                   `protobuf:"bytes,2,opt,name=msg" json:"msg,omitempty"`
	DeploymentSpec *ChaincodeDeploymentSpec `protobuf:"bytes,3,opt,name=deploymentSpec" json:"deploymentSpec,omitempty"`
}

func (*BuildResult) Descriptor ¶

func (*BuildResult) Descriptor() ([]byte, []int)

func (*BuildResult) GetDeploymentSpec ¶

func (m *BuildResult) GetDeploymentSpec() *ChaincodeDeploymentSpec

func (*BuildResult) ProtoMessage ¶

func (*BuildResult) ProtoMessage()

func (*BuildResult) Reset ¶

func (m *BuildResult) Reset()

func (*BuildResult) String ¶

func (m *BuildResult) String() string

type BuildResult_StatusCode ¶

type BuildResult_StatusCode int32
const (
	BuildResult_UNDEFINED BuildResult_StatusCode = 0
	BuildResult_SUCCESS   BuildResult_StatusCode = 1
	BuildResult_FAILURE   BuildResult_StatusCode = 2
)

func (BuildResult_StatusCode) EnumDescriptor ¶

func (BuildResult_StatusCode) EnumDescriptor() ([]byte, []int)

func (BuildResult_StatusCode) String ¶

func (x BuildResult_StatusCode) String() string

type ChaincodeDeploymentSpec ¶

type ChaincodeDeploymentSpec struct {
	ChaincodeSpec *ChaincodeSpec `protobuf:"bytes,1,opt,name=chaincodeSpec" json:"chaincodeSpec,omitempty"`
	// Controls when the chaincode becomes executable.
	EffectiveDate *google_protobuf.Timestamp                   `protobuf:"bytes,2,opt,name=effectiveDate" json:"effectiveDate,omitempty"`
	CodePackage   []byte                                       `protobuf:"bytes,3,opt,name=codePackage,proto3" json:"codePackage,omitempty"`
	ExecEnv       ChaincodeDeploymentSpec_ExecutionEnvironment `protobuf:"varint,4,opt,name=execEnv,enum=protos.ChaincodeDeploymentSpec_ExecutionEnvironment" json:"execEnv,omitempty"`
}

Specify the deployment of a chaincode. TODO: Define `codePackage`.

func (*ChaincodeDeploymentSpec) Descriptor ¶

func (*ChaincodeDeploymentSpec) Descriptor() ([]byte, []int)

func (*ChaincodeDeploymentSpec) GetChaincodeSpec ¶

func (m *ChaincodeDeploymentSpec) GetChaincodeSpec() *ChaincodeSpec

func (*ChaincodeDeploymentSpec) GetEffectiveDate ¶

func (m *ChaincodeDeploymentSpec) GetEffectiveDate() *google_protobuf.Timestamp

func (*ChaincodeDeploymentSpec) ProtoMessage ¶

func (*ChaincodeDeploymentSpec) ProtoMessage()

func (*ChaincodeDeploymentSpec) Reset ¶

func (m *ChaincodeDeploymentSpec) Reset()

func (*ChaincodeDeploymentSpec) String ¶

func (m *ChaincodeDeploymentSpec) String() string

type ChaincodeDeploymentSpec_ExecutionEnvironment ¶

type ChaincodeDeploymentSpec_ExecutionEnvironment int32
const (
	ChaincodeDeploymentSpec_DOCKER ChaincodeDeploymentSpec_ExecutionEnvironment = 0
	ChaincodeDeploymentSpec_SYSTEM ChaincodeDeploymentSpec_ExecutionEnvironment = 1
)

func (ChaincodeDeploymentSpec_ExecutionEnvironment) EnumDescriptor ¶

func (ChaincodeDeploymentSpec_ExecutionEnvironment) EnumDescriptor() ([]byte, []int)

func (ChaincodeDeploymentSpec_ExecutionEnvironment) String ¶

type ChaincodeEvent ¶

type ChaincodeEvent struct {
	ChaincodeID string `protobuf:"bytes,1,opt,name=chaincodeID" json:"chaincodeID,omitempty"`
	TxID        string `protobuf:"bytes,2,opt,name=txID" json:"txID,omitempty"`
	EventName   string `protobuf:"bytes,3,opt,name=eventName" json:"eventName,omitempty"`
	Payload     []byte `protobuf:"bytes,4,opt,name=payload,proto3" json:"payload,omitempty"`
}

ChaincodeEvent is used for events and registrations that are specific to chaincode string type - "chaincode"

func (*ChaincodeEvent) Descriptor ¶

func (*ChaincodeEvent) Descriptor() ([]byte, []int)

func (*ChaincodeEvent) ProtoMessage ¶

func (*ChaincodeEvent) ProtoMessage()

func (*ChaincodeEvent) Reset ¶

func (m *ChaincodeEvent) Reset()

func (*ChaincodeEvent) String ¶

func (m *ChaincodeEvent) String() string

type ChaincodeID ¶

type ChaincodeID struct {
	// deploy transaction will use the path
	Path string `protobuf:"bytes,1,opt,name=path" json:"path,omitempty"`
	// all other requests will use the name (really a hashcode) generated by
	// the deploy transaction
	Name string `protobuf:"bytes,2,opt,name=name" json:"name,omitempty"`
}

ChaincodeID contains the path as specified by the deploy transaction that created it as well as the hashCode that is generated by the system for the path. From the user level (ie, CLI, REST API and so on) deploy transaction is expected to provide the path and other requests are expected to provide the hashCode. The other value will be ignored. Internally, the structure could contain both values. For instance, the hashCode will be set when first generated using the path

func (*ChaincodeID) Descriptor ¶

func (*ChaincodeID) Descriptor() ([]byte, []int)

func (*ChaincodeID) ProtoMessage ¶

func (*ChaincodeID) ProtoMessage()

func (*ChaincodeID) Reset ¶

func (m *ChaincodeID) Reset()

func (*ChaincodeID) String ¶

func (m *ChaincodeID) String() string

type ChaincodeInput ¶

type ChaincodeInput struct {
	Args [][]byte `protobuf:"bytes,1,rep,name=args,proto3" json:"args,omitempty"`
}

Carries the chaincode function and its arguments. UnmarshalJSON in transaction.go converts the string-based REST/JSON input to the []byte-based current ChaincodeInput structure.

func (*ChaincodeInput) Descriptor ¶

func (*ChaincodeInput) Descriptor() ([]byte, []int)

func (*ChaincodeInput) ProtoMessage ¶

func (*ChaincodeInput) ProtoMessage()

func (*ChaincodeInput) Reset ¶

func (m *ChaincodeInput) Reset()

func (*ChaincodeInput) String ¶

func (m *ChaincodeInput) String() string

func (*ChaincodeInput) UnmarshalJSON ¶

func (c *ChaincodeInput) UnmarshalJSON(b []byte) error

UnmarshalJSON converts the string-based REST/JSON input to the []byte-based current ChaincodeInput structure.

type ChaincodeInvocationSpec ¶

type ChaincodeInvocationSpec struct {
	ChaincodeSpec *ChaincodeSpec `protobuf:"bytes,1,opt,name=chaincodeSpec" json:"chaincodeSpec,omitempty"`
	// This field can contain a user-specified ID generation algorithm
	// If supplied, this will be used to generate a ID
	// If not supplied (left empty), sha256base64 will be used
	// The algorithm consists of two parts:
	//  1, a hash function
	//  2, a decoding used to decode user (string) input to bytes
	// Currently, SHA256 with BASE64 is supported (e.g. idGenerationAlg='sha256base64')
	IdGenerationAlg string `protobuf:"bytes,2,opt,name=idGenerationAlg" json:"idGenerationAlg,omitempty"`
}

Carries the chaincode function and its arguments.

func (*ChaincodeInvocationSpec) Descriptor ¶

func (*ChaincodeInvocationSpec) Descriptor() ([]byte, []int)

func (*ChaincodeInvocationSpec) GetChaincodeSpec ¶

func (m *ChaincodeInvocationSpec) GetChaincodeSpec() *ChaincodeSpec

func (*ChaincodeInvocationSpec) ProtoMessage ¶

func (*ChaincodeInvocationSpec) ProtoMessage()

func (*ChaincodeInvocationSpec) Reset ¶

func (m *ChaincodeInvocationSpec) Reset()

func (*ChaincodeInvocationSpec) String ¶

func (m *ChaincodeInvocationSpec) String() string

type ChaincodeMessage ¶

type ChaincodeMessage struct {
	Type            ChaincodeMessage_Type      `protobuf:"varint,1,opt,name=type,enum=protos.ChaincodeMessage_Type" json:"type,omitempty"`
	Timestamp       *google_protobuf.Timestamp `protobuf:"bytes,2,opt,name=timestamp" json:"timestamp,omitempty"`
	Payload         []byte                     `protobuf:"bytes,3,opt,name=payload,proto3" json:"payload,omitempty"`
	Txid            string                     `protobuf:"bytes,4,opt,name=txid" json:"txid,omitempty"`
	SecurityContext *ChaincodeSecurityContext  `protobuf:"bytes,5,opt,name=securityContext" json:"securityContext,omitempty"`
	// event emmited by chaincode. Used only with Init or Invoke.
	// This event is then stored (currently)
	// with Block.NonHashData.TransactionResult
	ChaincodeEvent *ChaincodeEvent `protobuf:"bytes,6,opt,name=chaincodeEvent" json:"chaincodeEvent,omitempty"`
}

func (*ChaincodeMessage) Descriptor ¶

func (*ChaincodeMessage) Descriptor() ([]byte, []int)

func (*ChaincodeMessage) GetChaincodeEvent ¶

func (m *ChaincodeMessage) GetChaincodeEvent() *ChaincodeEvent

func (*ChaincodeMessage) GetSecurityContext ¶

func (m *ChaincodeMessage) GetSecurityContext() *ChaincodeSecurityContext

func (*ChaincodeMessage) GetTimestamp ¶

func (m *ChaincodeMessage) GetTimestamp() *google_protobuf.Timestamp

func (*ChaincodeMessage) ProtoMessage ¶

func (*ChaincodeMessage) ProtoMessage()

func (*ChaincodeMessage) Reset ¶

func (m *ChaincodeMessage) Reset()

func (*ChaincodeMessage) String ¶

func (m *ChaincodeMessage) String() string

type ChaincodeMessage_Type ¶

type ChaincodeMessage_Type int32
const (
	ChaincodeMessage_UNDEFINED               ChaincodeMessage_Type = 0
	ChaincodeMessage_REGISTER                ChaincodeMessage_Type = 1
	ChaincodeMessage_REGISTERED              ChaincodeMessage_Type = 2
	ChaincodeMessage_INIT                    ChaincodeMessage_Type = 3
	ChaincodeMessage_READY                   ChaincodeMessage_Type = 4
	ChaincodeMessage_TRANSACTION             ChaincodeMessage_Type = 5
	ChaincodeMessage_COMPLETED               ChaincodeMessage_Type = 6
	ChaincodeMessage_ERROR                   ChaincodeMessage_Type = 7
	ChaincodeMessage_GET_STATE               ChaincodeMessage_Type = 8
	ChaincodeMessage_PUT_STATE               ChaincodeMessage_Type = 9
	ChaincodeMessage_DEL_STATE               ChaincodeMessage_Type = 10
	ChaincodeMessage_INVOKE_CHAINCODE        ChaincodeMessage_Type = 11
	ChaincodeMessage_INVOKE_QUERY            ChaincodeMessage_Type = 12
	ChaincodeMessage_RESPONSE                ChaincodeMessage_Type = 13
	ChaincodeMessage_QUERY                   ChaincodeMessage_Type = 14
	ChaincodeMessage_QUERY_COMPLETED         ChaincodeMessage_Type = 15
	ChaincodeMessage_QUERY_ERROR             ChaincodeMessage_Type = 16
	ChaincodeMessage_RANGE_QUERY_STATE       ChaincodeMessage_Type = 17
	ChaincodeMessage_RANGE_QUERY_STATE_NEXT  ChaincodeMessage_Type = 18
	ChaincodeMessage_RANGE_QUERY_STATE_CLOSE ChaincodeMessage_Type = 19
	ChaincodeMessage_KEEPALIVE               ChaincodeMessage_Type = 20
)

func (ChaincodeMessage_Type) EnumDescriptor ¶

func (ChaincodeMessage_Type) EnumDescriptor() ([]byte, []int)

func (ChaincodeMessage_Type) String ¶

func (x ChaincodeMessage_Type) String() string

type ChaincodeReg ¶

type ChaincodeReg struct {
	ChaincodeID string `protobuf:"bytes,1,opt,name=chaincodeID" json:"chaincodeID,omitempty"`
	EventName   string `protobuf:"bytes,2,opt,name=eventName" json:"eventName,omitempty"`
}

ChaincodeReg is used for registering chaincode Interests when EventType is CHAINCODE

func (*ChaincodeReg) Descriptor ¶

func (*ChaincodeReg) Descriptor() ([]byte, []int)

func (*ChaincodeReg) ProtoMessage ¶

func (*ChaincodeReg) ProtoMessage()

func (*ChaincodeReg) Reset ¶

func (m *ChaincodeReg) Reset()

func (*ChaincodeReg) String ¶

func (m *ChaincodeReg) String() string

type ChaincodeSecurityContext ¶

type ChaincodeSecurityContext struct {
	CallerCert     []byte                     `protobuf:"bytes,1,opt,name=callerCert,proto3" json:"callerCert,omitempty"`
	CallerSign     []byte                     `protobuf:"bytes,2,opt,name=callerSign,proto3" json:"callerSign,omitempty"`
	Payload        []byte                     `protobuf:"bytes,3,opt,name=payload,proto3" json:"payload,omitempty"`
	Binding        []byte                     `protobuf:"bytes,4,opt,name=binding,proto3" json:"binding,omitempty"`
	Metadata       []byte                     `protobuf:"bytes,5,opt,name=metadata,proto3" json:"metadata,omitempty"`
	ParentMetadata []byte                     `protobuf:"bytes,6,opt,name=parentMetadata,proto3" json:"parentMetadata,omitempty"`
	TxTimestamp    *google_protobuf.Timestamp `protobuf:"bytes,7,opt,name=txTimestamp" json:"txTimestamp,omitempty"`
}

This structure contain transaction data that we send to the chaincode container shim and allow the chaincode to access through the shim interface. TODO: Consider remove this message and just pass the transaction object to the shim and/or allow the chaincode to query transactions.

func (*ChaincodeSecurityContext) Descriptor ¶

func (*ChaincodeSecurityContext) Descriptor() ([]byte, []int)

func (*ChaincodeSecurityContext) GetTxTimestamp ¶

func (m *ChaincodeSecurityContext) GetTxTimestamp() *google_protobuf.Timestamp

func (*ChaincodeSecurityContext) ProtoMessage ¶

func (*ChaincodeSecurityContext) ProtoMessage()

func (*ChaincodeSecurityContext) Reset ¶

func (m *ChaincodeSecurityContext) Reset()

func (*ChaincodeSecurityContext) String ¶

func (m *ChaincodeSecurityContext) String() string

type ChaincodeSpec ¶

type ChaincodeSpec struct {
	Type                 ChaincodeSpec_Type   `protobuf:"varint,1,opt,name=type,enum=protos.ChaincodeSpec_Type" json:"type,omitempty"`
	ChaincodeID          *ChaincodeID         `protobuf:"bytes,2,opt,name=chaincodeID" json:"chaincodeID,omitempty"`
	CtorMsg              *ChaincodeInput      `protobuf:"bytes,3,opt,name=ctorMsg" json:"ctorMsg,omitempty"`
	Timeout              int32                `protobuf:"varint,4,opt,name=timeout" json:"timeout,omitempty"`
	SecureContext        string               `protobuf:"bytes,5,opt,name=secureContext" json:"secureContext,omitempty"`
	ConfidentialityLevel ConfidentialityLevel `protobuf:"varint,6,opt,name=confidentialityLevel,enum=protos.ConfidentialityLevel" json:"confidentialityLevel,omitempty"`
	Metadata             []byte               `protobuf:"bytes,7,opt,name=metadata,proto3" json:"metadata,omitempty"`
	Attributes           []string             `protobuf:"bytes,8,rep,name=attributes" json:"attributes,omitempty"`
}

Carries the chaincode specification. This is the actual metadata required for defining a chaincode.

func (*ChaincodeSpec) Descriptor ¶

func (*ChaincodeSpec) Descriptor() ([]byte, []int)

func (*ChaincodeSpec) GetChaincodeID ¶

func (m *ChaincodeSpec) GetChaincodeID() *ChaincodeID

func (*ChaincodeSpec) GetCtorMsg ¶

func (m *ChaincodeSpec) GetCtorMsg() *ChaincodeInput

func (*ChaincodeSpec) ProtoMessage ¶

func (*ChaincodeSpec) ProtoMessage()

func (*ChaincodeSpec) Reset ¶

func (m *ChaincodeSpec) Reset()

func (*ChaincodeSpec) String ¶

func (m *ChaincodeSpec) String() string

type ChaincodeSpec_Type ¶

type ChaincodeSpec_Type int32
const (
	ChaincodeSpec_UNDEFINED ChaincodeSpec_Type = 0
	ChaincodeSpec_GOLANG    ChaincodeSpec_Type = 1
	ChaincodeSpec_NODE      ChaincodeSpec_Type = 2
	ChaincodeSpec_CAR       ChaincodeSpec_Type = 3
	ChaincodeSpec_JAVA      ChaincodeSpec_Type = 4
)

func (ChaincodeSpec_Type) EnumDescriptor ¶

func (ChaincodeSpec_Type) EnumDescriptor() ([]byte, []int)

func (ChaincodeSpec_Type) String ¶

func (x ChaincodeSpec_Type) String() string

type ChaincodeSupportClient ¶

type ChaincodeSupportClient interface {
	Register(ctx context.Context, opts ...grpc.CallOption) (ChaincodeSupport_RegisterClient, error)
}

func NewChaincodeSupportClient ¶

func NewChaincodeSupportClient(cc *grpc.ClientConn) ChaincodeSupportClient

type ChaincodeSupportServer ¶

type ChaincodeSupportServer interface {
	Register(ChaincodeSupport_RegisterServer) error
}

type ChaincodeSupport_RegisterClient ¶

type ChaincodeSupport_RegisterClient interface {
	Send(*ChaincodeMessage) error
	Recv() (*ChaincodeMessage, error)
	grpc.ClientStream
}

type ChaincodeSupport_RegisterServer ¶

type ChaincodeSupport_RegisterServer interface {
	Send(*ChaincodeMessage) error
	Recv() (*ChaincodeMessage, error)
	grpc.ServerStream
}

type ConfidentialityLevel ¶

type ConfidentialityLevel int32

Confidentiality Levels

const (
	ConfidentialityLevel_PUBLIC       ConfidentialityLevel = 0
	ConfidentialityLevel_CONFIDENTIAL ConfidentialityLevel = 1
)

func (ConfidentialityLevel) EnumDescriptor ¶

func (ConfidentialityLevel) EnumDescriptor() ([]byte, []int)

func (ConfidentialityLevel) String ¶

func (x ConfidentialityLevel) String() string

type DevopsClient ¶

type DevopsClient interface {
	// Log in - passed Secret object and returns Response object, where
	// msg is the security context to be used in subsequent invocations
	Login(ctx context.Context, in *Secret, opts ...grpc.CallOption) (*Response, error)
	// Build the chaincode package.
	Build(ctx context.Context, in *ChaincodeSpec, opts ...grpc.CallOption) (*ChaincodeDeploymentSpec, error)
	// Deploy the chaincode package to the chain.
	Deploy(ctx context.Context, in *ChaincodeSpec, opts ...grpc.CallOption) (*ChaincodeDeploymentSpec, error)
	// Invoke chaincode.
	Invoke(ctx context.Context, in *ChaincodeInvocationSpec, opts ...grpc.CallOption) (*Response, error)
	// Query chaincode.
	Query(ctx context.Context, in *ChaincodeInvocationSpec, opts ...grpc.CallOption) (*Response, error)
	// Retrieve a TCert.
	EXP_GetApplicationTCert(ctx context.Context, in *Secret, opts ...grpc.CallOption) (*Response, error)
	// Prepare for performing a TX, which will return a binding that can later be used to sign and then execute a transaction.
	EXP_PrepareForTx(ctx context.Context, in *Secret, opts ...grpc.CallOption) (*Response, error)
	// Prepare for performing a TX, which will return a binding that can later be used to sign and then execute a transaction.
	EXP_ProduceSigma(ctx context.Context, in *SigmaInput, opts ...grpc.CallOption) (*Response, error)
	// Execute a transaction with a specific binding
	EXP_ExecuteWithBinding(ctx context.Context, in *ExecuteWithBinding, opts ...grpc.CallOption) (*Response, error)
}

func NewDevopsClient ¶

func NewDevopsClient(cc *grpc.ClientConn) DevopsClient

type DevopsServer ¶

type DevopsServer interface {
	// Log in - passed Secret object and returns Response object, where
	// msg is the security context to be used in subsequent invocations
	Login(context.Context, *Secret) (*Response, error)
	// Build the chaincode package.
	Build(context.Context, *ChaincodeSpec) (*ChaincodeDeploymentSpec, error)
	// Deploy the chaincode package to the chain.
	Deploy(context.Context, *ChaincodeSpec) (*ChaincodeDeploymentSpec, error)
	// Invoke chaincode.
	Invoke(context.Context, *ChaincodeInvocationSpec) (*Response, error)
	// Query chaincode.
	Query(context.Context, *ChaincodeInvocationSpec) (*Response, error)
	// Retrieve a TCert.
	EXP_GetApplicationTCert(context.Context, *Secret) (*Response, error)
	// Prepare for performing a TX, which will return a binding that can later be used to sign and then execute a transaction.
	EXP_PrepareForTx(context.Context, *Secret) (*Response, error)
	// Prepare for performing a TX, which will return a binding that can later be used to sign and then execute a transaction.
	EXP_ProduceSigma(context.Context, *SigmaInput) (*Response, error)
	// Execute a transaction with a specific binding
	EXP_ExecuteWithBinding(context.Context, *ExecuteWithBinding) (*Response, error)
}

type Event ¶

type Event struct {
	// Types that are valid to be assigned to Event:
	//	*Event_Register
	//	*Event_Block
	//	*Event_ChaincodeEvent
	//	*Event_Rejection
	//	*Event_Unregister
	Event isEvent_Event `protobuf_oneof:"Event"`
}

Event is used by

  • consumers (adapters) to send Register
  • producer to advertise supported types and events

func (*Event) Descriptor ¶

func (*Event) Descriptor() ([]byte, []int)

func (*Event) GetBlock ¶

func (m *Event) GetBlock() *Block

func (*Event) GetChaincodeEvent ¶

func (m *Event) GetChaincodeEvent() *ChaincodeEvent

func (*Event) GetEvent ¶

func (m *Event) GetEvent() isEvent_Event

func (*Event) GetRegister ¶

func (m *Event) GetRegister() *Register

func (*Event) GetRejection ¶

func (m *Event) GetRejection() *Rejection

func (*Event) GetUnregister ¶

func (m *Event) GetUnregister() *Unregister

func (*Event) ProtoMessage ¶

func (*Event) ProtoMessage()

func (*Event) Reset ¶

func (m *Event) Reset()

func (*Event) String ¶

func (m *Event) String() string

func (*Event) XXX_OneofFuncs ¶

func (*Event) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

type EventType ¶

type EventType int32
const (
	EventType_REGISTER  EventType = 0
	EventType_BLOCK     EventType = 1
	EventType_CHAINCODE EventType = 2
	EventType_REJECTION EventType = 3
)

func (EventType) EnumDescriptor ¶

func (EventType) EnumDescriptor() ([]byte, []int)

func (EventType) String ¶

func (x EventType) String() string

type Event_Block ¶

type Event_Block struct {
	Block *Block `protobuf:"bytes,2,opt,name=block,oneof"`
}

type Event_ChaincodeEvent ¶

type Event_ChaincodeEvent struct {
	ChaincodeEvent *ChaincodeEvent `protobuf:"bytes,3,opt,name=chaincodeEvent,oneof"`
}

type Event_Register ¶

type Event_Register struct {
	Register *Register `protobuf:"bytes,1,opt,name=register,oneof"`
}

type Event_Rejection ¶

type Event_Rejection struct {
	Rejection *Rejection `protobuf:"bytes,4,opt,name=rejection,oneof"`
}

type Event_Unregister ¶

type Event_Unregister struct {
	Unregister *Unregister `protobuf:"bytes,5,opt,name=unregister,oneof"`
}

type EventsClient ¶

type EventsClient interface {
	// event chatting using Event
	Chat(ctx context.Context, opts ...grpc.CallOption) (Events_ChatClient, error)
}

func NewEventsClient ¶

func NewEventsClient(cc *grpc.ClientConn) EventsClient

type EventsServer ¶

type EventsServer interface {
	// event chatting using Event
	Chat(Events_ChatServer) error
}

type Events_ChatClient ¶

type Events_ChatClient interface {
	Send(*Event) error
	Recv() (*Event, error)
	grpc.ClientStream
}

type Events_ChatServer ¶

type Events_ChatServer interface {
	Send(*Event) error
	Recv() (*Event, error)
	grpc.ServerStream
}

type ExecuteWithBinding ¶

type ExecuteWithBinding struct {
	ChaincodeInvocationSpec *ChaincodeInvocationSpec `protobuf:"bytes,1,opt,name=chaincodeInvocationSpec" json:"chaincodeInvocationSpec,omitempty"`
	Binding                 []byte                   `protobuf:"bytes,2,opt,name=binding,proto3" json:"binding,omitempty"`
}

func (*ExecuteWithBinding) Descriptor ¶

func (*ExecuteWithBinding) Descriptor() ([]byte, []int)

func (*ExecuteWithBinding) GetChaincodeInvocationSpec ¶

func (m *ExecuteWithBinding) GetChaincodeInvocationSpec() *ChaincodeInvocationSpec

func (*ExecuteWithBinding) ProtoMessage ¶

func (*ExecuteWithBinding) ProtoMessage()

func (*ExecuteWithBinding) Reset ¶

func (m *ExecuteWithBinding) Reset()

func (*ExecuteWithBinding) String ¶

func (m *ExecuteWithBinding) String() string

type HelloMessage ¶

type HelloMessage struct {
	PeerEndpoint   *PeerEndpoint   `protobuf:"bytes,1,opt,name=peerEndpoint" json:"peerEndpoint,omitempty"`
	BlockchainInfo *BlockchainInfo `protobuf:"bytes,2,opt,name=blockchainInfo" json:"blockchainInfo,omitempty"`
}

func (*HelloMessage) Descriptor ¶

func (*HelloMessage) Descriptor() ([]byte, []int)

func (*HelloMessage) GetBlockchainInfo ¶

func (m *HelloMessage) GetBlockchainInfo() *BlockchainInfo

func (*HelloMessage) GetPeerEndpoint ¶

func (m *HelloMessage) GetPeerEndpoint() *PeerEndpoint

func (*HelloMessage) ProtoMessage ¶

func (*HelloMessage) ProtoMessage()

func (*HelloMessage) Reset ¶

func (m *HelloMessage) Reset()

func (*HelloMessage) String ¶

func (m *HelloMessage) String() string

type Interest ¶

type Interest struct {
	EventType EventType `protobuf:"varint,1,opt,name=eventType,enum=protos.EventType" json:"eventType,omitempty"`
	// Ideally we should just have the following oneof for different
	// Reg types and get rid of EventType. But this is an API change
	// Additional Reg types may add messages specific to their type
	// to the oneof.
	//
	// Types that are valid to be assigned to RegInfo:
	//	*Interest_ChaincodeRegInfo
	RegInfo isInterest_RegInfo `protobuf_oneof:"RegInfo"`
}

func (*Interest) Descriptor ¶

func (*Interest) Descriptor() ([]byte, []int)

func (*Interest) GetChaincodeRegInfo ¶

func (m *Interest) GetChaincodeRegInfo() *ChaincodeReg

func (*Interest) GetRegInfo ¶

func (m *Interest) GetRegInfo() isInterest_RegInfo

func (*Interest) ProtoMessage ¶

func (*Interest) ProtoMessage()

func (*Interest) Reset ¶

func (m *Interest) Reset()

func (*Interest) String ¶

func (m *Interest) String() string

func (*Interest) XXX_OneofFuncs ¶

func (*Interest) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

type Interest_ChaincodeRegInfo ¶

type Interest_ChaincodeRegInfo struct {
	ChaincodeRegInfo *ChaincodeReg `protobuf:"bytes,2,opt,name=chaincodeRegInfo,oneof"`
}

type Message ¶

type Message struct {
	Type      Message_Type               `protobuf:"varint,1,opt,name=type,enum=protos.Message_Type" json:"type,omitempty"`
	Timestamp *google_protobuf.Timestamp `protobuf:"bytes,2,opt,name=timestamp" json:"timestamp,omitempty"`
	Payload   []byte                     `protobuf:"bytes,3,opt,name=payload,proto3" json:"payload,omitempty"`
	Signature []byte                     `protobuf:"bytes,4,opt,name=signature,proto3" json:"signature,omitempty"`
}

func (*Message) Descriptor ¶

func (*Message) Descriptor() ([]byte, []int)

func (*Message) GetTimestamp ¶

func (m *Message) GetTimestamp() *google_protobuf.Timestamp

func (*Message) ProtoMessage ¶

func (*Message) ProtoMessage()

func (*Message) Reset ¶

func (m *Message) Reset()

func (*Message) String ¶

func (m *Message) String() string

type Message_Type ¶

type Message_Type int32
const (
	Message_UNDEFINED               Message_Type = 0
	Message_DISC_HELLO              Message_Type = 1
	Message_DISC_DISCONNECT         Message_Type = 2
	Message_DISC_GET_PEERS          Message_Type = 3
	Message_DISC_PEERS              Message_Type = 4
	Message_DISC_NEWMSG             Message_Type = 5
	Message_CHAIN_TRANSACTION       Message_Type = 6
	Message_SYNC_GET_BLOCKS         Message_Type = 11
	Message_SYNC_BLOCKS             Message_Type = 12
	Message_SYNC_BLOCK_ADDED        Message_Type = 13
	Message_SYNC_STATE_GET_SNAPSHOT Message_Type = 14
	Message_SYNC_STATE_SNAPSHOT     Message_Type = 15
	Message_SYNC_STATE_GET_DELTAS   Message_Type = 16
	Message_SYNC_STATE_DELTAS       Message_Type = 17
	Message_RESPONSE                Message_Type = 20
	Message_CONSENSUS               Message_Type = 21
)

func (Message_Type) EnumDescriptor ¶

func (Message_Type) EnumDescriptor() ([]byte, []int)

func (Message_Type) String ¶

func (x Message_Type) String() string

type NonHashData ¶

type NonHashData struct {
	LocalLedgerCommitTimestamp *google_protobuf.Timestamp `protobuf:"bytes,1,opt,name=localLedgerCommitTimestamp" json:"localLedgerCommitTimestamp,omitempty"`
	ChaincodeEvents            []*ChaincodeEvent          `protobuf:"bytes,2,rep,name=chaincodeEvents" json:"chaincodeEvents,omitempty"`
}

NonHashData is data that is recorded on the block, but not included in the block hash when verifying the blockchain. localLedgerCommitTimestamp - The time at which the block was added to the ledger on the local peer. chaincodeEvent - is an array ChaincodeEvents, one per transaction in the block

func (*NonHashData) Descriptor ¶

func (*NonHashData) Descriptor() ([]byte, []int)

func (*NonHashData) GetChaincodeEvents ¶

func (m *NonHashData) GetChaincodeEvents() []*ChaincodeEvent

func (*NonHashData) GetLocalLedgerCommitTimestamp ¶

func (m *NonHashData) GetLocalLedgerCommitTimestamp() *google_protobuf.Timestamp

func (*NonHashData) ProtoMessage ¶

func (*NonHashData) ProtoMessage()

func (*NonHashData) Reset ¶

func (m *NonHashData) Reset()

func (*NonHashData) String ¶

func (m *NonHashData) String() string

type OpenchainClient ¶

type OpenchainClient interface {
	// GetBlockchainInfo returns information about the blockchain ledger such as
	// height, current block hash, and previous block hash.
	GetBlockchainInfo(ctx context.Context, in *google_protobuf1.Empty, opts ...grpc.CallOption) (*BlockchainInfo, error)
	// GetBlockByNumber returns the data contained within a specific block in the
	// blockchain. The genesis block is block zero.
	GetBlockByNumber(ctx context.Context, in *BlockNumber, opts ...grpc.CallOption) (*Block, error)
	// GetBlockCount returns the current number of blocks in the blockchain data
	// structure.
	GetBlockCount(ctx context.Context, in *google_protobuf1.Empty, opts ...grpc.CallOption) (*BlockCount, error)
	// GetPeers returns a list of all peer nodes currently connected to the target
	// peer.
	GetPeers(ctx context.Context, in *google_protobuf1.Empty, opts ...grpc.CallOption) (*PeersMessage, error)
}

func NewOpenchainClient ¶

func NewOpenchainClient(cc *grpc.ClientConn) OpenchainClient

type OpenchainServer ¶

type OpenchainServer interface {
	// GetBlockchainInfo returns information about the blockchain ledger such as
	// height, current block hash, and previous block hash.
	GetBlockchainInfo(context.Context, *google_protobuf1.Empty) (*BlockchainInfo, error)
	// GetBlockByNumber returns the data contained within a specific block in the
	// blockchain. The genesis block is block zero.
	GetBlockByNumber(context.Context, *BlockNumber) (*Block, error)
	// GetBlockCount returns the current number of blocks in the blockchain data
	// structure.
	GetBlockCount(context.Context, *google_protobuf1.Empty) (*BlockCount, error)
	// GetPeers returns a list of all peer nodes currently connected to the target
	// peer.
	GetPeers(context.Context, *google_protobuf1.Empty) (*PeersMessage, error)
}

type PeerAddress ¶

type PeerAddress struct {
	Host string `protobuf:"bytes,1,opt,name=host" json:"host,omitempty"`
	Port int32  `protobuf:"varint,2,opt,name=port" json:"port,omitempty"`
}

func (*PeerAddress) Descriptor ¶

func (*PeerAddress) Descriptor() ([]byte, []int)

func (*PeerAddress) ProtoMessage ¶

func (*PeerAddress) ProtoMessage()

func (*PeerAddress) Reset ¶

func (m *PeerAddress) Reset()

func (*PeerAddress) String ¶

func (m *PeerAddress) String() string

type PeerClient ¶

type PeerClient interface {
	// Accepts a stream of Message during chat session, while receiving
	// other Message (e.g. from other peers).
	Chat(ctx context.Context, opts ...grpc.CallOption) (Peer_ChatClient, error)
	// Process a transaction from a remote source.
	ProcessTransaction(ctx context.Context, in *Transaction, opts ...grpc.CallOption) (*Response, error)
}

func NewPeerClient ¶

func NewPeerClient(cc *grpc.ClientConn) PeerClient

type PeerEndpoint ¶

type PeerEndpoint struct {
	ID      *PeerID           `protobuf:"bytes,1,opt,name=ID,json=iD" json:"ID,omitempty"`
	Address string            `protobuf:"bytes,2,opt,name=address" json:"address,omitempty"`
	Type    PeerEndpoint_Type `protobuf:"varint,3,opt,name=type,enum=protos.PeerEndpoint_Type" json:"type,omitempty"`
	PkiID   []byte            `protobuf:"bytes,4,opt,name=pkiID,proto3" json:"pkiID,omitempty"`
}

func (*PeerEndpoint) Descriptor ¶

func (*PeerEndpoint) Descriptor() ([]byte, []int)

func (*PeerEndpoint) GetID ¶

func (m *PeerEndpoint) GetID() *PeerID

func (*PeerEndpoint) ProtoMessage ¶

func (*PeerEndpoint) ProtoMessage()

func (*PeerEndpoint) Reset ¶

func (m *PeerEndpoint) Reset()

func (*PeerEndpoint) String ¶

func (m *PeerEndpoint) String() string

type PeerEndpoint_Type ¶

type PeerEndpoint_Type int32
const (
	PeerEndpoint_UNDEFINED     PeerEndpoint_Type = 0
	PeerEndpoint_VALIDATOR     PeerEndpoint_Type = 1
	PeerEndpoint_NON_VALIDATOR PeerEndpoint_Type = 2
)

func (PeerEndpoint_Type) EnumDescriptor ¶

func (PeerEndpoint_Type) EnumDescriptor() ([]byte, []int)

func (PeerEndpoint_Type) String ¶

func (x PeerEndpoint_Type) String() string

type PeerID ¶

type PeerID struct {
	Name string `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
}

func (*PeerID) Descriptor ¶

func (*PeerID) Descriptor() ([]byte, []int)

func (*PeerID) ProtoMessage ¶

func (*PeerID) ProtoMessage()

func (*PeerID) Reset ¶

func (m *PeerID) Reset()

func (*PeerID) String ¶

func (m *PeerID) String() string

type PeerServer ¶

type PeerServer interface {
	// Accepts a stream of Message during chat session, while receiving
	// other Message (e.g. from other peers).
	Chat(Peer_ChatServer) error
	// Process a transaction from a remote source.
	ProcessTransaction(context.Context, *Transaction) (*Response, error)
}

type Peer_ChatClient ¶

type Peer_ChatClient interface {
	Send(*Message) error
	Recv() (*Message, error)
	grpc.ClientStream
}

type Peer_ChatServer ¶

type Peer_ChatServer interface {
	Send(*Message) error
	Recv() (*Message, error)
	grpc.ServerStream
}

type PeersAddresses ¶

type PeersAddresses struct {
	Addresses []string `protobuf:"bytes,1,rep,name=addresses" json:"addresses,omitempty"`
}

func (*PeersAddresses) Descriptor ¶

func (*PeersAddresses) Descriptor() ([]byte, []int)

func (*PeersAddresses) ProtoMessage ¶

func (*PeersAddresses) ProtoMessage()

func (*PeersAddresses) Reset ¶

func (m *PeersAddresses) Reset()

func (*PeersAddresses) String ¶

func (m *PeersAddresses) String() string

type PeersMessage ¶

type PeersMessage struct {
	Peers []*PeerEndpoint `protobuf:"bytes,1,rep,name=peers" json:"peers,omitempty"`
}

func (*PeersMessage) Descriptor ¶

func (*PeersMessage) Descriptor() ([]byte, []int)

func (*PeersMessage) GetPeers ¶

func (m *PeersMessage) GetPeers() []*PeerEndpoint

func (*PeersMessage) ProtoMessage ¶

func (*PeersMessage) ProtoMessage()

func (*PeersMessage) Reset ¶

func (m *PeersMessage) Reset()

func (*PeersMessage) String ¶

func (m *PeersMessage) String() string

type PutStateInfo ¶

type PutStateInfo struct {
	Key   string `protobuf:"bytes,1,opt,name=key" json:"key,omitempty"`
	Value []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
}

func (*PutStateInfo) Descriptor ¶

func (*PutStateInfo) Descriptor() ([]byte, []int)

func (*PutStateInfo) ProtoMessage ¶

func (*PutStateInfo) ProtoMessage()

func (*PutStateInfo) Reset ¶

func (m *PutStateInfo) Reset()

func (*PutStateInfo) String ¶

func (m *PutStateInfo) String() string

type RangeQueryState ¶

type RangeQueryState struct {
	StartKey string `protobuf:"bytes,1,opt,name=startKey" json:"startKey,omitempty"`
	EndKey   string `protobuf:"bytes,2,opt,name=endKey" json:"endKey,omitempty"`
}

func (*RangeQueryState) Descriptor ¶

func (*RangeQueryState) Descriptor() ([]byte, []int)

func (*RangeQueryState) ProtoMessage ¶

func (*RangeQueryState) ProtoMessage()

func (*RangeQueryState) Reset ¶

func (m *RangeQueryState) Reset()

func (*RangeQueryState) String ¶

func (m *RangeQueryState) String() string

type RangeQueryStateClose ¶

type RangeQueryStateClose struct {
	ID string `protobuf:"bytes,1,opt,name=ID,json=iD" json:"ID,omitempty"`
}

func (*RangeQueryStateClose) Descriptor ¶

func (*RangeQueryStateClose) Descriptor() ([]byte, []int)

func (*RangeQueryStateClose) ProtoMessage ¶

func (*RangeQueryStateClose) ProtoMessage()

func (*RangeQueryStateClose) Reset ¶

func (m *RangeQueryStateClose) Reset()

func (*RangeQueryStateClose) String ¶

func (m *RangeQueryStateClose) String() string

type RangeQueryStateKeyValue ¶

type RangeQueryStateKeyValue struct {
	Key   string `protobuf:"bytes,1,opt,name=key" json:"key,omitempty"`
	Value []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
}

func (*RangeQueryStateKeyValue) Descriptor ¶

func (*RangeQueryStateKeyValue) Descriptor() ([]byte, []int)

func (*RangeQueryStateKeyValue) ProtoMessage ¶

func (*RangeQueryStateKeyValue) ProtoMessage()

func (*RangeQueryStateKeyValue) Reset ¶

func (m *RangeQueryStateKeyValue) Reset()

func (*RangeQueryStateKeyValue) String ¶

func (m *RangeQueryStateKeyValue) String() string

type RangeQueryStateNext ¶

type RangeQueryStateNext struct {
	ID string `protobuf:"bytes,1,opt,name=ID,json=iD" json:"ID,omitempty"`
}

func (*RangeQueryStateNext) Descriptor ¶

func (*RangeQueryStateNext) Descriptor() ([]byte, []int)

func (*RangeQueryStateNext) ProtoMessage ¶

func (*RangeQueryStateNext) ProtoMessage()

func (*RangeQueryStateNext) Reset ¶

func (m *RangeQueryStateNext) Reset()

func (*RangeQueryStateNext) String ¶

func (m *RangeQueryStateNext) String() string

type RangeQueryStateResponse ¶

type RangeQueryStateResponse struct {
	KeysAndValues []*RangeQueryStateKeyValue `protobuf:"bytes,1,rep,name=keysAndValues" json:"keysAndValues,omitempty"`
	HasMore       bool                       `protobuf:"varint,2,opt,name=hasMore" json:"hasMore,omitempty"`
	ID            string                     `protobuf:"bytes,3,opt,name=ID,json=iD" json:"ID,omitempty"`
}

func (*RangeQueryStateResponse) Descriptor ¶

func (*RangeQueryStateResponse) Descriptor() ([]byte, []int)

func (*RangeQueryStateResponse) GetKeysAndValues ¶

func (m *RangeQueryStateResponse) GetKeysAndValues() []*RangeQueryStateKeyValue

func (*RangeQueryStateResponse) ProtoMessage ¶

func (*RangeQueryStateResponse) ProtoMessage()

func (*RangeQueryStateResponse) Reset ¶

func (m *RangeQueryStateResponse) Reset()

func (*RangeQueryStateResponse) String ¶

func (m *RangeQueryStateResponse) String() string

type Register ¶

type Register struct {
	Events []*Interest `protobuf:"bytes,1,rep,name=events" json:"events,omitempty"`
}

---------- consumer events --------- Register is sent by consumers for registering events string type - "register"

func (*Register) Descriptor ¶

func (*Register) Descriptor() ([]byte, []int)

func (*Register) GetEvents ¶

func (m *Register) GetEvents() []*Interest

func (*Register) ProtoMessage ¶

func (*Register) ProtoMessage()

func (*Register) Reset ¶

func (m *Register) Reset()

func (*Register) String ¶

func (m *Register) String() string

type Rejection ¶

type Rejection struct {
	Tx       *Transaction `protobuf:"bytes,1,opt,name=tx" json:"tx,omitempty"`
	ErrorMsg string       `protobuf:"bytes,2,opt,name=errorMsg" json:"errorMsg,omitempty"`
}

Rejection is sent by consumers for erroneous transaction rejection events string type - "rejection"

func (*Rejection) Descriptor ¶

func (*Rejection) Descriptor() ([]byte, []int)

func (*Rejection) GetTx ¶

func (m *Rejection) GetTx() *Transaction

func (*Rejection) ProtoMessage ¶

func (*Rejection) ProtoMessage()

func (*Rejection) Reset ¶

func (m *Rejection) Reset()

func (*Rejection) String ¶

func (m *Rejection) String() string

type Response ¶

type Response struct {
	Status Response_StatusCode `protobuf:"varint,1,opt,name=status,enum=protos.Response_StatusCode" json:"status,omitempty"`
	Msg    []byte              `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"`
}

func (*Response) Descriptor ¶

func (*Response) Descriptor() ([]byte, []int)

func (*Response) ProtoMessage ¶

func (*Response) ProtoMessage()

func (*Response) Reset ¶

func (m *Response) Reset()

func (*Response) String ¶

func (m *Response) String() string

type Response_StatusCode ¶

type Response_StatusCode int32
const (
	Response_UNDEFINED Response_StatusCode = 0
	Response_SUCCESS   Response_StatusCode = 200
	Response_FAILURE   Response_StatusCode = 500
)

func (Response_StatusCode) EnumDescriptor ¶

func (Response_StatusCode) EnumDescriptor() ([]byte, []int)

func (Response_StatusCode) String ¶

func (x Response_StatusCode) String() string

type Secret ¶

type Secret struct {
	EnrollId     string `protobuf:"bytes,1,opt,name=enrollId" json:"enrollId,omitempty"`
	EnrollSecret string `protobuf:"bytes,2,opt,name=enrollSecret" json:"enrollSecret,omitempty"`
}

Secret is a temporary object to establish security with the Devops. A better solution using certificate will be introduced later

func (*Secret) Descriptor ¶

func (*Secret) Descriptor() ([]byte, []int)

func (*Secret) ProtoMessage ¶

func (*Secret) ProtoMessage()

func (*Secret) Reset ¶

func (m *Secret) Reset()

func (*Secret) String ¶

func (m *Secret) String() string

type ServerStatus ¶

type ServerStatus struct {
	Status ServerStatus_StatusCode `protobuf:"varint,1,opt,name=status,enum=protos.ServerStatus_StatusCode" json:"status,omitempty"`
}

func (*ServerStatus) Descriptor ¶

func (*ServerStatus) Descriptor() ([]byte, []int)

func (*ServerStatus) ProtoMessage ¶

func (*ServerStatus) ProtoMessage()

func (*ServerStatus) Reset ¶

func (m *ServerStatus) Reset()

func (*ServerStatus) String ¶

func (m *ServerStatus) String() string

type ServerStatus_StatusCode ¶

type ServerStatus_StatusCode int32
const (
	ServerStatus_UNDEFINED ServerStatus_StatusCode = 0
	ServerStatus_STARTED   ServerStatus_StatusCode = 1
	ServerStatus_STOPPED   ServerStatus_StatusCode = 2
	ServerStatus_PAUSED    ServerStatus_StatusCode = 3
	ServerStatus_ERROR     ServerStatus_StatusCode = 4
	ServerStatus_UNKNOWN   ServerStatus_StatusCode = 5
)

func (ServerStatus_StatusCode) EnumDescriptor ¶

func (ServerStatus_StatusCode) EnumDescriptor() ([]byte, []int)

func (ServerStatus_StatusCode) String ¶

func (x ServerStatus_StatusCode) String() string

type SigmaInput ¶

type SigmaInput struct {
	Secret   *Secret `protobuf:"bytes,1,opt,name=secret" json:"secret,omitempty"`
	AppTCert []byte  `protobuf:"bytes,2,opt,name=appTCert,proto3" json:"appTCert,omitempty"`
	Data     []byte  `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
}

func (*SigmaInput) Descriptor ¶

func (*SigmaInput) Descriptor() ([]byte, []int)

func (*SigmaInput) GetSecret ¶

func (m *SigmaInput) GetSecret() *Secret

func (*SigmaInput) ProtoMessage ¶

func (*SigmaInput) ProtoMessage()

func (*SigmaInput) Reset ¶

func (m *SigmaInput) Reset()

func (*SigmaInput) String ¶

func (m *SigmaInput) String() string

type SigmaOutput ¶

type SigmaOutput struct {
	Tcert        []byte `protobuf:"bytes,1,opt,name=tcert,proto3" json:"tcert,omitempty"`
	Sigma        []byte `protobuf:"bytes,2,opt,name=sigma,proto3" json:"sigma,omitempty"`
	Asn1Encoding []byte `protobuf:"bytes,3,opt,name=asn1Encoding,proto3" json:"asn1Encoding,omitempty"`
}

func (*SigmaOutput) Descriptor ¶

func (*SigmaOutput) Descriptor() ([]byte, []int)

func (*SigmaOutput) ProtoMessage ¶

func (*SigmaOutput) ProtoMessage()

func (*SigmaOutput) Reset ¶

func (m *SigmaOutput) Reset()

func (*SigmaOutput) String ¶

func (m *SigmaOutput) String() string

type SyncBlockRange ¶

type SyncBlockRange struct {
	CorrelationId uint64 `protobuf:"varint,1,opt,name=correlationId" json:"correlationId,omitempty"`
	Start         uint64 `protobuf:"varint,2,opt,name=start" json:"start,omitempty"`
	End           uint64 `protobuf:"varint,3,opt,name=end" json:"end,omitempty"`
}

SyncBlockRange is the payload of Message.SYNC_GET_BLOCKS, where start and end indicate the starting and ending blocks inclusively. The order in which blocks are returned is defined by the start and end values. For example, if start=3 and end=5, the order of blocks will be 3, 4, 5. If start=5 and end=3, the order will be 5, 4, 3.

func (*SyncBlockRange) Descriptor ¶

func (*SyncBlockRange) Descriptor() ([]byte, []int)

func (*SyncBlockRange) ProtoMessage ¶

func (*SyncBlockRange) ProtoMessage()

func (*SyncBlockRange) Reset ¶

func (m *SyncBlockRange) Reset()

func (*SyncBlockRange) String ¶

func (m *SyncBlockRange) String() string

type SyncBlocks ¶

type SyncBlocks struct {
	Range  *SyncBlockRange `protobuf:"bytes,1,opt,name=range" json:"range,omitempty"`
	Blocks []*Block        `protobuf:"bytes,2,rep,name=blocks" json:"blocks,omitempty"`
}

SyncBlocks is the payload of Message.SYNC_BLOCKS, where the range indicates the blocks responded to the request SYNC_GET_BLOCKS

func (*SyncBlocks) Descriptor ¶

func (*SyncBlocks) Descriptor() ([]byte, []int)

func (*SyncBlocks) GetBlocks ¶

func (m *SyncBlocks) GetBlocks() []*Block

func (*SyncBlocks) GetRange ¶

func (m *SyncBlocks) GetRange() *SyncBlockRange

func (*SyncBlocks) ProtoMessage ¶

func (*SyncBlocks) ProtoMessage()

func (*SyncBlocks) Reset ¶

func (m *SyncBlocks) Reset()

func (*SyncBlocks) String ¶

func (m *SyncBlocks) String() string

type SyncStateDeltas ¶

type SyncStateDeltas struct {
	Range  *SyncBlockRange `protobuf:"bytes,1,opt,name=range" json:"range,omitempty"`
	Deltas [][]byte        `protobuf:"bytes,2,rep,name=deltas,proto3" json:"deltas,omitempty"`
}

SyncStateDeltas is the payload of the Message.SYNC_STATE in response to the Message.SYNC_GET_STATE message.

func (*SyncStateDeltas) Descriptor ¶

func (*SyncStateDeltas) Descriptor() ([]byte, []int)

func (*SyncStateDeltas) GetRange ¶

func (m *SyncStateDeltas) GetRange() *SyncBlockRange

func (*SyncStateDeltas) ProtoMessage ¶

func (*SyncStateDeltas) ProtoMessage()

func (*SyncStateDeltas) Reset ¶

func (m *SyncStateDeltas) Reset()

func (*SyncStateDeltas) String ¶

func (m *SyncStateDeltas) String() string

type SyncStateDeltasRequest ¶

type SyncStateDeltasRequest struct {
	Range *SyncBlockRange `protobuf:"bytes,1,opt,name=range" json:"range,omitempty"`
}

SyncStateDeltasRequest is the payload of Message.SYNC_GET_STATE. blockNumber indicates the block number for the delta which is being requested. If no payload is included with SYNC_GET_STATE, it represents a request for a snapshot of the current state.

func (*SyncStateDeltasRequest) Descriptor ¶

func (*SyncStateDeltasRequest) Descriptor() ([]byte, []int)

func (*SyncStateDeltasRequest) GetRange ¶

func (m *SyncStateDeltasRequest) GetRange() *SyncBlockRange

func (*SyncStateDeltasRequest) ProtoMessage ¶

func (*SyncStateDeltasRequest) ProtoMessage()

func (*SyncStateDeltasRequest) Reset ¶

func (m *SyncStateDeltasRequest) Reset()

func (*SyncStateDeltasRequest) String ¶

func (m *SyncStateDeltasRequest) String() string

type SyncStateSnapshot ¶

type SyncStateSnapshot struct {
	Delta       []byte                    `protobuf:"bytes,1,opt,name=delta,proto3" json:"delta,omitempty"`
	Sequence    uint64                    `protobuf:"varint,2,opt,name=sequence" json:"sequence,omitempty"`
	BlockNumber uint64                    `protobuf:"varint,3,opt,name=blockNumber" json:"blockNumber,omitempty"`
	Request     *SyncStateSnapshotRequest `protobuf:"bytes,4,opt,name=request" json:"request,omitempty"`
}

SyncStateSnapshot is the payload of Message.SYNC_SNAPSHOT, which is a response to penchainMessage.SYNC_GET_SNAPSHOT. It contains the snapshot or a chunk of the snapshot on stream, and in which case, the sequence indicate the order starting at 0. The terminating message will have len(delta) == 0.

func (*SyncStateSnapshot) Descriptor ¶

func (*SyncStateSnapshot) Descriptor() ([]byte, []int)

func (*SyncStateSnapshot) GetRequest ¶

func (*SyncStateSnapshot) ProtoMessage ¶

func (*SyncStateSnapshot) ProtoMessage()

func (*SyncStateSnapshot) Reset ¶

func (m *SyncStateSnapshot) Reset()

func (*SyncStateSnapshot) String ¶

func (m *SyncStateSnapshot) String() string

type SyncStateSnapshotRequest ¶

type SyncStateSnapshotRequest struct {
	CorrelationId uint64 `protobuf:"varint,1,opt,name=correlationId" json:"correlationId,omitempty"`
}

SyncSnapshotRequest Payload for the penchainMessage.SYNC_GET_SNAPSHOT message.

func (*SyncStateSnapshotRequest) Descriptor ¶

func (*SyncStateSnapshotRequest) Descriptor() ([]byte, []int)

func (*SyncStateSnapshotRequest) ProtoMessage ¶

func (*SyncStateSnapshotRequest) ProtoMessage()

func (*SyncStateSnapshotRequest) Reset ¶

func (m *SyncStateSnapshotRequest) Reset()

func (*SyncStateSnapshotRequest) String ¶

func (m *SyncStateSnapshotRequest) String() string

type Transaction ¶

type Transaction struct {
	Type Transaction_Type `protobuf:"varint,1,opt,name=type,enum=protos.Transaction_Type" json:"type,omitempty"`
	// store ChaincodeID as bytes so its encrypted value can be stored
	ChaincodeID                    []byte                     `protobuf:"bytes,2,opt,name=chaincodeID,proto3" json:"chaincodeID,omitempty"`
	Payload                        []byte                     `protobuf:"bytes,3,opt,name=payload,proto3" json:"payload,omitempty"`
	Metadata                       []byte                     `protobuf:"bytes,4,opt,name=metadata,proto3" json:"metadata,omitempty"`
	Txid                           string                     `protobuf:"bytes,5,opt,name=txid" json:"txid,omitempty"`
	Timestamp                      *google_protobuf.Timestamp `protobuf:"bytes,6,opt,name=timestamp" json:"timestamp,omitempty"`
	ConfidentialityLevel           ConfidentialityLevel       `protobuf:"varint,7,opt,name=confidentialityLevel,enum=protos.ConfidentialityLevel" json:"confidentialityLevel,omitempty"`
	ConfidentialityProtocolVersion string                     `protobuf:"bytes,8,opt,name=confidentialityProtocolVersion" json:"confidentialityProtocolVersion,omitempty"`
	Nonce                          []byte                     `protobuf:"bytes,9,opt,name=nonce,proto3" json:"nonce,omitempty"`
	ToValidators                   []byte                     `protobuf:"bytes,10,opt,name=toValidators,proto3" json:"toValidators,omitempty"`
	Cert                           []byte                     `protobuf:"bytes,11,opt,name=cert,proto3" json:"cert,omitempty"`
	Signature                      []byte                     `protobuf:"bytes,12,opt,name=signature,proto3" json:"signature,omitempty"`
}

Transaction defines a function call to a contract. `args` is an array of type string so that the chaincode writer can choose whatever format they wish for the arguments for their chaincode. For example, they may wish to use JSON, XML, or a custom format. TODO: Defined remaining fields.

func NewChaincodeDeployTransaction ¶

func NewChaincodeDeployTransaction(chaincodeDeploymentSpec *ChaincodeDeploymentSpec, uuid string) (*Transaction, error)

NewChaincodeDeployTransaction is used to deploy chaincode.

func NewChaincodeExecute ¶

func NewChaincodeExecute(chaincodeInvocationSpec *ChaincodeInvocationSpec, uuid string, typ Transaction_Type) (*Transaction, error)

NewChaincodeExecute is used to invoke chaincode.

func NewTransaction ¶

func NewTransaction(chaincodeID ChaincodeID, uuid string, function string, arguments []string) (*Transaction, error)

NewTransaction creates a new transaction. It defines the function to call, the chaincodeID on which the function should be called, and the arguments string. The arguments could be a string of JSON, but there is no strict requirement.

func (*Transaction) Bytes ¶

func (transaction *Transaction) Bytes() ([]byte, error)

Bytes returns this transaction as an array of bytes.

func (*Transaction) Descriptor ¶

func (*Transaction) Descriptor() ([]byte, []int)

func (*Transaction) GetTimestamp ¶

func (m *Transaction) GetTimestamp() *google_protobuf.Timestamp

func (*Transaction) ProtoMessage ¶

func (*Transaction) ProtoMessage()

func (*Transaction) Reset ¶

func (m *Transaction) Reset()

func (*Transaction) String ¶

func (m *Transaction) String() string

type TransactionBlock ¶

type TransactionBlock struct {
	Transactions []*Transaction `protobuf:"bytes,1,rep,name=transactions" json:"transactions,omitempty"`
}

TransactionBlock carries a batch of transactions.

func (*TransactionBlock) Descriptor ¶

func (*TransactionBlock) Descriptor() ([]byte, []int)

func (*TransactionBlock) GetTransactions ¶

func (m *TransactionBlock) GetTransactions() []*Transaction

func (*TransactionBlock) ProtoMessage ¶

func (*TransactionBlock) ProtoMessage()

func (*TransactionBlock) Reset ¶

func (m *TransactionBlock) Reset()

func (*TransactionBlock) String ¶

func (m *TransactionBlock) String() string

type TransactionRequest ¶

type TransactionRequest struct {
	TransactionUuid string `protobuf:"bytes,1,opt,name=transactionUuid" json:"transactionUuid,omitempty"`
}

func (*TransactionRequest) Descriptor ¶

func (*TransactionRequest) Descriptor() ([]byte, []int)

func (*TransactionRequest) ProtoMessage ¶

func (*TransactionRequest) ProtoMessage()

func (*TransactionRequest) Reset ¶

func (m *TransactionRequest) Reset()

func (*TransactionRequest) String ¶

func (m *TransactionRequest) String() string

type TransactionResult ¶

type TransactionResult struct {
	Txid           string          `protobuf:"bytes,1,opt,name=txid" json:"txid,omitempty"`
	Result         []byte          `protobuf:"bytes,2,opt,name=result,proto3" json:"result,omitempty"`
	ErrorCode      uint32          `protobuf:"varint,3,opt,name=errorCode" json:"errorCode,omitempty"`
	Error          string          `protobuf:"bytes,4,opt,name=error" json:"error,omitempty"`
	ChaincodeEvent *ChaincodeEvent `protobuf:"bytes,5,opt,name=chaincodeEvent" json:"chaincodeEvent,omitempty"`
}

TransactionResult contains the return value of a transaction. It does not track potential state changes that were a result of the transaction. txid - The unique identifier of this transaction. result - The return value of the transaction. errorCode - An error code. 5xx will be logged as a failure in the dashboard. error - An error string for logging an issue. chaincodeEvent - any event emitted by a transaction

func (*TransactionResult) Descriptor ¶

func (*TransactionResult) Descriptor() ([]byte, []int)

func (*TransactionResult) GetChaincodeEvent ¶

func (m *TransactionResult) GetChaincodeEvent() *ChaincodeEvent

func (*TransactionResult) ProtoMessage ¶

func (*TransactionResult) ProtoMessage()

func (*TransactionResult) Reset ¶

func (m *TransactionResult) Reset()

func (*TransactionResult) String ¶

func (m *TransactionResult) String() string

type Transaction_Type ¶

type Transaction_Type int32
const (
	Transaction_UNDEFINED Transaction_Type = 0
	// deploy a chaincode to the network and call `Init` function
	Transaction_CHAINCODE_DEPLOY Transaction_Type = 1
	// call a chaincode `Invoke` function as a transaction
	Transaction_CHAINCODE_INVOKE Transaction_Type = 2
	// call a chaincode `query` function
	Transaction_CHAINCODE_QUERY Transaction_Type = 3
	// terminate a chaincode; not implemented yet
	Transaction_CHAINCODE_TERMINATE Transaction_Type = 4
)

func (Transaction_Type) EnumDescriptor ¶

func (Transaction_Type) EnumDescriptor() ([]byte, []int)

func (Transaction_Type) String ¶

func (x Transaction_Type) String() string

type Unregister ¶

type Unregister struct {
	Events []*Interest `protobuf:"bytes,1,rep,name=events" json:"events,omitempty"`
}

---------- producer events ---------

func (*Unregister) Descriptor ¶

func (*Unregister) Descriptor() ([]byte, []int)

func (*Unregister) GetEvents ¶

func (m *Unregister) GetEvents() []*Interest

func (*Unregister) ProtoMessage ¶

func (*Unregister) ProtoMessage()

func (*Unregister) Reset ¶

func (m *Unregister) Reset()

func (*Unregister) String ¶

func (m *Unregister) String() string

Jump to

Keyboard shortcuts

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