exec

package
v0.25.1 Latest Latest
Warning

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

 Go to latest Published: May 3, 2019 License: Apache-2.0 Imports: 23 Imported by: 37

Documentation

Overview

Package exec is a generated protocol buffer package.

It is generated from these files: 

exec.proto

It has these top-level messages: 

StreamEvent
StreamKey
BeginBlock
EndBlock
BeginTx
EndTx
TxHeader
BlockExecution
TxExecution
Origin
Header
Event
Result
LogEvent
CallEvent
GovernAccountEvent
InputEvent
OutputEvent
CallData

Index

Constants

View Source 
const (
	CallTypeCall     = CallType(0x00)
	CallTypeCode     = CallType(0x01)
	CallTypeDelegate = CallType(0x02)
	CallTypeStatic   = CallType(0x03)
	CallTypeSNative  = CallType(0x04)
)
View Source 
const LogNKeyPrefix = "Log"

Variables

View Source 
var (
	ErrInvalidLengthExec = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowExec   = fmt.Errorf("proto: integer overflow")
)

Functions

func EventStringAccountCall 

func EventStringAccountCall(addr crypto.Address) string

func EventStringAccountInput 

func EventStringAccountInput(addr crypto.Address) string

func EventStringAccountOutput 

func EventStringAccountOutput(addr crypto.Address) string

func EventStringBlockExecution 

func EventStringBlockExecution(height uint64) string

func EventStringGovernAccount 

func EventStringGovernAccount(addr *crypto.Address) string

func EventStringLogEvent 

func EventStringLogEvent(addr crypto.Address) string

func EventStringTxExecution 

func EventStringTxExecution(txHash []byte) string

func LogNKey 

func LogNKey(topic int) string

func LogNTextKey 

func LogNTextKey(topic int) string

func QueryForBlockExecution 

func QueryForBlockExecution() *query.Builder

func QueryForBlockExecutionFromHeight 

func QueryForBlockExecutionFromHeight(height uint64) *query.Builder

func QueryForTxExecution 

func QueryForTxExecution(txHash []byte) query.Queryable

Types

type BeginBlock added in v0.24.0 

type BeginBlock struct {
	// The height of this block
	Height uint64        `protobuf:"varint,1,opt,name=Height,proto3" json:"Height,omitempty"`
	Header *types.Header `protobuf:"bytes,2,opt,name=Header" json:"Header,omitempty"`
}

func (*BeginBlock) Descriptor added in v0.24.0 

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

func (*BeginBlock) GetHeader added in v0.24.0 

func (m *BeginBlock) GetHeader() *types.Header

func (*BeginBlock) GetHeight added in v0.24.0 

func (m *BeginBlock) GetHeight() uint64

func (*BeginBlock) Marshal added in v0.24.0 

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

func (*BeginBlock) MarshalTo added in v0.24.0 

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

func (*BeginBlock) ProtoMessage added in v0.24.0 

func (*BeginBlock) ProtoMessage()

func (*BeginBlock) Reset added in v0.24.0 

func (m *BeginBlock) Reset()

func (*BeginBlock) Size added in v0.24.0 

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

func (*BeginBlock) String added in v0.24.0 

func (m *BeginBlock) String() string

func (*BeginBlock) Unmarshal added in v0.24.0 

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

func (*BeginBlock) XXX_MessageName added in v0.24.0 

func (*BeginBlock) XXX_MessageName() string

type BeginTx added in v0.24.0 

type BeginTx struct {
	TxHeader *TxHeader `protobuf:"bytes,1,opt,name=TxHeader" json:"TxHeader,omitempty"`
	// Result of tx execution
	Result *Result `protobuf:"bytes,2,opt,name=Result" json:"Result,omitempty"`
	// If tx execution was an exception
	Exception *errors.Exception `protobuf:"bytes,4,opt,name=Exception" json:"Exception,omitempty"`
}

func (*BeginTx) Descriptor added in v0.24.0 

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

func (*BeginTx) GetException added in v0.24.0 

func (m *BeginTx) GetException() *errors.Exception

func (*BeginTx) GetResult added in v0.24.0 

func (m *BeginTx) GetResult() *Result

func (*BeginTx) GetTxHeader added in v0.24.0 

func (m *BeginTx) GetTxHeader() *TxHeader

func (*BeginTx) Marshal added in v0.24.0 

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

func (*BeginTx) MarshalTo added in v0.24.0 

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

func (*BeginTx) ProtoMessage added in v0.24.0 

func (*BeginTx) ProtoMessage()

func (*BeginTx) Reset added in v0.24.0 

func (m *BeginTx) Reset()

func (*BeginTx) Size added in v0.24.0 

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

func (*BeginTx) String added in v0.24.0 

func (m *BeginTx) String() string

func (*BeginTx) Unmarshal added in v0.24.0 

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

func (*BeginTx) XXX_MessageName added in v0.24.0 

func (*BeginTx) XXX_MessageName() string

