burrow: github.com/hyperledger/burrow/rpc/rpctransact Index | Files

package rpctransact

import "github.com/hyperledger/burrow/rpc/rpctransact"

Index

Package Files

rpctransact.pb.go transact_server.go

Variables

var (
    ErrInvalidLengthRpctransact        = fmt.Errorf("proto: negative length found during unmarshaling")
    ErrIntOverflowRpctransact          = fmt.Errorf("proto: integer overflow")
    ErrUnexpectedEndOfGroupRpctransact = fmt.Errorf("proto: unexpected end of group")
)

func RegisterTransactServer Uses

func RegisterTransactServer(s *grpc.Server, srv TransactServer)

type CallCodeParam Uses

type CallCodeParam struct {
    FromAddress          github_com_hyperledger_burrow_crypto.Address `protobuf:"bytes,1,opt,name=FromAddress,proto3,customtype=github.com/hyperledger/burrow/crypto.Address" json:"FromAddress"`
    Code                 []byte                                       `protobuf:"bytes,2,opt,name=Code,proto3" json:"Code,omitempty"`
    Data                 []byte                                       `protobuf:"bytes,3,opt,name=Data,proto3" json:"Data,omitempty"`
    XXX_NoUnkeyedLiteral struct{}                                     `json:"-"`
    XXX_unrecognized     []byte                                       `json:"-"`
    XXX_sizecache        int32                                        `json:"-"`
}

func (*CallCodeParam) Descriptor Uses

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

func (*CallCodeParam) GetCode Uses

func (m *CallCodeParam) GetCode() []byte

func (*CallCodeParam) GetData Uses

func (m *CallCodeParam) GetData() []byte

func (*CallCodeParam) Marshal Uses

func (m *CallCodeParam) Marshal() (dAtA []byte, err error)

func (*CallCodeParam) MarshalTo Uses

func (m *CallCodeParam) MarshalTo(dAtA []byte) (int, error)

func (*CallCodeParam) MarshalToSizedBuffer Uses

func (m *CallCodeParam) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CallCodeParam) ProtoMessage Uses

func (*CallCodeParam) ProtoMessage()

func (*CallCodeParam) Reset Uses

func (m *CallCodeParam) Reset()

func (*CallCodeParam) Size Uses

func (m *CallCodeParam) Size() (n int)

func (*CallCodeParam) String Uses

func (m *CallCodeParam) String() string

func (*CallCodeParam) Unmarshal Uses

func (m *CallCodeParam) Unmarshal(dAtA []byte) error

func (*CallCodeParam) XXX_DiscardUnknown Uses

func (m *CallCodeParam) XXX_DiscardUnknown()

func (*CallCodeParam) XXX_Marshal Uses

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

func (*CallCodeParam) XXX_Merge Uses

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

func (*CallCodeParam) XXX_MessageName Uses

func (*CallCodeParam) XXX_MessageName() string

func (*CallCodeParam) XXX_Size Uses

func (m *CallCodeParam) XXX_Size() int

func (*CallCodeParam) XXX_Unmarshal Uses

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

type TransactClient Uses

