exec

package
v0.34.4 Latest Latest
Warning

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

Go to latest
Published: Jul 23, 2021 License: Apache-2.0 Imports: 25 Imported by: 0

Documentation

Index

Constants

View Source
const (
	CallTypeInvalid  = CallType(1<<32 - 1)
	CallTypeCall     = CallType(0x00)
	CallTypeCode     = CallType(0x01)
	CallTypeDelegate = CallType(0x02)
	CallTypeStatic   = CallType(0x03)
)
View Source
const LogNKeyPrefix = "Log"

Variables

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

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 NewLogFreeEventSink added in v0.34.4

func NewLogFreeEventSink(eventSink EventSink) *logFreeEventSink

func NewNoopEventSink added in v0.34.4

func NewNoopEventSink() *noopEventSink

func QueryForBlockExecution

func QueryForBlockExecution() *query.Builder

func QueryForBlockExecutionFromHeight

func QueryForBlockExecutionFromHeight(height uint64) *query.Builder

func QueryForTxExecution

func QueryForTxExecution(txHash []byte) query.Queryable

func SolidityEventID added in v0.34.4

func SolidityEventID(topics []Word256) abi.EventID

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"`
	// The number of transactions in the block (used as a checksum when consuming StreamEvents)
	NumTxs uint64 `protobuf:"varint,3,opt,name=NumTxs,proto3" json:"NumTxs,omitempty"`
	// The height of the most recent block we stored in state (which is the last non-empty block in current implementation)
	PredecessorHeight    uint64        `protobuf:"varint,4,opt,name=PredecessorHeight,proto3" json:"PredecessorHeight,omitempty"`
	Header               *types.Header `protobuf:"bytes,2,opt,name=Header,proto3" json:"Header,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

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) GetNumTxs added in v0.34.4

func (m *BeginBlock) GetNumTxs() uint64

func (*BeginBlock) GetPredecessorHeight added in v0.34.4

func (m *BeginBlock) GetPredecessorHeight() 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) MarshalToSizedBuffer added in v0.34.4

func (m *BeginBlock) MarshalToSizedBuffer(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_DiscardUnknown added in v0.24.0

func (m *BeginBlock) XXX_DiscardUnknown()

func (*BeginBlock) XXX_Marshal added in v0.24.0

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

func (*BeginBlock) XXX_Merge added in v0.24.0

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

func (*BeginBlock) XXX_MessageName added in v0.24.0

func (*BeginBlock) XXX_MessageName() string

func (*BeginBlock) XXX_Size added in v0.24.0

func (m *BeginBlock) XXX_Size() int

func (*BeginBlock) XXX_Unmarshal added in v0.24.0

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

type BeginTx added in v0.24.0

type BeginTx struct {
	TxHeader *TxHeader `protobuf:"bytes,1,opt,name=TxHeader,proto3" json:"TxHeader,omitempty"`
	// The number of events generated by this transaction execution (used as a checksum when consuming StreamEvents)
	NumEvents uint64 `protobuf:"varint,5,opt,name=NumEvents,proto3" json:"NumEvents,omitempty"`
	// Result of tx execution
	Result *Result `protobuf:"bytes,2,opt,name=Result,proto3" json:"Result,omitempty"`
	// If tx execution was an exception
	Exception            *errors.Exception `protobuf:"bytes,4,opt,name=Exception,proto3" json:"Exception,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

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) GetNumEvents added in v0.34.4

func (m *BeginTx) GetNumEvents() uint64

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) MarshalToSizedBuffer added in v0.34.4