type BlockAccumulator added in v0.24.0 

type BlockAccumulator struct {
	// contains filtered or unexported fields
}

func (*BlockAccumulator) Consume added in v0.24.0 

func (ba *BlockAccumulator) Consume(ev *StreamEvent) *BlockExecution

Consume will add the StreamEvent passed to the block accumulator and if the block complete is complete return the BlockExecution, otherwise will return nil

type BlockExecution 

type BlockExecution struct {
	// The height of this block
	Height       uint64         `protobuf:"varint,1,opt,name=Height,proto3" json:"Height,omitempty"`
	Header       *types.Header  `protobuf:"bytes,2,opt,name=Header" json:"Header,omitempty"`
	TxExecutions []*TxExecution `protobuf:"bytes,3,rep,name=TxExecutions" json:"TxExecutions,omitempty"`
}

func ConsumeBlockExecution added in v0.24.0 

func ConsumeBlockExecution(stream EventStream) (block *BlockExecution, err error)

func (*BlockExecution) AppendTxs added in v0.24.0 

func (be *BlockExecution) AppendTxs(tail ...*TxExecution)

func (*BlockExecution) Descriptor 

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

func (*BlockExecution) Encode 

func (be *BlockExecution) Encode() ([]byte, error)

func (*BlockExecution) EncodeHeader added in v0.24.0 

func (be *BlockExecution) EncodeHeader() ([]byte, error)

func (*BlockExecution) EventType 

func (*BlockExecution) EventType() EventType

func (*BlockExecution) GetHeader added in v0.24.0 

func (m *BlockExecution) GetHeader() *types.Header

func (*BlockExecution) GetHeight 

func (m *BlockExecution) GetHeight() uint64

func (*BlockExecution) GetTxExecutions 

func (m *BlockExecution) GetTxExecutions() []*TxExecution

func (*BlockExecution) Marshal 

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

func (*BlockExecution) MarshalTo 

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

func (*BlockExecution) ProtoMessage 

func (*BlockExecution) ProtoMessage()

func (*BlockExecution) Reset 

func (m *BlockExecution) Reset()

func (*BlockExecution) Size 

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

func (*BlockExecution) StreamEvents added in v0.24.0 

func (be *BlockExecution) StreamEvents() StreamEvents

Write out TxExecutions parenthetically

func (*BlockExecution) String 

func (m *BlockExecution) String() string

func (*BlockExecution) Tagged 

func (be *BlockExecution) Tagged() *TaggedBlockExecution

func (*BlockExecution) Tx 

func (be *BlockExecution) Tx(txEnv *txs.Envelope) *TxExecution

func (*BlockExecution) Unmarshal 

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

func (*BlockExecution) XXX_MessageName 

func (*BlockExecution) XXX_MessageName() string

type CallData 

type CallData struct {
	Caller github_com_hyperledger_burrow_crypto.Address  `protobuf:"bytes,1,opt,name=Caller,proto3,customtype=github.com/hyperledger/burrow/crypto.Address" json:"Caller"`
	Callee github_com_hyperledger_burrow_crypto.Address  `protobuf:"bytes,2,opt,name=Callee,proto3,customtype=github.com/hyperledger/burrow/crypto.Address" json:"Callee"`
	Data   github_com_hyperledger_burrow_binary.HexBytes `protobuf:"bytes,3,opt,name=Data,proto3,customtype=github.com/hyperledger/burrow/binary.HexBytes" json:"Data"`
	Value  uint64                                        `protobuf:"varint,4,opt,name=Value,proto3" json:"Value,omitempty"`
	Gas    uint64                                        `protobuf:"varint,5,opt,name=Gas,proto3" json:"Gas,omitempty"`
}

func (*CallData) Descriptor 

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

func (*CallData) GetGas 

func (m *CallData) GetGas() uint64

func (*CallData) GetValue 

func (m *CallData) GetValue() uint64

func (*CallData) Marshal 

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

func (*CallData) MarshalTo 

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

func (*CallData) ProtoMessage 

func (*CallData) ProtoMessage()

func (*CallData) Reset 

func (m *CallData) Reset()

func (*CallData) Size 

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

func (*CallData) String 

func (m *CallData) String() string

func (*CallData) Unmarshal 

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

func (*CallData) XXX_MessageName 

func (*CallData) XXX_MessageName() string

type CallEvent 

type CallEvent struct {
	CallType   CallType                                      `protobuf:"varint,5,opt,name=CallType,proto3,casttype=CallType" json:"CallType,omitempty"`
	CallData   *CallData                                     `protobuf:"bytes,1,opt,name=CallData" json:"CallData,omitempty"`
	Origin     github_com_hyperledger_burrow_crypto.Address  `protobuf:"bytes,2,opt,name=Origin,proto3,customtype=github.com/hyperledger/burrow/crypto.Address" json:"Origin"`
	StackDepth uint64                                        `protobuf:"varint,3,opt,name=StackDepth,proto3" json:"StackDepth,omitempty"`
	Return     github_com_hyperledger_burrow_binary.HexBytes `protobuf:"bytes,4,opt,name=Return,proto3,customtype=github.com/hyperledger/burrow/binary.HexBytes" json:"Return"`
}

