exec

package
v0.30.5 Latest Latest
Warning

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

 Go to latest Published: Jul 9, 2020 License: Apache-2.0 Imports: 25 Imported by: 38

Documentation

Index

Constants

View Source 
const (
	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.29.0 

func NewLogFreeEventSink(eventSink EventSink) *logFreeEventSink

func NewNoopEventSink added in v0.29.0 

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

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.30.5 

func (m *BeginBlock) GetNumTxs() uint64

func (*BeginBlock) GetPredecessorHeight added in v0.30.5 

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.30.0 

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.30.5 

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.30.0 

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.30.5 

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.30.5 

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.28.0 

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.30.5 

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.30.0 

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"`
	Value                uint64                                        `protobuf:"varint,4,opt,name=Value,proto3" json:"Value,omitempty"`
	Gas                  uint64                                        `protobuf:"varint,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() 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) MarshalToSizedBuffer added in v0.30.0 

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.30.0 

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.30.5 

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 (ContinuityOpt) Allows added in v0.30.5 

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.30.0 

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.30.0 

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"`
	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.28.0 

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) 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.30.0 

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.29.0 

type EventSink interface {
	Call(call *CallEvent, exception *errors.Exception) error
	Log(log *LogEvent) 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
)

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.28.0 

type Events []*Event

func (*Events) Append added in v0.29.0 

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

func (*Events) Call added in v0.29.0 

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

func (Events) CallTrace added in v0.29.0 

func (evs Events) CallTrace() string

func (Events) ExceptionalCalls added in v0.29.0 

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

func (Events) Filter added in v0.28.0 

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

func (*Events) Log added in v0.29.0 

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

func (Events) NestedCallErrors added in v0.29.0 

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

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.30.0 

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

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.30.0 

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.30.0 

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) SolidityEventID added in v0.28.0 

func (log *LogEvent) SolidityEventID() abi.EventID

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.30.0 

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.30.0 

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 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.30.0 

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.28.0 

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.30.0 

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.28.0 

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

func (*StreamEvents) GetStreamEvents added in v0.28.0 

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

func (*StreamEvents) Marshal added in v0.28.0 

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

func (*StreamEvents) MarshalTo added in v0.28.0 

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

func (*StreamEvents) MarshalToSizedBuffer added in v0.30.0 

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

func (*StreamEvents) ProtoMessage added in v0.28.0 

func (*StreamEvents) ProtoMessage()

func (*StreamEvents) Recv added in v0.24.0 

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

func (*StreamEvents) Reset added in v0.28.0 

func (m *StreamEvents) Reset()

func (*StreamEvents) Size added in v0.28.0 

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

func (*StreamEvents) String added in v0.28.0 

func (m *StreamEvents) String() string

func (*StreamEvents) Unmarshal added in v0.28.0 

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

func (*StreamEvents) XXX_DiscardUnknown added in v0.28.0 

func (m *StreamEvents) XXX_DiscardUnknown()

func (*StreamEvents) XXX_Marshal added in v0.28.0 

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

func (*StreamEvents) XXX_Merge added in v0.28.0 

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

func (*StreamEvents) XXX_MessageName added in v0.28.0 

func (*StreamEvents) XXX_MessageName() string

func (*StreamEvents) XXX_Size added in v0.28.0 

func (m *StreamEvents) XXX_Size() int

func (*StreamEvents) XXX_Unmarshal added in v0.28.0 

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.28.0 

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.30.0 

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) 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.26.0 

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.26.0 

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

func (*TxExecutionKey) GetHeight added in v0.26.0 

func (m *TxExecutionKey) GetHeight() uint64

func (*TxExecutionKey) GetOffset added in v0.26.0 

func (m *TxExecutionKey) GetOffset() uint64

func (*TxExecutionKey) Marshal added in v0.26.0 

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

func (*TxExecutionKey) MarshalTo added in v0.26.0 

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

func (*TxExecutionKey) MarshalToSizedBuffer added in v0.30.0 

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

func (*TxExecutionKey) ProtoMessage added in v0.26.0 

func (*TxExecutionKey) ProtoMessage()

func (*TxExecutionKey) Reset added in v0.26.0 

func (m *TxExecutionKey) Reset()

func (*TxExecutionKey) Size added in v0.26.0 

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

func (*TxExecutionKey) String added in v0.26.0 

func (m *TxExecutionKey) String() string

func (*TxExecutionKey) Unmarshal added in v0.26.0 

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

func (*TxExecutionKey) XXX_DiscardUnknown added in v0.26.0 

func (m *TxExecutionKey) XXX_DiscardUnknown()

func (*TxExecutionKey) XXX_Marshal added in v0.26.0 

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

func (*TxExecutionKey) XXX_Merge added in v0.26.0 

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

func (*TxExecutionKey) XXX_MessageName added in v0.26.0 

func (*TxExecutionKey) XXX_MessageName() string

func (*TxExecutionKey) XXX_Size added in v0.26.0 

func (m *TxExecutionKey) XXX_Size() int

func (*TxExecutionKey) XXX_Unmarshal added in v0.26.0 

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

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.30.5 

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)

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.