func (m *BeginTx) MarshalToSizedBuffer(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_DiscardUnknown added in v0.24.0

func (m *BeginTx) XXX_DiscardUnknown()

func (*BeginTx) XXX_Marshal added in v0.24.0

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

func (*BeginTx) XXX_Merge added in v0.24.0

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

func (*BeginTx) XXX_MessageName added in v0.24.0

func (*BeginTx) XXX_MessageName() string

func (*BeginTx) XXX_Size added in v0.24.0

func (m *BeginTx) XXX_Size() int

func (*BeginTx) XXX_Unmarshal added in v0.24.0

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

type BlockAccumulator added in v0.24.0

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

func NewBlockAccumulator added in v0.34.4

func NewBlockAccumulator(continuityOptions ...ContinuityOpt) *BlockAccumulator

func (*BlockAccumulator) Consume added in v0.24.0

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

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

func (*BlockAccumulator) ConsumeBlockExecution added in v0.34.4

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

type BlockExecution

type BlockExecution struct {
	// The height of this block
	Height uint64 `protobuf:"varint,1,opt,name=Height,proto3" json:"Height,omitempty"`
	// The height of the most recent block we stored in state (which is the last non-empty block in current implementation)
	PredecessorHeight    uint64         `protobuf:"varint,4,opt,name=PredecessorHeight,proto3" json:"PredecessorHeight,omitempty"`
	Header               *types.Header  `protobuf:"bytes,2,opt,name=Header,proto3" json:"Header,omitempty"`
	TxExecutions         []*TxExecution `protobuf:"bytes,3,rep,name=TxExecutions,proto3" json:"TxExecutions,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*BlockExecution) AppendTxs added in v0.24.0

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

func (*BlockExecution) Descriptor

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

func (*BlockExecution) EventType

func (*BlockExecution) EventType() EventType

func (*BlockExecution) Get added in v0.34.4

func (be *BlockExecution) Get(key string) (interface{}, bool)

func (*BlockExecution) GetHeader added in v0.24.0

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

func (*BlockExecution) GetHeight

func (m *BlockExecution) GetHeight() uint64

func (*BlockExecution) GetPredecessorHeight added in v0.34.4

func (m *BlockExecution) GetPredecessorHeight() 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) MarshalToSizedBuffer added in v0.34.4

func (m *BlockExecution) MarshalToSizedBuffer(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() []*StreamEvent

Write out TxExecutions parenthetically

func (*BlockExecution) String

func (m *BlockExecution) String() string

func (*BlockExecution) Tx

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

func (*BlockExecution) Unmarshal

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

func (*BlockExecution) XXX_DiscardUnknown added in v0.23.0

func (m *BlockExecution) XXX_DiscardUnknown()

func (*BlockExecution) XXX_Marshal added in v0.23.0

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

func (*BlockExecution) XXX_Merge added in v0.23.0

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

func (*BlockExecution) XXX_MessageName

func (*BlockExecution) XXX_MessageName() string

func (*BlockExecution) XXX_Size added in v0.23.0

func (m *BlockExecution) XXX_Size() int

func (*BlockExecution) XXX_Unmarshal added in v0.23.0

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

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"`
	// Bytes of a big integer value
	Value                []byte   `protobuf:"bytes,4,opt,name=Value,proto3" json:"Value,omitempty"`
	Gas                  []byte   `protobuf:"bytes,5,opt,name=Gas,proto3" json:"Gas,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CallData) Descriptor

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

func (*CallData) GetGas

func (m *CallData) GetGas() []byte

func (*CallData) GetValue

func (m *CallData) GetValue() []byte

func (*CallData) Marshal

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

func (*CallData) MarshalTo

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

func (*CallData) MarshalToSizedBuffer added in v0.34.4

func (m *CallData) MarshalToSizedBuffer(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_DiscardUnknown added in v0.23.0

func (m *CallData) XXX_DiscardUnknown()

func (*CallData) XXX_Marshal added in v0.23.0

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

func (*CallData) XXX_Merge added in v0.23.0

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

func (*CallData) XXX_MessageName

func (*CallData) XXX_MessageName() string

func (*CallData) XXX_Size added in v0.23.0

func (m *CallData) XXX_Size() int

func (*CallData) XXX_Unmarshal added in v0.23.0

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

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,proto3" 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"`
	XXX_NoUnkeyedLiteral struct{}                                      `json:"-"`
	XXX_unrecognized     []byte                                        `json:"-"`
	XXX_sizecache        int32                                         `json:"-"`
}

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) MarshalToSizedBuffer added in v0.34.4