func (*CallEvent) Descriptor 

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

func (*CallEvent) GetCallData 

func (m *CallEvent) GetCallData() *CallData

func (*CallEvent) GetCallType added in v0.23.0 

func (m *CallEvent) GetCallType() CallType

func (*CallEvent) GetStackDepth 

func (m *CallEvent) GetStackDepth() uint64

func (*CallEvent) Marshal 

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

func (*CallEvent) MarshalTo 

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

func (*CallEvent) ProtoMessage 

func (*CallEvent) ProtoMessage()

func (*CallEvent) Reset 

func (m *CallEvent) Reset()

func (*CallEvent) Size 

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

func (*CallEvent) String 

func (m *CallEvent) String() string

func (*CallEvent) Unmarshal 

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

func (*CallEvent) XXX_MessageName 

func (*CallEvent) XXX_MessageName() string

type CallType added in v0.23.0 

type CallType uint32

func CallTypeFromString added in v0.23.0 

func CallTypeFromString(name string) CallType

func (CallType) MarshalText added in v0.23.0 

func (ct CallType) MarshalText() ([]byte, error)

func (CallType) String added in v0.23.0 

func (ct CallType) String() string

func (*CallType) UnmarshalText added in v0.23.0 

func (ct *CallType) UnmarshalText(data []byte) error

type EndBlock added in v0.24.0 

type EndBlock struct {
	Height uint64 `protobuf:"varint,1,opt,name=Height,proto3" json:"Height,omitempty"`
}

func (*EndBlock) Descriptor added in v0.24.0 

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

func (*EndBlock) GetHeight added in v0.24.0 

func (m *EndBlock) GetHeight() uint64

func (*EndBlock) Marshal added in v0.24.0 

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

func (*EndBlock) MarshalTo added in v0.24.0 

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

func (*EndBlock) ProtoMessage added in v0.24.0 

func (*EndBlock) ProtoMessage()

func (*EndBlock) Reset added in v0.24.0 

func (m *EndBlock) Reset()

func (*EndBlock) Size added in v0.24.0 

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

func (*EndBlock) String added in v0.24.0 

func (m *EndBlock) String() string

func (*EndBlock) Unmarshal added in v0.24.0 

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

func (*EndBlock) XXX_MessageName added in v0.24.0 

func (*EndBlock) XXX_MessageName() string

type EndTx added in v0.24.0 

type EndTx struct {
	// The hash of the transaction that caused this event to be generated
	TxHash github_com_hyperledger_burrow_binary.HexBytes `protobuf:"bytes,3,opt,name=TxHash,proto3,customtype=github.com/hyperledger/burrow/binary.HexBytes" json:"TxHash"`
}

func (*EndTx) Descriptor added in v0.24.0 

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

func (*EndTx) Marshal added in v0.24.0 

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

func (*EndTx) MarshalTo added in v0.24.0 

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

func (*EndTx) ProtoMessage added in v0.24.0 

func (*EndTx) ProtoMessage()

func (*EndTx) Reset added in v0.24.0 

func (m *EndTx) Reset()

func (*EndTx) Size added in v0.24.0 

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

func (*EndTx) String added in v0.24.0 

func (m *EndTx) String() string

func (*EndTx) Unmarshal added in v0.24.0 

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

func (*EndTx) XXX_MessageName added in v0.24.0 

func (*EndTx) XXX_MessageName() string

type Event 

type Event struct {
	Header        *Header             `protobuf:"bytes,1,opt,name=Header" json:"Header,omitempty"`
	Input         *InputEvent         `protobuf:"bytes,2,opt,name=Input" json:"Input,omitempty"`
	Output        *OutputEvent        `protobuf:"bytes,3,opt,name=Output" json:"Output,omitempty"`
	Call          *CallEvent          `protobuf:"bytes,4,opt,name=Call" json:"Call,omitempty"`
	Log           *LogEvent           `protobuf:"bytes,5,opt,name=Log" json:"Log,omitempty"`
	GovernAccount *GovernAccountEvent `protobuf:"bytes,6,opt,name=GovernAccount" json:"GovernAccount,omitempty"`
}

func (*Event) Body 

func (ev *Event) Body() string

func (*Event) Descriptor 

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

func (*Event) EventType 

func (ev *Event) EventType() EventType

func (*Event) GetCall 

func (m *Event) GetCall() *CallEvent

func (*Event) GetGovernAccount 

func (m *Event) GetGovernAccount() *GovernAccountEvent

func (*Event) GetHeader 

func (m *Event) GetHeader() *Header

func (*Event) GetInput 

func (m *Event) GetInput() *InputEvent

