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 

func (x ChaincodeDeploymentSpec_ExecutionEnvironment) String() 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 (m *SyncStateSnapshot) GetRequest() *SyncStateSnapshotRequest

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.