type TransactClient interface {
    // Broadcast a transaction to the mempool - if the transaction is not signed signing will be attempted server-side
    // and wait for it to be included in block
    BroadcastTxSync(ctx context.Context, in *TxEnvelopeParam, opts ...grpc.CallOption) (*exec.TxExecution, error)
    // Broadcast a transaction to the mempool - if the transaction is not signed signing will be attempted server-side
    BroadcastTxAsync(ctx context.Context, in *TxEnvelopeParam, opts ...grpc.CallOption) (*txs.Receipt, error)
    // Sign transaction server-side
    SignTx(ctx context.Context, in *TxEnvelopeParam, opts ...grpc.CallOption) (*TxEnvelope, error)
    // Formulate a transaction from a Payload and retrun the envelop with the Tx bytes ready to sign
    FormulateTx(ctx context.Context, in *payload.Any, opts ...grpc.CallOption) (*TxEnvelope, error)
    // Formulate and sign a CallTx transaction signed server-side and wait for it to be included in a block, retrieving response
    CallTxSync(ctx context.Context, in *payload.CallTx, opts ...grpc.CallOption) (*exec.TxExecution, error)
    // Formulate and sign a CallTx transaction signed server-side
    CallTxAsync(ctx context.Context, in *payload.CallTx, opts ...grpc.CallOption) (*txs.Receipt, error)
    // Perform a 'simulated' call of a contract against the current committed EVM state without any changes been saved
    // and wait for the transaction to be included in a block
    CallTxSim(ctx context.Context, in *payload.CallTx, opts ...grpc.CallOption) (*exec.TxExecution, error)
    // Perform a 'simulated' execution of provided code against the current committed EVM state without any changes been saved
    CallCodeSim(ctx context.Context, in *CallCodeParam, opts ...grpc.CallOption) (*exec.TxExecution, error)
    // Formulate a SendTx transaction signed server-side and wait for it to be included in a block, retrieving response
    SendTxSync(ctx context.Context, in *payload.SendTx, opts ...grpc.CallOption) (*exec.TxExecution, error)
    // Formulate and  SendTx transaction signed server-side
    SendTxAsync(ctx context.Context, in *payload.SendTx, opts ...grpc.CallOption) (*txs.Receipt, error)
    // Formulate a NameTx signed server-side and wait for it to be included in a block returning the registered name
    NameTxSync(ctx context.Context, in *payload.NameTx, opts ...grpc.CallOption) (*exec.TxExecution, error)
    // Formulate a NameTx signed server-side
    NameTxAsync(ctx context.Context, in *payload.NameTx, opts ...grpc.CallOption) (*txs.Receipt, error)
}

TransactClient is the client API for Transact service.

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

func NewTransactClient Uses

func NewTransactClient(cc *grpc.ClientConn) TransactClient

type TransactServer Uses

type TransactServer interface {
    // Broadcast a transaction to the mempool - if the transaction is not signed signing will be attempted server-side
    // and wait for it to be included in block
    BroadcastTxSync(context.Context, *TxEnvelopeParam) (*exec.TxExecution, error)
    // Broadcast a transaction to the mempool - if the transaction is not signed signing will be attempted server-side
    BroadcastTxAsync(context.Context, *TxEnvelopeParam) (*txs.Receipt, error)
    // Sign transaction server-side
    SignTx(context.Context, *TxEnvelopeParam) (*TxEnvelope, error)
    // Formulate a transaction from a Payload and retrun the envelop with the Tx bytes ready to sign
    FormulateTx(context.Context, *payload.Any) (*TxEnvelope, error)
    // Formulate and sign a CallTx transaction signed server-side and wait for it to be included in a block, retrieving response
    CallTxSync(context.Context, *payload.CallTx) (*exec.TxExecution, error)
    // Formulate and sign a CallTx transaction signed server-side
    CallTxAsync(context.Context, *payload.CallTx) (*txs.Receipt, error)
    // Perform a 'simulated' call of a contract against the current committed EVM state without any changes been saved
    // and wait for the transaction to be included in a block
    CallTxSim(context.Context, *payload.CallTx) (*exec.TxExecution, error)
    // Perform a 'simulated' execution of provided code against the current committed EVM state without any changes been saved
    CallCodeSim(context.Context, *CallCodeParam) (*exec.TxExecution, error)
    // Formulate a SendTx transaction signed server-side and wait for it to be included in a block, retrieving response
    SendTxSync(context.Context, *payload.SendTx) (*exec.TxExecution, error)
    // Formulate and  SendTx transaction signed server-side
    SendTxAsync(context.Context, *payload.SendTx) (*txs.Receipt, error)
    // Formulate a NameTx signed server-side and wait for it to be included in a block returning the registered name
    NameTxSync(context.Context, *payload.NameTx) (*exec.TxExecution, error)
    // Formulate a NameTx signed server-side
    NameTxAsync(context.Context, *payload.NameTx) (*txs.Receipt, error)
}

TransactServer is the server API for Transact service.

func NewTransactServer Uses