func (*Event) GetLog 

func (m *Event) GetLog() *LogEvent

func (*Event) GetOutput 

func (m *Event) GetOutput() *OutputEvent

func (*Event) GetValue added in v0.23.0 

func (this *Event) GetValue() interface{}

func (*Event) Marshal 

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

func (*Event) MarshalTo 

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

func (*Event) ProtoMessage 

func (*Event) ProtoMessage()

func (*Event) Reset 

func (m *Event) Reset()

func (*Event) SetValue added in v0.23.0 

func (this *Event) SetValue(value interface{}) bool

func (*Event) Size 

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

func (*Event) String 

func (ev *Event) String() string

func (*Event) Tagged 

func (ev *Event) Tagged() *TaggedEvent

func (*Event) Unmarshal 

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

func (*Event) XXX_MessageName 

func (*Event) XXX_MessageName() string

type EventStream added in v0.24.0 

type EventStream interface {
	Recv() (*StreamEvent, error)
}

type EventType 

type EventType uint32
const (
	TypeUnknown EventType = iota
	TypeCall
	TypeLog
	TypeAccountInput
	TypeAccountOutput
	TypeTxExecution
	TypeBlockExecution
	TypeGovernAccount
	TypeBeginBlock
	TypeBeginTx
	TypeEnvelope
	TypeEndTx
	TypeEndBlock
)

Execution event types

func EventTypeFromString 

func EventTypeFromString(name string) EventType

func (EventType) MarshalText 

func (typ EventType) MarshalText() ([]byte, error)

func (EventType) String 

func (typ EventType) String() string

func (*EventType) UnmarshalText 

func (typ *EventType) UnmarshalText(data []byte) error

type GovernAccountEvent 

type GovernAccountEvent struct {
	AccountUpdate *spec.TemplateAccount `protobuf:"bytes,1,opt,name=AccountUpdate" json:"AccountUpdate,omitempty"`
}

func (*GovernAccountEvent) Descriptor 

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

func (*GovernAccountEvent) GetAccountUpdate 

func (m *GovernAccountEvent) GetAccountUpdate() *spec.TemplateAccount

func (*GovernAccountEvent) Marshal 

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

func (*GovernAccountEvent) MarshalTo 

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

func (*GovernAccountEvent) ProtoMessage 

func (*GovernAccountEvent) ProtoMessage()

func (*GovernAccountEvent) Reset 

func (m *GovernAccountEvent) Reset()

func (*GovernAccountEvent) Size 

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

func (*GovernAccountEvent) String 

func (m *GovernAccountEvent) String() string

func (*GovernAccountEvent) Unmarshal 

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

func (*GovernAccountEvent) XXX_MessageName 

func (*GovernAccountEvent) XXX_MessageName() string
type Header struct {
	// Transaction type
	TxType github_com_hyperledger_burrow_txs_payload.Type `protobuf:"varint,1,opt,name=TxType,proto3,casttype=github.com/hyperledger/burrow/txs/payload.Type" json:"TxType,omitempty"`
	// The hash of the transaction that caused this event to be generated
	TxHash github_com_hyperledger_burrow_binary.HexBytes `protobuf:"bytes,2,opt,name=TxHash,proto3,customtype=github.com/hyperledger/burrow/binary.HexBytes" json:"TxHash"`
	// The type of event
	EventType EventType `protobuf:"varint,3,opt,name=EventType,proto3,casttype=EventType" json:"EventType,omitempty"`
	// EventID published with event
	EventID string `protobuf:"bytes,4,opt,name=EventID,proto3" json:"EventID,omitempty"`
	// The block height at which this event was emitted
	Height uint64 `protobuf:"varint,5,opt,name=Height,proto3" json:"Height,omitempty"`
	// The index of this event relative to other events generated by the same transaction
	Index uint64 `protobuf:"varint,6,opt,name=Index,proto3" json:"Index,omitempty"`
	// If event is exception
	Exception *errors.Exception `protobuf:"bytes,7,opt,name=Exception" json:"Exception,omitempty"`
}

func (*Header) Descriptor 

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

func (*Header) GetEventID 

func (m *Header) GetEventID() string

func (*Header) GetEventType 

func (m *Header) GetEventType() EventType

func (*Header) GetException 

func (m *Header) GetException() *errors.Exception

func (*Header) GetHeight 

func (m *Header) GetHeight() uint64

func (*Header) GetIndex 

func (m *Header) GetIndex() uint64

func (*Header) GetTxType 

func (m *Header) GetTxType() github_com_hyperledger_burrow_txs_payload.Type

func (*Header) Marshal 

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

func (*Header) MarshalTo 

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

func (*Header) ProtoMessage 

func (*Header) ProtoMessage()

func (*Header) Reset 

func (m *Header) Reset()

func (*Header) Size 

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

func (*Header) String 

func (h *Header) String() string

func (*Header) Unmarshal 

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

func (*Header) XXX_MessageName 