func (m *CallEvent) MarshalToSizedBuffer(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_DiscardUnknown added in v0.23.0

func (m *CallEvent) XXX_DiscardUnknown()

func (*CallEvent) XXX_Marshal added in v0.23.0

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

func (*CallEvent) XXX_Merge added in v0.23.0

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

func (*CallEvent) XXX_MessageName

func (*CallEvent) XXX_MessageName() string

func (*CallEvent) XXX_Size added in v0.23.0

func (m *CallEvent) XXX_Size() int

func (*CallEvent) XXX_Unmarshal added in v0.23.0

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

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 ContinuityOpt added in v0.34.4

type ContinuityOpt byte
const (
	// Default - continuous blocks, txs, and events are always permitted
	Continuous ContinuityOpt = iota
	// Allows consumption of blocks where the next block has a different predecessor block to that which was last consumed
	NonConsecutiveBlocks
	// Allows consumption of transactions with non-monotonic index (within block) or a different number of transactions
	// to that which is expected
	NonConsecutiveTxs
	// Allows consumption of events with non-monotonic index (within transaction) or a different number of events
	// to that which is expected
	NonConsecutiveEvents
)

ContinuityOpt encodes the following possible relaxations in continuity

func GetContinuity added in v0.34.4

func GetContinuity(continuityOptions ...ContinuityOpt) ContinuityOpt

func (ContinuityOpt) Allows added in v0.34.4

func (so ContinuityOpt) Allows(opt ContinuityOpt) bool

type EndBlock added in v0.24.0

type EndBlock struct {
	Height               uint64   `protobuf:"varint,1,opt,name=Height,proto3" json:"Height,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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) MarshalToSizedBuffer added in v0.34.4

func (m *EndBlock) MarshalToSizedBuffer(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_DiscardUnknown added in v0.24.0

func (m *EndBlock) XXX_DiscardUnknown()

func (*EndBlock) XXX_Marshal added in v0.24.0

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

func (*EndBlock) XXX_Merge added in v0.24.0

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

func (*EndBlock) XXX_MessageName added in v0.24.0

func (*EndBlock) XXX_MessageName() string

func (*EndBlock) XXX_Size added in v0.24.0

func (m *EndBlock) XXX_Size() int

func (*EndBlock) XXX_Unmarshal added in v0.24.0

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

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"`
	XXX_NoUnkeyedLiteral struct{}                                      `json:"-"`
	XXX_unrecognized     []byte                                        `json:"-"`
	XXX_sizecache        int32                                         `json:"-"`
}

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) MarshalToSizedBuffer added in v0.34.4