func NewTransactServer(state acmstate.Reader, blockchain bcm.BlockchainInfo, transactor *execution.Transactor,
    txCodec txs.Codec, logger *logging.Logger) TransactServer

type TxEnvelope Uses

type TxEnvelope struct {
    Envelope             *github_com_hyperledger_burrow_txs.Envelope `protobuf:"bytes,1,opt,name=Envelope,proto3,customtype=github.com/hyperledger/burrow/txs.Envelope" json:"Envelope,omitempty"`
    XXX_NoUnkeyedLiteral struct{}                                    `json:"-"`
    XXX_unrecognized     []byte                                      `json:"-"`
    XXX_sizecache        int32                                       `json:"-"`
}

func (*TxEnvelope) Descriptor Uses

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

func (*TxEnvelope) Marshal Uses

func (m *TxEnvelope) Marshal() (dAtA []byte, err error)

func (*TxEnvelope) MarshalTo Uses

func (m *TxEnvelope) MarshalTo(dAtA []byte) (int, error)

func (*TxEnvelope) MarshalToSizedBuffer Uses

func (m *TxEnvelope) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*TxEnvelope) ProtoMessage Uses

func (*TxEnvelope) ProtoMessage()

func (*TxEnvelope) Reset Uses

func (m *TxEnvelope) Reset()

func (*TxEnvelope) Size Uses

func (m *TxEnvelope) Size() (n int)

func (*TxEnvelope) String Uses

func (m *TxEnvelope) String() string

func (*TxEnvelope) Unmarshal Uses

func (m *TxEnvelope) Unmarshal(dAtA []byte) error

func (*TxEnvelope) XXX_DiscardUnknown Uses

func (m *TxEnvelope) XXX_DiscardUnknown()

func (*TxEnvelope) XXX_Marshal Uses

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

func (*TxEnvelope) XXX_Merge Uses

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

func (*TxEnvelope) XXX_MessageName Uses

func (*TxEnvelope) XXX_MessageName() string

func (*TxEnvelope) XXX_Size Uses

func (m *TxEnvelope) XXX_Size() int

func (*TxEnvelope) XXX_Unmarshal Uses

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

type TxEnvelopeParam Uses

type TxEnvelopeParam struct {
    // An existing Envelope - either signed or unsigned - if the latter will be signed server-side
    Envelope *github_com_hyperledger_burrow_txs.Envelope `protobuf:"bytes,1,opt,name=Envelope,proto3,customtype=github.com/hyperledger/burrow/txs.Envelope" json:"Envelope,omitempty"`
    // If no Envelope provided then one will be generated from the provided payload and signed server-side
    Payload *payload.Any `protobuf:"bytes,2,opt,name=Payload,proto3" json:"Payload,omitempty"`
    // The amount of time to wait for the transaction to be committed and the TxExecution to be returned (server-side).
    // If zero there wait is unbounded. Timed out transactions return SyncInfo state that may be helpful debugging
    // non-committed transactions - this timeout must be less than client timeout to see such information!
    Timeout              time.Duration `protobuf:"bytes,3,opt,name=Timeout,proto3,stdduration" json:"Timeout"`
    XXX_NoUnkeyedLiteral struct{}      `json:"-"`
    XXX_unrecognized     []byte        `json:"-"`
    XXX_sizecache        int32         `json:"-"`
}

func (*TxEnvelopeParam) Descriptor Uses

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

func (*TxEnvelopeParam) GetEnvelope Uses

func (te *TxEnvelopeParam) GetEnvelope(chainID string) *txs.Envelope

func (*TxEnvelopeParam) GetPayload Uses

func (m *TxEnvelopeParam) GetPayload() *payload.Any

func (*TxEnvelopeParam) GetTimeout Uses

func (m *TxEnvelopeParam) GetTimeout() time.Duration

func (*TxEnvelopeParam) Marshal Uses

func (m *TxEnvelopeParam) Marshal() (dAtA []byte, err error)

func (*TxEnvelopeParam) MarshalTo Uses

func (m *TxEnvelopeParam) MarshalTo(dAtA []byte) (int, error)