func (*Header) XXX_MessageName() string

type InputEvent 

type InputEvent struct {
	Address github_com_hyperledger_burrow_crypto.Address `protobuf:"bytes,1,opt,name=Address,proto3,customtype=github.com/hyperledger/burrow/crypto.Address" json:"Address"`
}

func (*InputEvent) Descriptor 

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

func (*InputEvent) Marshal 

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

func (*InputEvent) MarshalTo 

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

func (*InputEvent) ProtoMessage 

func (*InputEvent) ProtoMessage()

func (*InputEvent) Reset 

func (m *InputEvent) Reset()

func (*InputEvent) Size 

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

func (*InputEvent) String 

func (m *InputEvent) String() string

func (*InputEvent) Unmarshal 

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

func (*InputEvent) XXX_MessageName 

func (*InputEvent) XXX_MessageName() string

type LogEvent 

type LogEvent struct {
	Address github_com_hyperledger_burrow_crypto.Address   `protobuf:"bytes,1,opt,name=Address,proto3,customtype=github.com/hyperledger/burrow/crypto.Address" json:"Address"`
	Data    github_com_hyperledger_burrow_binary.HexBytes  `protobuf:"bytes,2,opt,name=Data,proto3,customtype=github.com/hyperledger/burrow/binary.HexBytes" json:"Data"`
	Topics  []github_com_hyperledger_burrow_binary.Word256 `protobuf:"bytes,3,rep,name=Topics,customtype=github.com/hyperledger/burrow/binary.Word256" json:"Topics"`
}

func (*LogEvent) Descriptor 

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

func (*LogEvent) Get 

func (log *LogEvent) Get(key string) (string, bool)

func (*LogEvent) GetTopic 

func (log *LogEvent) GetTopic(i int) Word256

func (*LogEvent) Keys 

func (log *LogEvent) Keys() []string

func (*LogEvent) Len 

func (log *LogEvent) Len() int

func (*LogEvent) Marshal 

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

func (*LogEvent) MarshalTo 

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

func (*LogEvent) ProtoMessage 

func (*LogEvent) ProtoMessage()

func (*LogEvent) Reset 

func (m *LogEvent) Reset()

func (*LogEvent) Size 

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

func (*LogEvent) String 

func (m *LogEvent) String() string

func (*LogEvent) Unmarshal 

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

func (*LogEvent) XXX_MessageName 

func (*LogEvent) XXX_MessageName() string

type Origin added in v0.24.0 

type Origin struct {
	// The original ChainID from for this transaction
	ChainID string `protobuf:"bytes,1,opt,name=ChainID,proto3" json:"ChainID,omitempty"`
	// The original height at which this transaction was committed
	Height uint64 `protobuf:"varint,2,opt,name=Height,proto3" json:"Height,omitempty"`
	// The original index in the block
	Index uint64 `protobuf:"varint,3,opt,name=Index,proto3" json:"Index,omitempty"`
	// The original block time for this transaction
	Time time.Time `protobuf:"bytes,4,opt,name=Time,stdtime" json:"Time"`
}

func (*Origin) Descriptor added in v0.24.0 

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

func (*Origin) GetChainID added in v0.24.0 

func (m *Origin) GetChainID() string

func (*Origin) GetHeight added in v0.24.0 

func (m *Origin) GetHeight() uint64

func (*Origin) GetIndex added in v0.24.0 

func (m *Origin) GetIndex() uint64

func (*Origin) GetTime added in v0.24.0 

func (m *Origin) GetTime() time.Time

func (*Origin) Marshal added in v0.24.0 

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

func (*Origin) MarshalTo added in v0.24.0 

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

func (*Origin) ProtoMessage added in v0.24.0 

func (*Origin) ProtoMessage()

func (*Origin) Reset added in v0.24.0 

func (m *Origin) Reset()

func (*Origin) Size added in v0.24.0 

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

func (*Origin) String added in v0.24.0 

func (m *Origin) String() string

func (*Origin) Unmarshal added in v0.24.0 

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

func (*Origin) XXX_MessageName added in v0.24.0 

func (*Origin) XXX_MessageName() string

type OutputEvent 

type OutputEvent struct {
	Address github_com_hyperledger_burrow_crypto.Address `protobuf:"bytes,1,opt,name=Address,proto3,customtype=github.com/hyperledger/burrow/crypto.Address" json:"Address"`
}

func (*OutputEvent) Descriptor 

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

func (*OutputEvent) Marshal 

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

func (*OutputEvent) MarshalTo 

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

func (*OutputEvent) ProtoMessage 

func (*OutputEvent) ProtoMessage()

func (*OutputEvent) Reset 

func (m *OutputEvent) Reset()

func (*OutputEvent) Size 

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

func (*OutputEvent) String 

func (m *OutputEvent) String() string

func (*OutputEvent) Unmarshal 

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

func (*OutputEvent) XXX_MessageName 

func (*OutputEvent) XXX_MessageName() string

