gateway

package
v1.0.7 Latest Latest
Warning

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

 Go to latest Published: Mar 21, 2024 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterGatewayServer 

func RegisterGatewayServer(s *grpc.Server, srv GatewayServer)

Types

type ChaincodeEventsRequest 

type ChaincodeEventsRequest struct {
	// Identifier of the channel this request is bound for.
	ChannelId string `protobuf:"bytes,1,opt,name=channel_id,json=channelId,proto3" json:"channel_id,omitempty"`
	// Name of the chaincode for which events are requested.
	ChaincodeId string `protobuf:"bytes,2,opt,name=chaincode_id,json=chaincodeId,proto3" json:"chaincode_id,omitempty"`
	// Client requestor identity.
	Identity []byte `protobuf:"bytes,3,opt,name=identity,proto3" json:"identity,omitempty"`
	// Position within the ledger at which to start reading events.
	StartPosition *orderer.SeekPosition `protobuf:"bytes,4,opt,name=start_position,json=startPosition,proto3" json:"start_position,omitempty"`
	// Only returns events after this transaction ID. Transactions up to and including this one should be ignored. This
	// is used to allow resume of event listening from a certain position within a start block specified by
	// start_position.
	AfterTransactionId   string   `protobuf:"bytes,5,opt,name=after_transaction_id,json=afterTransactionId,proto3" json:"after_transaction_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

ChaincodeEventsRequest contains details of the chaincode events that the caller wants to receive.

func (*ChaincodeEventsRequest) Descriptor 

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

func (*ChaincodeEventsRequest) GetAfterTransactionId 

func (m *ChaincodeEventsRequest) GetAfterTransactionId() string

func (*ChaincodeEventsRequest) GetChaincodeId 

func (m *ChaincodeEventsRequest) GetChaincodeId() string

func (*ChaincodeEventsRequest) GetChannelId 

func (m *ChaincodeEventsRequest) GetChannelId() string

func (*ChaincodeEventsRequest) GetIdentity 

func (m *ChaincodeEventsRequest) GetIdentity() []byte

func (*ChaincodeEventsRequest) GetStartPosition 

func (m *ChaincodeEventsRequest) GetStartPosition() *orderer.SeekPosition

func (*ChaincodeEventsRequest) ProtoMessage 

func (*ChaincodeEventsRequest) ProtoMessage()

func (*ChaincodeEventsRequest) Reset 

func (m *ChaincodeEventsRequest) Reset()

func (*ChaincodeEventsRequest) String 

func (m *ChaincodeEventsRequest) String() string

func (*ChaincodeEventsRequest) XXX_DiscardUnknown 

func (m *ChaincodeEventsRequest) XXX_DiscardUnknown()

func (*ChaincodeEventsRequest) XXX_Marshal 

func (m *ChaincodeEventsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ChaincodeEventsRequest) XXX_Merge 

func (m *ChaincodeEventsRequest) XXX_Merge(src proto.Message)

func (*ChaincodeEventsRequest) XXX_Size 

func (m *ChaincodeEventsRequest) XXX_Size() int

func (*ChaincodeEventsRequest) XXX_Unmarshal 

func (m *ChaincodeEventsRequest) XXX_Unmarshal(b []byte) error

type ChaincodeEventsResponse 

type ChaincodeEventsResponse struct {
	// Chaincode events emitted by the requested chaincode. The events are presented in the same order that the
	// transactions that emitted them appear within the block.
	Events []*peer.ChaincodeEvent `protobuf:"bytes,1,rep,name=events,proto3" json:"events,omitempty"`
	// Block number in which the chaincode events were emitted.
	BlockNumber          uint64   `protobuf:"varint,2,opt,name=block_number,json=blockNumber,proto3" json:"block_number,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

ChaincodeEventsResponse returns chaincode events emitted from a specific block.

func (*ChaincodeEventsResponse) Descriptor 

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

func (*ChaincodeEventsResponse) GetBlockNumber 

func (m *ChaincodeEventsResponse) GetBlockNumber() uint64

func (*ChaincodeEventsResponse) GetEvents 

func (m *ChaincodeEventsResponse) GetEvents() []*peer.ChaincodeEvent

func (*ChaincodeEventsResponse) ProtoMessage 

func (*ChaincodeEventsResponse) ProtoMessage()

func (*ChaincodeEventsResponse) Reset 

func (m *ChaincodeEventsResponse) Reset()

func (*ChaincodeEventsResponse) String 

func (m *ChaincodeEventsResponse) String() string

func (*ChaincodeEventsResponse) XXX_DiscardUnknown 

func (m *ChaincodeEventsResponse) XXX_DiscardUnknown()

func (*ChaincodeEventsResponse) XXX_Marshal 

func (m *ChaincodeEventsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ChaincodeEventsResponse) XXX_Merge 

func (m *ChaincodeEventsResponse) XXX_Merge(src proto.Message)

func (*ChaincodeEventsResponse) XXX_Size 

func (m *ChaincodeEventsResponse) XXX_Size() int

func (*ChaincodeEventsResponse) XXX_Unmarshal 

func (m *ChaincodeEventsResponse) XXX_Unmarshal(b []byte) error

type CommitStatusRequest 

type CommitStatusRequest struct {
	// Identifier of the transaction to check.
	TransactionId string `protobuf:"bytes,1,opt,name=transaction_id,json=transactionId,proto3" json:"transaction_id,omitempty"`
	// Identifier of the channel this request is bound for.
	ChannelId string `protobuf:"bytes,2,opt,name=channel_id,json=channelId,proto3" json:"channel_id,omitempty"`
	// Client requestor identity.
	Identity             []byte   `protobuf:"bytes,3,opt,name=identity,proto3" json:"identity,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

CommitStatusRequest contains the details required to check whether a transaction has been successfully committed.

func (*CommitStatusRequest) Descriptor 

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

func (*CommitStatusRequest) GetChannelId 

func (m *CommitStatusRequest) GetChannelId() string

func (*CommitStatusRequest) GetIdentity 

func (m *CommitStatusRequest) GetIdentity() []byte

func (*CommitStatusRequest) GetTransactionId 

func (m *CommitStatusRequest) GetTransactionId() string

func (*CommitStatusRequest) ProtoMessage 

func (*CommitStatusRequest) ProtoMessage()

func (*CommitStatusRequest) Reset 

func (m *CommitStatusRequest) Reset()

func (*CommitStatusRequest) String 

func (m *CommitStatusRequest) String() string

func (*CommitStatusRequest) XXX_DiscardUnknown 

func (m *CommitStatusRequest) XXX_DiscardUnknown()

func (*CommitStatusRequest) XXX_Marshal 

func (m *CommitStatusRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CommitStatusRequest) XXX_Merge 

func (m *CommitStatusRequest) XXX_Merge(src proto.Message)

func (*CommitStatusRequest) XXX_Size 

func (m *CommitStatusRequest) XXX_Size() int

func (*CommitStatusRequest) XXX_Unmarshal 

func (m *CommitStatusRequest) XXX_Unmarshal(b []byte) error

type CommitStatusResponse 

type CommitStatusResponse struct {
	// The result of the transaction commit, as defined in peer/transaction.proto.
	Result peer.TxValidationCode `protobuf:"varint,1,opt,name=result,proto3,enum=protos.TxValidationCode" json:"result,omitempty"`
	// Block number that contains the transaction.
	BlockNumber          uint64   `protobuf:"varint,2,opt,name=block_number,json=blockNumber,proto3" json:"block_number,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

CommitStatusResponse returns the result of committing a transaction.

func (*CommitStatusResponse) Descriptor 

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

func (*CommitStatusResponse) GetBlockNumber 

func (m *CommitStatusResponse) GetBlockNumber() uint64

func (*CommitStatusResponse) GetResult 

func (m *CommitStatusResponse) GetResult() peer.TxValidationCode

func (*CommitStatusResponse) ProtoMessage 

func (*CommitStatusResponse) ProtoMessage()

func (*CommitStatusResponse) Reset 

func (m *CommitStatusResponse) Reset()

func (*CommitStatusResponse) String 

func (m *CommitStatusResponse) String() string

func (*CommitStatusResponse) XXX_DiscardUnknown 

func (m *CommitStatusResponse) XXX_DiscardUnknown()

func (*CommitStatusResponse) XXX_Marshal 

func (m *CommitStatusResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CommitStatusResponse) XXX_Merge 

func (m *CommitStatusResponse) XXX_Merge(src proto.Message)

func (*CommitStatusResponse) XXX_Size 

func (m *CommitStatusResponse) XXX_Size() int

func (*CommitStatusResponse) XXX_Unmarshal 

func (m *CommitStatusResponse) XXX_Unmarshal(b []byte) error

type EndorseRequest 

type EndorseRequest struct {
	// The unique identifier for the transaction.
	TransactionId string `protobuf:"bytes,1,opt,name=transaction_id,json=transactionId,proto3" json:"transaction_id,omitempty"`
	// Identifier of the channel this request is bound for.
	ChannelId string `protobuf:"bytes,2,opt,name=channel_id,json=channelId,proto3" json:"channel_id,omitempty"`
	// The signed proposal ready for endorsement.
	ProposedTransaction *peer.SignedProposal `protobuf:"bytes,3,opt,name=proposed_transaction,json=proposedTransaction,proto3" json:"proposed_transaction,omitempty"`
	// If targeting the peers of specific organizations (e.g. for private data scenarios),
	// the list of organizations' MSPIDs should be supplied here.
	EndorsingOrganizations []string `` /* 127-byte string literal not displayed */
	XXX_NoUnkeyedLiteral   struct{} `json:"-"`
	XXX_unrecognized       []byte   `json:"-"`
	XXX_sizecache          int32    `json:"-"`
}

EndorseRequest contains the details required to obtain sufficient endorsements for a transaction to be committed to the ledger.

func (*EndorseRequest) Descriptor 

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

func (*EndorseRequest) GetChannelId 

func (m *EndorseRequest) GetChannelId() string

func (*EndorseRequest) GetEndorsingOrganizations 

func (m *EndorseRequest) GetEndorsingOrganizations() []string

func (*EndorseRequest) GetProposedTransaction 

func (m *EndorseRequest) GetProposedTransaction() *peer.SignedProposal

func (*EndorseRequest) GetTransactionId 

func (m *EndorseRequest) GetTransactionId() string

func (*EndorseRequest) ProtoMessage 

func (*EndorseRequest) ProtoMessage()

func (*EndorseRequest) Reset 

func (m *EndorseRequest) Reset()

func (*EndorseRequest) String 

func (m *EndorseRequest) String() string

func (*EndorseRequest) XXX_DiscardUnknown 

func (m *EndorseRequest) XXX_DiscardUnknown()

func (*EndorseRequest) XXX_Marshal 

func (m *EndorseRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EndorseRequest) XXX_Merge 

func (m *EndorseRequest) XXX_Merge(src proto.Message)

func (*EndorseRequest) XXX_Size 

func (m *EndorseRequest) XXX_Size() int

func (*EndorseRequest) XXX_Unmarshal 

func (m *EndorseRequest) XXX_Unmarshal(b []byte) error

type EndorseResponse 

type EndorseResponse struct {
	// The unsigned set of transaction responses from the endorsing peers for signing by the client
	// before submitting to ordering service (via gateway).
	PreparedTransaction  *common.Envelope `protobuf:"bytes,1,opt,name=prepared_transaction,json=preparedTransaction,proto3" json:"prepared_transaction,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

EndorseResponse returns the result of endorsing a transaction.

func (*EndorseResponse) Descriptor 

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

func (*EndorseResponse) GetPreparedTransaction 

func (m *EndorseResponse) GetPreparedTransaction() *common.Envelope

func (*EndorseResponse) ProtoMessage 

func (*EndorseResponse) ProtoMessage()

func (*EndorseResponse) Reset 

func (m *EndorseResponse) Reset()

func (*EndorseResponse) String 

func (m *EndorseResponse) String() string

func (*EndorseResponse) XXX_DiscardUnknown 

func (m *EndorseResponse) XXX_DiscardUnknown()

func (*EndorseResponse) XXX_Marshal 

func (m *EndorseResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EndorseResponse) XXX_Merge 

func (m *EndorseResponse) XXX_Merge(src proto.Message)

func (*EndorseResponse) XXX_Size 

func (m *EndorseResponse) XXX_Size() int

func (*EndorseResponse) XXX_Unmarshal 

func (m *EndorseResponse) XXX_Unmarshal(b []byte) error

type ErrorDetail 

type ErrorDetail struct {
	// The address of the endorsing peer or ordering node that returned an error.
	Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	// The MSP Identifier of this node.
	MspId string `protobuf:"bytes,2,opt,name=msp_id,json=mspId,proto3" json:"msp_id,omitempty"`
	// The error message returned by this node.
	Message              string   `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

If any of the functions in the Gateway service returns an error, then it will be in the format of a google.rpc.Status message. The 'details' field of this message will be populated with extra information if the error is a result of one or more failed requests to remote peers or orderer nodes. ErrorDetail contains details of errors that are received by any of the endorsing peers as a result of processing the Evaluate or Endorse services, or from the ordering node(s) as a result of processing the Submit service.

func (*ErrorDetail) Descriptor 

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

func (*ErrorDetail) GetAddress 

func (m *ErrorDetail) GetAddress() string

func (*ErrorDetail) GetMessage 

func (m *ErrorDetail) GetMessage() string

func (*ErrorDetail) GetMspId 

func (m *ErrorDetail) GetMspId() string

func (*ErrorDetail) ProtoMessage 

func (*ErrorDetail) ProtoMessage()

func (*ErrorDetail) Reset 

func (m *ErrorDetail) Reset()

func (*ErrorDetail) String 

func (m *ErrorDetail) String() string

func (*ErrorDetail) XXX_DiscardUnknown 

func (m *ErrorDetail) XXX_DiscardUnknown()

func (*ErrorDetail) XXX_Marshal 

func (m *ErrorDetail) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ErrorDetail) XXX_Merge 

func (m *ErrorDetail) XXX_Merge(src proto.Message)

func (*ErrorDetail) XXX_Size 

func (m *ErrorDetail) XXX_Size() int

func (*ErrorDetail) XXX_Unmarshal 

func (m *ErrorDetail) XXX_Unmarshal(b []byte) error

type EvaluateRequest 

type EvaluateRequest struct {
	// Identifier of the transaction to evaluate.
	TransactionId string `protobuf:"bytes,1,opt,name=transaction_id,json=transactionId,proto3" json:"transaction_id,omitempty"`
	// Identifier of the channel this request is bound for.
	ChannelId string `protobuf:"bytes,2,opt,name=channel_id,json=channelId,proto3" json:"channel_id,omitempty"`
	// The signed proposal ready for evaluation.
	ProposedTransaction *peer.SignedProposal `protobuf:"bytes,3,opt,name=proposed_transaction,json=proposedTransaction,proto3" json:"proposed_transaction,omitempty"`
	// If targeting the peers of specific organizations (e.g. for private data scenarios),
	// the list of organizations' MSPIDs should be supplied here.
	TargetOrganizations  []string `protobuf:"bytes,4,rep,name=target_organizations,json=targetOrganizations,proto3" json:"target_organizations,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

EvaluateRequest contains the details required to evaluate a transaction (query the ledger).

func (*EvaluateRequest) Descriptor 

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

func (*EvaluateRequest) GetChannelId 

func (m *EvaluateRequest) GetChannelId() string

func (*EvaluateRequest) GetProposedTransaction 

func (m *EvaluateRequest) GetProposedTransaction() *peer.SignedProposal

func (*EvaluateRequest) GetTargetOrganizations 

func (m *EvaluateRequest) GetTargetOrganizations() []string

func (*EvaluateRequest) GetTransactionId 

func (m *EvaluateRequest) GetTransactionId() string

func (*EvaluateRequest) ProtoMessage 

func (*EvaluateRequest) ProtoMessage()

func (*EvaluateRequest) Reset 

func (m *EvaluateRequest) Reset()

func (*EvaluateRequest) String 

func (m *EvaluateRequest) String() string

func (*EvaluateRequest) XXX_DiscardUnknown 

func (m *EvaluateRequest) XXX_DiscardUnknown()

func (*EvaluateRequest) XXX_Marshal 

func (m *EvaluateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EvaluateRequest) XXX_Merge 

func (m *EvaluateRequest) XXX_Merge(src proto.Message)

func (*EvaluateRequest) XXX_Size 

func (m *EvaluateRequest) XXX_Size() int

func (*EvaluateRequest) XXX_Unmarshal 

func (m *EvaluateRequest) XXX_Unmarshal(b []byte) error

type EvaluateResponse 

type EvaluateResponse struct {
	// The response that is returned by the transaction function, as defined
	// in peer/proposal_response.proto.
	Result               *peer.Response `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

EvaluateResponse returns the result of evaluating a transaction.

func (*EvaluateResponse) Descriptor 

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

func (*EvaluateResponse) GetResult 

func (m *EvaluateResponse) GetResult() *peer.Response

func (*EvaluateResponse) ProtoMessage 

func (*EvaluateResponse) ProtoMessage()

func (*EvaluateResponse) Reset 

func (m *EvaluateResponse) Reset()

func (*EvaluateResponse) String 

func (m *EvaluateResponse) String() string

func (*EvaluateResponse) XXX_DiscardUnknown 

func (m *EvaluateResponse) XXX_DiscardUnknown()

func (*EvaluateResponse) XXX_Marshal 

func (m *EvaluateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EvaluateResponse) XXX_Merge 

func (m *EvaluateResponse) XXX_Merge(src proto.Message)

func (*EvaluateResponse) XXX_Size 

func (m *EvaluateResponse) XXX_Size() int

func (*EvaluateResponse) XXX_Unmarshal 

func (m *EvaluateResponse) XXX_Unmarshal(b []byte) error

type GatewayClient 

type GatewayClient interface {
	// The Endorse service passes a proposed transaction to the gateway in order to
	// obtain sufficient endorsement.
	// The gateway will determine the endorsement plan for the requested chaincode and
	// forward to the appropriate peers for endorsement. It will return to the client a
	// prepared transaction in the form of an Envelope message as defined
	// in common/common.proto. The client must sign the contents of this envelope
	// before invoking the Submit service.
	Endorse(ctx context.Context, in *EndorseRequest, opts ...grpc.CallOption) (*EndorseResponse, error)
	// The Submit service will process the prepared transaction returned from Endorse service
	// once it has been signed by the client. It will wait for the transaction to be submitted to the
	// ordering service but the client must invoke the CommitStatus service to wait for the transaction
	// to be committed.
	Submit(ctx context.Context, in *SubmitRequest, opts ...grpc.CallOption) (*SubmitResponse, error)
	// The CommitStatus service will indicate whether a prepared transaction previously submitted to
	// the Submit service has been committed. It will wait for the commit to occur if it hasn’t already
	// committed.
	CommitStatus(ctx context.Context, in *SignedCommitStatusRequest, opts ...grpc.CallOption) (*CommitStatusResponse, error)
	// The Evaluate service passes a proposed transaction to the gateway in order to invoke the
	// transaction function and return the result to the client. No ledger updates are made.
	// The gateway will select an appropriate peer to query based on block height and load.
	Evaluate(ctx context.Context, in *EvaluateRequest, opts ...grpc.CallOption) (*EvaluateResponse, error)
	// The ChaincodeEvents service supplies a stream of responses, each containing all the events emitted by the
	// requested chaincode for a specific block. The streamed responses are ordered by ascending block number. Responses
	// are only returned for blocks that contain the requested events, while blocks not containing any of the requested
	// events are skipped.
	ChaincodeEvents(ctx context.Context, in *SignedChaincodeEventsRequest, opts ...grpc.CallOption) (Gateway_ChaincodeEventsClient, error)
}

GatewayClient is the client API for Gateway service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewGatewayClient 

func NewGatewayClient(cc *grpc.ClientConn) GatewayClient

type GatewayServer 

type GatewayServer interface {
	// The Endorse service passes a proposed transaction to the gateway in order to
	// obtain sufficient endorsement.
	// The gateway will determine the endorsement plan for the requested chaincode and
	// forward to the appropriate peers for endorsement. It will return to the client a
	// prepared transaction in the form of an Envelope message as defined
	// in common/common.proto. The client must sign the contents of this envelope
	// before invoking the Submit service.
	Endorse(context.Context, *EndorseRequest) (*EndorseResponse, error)
	// The Submit service will process the prepared transaction returned from Endorse service
	// once it has been signed by the client. It will wait for the transaction to be submitted to the
	// ordering service but the client must invoke the CommitStatus service to wait for the transaction
	// to be committed.
	Submit(context.Context, *SubmitRequest) (*SubmitResponse, error)
	// The CommitStatus service will indicate whether a prepared transaction previously submitted to
	// the Submit service has been committed. It will wait for the commit to occur if it hasn’t already
	// committed.
	CommitStatus(context.Context, *SignedCommitStatusRequest) (*CommitStatusResponse, error)
	// The Evaluate service passes a proposed transaction to the gateway in order to invoke the
	// transaction function and return the result to the client. No ledger updates are made.
	// The gateway will select an appropriate peer to query based on block height and load.
	Evaluate(context.Context, *EvaluateRequest) (*EvaluateResponse, error)
	// The ChaincodeEvents service supplies a stream of responses, each containing all the events emitted by the
	// requested chaincode for a specific block. The streamed responses are ordered by ascending block number. Responses
	// are only returned for blocks that contain the requested events, while blocks not containing any of the requested
	// events are skipped.
	ChaincodeEvents(*SignedChaincodeEventsRequest, Gateway_ChaincodeEventsServer) error
}

GatewayServer is the server API for Gateway service.

type Gateway_ChaincodeEventsClient 

type Gateway_ChaincodeEventsClient interface {
	Recv() (*ChaincodeEventsResponse, error)
	grpc.ClientStream
}

type Gateway_ChaincodeEventsServer 

type Gateway_ChaincodeEventsServer interface {
	Send(*ChaincodeEventsResponse) error
	grpc.ServerStream
}

type PreparedTransaction 

type PreparedTransaction struct {
	// Identifier of the prepared transaction.
	TransactionId string `protobuf:"bytes,1,opt,name=transaction_id,json=transactionId,proto3" json:"transaction_id,omitempty"`
	// The transaction envelope.
	Envelope             *common.Envelope `protobuf:"bytes,2,opt,name=envelope,proto3" json:"envelope,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

PreparedTransaction contains the details required for offline signing prior to submitting a transaction.

func (*PreparedTransaction) Descriptor 

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

func (*PreparedTransaction) GetEnvelope 

func (m *PreparedTransaction) GetEnvelope() *common.Envelope

func (*PreparedTransaction) GetTransactionId 

func (m *PreparedTransaction) GetTransactionId() string

func (*PreparedTransaction) ProtoMessage 

func (*PreparedTransaction) ProtoMessage()

func (*PreparedTransaction) Reset 

func (m *PreparedTransaction) Reset()

func (*PreparedTransaction) String 

func (m *PreparedTransaction) String() string

func (*PreparedTransaction) XXX_DiscardUnknown 

func (m *PreparedTransaction) XXX_DiscardUnknown()

func (*PreparedTransaction) XXX_Marshal 

func (m *PreparedTransaction) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PreparedTransaction) XXX_Merge 

func (m *PreparedTransaction) XXX_Merge(src proto.Message)

func (*PreparedTransaction) XXX_Size 

func (m *PreparedTransaction) XXX_Size() int

func (*PreparedTransaction) XXX_Unmarshal 

func (m *PreparedTransaction) XXX_Unmarshal(b []byte) error

type ProposedTransaction 

type ProposedTransaction struct {
	// Identifier of the proposed transaction.
	TransactionId string `protobuf:"bytes,1,opt,name=transaction_id,json=transactionId,proto3" json:"transaction_id,omitempty"`
	// The signed proposal.
	Proposal *peer.SignedProposal `protobuf:"bytes,2,opt,name=proposal,proto3" json:"proposal,omitempty"`
	// The list of endorsing organizations.
	EndorsingOrganizations []string `` /* 127-byte string literal not displayed */
	XXX_NoUnkeyedLiteral   struct{} `json:"-"`
	XXX_unrecognized       []byte   `json:"-"`
	XXX_sizecache          int32    `json:"-"`
}

ProposedTransaction contains the details required for offline signing prior to evaluating or endorsing a transaction.

func (*ProposedTransaction) Descriptor 

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

func (*ProposedTransaction) GetEndorsingOrganizations 

func (m *ProposedTransaction) GetEndorsingOrganizations() []string

func (*ProposedTransaction) GetProposal 

func (m *ProposedTransaction) GetProposal() *peer.SignedProposal

func (*ProposedTransaction) GetTransactionId 

func (m *ProposedTransaction) GetTransactionId() string

func (*ProposedTransaction) ProtoMessage 

func (*ProposedTransaction) ProtoMessage()

func (*ProposedTransaction) Reset 

func (m *ProposedTransaction) Reset()

func (*ProposedTransaction) String 

func (m *ProposedTransaction) String() string

func (*ProposedTransaction) XXX_DiscardUnknown 

func (m *ProposedTransaction) XXX_DiscardUnknown()

func (*ProposedTransaction) XXX_Marshal 

func (m *ProposedTransaction) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ProposedTransaction) XXX_Merge 

func (m *ProposedTransaction) XXX_Merge(src proto.Message)

func (*ProposedTransaction) XXX_Size 

func (m *ProposedTransaction) XXX_Size() int

func (*ProposedTransaction) XXX_Unmarshal 

func (m *ProposedTransaction) XXX_Unmarshal(b []byte) error

type SignedChaincodeEventsRequest 

type SignedChaincodeEventsRequest struct {
	// Serialized ChaincodeEventsRequest message.
	Request []byte `protobuf:"bytes,1,opt,name=request,proto3" json:"request,omitempty"`
	// Signature for request message.
	Signature            []byte   `protobuf:"bytes,2,opt,name=signature,proto3" json:"signature,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

SignedChaincodeEventsRequest contains a serialized ChaincodeEventsRequest message, and a digital signature for the serialized request message.

func (*SignedChaincodeEventsRequest) Descriptor 

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

func (*SignedChaincodeEventsRequest) GetRequest 

func (m *SignedChaincodeEventsRequest) GetRequest() []byte

func (*SignedChaincodeEventsRequest) GetSignature 

func (m *SignedChaincodeEventsRequest) GetSignature() []byte

func (*SignedChaincodeEventsRequest) ProtoMessage 

func (*SignedChaincodeEventsRequest) ProtoMessage()

func (*SignedChaincodeEventsRequest) Reset 

func (m *SignedChaincodeEventsRequest) Reset()

func (*SignedChaincodeEventsRequest) String 

func (m *SignedChaincodeEventsRequest) String() string

func (*SignedChaincodeEventsRequest) XXX_DiscardUnknown 

func (m *SignedChaincodeEventsRequest) XXX_DiscardUnknown()

func (*SignedChaincodeEventsRequest) XXX_Marshal 

func (m *SignedChaincodeEventsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SignedChaincodeEventsRequest) XXX_Merge 

func (m *SignedChaincodeEventsRequest) XXX_Merge(src proto.Message)

func (*SignedChaincodeEventsRequest) XXX_Size 

func (m *SignedChaincodeEventsRequest) XXX_Size() int

func (*SignedChaincodeEventsRequest) XXX_Unmarshal 

func (m *SignedChaincodeEventsRequest) XXX_Unmarshal(b []byte) error

type SignedCommitStatusRequest 

type SignedCommitStatusRequest struct {
	// Serialized CommitStatusRequest message.
	Request []byte `protobuf:"bytes,1,opt,name=request,proto3" json:"request,omitempty"`
	// Signature for request message.
	Signature            []byte   `protobuf:"bytes,2,opt,name=signature,proto3" json:"signature,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

SignedCommitStatusRequest contains a serialized CommitStatusRequest message, and a digital signature for the serialized request message.

func (*SignedCommitStatusRequest) Descriptor 

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

func (*SignedCommitStatusRequest) GetRequest 

func (m *SignedCommitStatusRequest) GetRequest() []byte

func (*SignedCommitStatusRequest) GetSignature 

func (m *SignedCommitStatusRequest) GetSignature() []byte

func (*SignedCommitStatusRequest) ProtoMessage 

func (*SignedCommitStatusRequest) ProtoMessage()

func (*SignedCommitStatusRequest) Reset 

func (m *SignedCommitStatusRequest) Reset()

func (*SignedCommitStatusRequest) String 

func (m *SignedCommitStatusRequest) String() string

func (*SignedCommitStatusRequest) XXX_DiscardUnknown 

func (m *SignedCommitStatusRequest) XXX_DiscardUnknown()

func (*SignedCommitStatusRequest) XXX_Marshal 

func (m *SignedCommitStatusRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SignedCommitStatusRequest) XXX_Merge 

func (m *SignedCommitStatusRequest) XXX_Merge(src proto.Message)

func (*SignedCommitStatusRequest) XXX_Size 

func (m *SignedCommitStatusRequest) XXX_Size() int

func (*SignedCommitStatusRequest) XXX_Unmarshal 

func (m *SignedCommitStatusRequest) XXX_Unmarshal(b []byte) error

type SubmitRequest 

type SubmitRequest struct {
	// Identifier of the transaction to submit.
	TransactionId string `protobuf:"bytes,1,opt,name=transaction_id,json=transactionId,proto3" json:"transaction_id,omitempty"`
	// Identifier of the channel this request is bound for.
	ChannelId string `protobuf:"bytes,2,opt,name=channel_id,json=channelId,proto3" json:"channel_id,omitempty"`
	// The signed set of endorsed transaction responses to submit.
	PreparedTransaction  *common.Envelope `protobuf:"bytes,3,opt,name=prepared_transaction,json=preparedTransaction,proto3" json:"prepared_transaction,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

SubmitRequest contains the details required to submit a transaction (update the ledger).

func (*SubmitRequest) Descriptor 

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

func (*SubmitRequest) GetChannelId 

func (m *SubmitRequest) GetChannelId() string

func (*SubmitRequest) GetPreparedTransaction 

func (m *SubmitRequest) GetPreparedTransaction() *common.Envelope

func (*SubmitRequest) GetTransactionId 

func (m *SubmitRequest) GetTransactionId() string

func (*SubmitRequest) ProtoMessage 

func (*SubmitRequest) ProtoMessage()

func (*SubmitRequest) Reset 

func (m *SubmitRequest) Reset()

func (*SubmitRequest) String 

func (m *SubmitRequest) String() string

func (*SubmitRequest) XXX_DiscardUnknown 

func (m *SubmitRequest) XXX_DiscardUnknown()

func (*SubmitRequest) XXX_Marshal 

func (m *SubmitRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SubmitRequest) XXX_Merge 

func (m *SubmitRequest) XXX_Merge(src proto.Message)

func (*SubmitRequest) XXX_Size 

func (m *SubmitRequest) XXX_Size() int

func (*SubmitRequest) XXX_Unmarshal 

func (m *SubmitRequest) XXX_Unmarshal(b []byte) error

type SubmitResponse 

type SubmitResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

SubmitResponse returns the result of submitting a transaction.

func (*SubmitResponse) Descriptor 

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

func (*SubmitResponse) ProtoMessage 

func (*SubmitResponse) ProtoMessage()

func (*SubmitResponse) Reset 

func (m *SubmitResponse) Reset()

func (*SubmitResponse) String 

func (m *SubmitResponse) String() string

func (*SubmitResponse) XXX_DiscardUnknown 

func (m *SubmitResponse) XXX_DiscardUnknown()

func (*SubmitResponse) XXX_Marshal 

func (m *SubmitResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SubmitResponse) XXX_Merge 

func (m *SubmitResponse) XXX_Merge(src proto.Message)

func (*SubmitResponse) XXX_Size 

func (m *SubmitResponse) XXX_Size() int

func (*SubmitResponse) XXX_Unmarshal 

func (m *SubmitResponse) XXX_Unmarshal(b []byte) error

type UnimplementedGatewayServer 

type UnimplementedGatewayServer struct {
}

UnimplementedGatewayServer can be embedded to have forward compatible implementations.

func (*UnimplementedGatewayServer) ChaincodeEvents 

func (*UnimplementedGatewayServer) ChaincodeEvents(req *SignedChaincodeEventsRequest, srv Gateway_ChaincodeEventsServer) error

func (*UnimplementedGatewayServer) CommitStatus 

func (*UnimplementedGatewayServer) CommitStatus(ctx context.Context, req *SignedCommitStatusRequest) (*CommitStatusResponse, error)

func (*UnimplementedGatewayServer) Endorse 

func (*UnimplementedGatewayServer) Endorse(ctx context.Context, req *EndorseRequest) (*EndorseResponse, error)

func (*UnimplementedGatewayServer) Evaluate 

func (*UnimplementedGatewayServer) Evaluate(ctx context.Context, req *EvaluateRequest) (*EvaluateResponse, error)

func (*UnimplementedGatewayServer) Submit 

func (*UnimplementedGatewayServer) Submit(ctx context.Context, req *SubmitRequest) (*SubmitResponse, error)

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.