func (m *EndTx) MarshalToSizedBuffer(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_DiscardUnknown added in v0.24.0

func (m *EndTx) XXX_DiscardUnknown()

func (*EndTx) XXX_Marshal added in v0.24.0

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

func (*EndTx) XXX_Merge added in v0.24.0

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

func (*EndTx) XXX_MessageName added in v0.24.0

func (*EndTx) XXX_MessageName() string

func (*EndTx) XXX_Size added in v0.24.0

func (m *EndTx) XXX_Size() int

func (*EndTx) XXX_Unmarshal added in v0.24.0

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

type Event

type Event struct {
	Header               *Header             `protobuf:"bytes,1,opt,name=Header,proto3" json:"Header,omitempty"`
	Input                *InputEvent         `protobuf:"bytes,2,opt,name=Input,proto3" json:"Input,omitempty"`
	Output               *OutputEvent        `protobuf:"bytes,3,opt,name=Output,proto3" json:"Output,omitempty"`
	Call                 *CallEvent          `protobuf:"bytes,4,opt,name=Call,proto3" json:"Call,omitempty"`
	Log                  *LogEvent           `protobuf:"bytes,5,opt,name=Log,proto3" json:"Log,omitempty"`
	GovernAccount        *GovernAccountEvent `protobuf:"bytes,6,opt,name=GovernAccount,proto3" json:"GovernAccount,omitempty"`
	Print                *PrintEvent         `protobuf:"bytes,7,opt,name=Print,proto3" json:"Print,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

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) Get added in v0.34.4

func (ev *Event) Get(key string) (value interface{}, ok bool)

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) GetPrint added in v0.34.4

func (m *Event) GetPrint() *PrintEvent

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) MarshalToSizedBuffer added in v0.34.4

func (m *Event) MarshalToSizedBuffer(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) Unmarshal

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

func (*Event) XXX_DiscardUnknown added in v0.23.0

func (m *Event) XXX_DiscardUnknown()

func (*Event) XXX_Marshal added in v0.23.0

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

func (*Event) XXX_Merge added in v0.23.0

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

func (*Event) XXX_MessageName

func (*Event) XXX_MessageName() string

func (*Event) XXX_Size added in v0.23.0

func (m *Event) XXX_Size() int

func (*Event) XXX_Unmarshal added in v0.23.0

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

type EventSink added in v0.34.4

type EventSink interface {
	Call(call *CallEvent, exception *errors.Exception) error
	Log(log *LogEvent) error
	Print(print *PrintEvent) error
}

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
	TypePrint
)

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 Events added in v0.34.4

type Events []*Event

func (*Events) Append added in v0.34.4

func (evs *Events) Append(tail ...*Event)

func (*Events) Call added in v0.34.4

func (evs *Events) Call(call *CallEvent, exception *errors.Exception) error

func (Events) CallTrace added in v0.34.4

func (evs Events) CallTrace() string

func (Events) ExceptionalCalls added in v0.34.4

func (evs Events) ExceptionalCalls() []*Event

func (Events) Filter added in v0.34.4

func (evs Events) Filter(qry query.Query) Events

func (*Events) Log added in v0.34.4

func (evs *Events) Log(log *LogEvent) error

func (Events) NestedCallErrors added in v0.34.4

func (evs Events) NestedCallErrors() []errors.NestedCallError

func (*Events) Print added in v0.34.4

func (evs *Events) Print(print *PrintEvent) error

type GovernAccountEvent

type GovernAccountEvent struct {
	AccountUpdate        *spec.TemplateAccount `protobuf:"bytes,1,opt,name=AccountUpdate,proto3" json:"AccountUpdate,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

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) MarshalToSizedBuffer added in v0.34.4

func (m *GovernAccountEvent) MarshalToSizedBuffer(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_DiscardUnknown added in v0.23.0

func (m *GovernAccountEvent) XXX_DiscardUnknown()

func (*GovernAccountEvent) XXX_Marshal added in v0.23.0

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

func (*GovernAccountEvent) XXX_Merge added in v0.23.0

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

func (*GovernAccountEvent) XXX_MessageName

func (*GovernAccountEvent) XXX_MessageName() string

func (*GovernAccountEvent) XXX_Size added in v0.23.0

func (m *GovernAccountEvent) XXX_Size() int

func (*GovernAccountEvent) XXX_Unmarshal added in v0.23.0

func (m *GovernAccountEvent) XXX_Unmarshal(b []byte) error
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,proto3" json:"Exception,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

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 (*Header) Marshal

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

func (*Header) MarshalTo

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

func (*Header) MarshalToSizedBuffer added in v0.34.4

func (m *Header) MarshalToSizedBuffer(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_DiscardUnknown added in v0.23.0

func (m *Header) XXX_DiscardUnknown()

func (*Header) XXX_Marshal added in v0.23.0

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

func (*Header) XXX_Merge added in v0.23.0

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

func (*Header) XXX_MessageName

func (*Header) XXX_MessageName() string

func (*Header) XXX_Size added in v0.23.0

func (m *Header) XXX_Size() int

func (*Header) XXX_Unmarshal added in v0.23.0

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

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"`
	XXX_NoUnkeyedLiteral struct{}                                     `json:"-"`
	XXX_unrecognized     []byte                                       `json:"-"`
	XXX_sizecache        int32                                        `json:"-"`
}

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) MarshalToSizedBuffer added in v0.34.4

func (m *InputEvent) MarshalToSizedBuffer(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_DiscardUnknown added in v0.23.0

func (m *InputEvent) XXX_DiscardUnknown()

func (*InputEvent) XXX_Marshal added in v0.23.0

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

func (*InputEvent) XXX_Merge added in v0.23.0

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

func (*InputEvent) XXX_MessageName

func (*InputEvent) XXX_MessageName() string

func (*InputEvent) XXX_Size added in v0.23.0

func (m *InputEvent) XXX_Size() int

func (*InputEvent) XXX_Unmarshal added in v0.23.0

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

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,proto3,customtype=github.com/hyperledger/burrow/binary.Word256" json:"Topics"`
	XXX_NoUnkeyedLiteral struct{}                                       `json:"-"`
	XXX_unrecognized     []byte                                         `json:"-"`
	XXX_sizecache        int32                                          `json:"-"`
}

func (*LogEvent) Descriptor

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

func (*LogEvent) Get

func (log *LogEvent) Get(key string) (interface{}, bool)

func (*LogEvent) GetTopic

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

func (*LogEvent) Marshal

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

func (*LogEvent) MarshalTo

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

func (*LogEvent) MarshalToSizedBuffer added in v0.34.4

func (m *LogEvent) MarshalToSizedBuffer(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_DiscardUnknown added in v0.23.0

func (m *LogEvent) XXX_DiscardUnknown()

func (*LogEvent) XXX_Marshal added in v0.23.0

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

func (*LogEvent) XXX_Merge added in v0.23.0

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

func (*LogEvent) XXX_MessageName

func (*LogEvent) XXX_MessageName() string

func (*LogEvent) XXX_Size added in v0.23.0

func (m *LogEvent) XXX_Size() int

func (*LogEvent) XXX_Unmarshal added in v0.23.0

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

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,proto3,stdtime" json:"Time"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

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) MarshalToSizedBuffer added in v0.34.4

func (m *Origin) MarshalToSizedBuffer(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_DiscardUnknown added in v0.24.0

func (m *Origin) XXX_DiscardUnknown()

func (*Origin) XXX_Marshal added in v0.24.0

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

func (*Origin) XXX_Merge added in v0.24.0

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

func (*Origin) XXX_MessageName added in v0.24.0

func (*Origin) XXX_MessageName() string

func (*Origin) XXX_Size added in v0.24.0

func (m *Origin) XXX_Size() int

func (*Origin) XXX_Unmarshal added in v0.24.0

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

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"`
	XXX_NoUnkeyedLiteral struct{}                                     `json:"-"`
	XXX_unrecognized     []byte                                       `json:"-"`
	XXX_sizecache        int32                                        `json:"-"`
}

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) MarshalToSizedBuffer added in v0.34.4