type Result 

type Result struct {
	// EVM execution return
	Return []byte `protobuf:"bytes,1,opt,name=Return,proto3" json:"Return,omitempty"`
	// Gas used in computation
	GasUsed uint64 `protobuf:"varint,2,opt,name=GasUsed,proto3" json:"GasUsed,omitempty"`
	// Name entry created
	NameEntry *names.Entry `protobuf:"bytes,3,opt,name=NameEntry" json:"NameEntry,omitempty"`
	// Permission update performed
	PermArgs *permission.PermArgs `protobuf:"bytes,4,opt,name=PermArgs" json:"PermArgs,omitempty"`
}

Could structure this further if needed - sum type of various results relevant to different transaction types

func (*Result) Descriptor 

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

func (*Result) GetGasUsed 

func (m *Result) GetGasUsed() uint64

func (*Result) GetNameEntry 

func (m *Result) GetNameEntry() *names.Entry

func (*Result) GetPermArgs 

func (m *Result) GetPermArgs() *permission.PermArgs

func (*Result) GetReturn 

func (m *Result) GetReturn() []byte

func (*Result) Marshal 

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

func (*Result) MarshalTo 

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

func (*Result) ProtoMessage 

func (*Result) ProtoMessage()

func (*Result) Reset 

func (m *Result) Reset()

func (*Result) Size 

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

func (*Result) String 

func (m *Result) String() string

func (*Result) Unmarshal 

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

func (*Result) XXX_MessageName 

func (*Result) XXX_MessageName() string

type StreamEvent added in v0.24.0 

type StreamEvent struct {
	BeginBlock *BeginBlock                                 `protobuf:"bytes,1,opt,name=BeginBlock" json:"BeginBlock,omitempty"`
	BeginTx    *BeginTx                                    `protobuf:"bytes,2,opt,name=BeginTx" json:"BeginTx,omitempty"`
	Envelope   *github_com_hyperledger_burrow_txs.Envelope `protobuf:"bytes,3,opt,name=Envelope,customtype=github.com/hyperledger/burrow/txs.Envelope" json:"Envelope,omitempty"`
	Event      *Event                                      `protobuf:"bytes,4,opt,name=Event" json:"Event,omitempty"`
	EndTx      *EndTx                                      `protobuf:"bytes,5,opt,name=EndTx" json:"EndTx,omitempty"`
	EndBlock   *EndBlock                                   `protobuf:"bytes,6,opt,name=EndBlock" json:"EndBlock,omitempty"`
}

func DecodeStreamEvent added in v0.24.0 

func DecodeStreamEvent(bs []byte) (*StreamEvent, error)

func (*StreamEvent) Descriptor added in v0.24.0 

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

func (*StreamEvent) Encode added in v0.24.0 

func (be *StreamEvent) Encode() ([]byte, error)

func (*StreamEvent) EventType added in v0.24.0 

func (ev *StreamEvent) EventType() EventType

func (*StreamEvent) GetBeginBlock added in v0.24.0 

func (m *StreamEvent) GetBeginBlock() *BeginBlock

func (*StreamEvent) GetBeginTx added in v0.24.0 

func (m *StreamEvent) GetBeginTx() *BeginTx

func (*StreamEvent) GetEndBlock added in v0.24.0 

func (m *StreamEvent) GetEndBlock() *EndBlock

func (*StreamEvent) GetEndTx added in v0.24.0 

func (m *StreamEvent) GetEndTx() *EndTx

func (*StreamEvent) GetEvent added in v0.24.0 

func (m *StreamEvent) GetEvent() *Event

func (*StreamEvent) GetValue added in v0.24.0 

func (this *StreamEvent) GetValue() interface{}

func (*StreamEvent) Marshal added in v0.24.0 

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

func (*StreamEvent) MarshalTo added in v0.24.0 

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

func (*StreamEvent) ProtoMessage added in v0.24.0 

func (*StreamEvent) ProtoMessage()

func (*StreamEvent) Reset added in v0.24.0 

func (m *StreamEvent) Reset()

func (*StreamEvent) SetValue added in v0.24.0 

func (this *StreamEvent) SetValue(value interface{}) bool

func (*StreamEvent) Size added in v0.24.0 

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

func (*StreamEvent) String added in v0.24.0 

func (m *StreamEvent) String() string

func (*StreamEvent) Tagged added in v0.24.0 

func (ev *StreamEvent) Tagged() *TaggedBlockEvent

func (*StreamEvent) Unmarshal added in v0.24.0 

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

func (*StreamEvent) XXX_MessageName added in v0.24.0 

func (*StreamEvent) XXX_MessageName() string

type StreamEvents added in v0.24.0 

type StreamEvents []*StreamEvent

func (*StreamEvents) Recv added in v0.24.0 

func (ses *StreamEvents) Recv() (*StreamEvent, error)

type StreamKey added in v0.24.0 