func (*TxEnvelopeParam) MarshalToSizedBuffer Uses

func (m *TxEnvelopeParam) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*TxEnvelopeParam) ProtoMessage Uses

func (*TxEnvelopeParam) ProtoMessage()

func (*TxEnvelopeParam) Reset Uses

func (m *TxEnvelopeParam) Reset()

func (*TxEnvelopeParam) Size Uses

func (m *TxEnvelopeParam) Size() (n int)

func (*TxEnvelopeParam) String Uses

func (m *TxEnvelopeParam) String() string

func (*TxEnvelopeParam) Unmarshal Uses

func (m *TxEnvelopeParam) Unmarshal(dAtA []byte) error

func (*TxEnvelopeParam) XXX_DiscardUnknown Uses

func (m *TxEnvelopeParam) XXX_DiscardUnknown()

func (*TxEnvelopeParam) XXX_Marshal Uses

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

func (*TxEnvelopeParam) XXX_Merge Uses

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

func (*TxEnvelopeParam) XXX_MessageName Uses

func (*TxEnvelopeParam) XXX_MessageName() string

func (*TxEnvelopeParam) XXX_Size Uses

func (m *TxEnvelopeParam) XXX_Size() int

func (*TxEnvelopeParam) XXX_Unmarshal Uses

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

type UnimplementedTransactServer Uses

type UnimplementedTransactServer struct {
}

UnimplementedTransactServer can be embedded to have forward compatible implementations.

func (*UnimplementedTransactServer) BroadcastTxAsync Uses

func (*UnimplementedTransactServer) BroadcastTxAsync(ctx context.Context, req *TxEnvelopeParam) (*txs.Receipt, error)

func (*UnimplementedTransactServer) BroadcastTxSync Uses

func (*UnimplementedTransactServer) BroadcastTxSync(ctx context.Context, req *TxEnvelopeParam) (*exec.TxExecution, error)

func (*UnimplementedTransactServer) CallCodeSim Uses

func (*UnimplementedTransactServer) CallCodeSim(ctx context.Context, req *CallCodeParam) (*exec.TxExecution, error)

func (*UnimplementedTransactServer) CallTxAsync Uses

func (*UnimplementedTransactServer) CallTxAsync(ctx context.Context, req *payload.CallTx) (*txs.Receipt, error)

func (*UnimplementedTransactServer) CallTxSim Uses

func (*UnimplementedTransactServer) CallTxSim(ctx context.Context, req *payload.CallTx) (*exec.TxExecution, error)

func (*UnimplementedTransactServer) CallTxSync Uses

func (*UnimplementedTransactServer) CallTxSync(ctx context.Context, req *payload.CallTx) (*exec.TxExecution, error)

func (*UnimplementedTransactServer) FormulateTx Uses

func (*UnimplementedTransactServer) FormulateTx(ctx context.Context, req *payload.Any) (*TxEnvelope, error)

func (*UnimplementedTransactServer) NameTxAsync Uses

func (*UnimplementedTransactServer) NameTxAsync(ctx context.Context, req *payload.NameTx) (*txs.Receipt, error)

func (*UnimplementedTransactServer) NameTxSync Uses

func (*UnimplementedTransactServer) NameTxSync(ctx context.Context, req *payload.NameTx) (*exec.TxExecution, error)

func (*UnimplementedTransactServer) SendTxAsync Uses

func (*UnimplementedTransactServer) SendTxAsync(ctx context.Context, req *payload.SendTx) (*txs.Receipt, error)

func (*UnimplementedTransactServer) SendTxSync Uses

func (*UnimplementedTransactServer) SendTxSync(ctx context.Context, req *payload.SendTx) (*exec.TxExecution, error)

func (*UnimplementedTransactServer) SignTx Uses

func (*UnimplementedTransactServer) SignTx(ctx context.Context, req *TxEnvelopeParam) (*TxEnvelope, error)

Package rpctransact imports 24 packages (graph) and is imported by 13 packages. Updated 2020-04-15. Refresh now. Tools for package owners.