func (m *OutputEvent) MarshalToSizedBuffer(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_DiscardUnknown added in v0.23.0

func (m *OutputEvent) XXX_DiscardUnknown()

func (*OutputEvent) XXX_Marshal added in v0.23.0

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

func (*OutputEvent) XXX_Merge added in v0.23.0

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

func (*OutputEvent) XXX_MessageName

func (*OutputEvent) XXX_MessageName() string

func (*OutputEvent) XXX_Size added in v0.23.0

func (m *OutputEvent) XXX_Size() int

func (*OutputEvent) XXX_Unmarshal added in v0.23.0

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

type PrintEvent added in v0.34.4

type PrintEvent 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"`
	XXX_NoUnkeyedLiteral struct{}                                      `json:"-"`
	XXX_unrecognized     []byte                                        `json:"-"`
	XXX_sizecache        int32                                         `json:"-"`
}

func (*PrintEvent) Descriptor added in v0.34.4

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

func (*PrintEvent) Marshal added in v0.34.4

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

func (*PrintEvent) MarshalTo added in v0.34.4

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

func (*PrintEvent) MarshalToSizedBuffer added in v0.34.4

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

func (*PrintEvent) ProtoMessage added in v0.34.4

func (*PrintEvent) ProtoMessage()

func (*PrintEvent) Reset added in v0.34.4

func (m *PrintEvent) Reset()

func (*PrintEvent) Size added in v0.34.4

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

func (*PrintEvent) String added in v0.34.4

func (m *PrintEvent) String() string

func (*PrintEvent) Unmarshal added in v0.34.4

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

func (*PrintEvent) XXX_DiscardUnknown added in v0.34.4

func (m *PrintEvent) XXX_DiscardUnknown()

func (*PrintEvent) XXX_Marshal added in v0.34.4

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

func (*PrintEvent) XXX_Merge added in v0.34.4

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

func (*PrintEvent) XXX_MessageName added in v0.34.4

func (*PrintEvent) XXX_MessageName() string

func (*PrintEvent) XXX_Size added in v0.34.4

func (m *PrintEvent) XXX_Size() int

