exec

package
v0.24.1 Latest Latest
Warning

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

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

Documentation

Index

Constants

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

Variables

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

Functions

func EventStringAccountCall 

func EventStringAccountCall(addr crypto.Address) string

func EventStringAccountInput 

func EventStringAccountInput(addr crypto.Address) string

func EventStringAccountOutput 

func EventStringAccountOutput(addr crypto.Address) string

func EventStringBlockExecution 

func EventStringBlockExecution(height uint64) string

func EventStringGovernAccount 

func EventStringGovernAccount(addr *crypto.Address) string

func EventStringLogEvent 

func EventStringLogEvent(addr crypto.Address) string

func EventStringTxExecution 

func EventStringTxExecution(txHash []byte) string

func LogNKey 

func LogNKey(topic int) string

func LogNTextKey 

func LogNTextKey(topic int) string

func QueryForBlockExecution 

func QueryForBlockExecution() *query.Builder

func QueryForBlockExecutionFromHeight 

func QueryForBlockExecutionFromHeight(height uint64) *query.Builder

func QueryForTxExecution 

func QueryForTxExecution(txHash []byte) query.Queryable

Types

type BeginBlock added in v0.24.0 

type BeginBlock struct {
	// The height of this block
	Height               uint64        `protobuf:"varint,1,opt,name=Height,proto3" json:"Height,omitempty"`
	Header               *types.Header `protobuf:"bytes,2,opt,name=Header" json:"Header,omitempty"`
	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) Marshal added in v0.24.0 

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

func (*BeginBlock) MarshalTo added in v0.24.0 

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

func (*BeginBlock) ProtoMessage added in v0.24.0 

func (*BeginBlock) ProtoMessage()

func (*BeginBlock) Reset added in v0.24.0 

func (m *BeginBlock) Reset()

func (*BeginBlock) Size added in v0.24.0 

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

func (*BeginBlock) String added in v0.24.0 

func (m *BeginBlock) String() string

func (*BeginBlock) Unmarshal added in v0.24.0 

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

func (*BeginBlock) XXX_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 (dst *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" json:"TxHeader,omitempty"`
	// Result of tx execution
	Result *Result `protobuf:"bytes,2,opt,name=Result" json:"Result,omitempty"`
	// If tx execution was an exception
	Exception            *errors.Exception `protobuf:"bytes,4,opt,name=Exception" json:"Exception,omitempty"`
	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) GetResult added in v0.24.0 

func (m *BeginTx) GetResult() *Result

func (*BeginTx) GetTxHeader added in v0.24.0 

func (m *BeginTx) GetTxHeader() *TxHeader

func (*BeginTx) Marshal added in v0.24.0 

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

func (*BeginTx) MarshalTo added in v0.24.0 

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

func (*BeginTx) ProtoMessage added in v0.24.0 

func (*BeginTx) ProtoMessage()

func (*BeginTx) Reset added in v0.24.0 

func (m *BeginTx) Reset()

func (*BeginTx) Size added in v0.24.0 

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

func (*BeginTx) String added in v0.24.0 

func (m *BeginTx) String() string

func (*BeginTx) Unmarshal added in v0.24.0 

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