type StreamKey struct {
	// The block height
	Height uint64 `protobuf:"varint,1,opt,name=Height,proto3" json:"Height,omitempty"`
	// The index of the StreamEvent amongst other StreamEvents at the same height
	Index uint64 `protobuf:"varint,2,opt,name=Index,proto3" json:"Index,omitempty"`
}

A key to a stream event

func (*StreamKey) Descriptor added in v0.24.0 

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

func (*StreamKey) GetHeight added in v0.24.0 

func (m *StreamKey) GetHeight() uint64

func (*StreamKey) GetIndex added in v0.24.0 

func (m *StreamKey) GetIndex() uint64

func (*StreamKey) Marshal added in v0.24.0 

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

func (*StreamKey) MarshalTo added in v0.24.0 

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

func (*StreamKey) ProtoMessage added in v0.24.0 

func (*StreamKey) ProtoMessage()

func (*StreamKey) Reset added in v0.24.0 

func (m *StreamKey) Reset()

func (*StreamKey) Size added in v0.24.0 

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

func (*StreamKey) String added in v0.24.0 

func (m *StreamKey) String() string

func (*StreamKey) Unmarshal added in v0.24.0 

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

func (*StreamKey) XXX_MessageName added in v0.24.0 

func (*StreamKey) XXX_MessageName() string

type TaggedBlockEvent added in v0.24.0 

type TaggedBlockEvent struct {
	query.Tagged
	*StreamEvent
}

type TaggedBlockExecution 

type TaggedBlockExecution struct {
	query.Tagged
	*BlockExecution
}

Tags

type TaggedEvent 

type TaggedEvent struct {
	query.Tagged
	*Event
}

Tags

type TaggedEvents 

type TaggedEvents []*TaggedEvent

func (TaggedEvents) Filter 

func (tevs TaggedEvents) Filter(qry query.Query) TaggedEvents

type TaggedTxExecution 

type TaggedTxExecution struct {
	query.Tagged
	*TxExecution
}

Tags

type TxExecution 

type TxExecution struct {
	*TxHeader `protobuf:"bytes,1,opt,name=Header,embedded=Header" json:"Header,omitempty"`
	// Signed Tx that triggered this execution
	Envelope *github_com_hyperledger_burrow_txs.Envelope `protobuf:"bytes,6,opt,name=Envelope,customtype=github.com/hyperledger/burrow/txs.Envelope" json:"Envelope,omitempty"`
	// Execution events
	Events []*Event `protobuf:"bytes,7,rep,name=Events" json:"Events,omitempty"`
	// The execution results
	Result *Result `protobuf:"bytes,8,opt,name=Result" json:"Result,omitempty"`
	// The transaction receipt
	Receipt *txs.Receipt `protobuf:"bytes,9,opt,name=Receipt" json:"Receipt,omitempty"`
	// If execution was an exception
	Exception *errors.Exception `protobuf:"bytes,10,opt,name=Exception" json:"Exception,omitempty"`
	// A proposal may contain other transactions
	TxExecutions []*TxExecution `protobuf:"bytes,11,rep,name=TxExecutions" json:"TxExecutions,omitempty"`
}

func DecodeTxExecution 

func DecodeTxExecution(bs []byte) (*TxExecution, error)

func NewTxExecution 

func NewTxExecution(txEnv *txs.Envelope) *TxExecution

func (*TxExecution) Append 

func (txe *TxExecution) Append(tail ...*Event)

func (*TxExecution) Call 

func (txe *TxExecution) Call(call *CallEvent, exception *errors.Exception) error

func (*TxExecution) CallError added in v0.23.0 

func (txe *TxExecution) CallError() *errors.CallError

func (*TxExecution) CallTrace added in v0.24.3 

func (txe *TxExecution) CallTrace() string

func (*TxExecution) Descriptor 

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

func (*TxExecution) Encode 

func (txe *TxExecution) Encode() ([]byte, error)

func (*TxExecution) EventType 

func (*TxExecution) EventType() EventType

func (*TxExecution) ExceptionalCalls added in v0.23.0 

func (txe *TxExecution) ExceptionalCalls() []*Event

func (*TxExecution) GetEvents 

func (m *TxExecution) GetEvents() []*Event

func (*TxExecution) GetException 

func (m *TxExecution) GetException() *errors.Exception

func (*TxExecution) GetReceipt 

func (m *TxExecution) GetReceipt() *txs.Receipt

func (*TxExecution) GetResult 

func (m *TxExecution) GetResult() *Result

func (*TxExecution) GetTxExecutions added in v0.24.0 

func (m *TxExecution) GetTxExecutions() []*TxExecution

func (*TxExecution) GetTxHash added in v0.24.0 

func (txe *TxExecution) GetTxHash() binary.HexBytes

func (*TxExecution) GovernAccount 

func (txe *TxExecution) GovernAccount(governAccount *GovernAccountEvent, exception *errors.Exception)

func (*TxExecution) Header 