func (*PrintEvent) XXX_Unmarshal added in v0.34.4

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

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,proto3" json:"NameEntry,omitempty"`
	// Permission update performed
	PermArgs             *permission.PermArgs `protobuf:"bytes,4,opt,name=PermArgs,proto3" json:"PermArgs,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

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) MarshalToSizedBuffer added in v0.34.4

func (m *Result) MarshalToSizedBuffer(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_DiscardUnknown added in v0.23.0

func (m *Result) XXX_DiscardUnknown()

func (*Result) XXX_Marshal added in v0.23.0

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

func (*Result) XXX_Merge added in v0.23.0

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

func (*Result) XXX_MessageName

func (*Result) XXX_MessageName() string

func (*Result) XXX_Size added in v0.23.0

func (m *Result) XXX_Size() int

func (*Result) XXX_Unmarshal added in v0.23.0

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

type StreamEvent added in v0.24.0

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

func (*StreamEvent) Descriptor added in v0.24.0

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

func (*StreamEvent) EventType added in v0.24.0

func (ev *StreamEvent) EventType() EventType

func (*StreamEvent) Get added in v0.34.4

func (ev *StreamEvent) Get(key string) (interface{}, bool)

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) MarshalToSizedBuffer added in v0.34.4

func (m *StreamEvent) MarshalToSizedBuffer(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) Unmarshal added in v0.24.0

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

func (*StreamEvent) XXX_DiscardUnknown added in v0.24.0

func (m *StreamEvent) XXX_DiscardUnknown()

func (*StreamEvent) XXX_Marshal added in v0.24.0

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

func (*StreamEvent) XXX_Merge added in v0.24.0

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

func (*StreamEvent) XXX_MessageName added in v0.24.0

func (*StreamEvent) XXX_MessageName() string

func (*StreamEvent) XXX_Size added in v0.24.0

func (m *StreamEvent) XXX_Size() int

func (*StreamEvent) XXX_Unmarshal added in v0.24.0

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

type StreamEvents added in v0.24.0

type StreamEvents struct {
	StreamEvents         []*StreamEvent `protobuf:"bytes,1,rep,name=StreamEvents,proto3" json:"StreamEvents,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

This message exists purely for framing []StreamEvent

func (*StreamEvents) Descriptor added in v0.34.4

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

func (*StreamEvents) GetStreamEvents added in v0.34.4

func (m *StreamEvents) GetStreamEvents() []*StreamEvent

func (*StreamEvents) Marshal added in v0.34.4

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

func (*StreamEvents) MarshalTo added in v0.34.4

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

func (*StreamEvents) MarshalToSizedBuffer added in v0.34.4

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

func (*StreamEvents) ProtoMessage added in v0.34.4

func (*StreamEvents) ProtoMessage()

func (*StreamEvents) Recv added in v0.24.0

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

func (*StreamEvents) Reset added in v0.34.4

func (m *StreamEvents) Reset()

func (*StreamEvents) Size added in v0.34.4

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

func (*StreamEvents) String added in v0.34.4

func (m *StreamEvents) String() string

func (*StreamEvents) Unmarshal added in v0.34.4

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

func (*StreamEvents) XXX_DiscardUnknown added in v0.34.4

func (m *StreamEvents) XXX_DiscardUnknown()

func (*StreamEvents) XXX_Marshal added in v0.34.4

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

func (*StreamEvents) XXX_Merge added in v0.34.4

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

func (*StreamEvents) XXX_MessageName added in v0.34.4

func (*StreamEvents) XXX_MessageName() string

func (*StreamEvents) XXX_Size added in v0.34.4

func (m *StreamEvents) XXX_Size() int

func (*StreamEvents) XXX_Unmarshal added in v0.34.4

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

type TxExecution

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

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) EventType

func (*TxExecution) EventType() EventType

func (*TxExecution) ExceptionalCalls added in v0.23.0

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

func (*TxExecution) Get added in v0.34.4

func (txe *TxExecution) Get(key string) (interface{}, bool)

Tags

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) MarshalToSizedBuffer added in v0.34.4

func (m *TxExecution) MarshalToSizedBuffer(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) Print added in v0.34.4

func (txe *TxExecution) Print(print *PrintEvent) error

func (*TxExecution) ProtoMessage

