Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	ErrInvalidLengthRpctransact        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowRpctransact          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupRpctransact = fmt.Errorf("proto: unexpected end of group")
)
View Source
var Transact_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "rpctransact.Transact",
	HandlerType: (*TransactServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "BroadcastTxSync",
			Handler:    _Transact_BroadcastTxSync_Handler,
		},
		{
			MethodName: "BroadcastTxAsync",
			Handler:    _Transact_BroadcastTxAsync_Handler,
		},
		{
			MethodName: "SignTx",
			Handler:    _Transact_SignTx_Handler,
		},
		{
			MethodName: "FormulateTx",
			Handler:    _Transact_FormulateTx_Handler,
		},
		{
			MethodName: "CallTxSync",
			Handler:    _Transact_CallTxSync_Handler,
		},
		{
			MethodName: "CallTxAsync",
			Handler:    _Transact_CallTxAsync_Handler,
		},
		{
			MethodName: "CallTxSim",
			Handler:    _Transact_CallTxSim_Handler,
		},
		{
			MethodName: "CallCodeSim",
			Handler:    _Transact_CallCodeSim_Handler,
		},
		{
			MethodName: "SendTxSync",
			Handler:    _Transact_SendTxSync_Handler,
		},
		{
			MethodName: "SendTxAsync",
			Handler:    _Transact_SendTxAsync_Handler,
		},
		{
			MethodName: "NameTxSync",
			Handler:    _Transact_NameTxSync_Handler,
		},
		{
			MethodName: "NameTxAsync",
			Handler:    _Transact_NameTxAsync_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "rpctransact.proto",
}

Transact_ServiceDesc is the grpc.ServiceDesc for Transact service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterTransactServer

func RegisterTransactServer(s grpc.ServiceRegistrar, srv TransactServer)

Types

type CallCodeParam

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

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

func (*CallCodeParam) GetCode

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

func (*CallCodeParam) GetData

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

func (*CallCodeParam) Marshal

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

func (*CallCodeParam) MarshalTo

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

func (*CallCodeParam) MarshalToSizedBuffer

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

func (*CallCodeParam) ProtoMessage

func (*CallCodeParam) ProtoMessage()

func (*CallCodeParam) Reset

func (m *CallCodeParam) Reset()

func (*CallCodeParam) Size

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

func (*CallCodeParam) String

func (m *CallCodeParam) String() string

func (*CallCodeParam) Unmarshal

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

func (*CallCodeParam) XXX_DiscardUnknown

func (m *CallCodeParam) XXX_DiscardUnknown()

func (*CallCodeParam) XXX_Marshal

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

func (*CallCodeParam) XXX_Merge

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

func (*CallCodeParam) XXX_MessageName

func (*CallCodeParam) XXX_MessageName() string

func (*CallCodeParam) XXX_Size

func (m *CallCodeParam) XXX_Size() int

func (*CallCodeParam) XXX_Unmarshal

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

type TransactClient

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://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewTransactClient

func NewTransactClient(cc grpc.ClientConnInterface) TransactClient

type TransactServer

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)
	// contains filtered or unexported methods
}

TransactServer is the server API for Transact service. All implementations must embed UnimplementedTransactServer for forward compatibility

func NewTransactServer

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

type TxEnvelope

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

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

func (*TxEnvelope) Marshal

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

func (*TxEnvelope) MarshalTo

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

func (*TxEnvelope) MarshalToSizedBuffer

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

func (*TxEnvelope) ProtoMessage

func (*TxEnvelope) ProtoMessage()

func (*TxEnvelope) Reset

func (m *TxEnvelope) Reset()

func (*TxEnvelope) Size

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

func (*TxEnvelope) String

func (m *TxEnvelope) String() string

func (*TxEnvelope) Unmarshal

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

func (*TxEnvelope) XXX_DiscardUnknown

func (m *TxEnvelope) XXX_DiscardUnknown()

func (*TxEnvelope) XXX_Marshal

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

func (*TxEnvelope) XXX_Merge

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

func (*TxEnvelope) XXX_MessageName

func (*TxEnvelope) XXX_MessageName() string

func (*TxEnvelope) XXX_Size

func (m *TxEnvelope) XXX_Size() int

func (*TxEnvelope) XXX_Unmarshal

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

type TxEnvelopeParam

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

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

func (*TxEnvelopeParam) GetEnvelope

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

func (*TxEnvelopeParam) GetPayload

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

func (*TxEnvelopeParam) GetTimeout

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

func (*TxEnvelopeParam) Marshal

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

func (*TxEnvelopeParam) MarshalTo

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

func (*TxEnvelopeParam) MarshalToSizedBuffer

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

func (*TxEnvelopeParam) ProtoMessage

func (*TxEnvelopeParam) ProtoMessage()

func (*TxEnvelopeParam) Reset

func (m *TxEnvelopeParam) Reset()

func (*TxEnvelopeParam) Size

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

func (*TxEnvelopeParam) String

func (m *TxEnvelopeParam) String() string

func (*TxEnvelopeParam) Unmarshal

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

func (*TxEnvelopeParam) XXX_DiscardUnknown

func (m *TxEnvelopeParam) XXX_DiscardUnknown()

func (*TxEnvelopeParam) XXX_Marshal

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

func (*TxEnvelopeParam) XXX_Merge

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

func (*TxEnvelopeParam) XXX_MessageName

func (*TxEnvelopeParam) XXX_MessageName() string

func (*TxEnvelopeParam) XXX_Size

func (m *TxEnvelopeParam) XXX_Size() int

func (*TxEnvelopeParam) XXX_Unmarshal

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

type UnimplementedTransactServer

type UnimplementedTransactServer struct {
}

UnimplementedTransactServer must be embedded to have forward compatible implementations.

func (UnimplementedTransactServer) BroadcastTxAsync

func (UnimplementedTransactServer) BroadcastTxSync

func (UnimplementedTransactServer) CallCodeSim

func (UnimplementedTransactServer) CallTxAsync

func (UnimplementedTransactServer) CallTxSim

func (UnimplementedTransactServer) CallTxSync

func (UnimplementedTransactServer) FormulateTx

func (UnimplementedTransactServer) NameTxAsync

func (UnimplementedTransactServer) NameTxSync

func (UnimplementedTransactServer) SendTxAsync

func (UnimplementedTransactServer) SendTxSync

func (UnimplementedTransactServer) SignTx

type UnsafeTransactServer

type UnsafeTransactServer interface {
	// contains filtered or unexported methods
}

UnsafeTransactServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to TransactServer will result in compilation errors.