func (txe *TxExecution) Header(eventType EventType, eventID string, exception *errors.Exception) *Header

func (*TxExecution) Input 

func (txe *TxExecution) Input(address crypto.Address, exception *errors.Exception)

Emit events

func (*TxExecution) Log 

func (txe *TxExecution) Log(log *LogEvent) error

func (*TxExecution) Marshal 

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

func (*TxExecution) MarshalTo 

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

func (*TxExecution) Name 

func (txe *TxExecution) Name(entry *names.Entry)

func (*TxExecution) Output 

func (txe *TxExecution) Output(address crypto.Address, exception *errors.Exception)

func (*TxExecution) Permission 

func (txe *TxExecution) Permission(permArgs *permission.PermArgs)

func (*TxExecution) ProtoMessage 

func (*TxExecution) ProtoMessage()

func (*TxExecution) PushError added in v0.23.0 

func (txe *TxExecution) PushError(err error)

Errors pushed to TxExecutions end up in merkle state so it is essential that they are deterministic and independent of the code path taken to execution (e.g. replay takes a different path to that of normal consensus reactor so stack traces may differ - as they may across architectures)

func (*TxExecution) Reset 

func (m *TxExecution) Reset()

func (*TxExecution) Return 

func (txe *TxExecution) Return(returnValue []byte, gasUsed uint64)

Set result

func (*TxExecution) Size 

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

func (*TxExecution) StreamEvents added in v0.24.0 

func (txe *TxExecution) StreamEvents() StreamEvents

func (*TxExecution) String 

func (m *TxExecution) String() string

func (*TxExecution) Tagged 

func (txe *TxExecution) Tagged() *TaggedTxExecution

func (*TxExecution) TaggedEvents 

func (txe *TxExecution) TaggedEvents() TaggedEvents

func (*TxExecution) Unmarshal 

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

func (*TxExecution) XXX_MessageName 

func (*TxExecution) XXX_MessageName() string

type TxHeader added in v0.24.0 

type TxHeader struct {
	// Transaction type
	TxType github_com_hyperledger_burrow_txs_payload.Type `protobuf:"varint,1,opt,name=TxType,proto3,casttype=github.com/hyperledger/burrow/txs/payload.Type" json:"TxType,omitempty"`
	// The hash of the transaction that caused this event to be generated
	TxHash github_com_hyperledger_burrow_binary.HexBytes `protobuf:"bytes,2,opt,name=TxHash,proto3,customtype=github.com/hyperledger/burrow/binary.HexBytes" json:"TxHash"`
	// The block height at which this Tx was included
	Height uint64 `protobuf:"varint,3,opt,name=Height,proto3" json:"Height,omitempty"`
	// The index of this transaction within the block
	Index uint64 `protobuf:"varint,4,opt,name=Index,proto3" json:"Index,omitempty"`
	// The origin information from the chain on which this tx was originally committed (if restored or otherwise imported)
	Origin *Origin `protobuf:"bytes,5,opt,name=Origin" json:"Origin,omitempty"`
}

func (*TxHeader) Descriptor added in v0.24.0 

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

func (*TxHeader) GetHeight added in v0.24.0 

func (m *TxHeader) GetHeight() uint64

func (*TxHeader) GetIndex added in v0.24.0 

func (m *TxHeader) GetIndex() uint64

func (*TxHeader) GetOrigin added in v0.24.0 

func (m *TxHeader) GetOrigin() *Origin

func (*TxHeader) GetTxType added in v0.24.0 

func (m *TxHeader) GetTxType() github_com_hyperledger_burrow_txs_payload.Type

func (*TxHeader) Marshal added in v0.24.0 

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

func (*TxHeader) MarshalTo added in v0.24.0 

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

func (*TxHeader) ProtoMessage added in v0.24.0 

func (*TxHeader) ProtoMessage()

func (*TxHeader) Reset added in v0.24.0 

func (m *TxHeader) Reset()

func (*TxHeader) Size added in v0.24.0 

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

func (*TxHeader) String added in v0.24.0 

func (m *TxHeader) String() string

func (*TxHeader) Unmarshal added in v0.24.0 

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

func (*TxHeader) XXX_MessageName added in v0.24.0 

func (*TxHeader) XXX_MessageName() string

type TxStack added in v0.24.0 

type TxStack []*TxExecution

TxStack is able to consume potentially nested txs

func (*TxStack) Consume added in v0.24.0 

func (stack *TxStack) Consume(ev *StreamEvent) *TxExecution

Consume will add the StreamEvent to the transaction stack and if that completes a single outermost transaction returns the TxExecution otherwise will return nil

func (TxStack) Peek added in v0.24.0 

func (stack TxStack) Peek() *TxExecution

func (*TxStack) Pop added in v0.24.0 

func (stack *TxStack) Pop() *TxExecution

func (*TxStack) Push added in v0.24.0 

func (stack *TxStack) Push(txe *TxExecution)

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.