func (*BeginTx) XXX_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 (dst *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 (*BlockAccumulator) Consume added in v0.24.0 

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

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

type BlockExecution 

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

func ConsumeBlockExecution added in v0.24.0 

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

func (*BlockExecution) AppendTxs added in v0.24.0 

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

func (*BlockExecution) Descriptor 

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

func (*BlockExecution) Encode 

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

func (*BlockExecution) EncodeHeader added in v0.24.0 

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

func (*BlockExecution) EventType 

func (*BlockExecution) EventType() EventType

func (*BlockExecution) GetHeader added in v0.24.0 

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

func (*BlockExecution) GetHeight 

func (m *BlockExecution) GetHeight() uint64

func (*BlockExecution) GetTxExecutions 

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

func (*BlockExecution) Marshal 

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

func (*BlockExecution) MarshalTo 

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

func (*BlockExecution) ProtoMessage 

func (*BlockExecution) ProtoMessage()

func (*BlockExecution) Reset 

func (m *BlockExecution) Reset()

func (*BlockExecution) Size 

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

func (*BlockExecution) StreamEvents added in v0.24.0 

func (be *BlockExecution) StreamEvents() StreamEvents

Write out TxExecutions parenthetically

func (*BlockExecution) String 

func (m *BlockExecution) String() string

func (*BlockExecution) Tagged 

func (be *BlockExecution) Tagged() *TaggedBlockExecution

func (*BlockExecution) Tx 

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

func (*BlockExecution) Unmarshal 

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

func (*BlockExecution) XXX_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 (dst *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) 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 (dst *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" 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) 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 (dst *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 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) 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 (dst *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) 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 (dst *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" json:"Header,omitempty"`
	Input                *InputEvent         `protobuf:"bytes,2,opt,name=Input" json:"Input,omitempty"`
	Output               *OutputEvent        `protobuf:"bytes,3,opt,name=Output" json:"Output,omitempty"`
	Call                 *CallEvent          `protobuf:"bytes,4,opt,name=Call" json:"Call,omitempty"`
	Log                  *LogEvent           `protobuf:"bytes,5,opt,name=Log" json:"Log,omitempty"`
	GovernAccount        *GovernAccountEvent `protobuf:"bytes,6,opt,name=GovernAccount" json:"GovernAccount,omitempty"`
	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) GetCall 

func (m *Event) GetCall() *CallEvent

func (*Event) GetGovernAccount 

func (m *Event) GetGovernAccount() *GovernAccountEvent

func (*Event) GetHeader 

func (m *Event) GetHeader() *Header

func (*Event) GetInput 

func (m *Event) GetInput() *InputEvent

func (*Event) GetLog 

func (m *Event) GetLog() *LogEvent

func (*Event) GetOutput 

func (m *Event) GetOutput() *OutputEvent

func (*Event) GetValue added in v0.23.0 

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

func (*Event) Marshal 

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

func (*Event) MarshalTo 

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

func (*Event) ProtoMessage 

func (*Event) ProtoMessage()

func (*Event) Reset 

func (m *Event) Reset()

func (*Event) SetValue added in v0.23.0 

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

func (*Event) Size 

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

func (*Event) String 

func (ev *Event) String() string

func (*Event) Tagged 

func (ev *Event) Tagged() *TaggedEvent

func (*Event) Unmarshal 

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

func (*Event) XXX_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 (dst *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 EventStream added in v0.24.0 

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

type EventType 

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

Execution event types

func EventTypeFromString 

func EventTypeFromString(name string) EventType

func (EventType) MarshalText 

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

func (EventType) String 

func (typ EventType) String() string

func (*EventType) UnmarshalText 

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

type GovernAccountEvent 

type GovernAccountEvent struct {
	AccountUpdate        *spec.TemplateAccount `protobuf:"bytes,1,opt,name=AccountUpdate" json:"AccountUpdate,omitempty"`
	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) 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 (dst *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" 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) 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 (dst *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) 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 (dst *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,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) (string, bool)

func (*LogEvent) GetTopic 

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

func (*LogEvent) Keys 

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

func (*LogEvent) Len 

func (log *LogEvent) Len() int

func (*LogEvent) Marshal 

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

func (*LogEvent) MarshalTo 

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

func (*LogEvent) ProtoMessage 

func (*LogEvent) ProtoMessage()

func (*LogEvent) Reset 

func (m *LogEvent) Reset()

func (*LogEvent) Size 

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

func (*LogEvent) String 

func (m *LogEvent) String() string

func (*LogEvent) Unmarshal 

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

func (*LogEvent) XXX_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 (dst *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,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) 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 (dst *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) 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 (dst *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" json:"NameEntry,omitempty"`
	// Permission update performed
	PermArgs             *permission.PermArgs `protobuf:"bytes,4,opt,name=PermArgs" 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) 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 (dst *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" json:"BeginBlock,omitempty"`
	BeginTx              *BeginTx                                    `protobuf:"bytes,2,opt,name=BeginTx" json:"BeginTx,omitempty"`
	Envelope             *github_com_hyperledger_burrow_txs.Envelope `protobuf:"bytes,3,opt,name=Envelope,customtype=github.com/hyperledger/burrow/txs.Envelope" json:"Envelope,omitempty"`
	Event                *Event                                      `protobuf:"bytes,4,opt,name=Event" json:"Event,omitempty"`
	EndTx                *EndTx                                      `protobuf:"bytes,5,opt,name=EndTx" json:"EndTx,omitempty"`
	EndBlock             *EndBlock                                   `protobuf:"bytes,6,opt,name=EndBlock" json:"EndBlock,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                                    `json:"-"`
	XXX_unrecognized     []byte                                      `json:"-"`
	XXX_sizecache        int32                                       `json:"-"`
}

func DecodeStreamEvent added in v0.24.0 

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

func (*StreamEvent) Descriptor added in v0.24.0 

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

func (*StreamEvent) Encode added in v0.24.0 

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

func (*StreamEvent) EventType added in v0.24.0 

func (ev *StreamEvent) EventType() EventType

func (*StreamEvent) GetBeginBlock added in v0.24.0 

func (m *StreamEvent) GetBeginBlock() *BeginBlock

func (*StreamEvent) GetBeginTx added in v0.24.0 

func (m *StreamEvent) GetBeginTx() *BeginTx

func (*StreamEvent) GetEndBlock added in v0.24.0 

func (m *StreamEvent) GetEndBlock() *EndBlock

func (*StreamEvent) GetEndTx added in v0.24.0 

func (m *StreamEvent) GetEndTx() *EndTx

func (*StreamEvent) GetEvent added in v0.24.0 

func (m *StreamEvent) GetEvent() *Event

func (*StreamEvent) GetValue added in v0.24.0 

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

func (*StreamEvent) Marshal added in v0.24.0 

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

func (*StreamEvent) MarshalTo added in v0.24.0 

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

func (*StreamEvent) ProtoMessage added in v0.24.0 

func (*StreamEvent) ProtoMessage()

func (*StreamEvent) Reset added in v0.24.0 

func (m *StreamEvent) Reset()

func (*StreamEvent) SetValue added in v0.24.0 

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

func (*StreamEvent) Size added in v0.24.0 

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

func (*StreamEvent) String added in v0.24.0 

func (m *StreamEvent) String() string

func (*StreamEvent) Tagged added in v0.24.0 

func (ev *StreamEvent) Tagged() *TaggedBlockEvent

func (*StreamEvent) Unmarshal added in v0.24.0 

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

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

func (*StreamEvents) Recv added in v0.24.0 

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

type StreamKey added in v0.24.0 

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

A key to a stream event

func (*StreamKey) Descriptor added in v0.24.0 

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

func (*StreamKey) GetHeight added in v0.24.0 

func (m *StreamKey) GetHeight() uint64

func (*StreamKey) GetIndex added in v0.24.0 

func (m *StreamKey) GetIndex() uint64

func (*StreamKey) Marshal added in v0.24.0 

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

func (*StreamKey) MarshalTo added in v0.24.0 

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

func (*StreamKey) ProtoMessage added in v0.24.0 

func (*StreamKey) ProtoMessage()

func (*StreamKey) Reset added in v0.24.0 

func (m *StreamKey) Reset()

func (*StreamKey) Size added in v0.24.0 

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

func (*StreamKey) String added in v0.24.0 

func (m *StreamKey) String() string

func (*StreamKey) Unmarshal added in v0.24.0 

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

func (*StreamKey) XXX_DiscardUnknown added in v0.24.0 

func (m *StreamKey) XXX_DiscardUnknown()

func (*StreamKey) XXX_Marshal added in v0.24.0 

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

func (*StreamKey) XXX_Merge added in v0.24.0 

func (dst *StreamKey) XXX_Merge(src proto.Message)

func (*StreamKey) XXX_MessageName added in v0.24.0 

func (*StreamKey) XXX_MessageName() string

func (*StreamKey) XXX_Size added in v0.24.0 

func (m *StreamKey) XXX_Size() int

func (*StreamKey) XXX_Unmarshal added in v0.24.0 

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

type TaggedBlockEvent added in v0.24.0 

type TaggedBlockEvent struct {
	query.Tagged
	*StreamEvent
}

type TaggedBlockExecution 

type TaggedBlockExecution struct {
	query.Tagged
	*BlockExecution
}

Tags

type TaggedEvent 

type TaggedEvent struct {
	query.Tagged
	*Event
}

Tags

type TaggedEvents 

type TaggedEvents []*TaggedEvent

func (TaggedEvents) Filter 

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

type TaggedTxExecution 

type TaggedTxExecution struct {
	query.Tagged
	*TxExecution
}

Tags

type TxExecution 

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

func DecodeTxExecution 

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

func NewTxExecution 

func NewTxExecution(txEnv *txs.Envelope) *TxExecution

func (*TxExecution) Append 

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

func (*TxExecution) Call 

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

func (*TxExecution) CallError added in v0.23.0 

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

func (*TxExecution) Descriptor 

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

func (*TxExecution) Encode 

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

func (*TxExecution) EventType 

func (*TxExecution) EventType() EventType

func (*TxExecution) ExceptionalCalls added in v0.23.0 

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

func (*TxExecution) GetEvents 

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

func (*TxExecution) GetException 

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

func (*TxExecution) GetReceipt 

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

func (*TxExecution) GetResult 

func (m *TxExecution) GetResult() *Result

func (*TxExecution) GetTxExecutions added in v0.24.0 

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

func (*TxExecution) GetTxHash added in v0.24.0 

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

func (*TxExecution) GovernAccount 

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

func (*TxExecution) Header 

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

func (*TxExecution) Input 

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

Emit events

func (*TxExecution) Log 

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

func (*TxExecution) Marshal 

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

func (*TxExecution) MarshalTo 

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

func (*TxExecution) Name 

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

func (*TxExecution) Output 

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

func (*TxExecution) Permission 

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

func (*TxExecution) ProtoMessage 

func (*TxExecution) ProtoMessage()

func (*TxExecution) PushError added in v0.23.0 

func (txe *TxExecution) PushError(err error)

func (*TxExecution) Reset 

func (m *TxExecution) Reset()

func (*TxExecution) Return 

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

Set result

func (*TxExecution) Size 

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

func (*TxExecution) StreamEvents added in v0.24.0 

func (txe *TxExecution) StreamEvents() StreamEvents

func (*TxExecution) String 

func (m *TxExecution) String() string

func (*TxExecution) Tagged 

func (txe *TxExecution) Tagged() *TaggedTxExecution

func (*TxExecution) TaggedEvents 

func (txe *TxExecution) TaggedEvents() TaggedEvents

func (*TxExecution) Trace added in v0.23.0 

func (txe *TxExecution) Trace() string

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 (dst *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 TxHeader added in v0.24.0 

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

TxStack is able to consume potentially nested txs

func (*TxStack) Consume added in v0.24.0 

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

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

func (TxStack) Peek added in v0.24.0 

func (stack TxStack) Peek() *TxExecution

func (*TxStack) Pop added in v0.24.0 

func (stack *TxStack) Pop() *TxExecution

func (*TxStack) Push added in v0.24.0 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.