func (*TxExecution) ProtoMessage()

func (*TxExecution) PushError added in v0.23.0

func (txe *TxExecution) PushError(err error) bool

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() []*StreamEvent

func (*TxExecution) String

func (m *TxExecution) String() string

func (*TxExecution) TaggedEvents

func (txe *TxExecution) TaggedEvents() Events

func (*TxExecution) Unmarshal

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

func (*TxExecution) XXX_DiscardUnknown added in v0.23.0

func (m *TxExecution) XXX_DiscardUnknown()

func (*TxExecution) XXX_Marshal added in v0.23.0

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

func (*TxExecution) XXX_Merge added in v0.23.0

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

func (*TxExecution) XXX_MessageName

func (*TxExecution) XXX_MessageName() string

func (*TxExecution) XXX_Size added in v0.23.0

func (m *TxExecution) XXX_Size() int

func (*TxExecution) XXX_Unmarshal added in v0.23.0

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

type TxExecutionKey added in v0.34.4

type TxExecutionKey struct {
	// The block height
	Height uint64 `protobuf:"varint,1,opt,name=Height,proto3" json:"Height,omitempty"`
	// The offset of the TxExecution in bytes
	Offset               uint64   `protobuf:"varint,2,opt,name=Offset,proto3" json:"Offset,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*TxExecutionKey) Descriptor added in v0.34.4

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

func (*TxExecutionKey) GetHeight added in v0.34.4

func (m *TxExecutionKey) GetHeight() uint64

func (*TxExecutionKey) GetOffset added in v0.34.4

func (m *TxExecutionKey) GetOffset() uint64

func (*TxExecutionKey) Marshal added in v0.34.4

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

func (*TxExecutionKey) MarshalTo added in v0.34.4

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

func (*TxExecutionKey) MarshalToSizedBuffer added in v0.34.4

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

func (*TxExecutionKey) ProtoMessage added in v0.34.4

func (*TxExecutionKey) ProtoMessage()

func (*TxExecutionKey) Reset added in v0.34.4

func (m *TxExecutionKey) Reset()

func (*TxExecutionKey) Size added in v0.34.4

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

func (*TxExecutionKey) String added in v0.34.4

func (m *TxExecutionKey) String() string

func (*TxExecutionKey) Unmarshal added in v0.34.4

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

func (*TxExecutionKey) XXX_DiscardUnknown added in v0.34.4

func (m *TxExecutionKey) XXX_DiscardUnknown()

func (*TxExecutionKey) XXX_Marshal added in v0.34.4

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

func (*TxExecutionKey) XXX_Merge added in v0.34.4

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

func (*TxExecutionKey) XXX_MessageName added in v0.34.4

func (*TxExecutionKey) XXX_MessageName() string

func (*TxExecutionKey) XXX_Size added in v0.34.4

func (m *TxExecutionKey) XXX_Size() int

func (*TxExecutionKey) XXX_Unmarshal added in v0.34.4

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

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 transaction 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,proto3" json:"Origin,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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 (*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) MarshalToSizedBuffer added in v0.34.4

func (m *TxHeader) MarshalToSizedBuffer(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_DiscardUnknown added in v0.24.0

func (m *TxHeader) XXX_DiscardUnknown()

func (*TxHeader) XXX_Marshal added in v0.24.0

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

func (*TxHeader) XXX_Merge added in v0.24.0

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

func (*TxHeader) XXX_MessageName added in v0.24.0

func (*TxHeader) XXX_MessageName() string

func (*TxHeader) XXX_Size added in v0.24.0

func (m *TxHeader) XXX_Size() int

func (*TxHeader) XXX_Unmarshal added in v0.24.0

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

type TxStack added in v0.24.0

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

TxStack is able to consume potentially nested txs

func (*TxStack) Consume added in v0.24.0

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

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) Length added in v0.34.4

func (stack *TxStack) Length() int

func (*TxStack) Peek added in v0.24.0

func (stack *TxStack) Peek() (*TxExecution, error)

func (*TxStack) Pop added in v0.24.0

func (stack *TxStack) Pop() (*TxExecution, error)

func (*TxStack) Push added in v0.24.0

func (stack *TxStack) Push(beginTx *BeginTx)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL