burrow: github.com/hyperledger/burrow/execution/exec Index | Files

package exec

import "github.com/hyperledger/burrow/execution/exec"

Index

Package Files

block_execution.go call_event.go codec.go event.go event_sink.go events.go exec.pb.go govern_account_event.go header.go log_event.go stream_event.go tx_execution.go

Constants

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

Variables

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

func EventStringAccountCall Uses

func EventStringAccountCall(addr crypto.Address) string

func EventStringAccountInput Uses

func EventStringAccountInput(addr crypto.Address) string

func EventStringAccountOutput Uses

func EventStringAccountOutput(addr crypto.Address) string

func EventStringBlockExecution Uses

func EventStringBlockExecution(height uint64) string

func EventStringGovernAccount Uses

func EventStringGovernAccount(addr *crypto.Address) string

func EventStringLogEvent Uses

func EventStringLogEvent(addr crypto.Address) string

func EventStringTxExecution Uses

func EventStringTxExecution(txHash []byte) string

func LogNKey Uses

func LogNKey(topic int) string

func LogNTextKey Uses

func LogNTextKey(topic int) string

func NewLogFreeEventSink Uses

func NewLogFreeEventSink(eventSink EventSink) *logFreeEventSink

func NewNoopEventSink Uses

func NewNoopEventSink() *noopEventSink

func QueryForBlockExecution Uses

func QueryForBlockExecution() *query.Builder

func QueryForBlockExecutionFromHeight Uses

func QueryForBlockExecutionFromHeight(height uint64) *query.Builder

func QueryForTxExecution Uses

func QueryForTxExecution(txHash []byte) query.Queryable

type BeginBlock Uses

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 Uses

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

func (*BeginBlock) GetHeader Uses

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

func (*BeginBlock) GetHeight Uses

func (m *BeginBlock) GetHeight() uint64

func (*BeginBlock) GetNumTxs Uses

func (m *BeginBlock) GetNumTxs() uint64

func (*BeginBlock) GetPredecessorHeight Uses

func (m *BeginBlock) GetPredecessorHeight() uint64

func (*BeginBlock) Marshal Uses

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

func (*BeginBlock) MarshalTo Uses

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

func (*BeginBlock) MarshalToSizedBuffer Uses

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

func (*BeginBlock) ProtoMessage Uses

func (*BeginBlock) ProtoMessage()

func (*BeginBlock) Reset Uses

func (m *BeginBlock) Reset()

func (*BeginBlock) Size Uses

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

func (*BeginBlock) String Uses

func (m *BeginBlock) String() string

func (*BeginBlock) Unmarshal Uses

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

func (*BeginBlock) XXX_DiscardUnknown Uses

func (m *BeginBlock) XXX_DiscardUnknown()

func (*BeginBlock) XXX_Marshal Uses

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

func (*BeginBlock) XXX_Merge Uses

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

func (*BeginBlock) XXX_MessageName Uses

func (*BeginBlock) XXX_MessageName() string

func (*BeginBlock) XXX_Size Uses

func (m *BeginBlock) XXX_Size() int

func (*BeginBlock) XXX_Unmarshal Uses

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

type BeginTx Uses

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 Uses

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

func (*BeginTx) GetException Uses

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

func (*BeginTx) GetNumEvents Uses

func (m *BeginTx) GetNumEvents() uint64

func (*BeginTx) GetResult Uses

func (m *BeginTx) GetResult() *Result

func (*BeginTx) GetTxHeader Uses

func (m *BeginTx) GetTxHeader() *TxHeader

func (*BeginTx) Marshal Uses

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

func (*BeginTx) MarshalTo Uses

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

func (*BeginTx) MarshalToSizedBuffer Uses

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

func (*BeginTx) ProtoMessage Uses

func (*BeginTx) ProtoMessage()

func (*BeginTx) Reset Uses

func (m *BeginTx) Reset()

func (*BeginTx) Size Uses

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

func (*BeginTx) String Uses

func (m *BeginTx) String() string

func (*BeginTx) Unmarshal Uses

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

func (*BeginTx) XXX_DiscardUnknown Uses

func (m *BeginTx) XXX_DiscardUnknown()

func (*BeginTx) XXX_Marshal Uses

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

func (*BeginTx) XXX_Merge Uses

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

func (*BeginTx) XXX_MessageName Uses

func (*BeginTx) XXX_MessageName() string

func (*BeginTx) XXX_Size Uses

func (m *BeginTx) XXX_Size() int

func (*BeginTx) XXX_Unmarshal Uses

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

type BlockAccumulator Uses

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

func NewBlockAccumulator Uses

func NewBlockAccumulator(continuityOptions ...ContinuityOpt) *BlockAccumulator

func (*BlockAccumulator) Consume Uses

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 Uses

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

type BlockExecution Uses

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 Uses

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

func (*BlockExecution) Descriptor Uses

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

func (*BlockExecution) EventType Uses

func (*BlockExecution) EventType() EventType

func (*BlockExecution) Get Uses

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

func (*BlockExecution) GetHeader Uses

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

func (*BlockExecution) GetHeight Uses

func (m *BlockExecution) GetHeight() uint64

func (*BlockExecution) GetPredecessorHeight Uses

func (m *BlockExecution) GetPredecessorHeight() uint64

func (*BlockExecution) GetTxExecutions Uses

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

func (*BlockExecution) Marshal Uses

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

func (*BlockExecution) MarshalTo Uses

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

func (*BlockExecution) MarshalToSizedBuffer Uses

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

func (*BlockExecution) ProtoMessage Uses

func (*BlockExecution) ProtoMessage()

func (*BlockExecution) Reset Uses

func (m *BlockExecution) Reset()

func (*BlockExecution) Size Uses

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

func (*BlockExecution) StreamEvents Uses

func (be *BlockExecution) StreamEvents() []*StreamEvent

Write out TxExecutions parenthetically

func (*BlockExecution) String Uses

func (m *BlockExecution) String() string

func (*BlockExecution) Tx Uses

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

func (*BlockExecution) Unmarshal Uses

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

func (*BlockExecution) XXX_DiscardUnknown Uses

func (m *BlockExecution) XXX_DiscardUnknown()

func (*BlockExecution) XXX_Marshal Uses

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

func (*BlockExecution) XXX_Merge Uses

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

func (*BlockExecution) XXX_MessageName Uses

func (*BlockExecution) XXX_MessageName() string

func (*BlockExecution) XXX_Size Uses

func (m *BlockExecution) XXX_Size() int

func (*BlockExecution) XXX_Unmarshal Uses

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

type CallData Uses

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 Uses

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

func (*CallData) GetGas Uses

func (m *CallData) GetGas() uint64

func (*CallData) GetValue Uses

func (m *CallData) GetValue() uint64

func (*CallData) Marshal Uses

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

func (*CallData) MarshalTo Uses

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

func (*CallData) MarshalToSizedBuffer Uses

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

func (*CallData) ProtoMessage Uses

func (*CallData) ProtoMessage()

func (*CallData) Reset Uses

func (m *CallData) Reset()

func (*CallData) Size Uses

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

func (*CallData) String Uses

func (m *CallData) String() string

func (*CallData) Unmarshal Uses

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

func (*CallData) XXX_DiscardUnknown Uses

func (m *CallData) XXX_DiscardUnknown()

func (*CallData) XXX_Marshal Uses

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

func (*CallData) XXX_Merge Uses

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

func (*CallData) XXX_MessageName Uses

func (*CallData) XXX_MessageName() string

func (*CallData) XXX_Size Uses

func (m *CallData) XXX_Size() int

func (*CallData) XXX_Unmarshal Uses

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

type CallEvent Uses

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 Uses

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

func (*CallEvent) GetCallData Uses

func (m *CallEvent) GetCallData() *CallData

func (*CallEvent) GetCallType Uses

func (m *CallEvent) GetCallType() CallType

func (*CallEvent) GetStackDepth Uses

func (m *CallEvent) GetStackDepth() uint64

func (*CallEvent) Marshal Uses

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

func (*CallEvent) MarshalTo Uses

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

func (*CallEvent) MarshalToSizedBuffer Uses

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

func (*CallEvent) ProtoMessage Uses

func (*CallEvent) ProtoMessage()

func (*CallEvent) Reset Uses

func (m *CallEvent) Reset()

func (*CallEvent) Size Uses

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

func (*CallEvent) String Uses

func (m *CallEvent) String() string

func (*CallEvent) Unmarshal Uses

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

func (*CallEvent) XXX_DiscardUnknown Uses

func (m *CallEvent) XXX_DiscardUnknown()

func (*CallEvent) XXX_Marshal Uses

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

func (*CallEvent) XXX_Merge Uses

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

func (*CallEvent) XXX_MessageName Uses

func (*CallEvent) XXX_MessageName() string

func (*CallEvent) XXX_Size Uses

func (m *CallEvent) XXX_Size() int

func (*CallEvent) XXX_Unmarshal Uses

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

type CallType Uses

type CallType uint32

func CallTypeFromString Uses

func CallTypeFromString(name string) CallType

func (CallType) MarshalText Uses

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

func (CallType) String Uses

func (ct CallType) String() string

func (*CallType) UnmarshalText Uses

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

type ContinuityOpt Uses

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 Uses

func (so ContinuityOpt) Allows(opt ContinuityOpt) bool

type EndBlock Uses

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 Uses

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

func (*EndBlock) GetHeight Uses

func (m *EndBlock) GetHeight() uint64

func (*EndBlock) Marshal Uses

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

func (*EndBlock) MarshalTo Uses

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

func (*EndBlock) MarshalToSizedBuffer Uses

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

func (*EndBlock) ProtoMessage Uses

func (*EndBlock) ProtoMessage()

func (*EndBlock) Reset Uses

func (m *EndBlock) Reset()

func (*EndBlock) Size Uses

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

func (*EndBlock) String Uses

func (m *EndBlock) String() string

func (*EndBlock) Unmarshal Uses

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

func (*EndBlock) XXX_DiscardUnknown Uses

func (m *EndBlock) XXX_DiscardUnknown()

func (*EndBlock) XXX_Marshal Uses

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

func (*EndBlock) XXX_Merge Uses

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

func (*EndBlock) XXX_MessageName Uses

func (*EndBlock) XXX_MessageName() string

func (*EndBlock) XXX_Size Uses

func (m *EndBlock) XXX_Size() int

func (*EndBlock) XXX_Unmarshal Uses

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

type EndTx Uses

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 Uses

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

func (*EndTx) Marshal Uses

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

func (*EndTx) MarshalTo Uses

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

func (*EndTx) MarshalToSizedBuffer Uses

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

func (*EndTx) ProtoMessage Uses

func (*EndTx) ProtoMessage()

func (*EndTx) Reset Uses

func (m *EndTx) Reset()

func (*EndTx) Size Uses

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

func (*EndTx) String Uses

func (m *EndTx) String() string

func (*EndTx) Unmarshal Uses

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

func (*EndTx) XXX_DiscardUnknown Uses

func (m *EndTx) XXX_DiscardUnknown()

func (*EndTx) XXX_Marshal Uses

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

func (*EndTx) XXX_Merge Uses

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

func (*EndTx) XXX_MessageName Uses

func (*EndTx) XXX_MessageName() string

func (*EndTx) XXX_Size Uses

func (m *EndTx) XXX_Size() int

func (*EndTx) XXX_Unmarshal Uses

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

type Event Uses

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 Uses

func (ev *Event) Body() string

func (*Event) Descriptor Uses

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

func (*Event) EventType Uses

func (ev *Event) EventType() EventType

func (*Event) Get Uses

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

func (*Event) GetCall Uses

func (m *Event) GetCall() *CallEvent

func (*Event) GetGovernAccount Uses

func (m *Event) GetGovernAccount() *GovernAccountEvent

func (*Event) GetHeader Uses

func (m *Event) GetHeader() *Header

func (*Event) GetInput Uses

func (m *Event) GetInput() *InputEvent

func (*Event) GetLog Uses

func (m *Event) GetLog() *LogEvent

func (*Event) GetOutput Uses

func (m *Event) GetOutput() *OutputEvent

func (*Event) GetValue Uses

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

func (*Event) Marshal Uses

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

func (*Event) MarshalTo Uses

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

func (*Event) MarshalToSizedBuffer Uses

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

func (*Event) ProtoMessage Uses

func (*Event) ProtoMessage()

func (*Event) Reset Uses

func (m *Event) Reset()

func (*Event) SetValue Uses

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

func (*Event) Size Uses

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

func (*Event) String Uses

func (ev *Event) String() string

func (*Event) Unmarshal Uses

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

func (*Event) XXX_DiscardUnknown Uses

func (m *Event) XXX_DiscardUnknown()

func (*Event) XXX_Marshal Uses

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

func (*Event) XXX_Merge Uses

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

func (*Event) XXX_MessageName Uses

func (*Event) XXX_MessageName() string

func (*Event) XXX_Size Uses

func (m *Event) XXX_Size() int

func (*Event) XXX_Unmarshal Uses

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

type EventSink Uses

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

type EventStream Uses

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

type EventType Uses

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

Execution event types

func EventTypeFromString Uses

func EventTypeFromString(name string) EventType

func (EventType) MarshalText Uses

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

func (EventType) String Uses

func (typ EventType) String() string

func (*EventType) UnmarshalText Uses

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

type Events Uses

type Events []*Event

func (*Events) Append Uses

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

func (*Events) Call Uses

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

func (Events) CallTrace Uses

func (evs Events) CallTrace() string

func (Events) ExceptionalCalls Uses

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

func (Events) Filter Uses

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

func (*Events) Log Uses

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

func (Events) NestedCallErrors Uses

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

type GovernAccountEvent Uses

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 Uses

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

func (*GovernAccountEvent) GetAccountUpdate Uses

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

func (*GovernAccountEvent) Marshal Uses

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

func (*GovernAccountEvent) MarshalTo Uses

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

func (*GovernAccountEvent) MarshalToSizedBuffer Uses

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

func (*GovernAccountEvent) ProtoMessage Uses

func (*GovernAccountEvent) ProtoMessage()

func (*GovernAccountEvent) Reset Uses

func (m *GovernAccountEvent) Reset()

func (*GovernAccountEvent) Size Uses

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

func (*GovernAccountEvent) String Uses

func (m *GovernAccountEvent) String() string

func (*GovernAccountEvent) Unmarshal Uses

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

func (*GovernAccountEvent) XXX_DiscardUnknown Uses

func (m *GovernAccountEvent) XXX_DiscardUnknown()

func (*GovernAccountEvent) XXX_Marshal Uses

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

func (*GovernAccountEvent) XXX_Merge Uses

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

func (*GovernAccountEvent) XXX_MessageName Uses

func (*GovernAccountEvent) XXX_MessageName() string

func (*GovernAccountEvent) XXX_Size Uses

func (m *GovernAccountEvent) XXX_Size() int

func (*GovernAccountEvent) XXX_Unmarshal Uses

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 Uses

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

func (*Header) GetEventID Uses

func (m *Header) GetEventID() string

func (*Header) GetEventType Uses

func (m *Header) GetEventType() EventType

func (*Header) GetException Uses

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

func (*Header) GetHeight Uses

func (m *Header) GetHeight() uint64

func (*Header) GetIndex Uses

func (m *Header) GetIndex() uint64

func (*Header) GetTxType Uses

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

func (*Header) Marshal Uses

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

func (*Header) MarshalTo Uses

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

func (*Header) MarshalToSizedBuffer Uses

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

func (*Header) ProtoMessage Uses

func (*Header) ProtoMessage()

func (*Header) Reset Uses

func (m *Header) Reset()

func (*Header) Size Uses

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

func (*Header) String Uses

func (h *Header) String() string

func (*Header) Unmarshal Uses

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

func (*Header) XXX_DiscardUnknown Uses

func (m *Header) XXX_DiscardUnknown()

func (*Header) XXX_Marshal Uses

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

func (*Header) XXX_Merge Uses

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

func (*Header) XXX_MessageName Uses

func (*Header) XXX_MessageName() string

func (*Header) XXX_Size Uses

func (m *Header) XXX_Size() int

func (*Header) XXX_Unmarshal Uses

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

type InputEvent Uses

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 Uses

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

func (*InputEvent) Marshal Uses

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

func (*InputEvent) MarshalTo Uses

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

func (*InputEvent) MarshalToSizedBuffer Uses

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

func (*InputEvent) ProtoMessage Uses

func (*InputEvent) ProtoMessage()

func (*InputEvent) Reset Uses

func (m *InputEvent) Reset()

func (*InputEvent) Size Uses

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

func (*InputEvent) String Uses

func (m *InputEvent) String() string

func (*InputEvent) Unmarshal Uses

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

func (*InputEvent) XXX_DiscardUnknown Uses

func (m *InputEvent) XXX_DiscardUnknown()

func (*InputEvent) XXX_Marshal Uses

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

func (*InputEvent) XXX_Merge Uses

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

func (*InputEvent) XXX_MessageName Uses

func (*InputEvent) XXX_MessageName() string

func (*InputEvent) XXX_Size Uses

func (m *InputEvent) XXX_Size() int

func (*InputEvent) XXX_Unmarshal Uses

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

type LogEvent Uses

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 Uses

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

func (*LogEvent) Get Uses

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

func (*LogEvent) GetTopic Uses

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

func (*LogEvent) Marshal Uses

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

func (*LogEvent) MarshalTo Uses

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

func (*LogEvent) MarshalToSizedBuffer Uses

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

func (*LogEvent) ProtoMessage Uses

func (*LogEvent) ProtoMessage()

func (*LogEvent) Reset Uses

func (m *LogEvent) Reset()

func (*LogEvent) Size Uses

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

func (*LogEvent) SolidityEventID Uses

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

func (*LogEvent) String Uses

func (m *LogEvent) String() string

func (*LogEvent) Unmarshal Uses

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

func (*LogEvent) XXX_DiscardUnknown Uses

func (m *LogEvent) XXX_DiscardUnknown()

func (*LogEvent) XXX_Marshal Uses

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

func (*LogEvent) XXX_Merge Uses

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

func (*LogEvent) XXX_MessageName Uses

func (*LogEvent) XXX_MessageName() string

func (*LogEvent) XXX_Size Uses

func (m *LogEvent) XXX_Size() int

func (*LogEvent) XXX_Unmarshal Uses

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

type Origin Uses

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 Uses

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

func (*Origin) GetChainID Uses

func (m *Origin) GetChainID() string

func (*Origin) GetHeight Uses

func (m *Origin) GetHeight() uint64

func (*Origin) GetIndex Uses

func (m *Origin) GetIndex() uint64

func (*Origin) GetTime Uses

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

func (*Origin) Marshal Uses

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

func (*Origin) MarshalTo Uses

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

func (*Origin) MarshalToSizedBuffer Uses

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

func (*Origin) ProtoMessage Uses

func (*Origin) ProtoMessage()

func (*Origin) Reset Uses

func (m *Origin) Reset()

func (*Origin) Size Uses

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

func (*Origin) String Uses

func (m *Origin) String() string

func (*Origin) Unmarshal Uses

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

func (*Origin) XXX_DiscardUnknown Uses

func (m *Origin) XXX_DiscardUnknown()

func (*Origin) XXX_Marshal Uses

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

func (*Origin) XXX_Merge Uses

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

func (*Origin) XXX_MessageName Uses

func (*Origin) XXX_MessageName() string

func (*Origin) XXX_Size Uses

func (m *Origin) XXX_Size() int

func (*Origin) XXX_Unmarshal Uses

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

type OutputEvent Uses

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 Uses

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

func (*OutputEvent) Marshal Uses

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

func (*OutputEvent) MarshalTo Uses

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

func (*OutputEvent) MarshalToSizedBuffer Uses

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

func (*OutputEvent) ProtoMessage Uses

func (*OutputEvent) ProtoMessage()

func (*OutputEvent) Reset Uses

func (m *OutputEvent) Reset()

func (*OutputEvent) Size Uses

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

func (*OutputEvent) String Uses

func (m *OutputEvent) String() string

func (*OutputEvent) Unmarshal Uses

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

func (*OutputEvent) XXX_DiscardUnknown Uses

func (m *OutputEvent) XXX_DiscardUnknown()

func (*OutputEvent) XXX_Marshal Uses

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

func (*OutputEvent) XXX_Merge Uses

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

func (*OutputEvent) XXX_MessageName Uses

func (*OutputEvent) XXX_MessageName() string

func (*OutputEvent) XXX_Size Uses

func (m *OutputEvent) XXX_Size() int

func (*OutputEvent) XXX_Unmarshal Uses

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

type Result Uses

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 Uses

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

func (*Result) GetGasUsed Uses

func (m *Result) GetGasUsed() uint64

func (*Result) GetNameEntry Uses

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

func (*Result) GetPermArgs Uses

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

func (*Result) GetReturn Uses

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

func (*Result) Marshal Uses

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

func (*Result) MarshalTo Uses

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

func (*Result) MarshalToSizedBuffer Uses

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

func (*Result) ProtoMessage Uses

func (*Result) ProtoMessage()

func (*Result) Reset Uses

func (m *Result) Reset()

func (*Result) Size Uses

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

func (*Result) String Uses

func (m *Result) String() string

func (*Result) Unmarshal Uses

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

func (*Result) XXX_DiscardUnknown Uses

func (m *Result) XXX_DiscardUnknown()

func (*Result) XXX_Marshal Uses

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

func (*Result) XXX_Merge Uses

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

func (*Result) XXX_MessageName Uses

func (*Result) XXX_MessageName() string

func (*Result) XXX_Size Uses

func (m *Result) XXX_Size() int

func (*Result) XXX_Unmarshal Uses

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

type StreamEvent Uses

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 Uses

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

func (*StreamEvent) EventType Uses

func (ev *StreamEvent) EventType() EventType

func (*StreamEvent) Get Uses

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

func (*StreamEvent) GetBeginBlock Uses

func (m *StreamEvent) GetBeginBlock() *BeginBlock

func (*StreamEvent) GetBeginTx Uses

func (m *StreamEvent) GetBeginTx() *BeginTx

func (*StreamEvent) GetEndBlock Uses

func (m *StreamEvent) GetEndBlock() *EndBlock

func (*StreamEvent) GetEndTx Uses

func (m *StreamEvent) GetEndTx() *EndTx

func (*StreamEvent) GetEvent Uses

func (m *StreamEvent) GetEvent() *Event

func (*StreamEvent) GetValue Uses

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

func (*StreamEvent) Marshal Uses

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

func (*StreamEvent) MarshalTo Uses

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

func (*StreamEvent) MarshalToSizedBuffer Uses

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

func (*StreamEvent) ProtoMessage Uses

func (*StreamEvent) ProtoMessage()

func (*StreamEvent) Reset Uses

func (m *StreamEvent) Reset()

func (*StreamEvent) SetValue Uses

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

func (*StreamEvent) Size Uses

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

func (*StreamEvent) String Uses

func (m *StreamEvent) String() string

func (*StreamEvent) Unmarshal Uses

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

func (*StreamEvent) XXX_DiscardUnknown Uses

func (m *StreamEvent) XXX_DiscardUnknown()

func (*StreamEvent) XXX_Marshal Uses

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

func (*StreamEvent) XXX_Merge Uses

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

func (*StreamEvent) XXX_MessageName Uses

func (*StreamEvent) XXX_MessageName() string

func (*StreamEvent) XXX_Size Uses

func (m *StreamEvent) XXX_Size() int

func (*StreamEvent) XXX_Unmarshal Uses

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

type StreamEvents Uses

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 Uses

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

func (*StreamEvents) GetStreamEvents Uses

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

func (*StreamEvents) Marshal Uses

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

func (*StreamEvents) MarshalTo Uses

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

func (*StreamEvents) MarshalToSizedBuffer Uses

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

func (*StreamEvents) ProtoMessage Uses

func (*StreamEvents) ProtoMessage()

func (*StreamEvents) Recv Uses

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

func (*StreamEvents) Reset Uses

func (m *StreamEvents) Reset()

func (*StreamEvents) Size Uses

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

func (*StreamEvents) String Uses

func (m *StreamEvents) String() string

func (*StreamEvents) Unmarshal Uses

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

func (*StreamEvents) XXX_DiscardUnknown Uses

func (m *StreamEvents) XXX_DiscardUnknown()

func (*StreamEvents) XXX_Marshal Uses

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

func (*StreamEvents) XXX_Merge Uses

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

func (*StreamEvents) XXX_MessageName Uses

func (*StreamEvents) XXX_MessageName() string

func (*StreamEvents) XXX_Size Uses

func (m *StreamEvents) XXX_Size() int

func (*StreamEvents) XXX_Unmarshal Uses

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

type TxExecution Uses

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 Uses

func NewTxExecution(txEnv *txs.Envelope) *TxExecution

func (*TxExecution) Append Uses

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

func (*TxExecution) Call Uses

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

func (*TxExecution) CallError Uses

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

func (*TxExecution) CallTrace Uses

func (txe *TxExecution) CallTrace() string

func (*TxExecution) Descriptor Uses

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

func (*TxExecution) EventType Uses

func (*TxExecution) EventType() EventType

func (*TxExecution) ExceptionalCalls Uses

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

func (*TxExecution) Get Uses

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

Tags

func (*TxExecution) GetEvents Uses

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

func (*TxExecution) GetException Uses

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

func (*TxExecution) GetReceipt Uses

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

func (*TxExecution) GetResult Uses

func (m *TxExecution) GetResult() *Result

func (*TxExecution) GetTxExecutions Uses

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

func (*TxExecution) GetTxHash Uses

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

func (*TxExecution) GovernAccount Uses

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

func (*TxExecution) Header Uses

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

func (*TxExecution) Input Uses

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

Emit events

func (*TxExecution) Log Uses

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

func (*TxExecution) Marshal Uses

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

func (*TxExecution) MarshalTo Uses

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

func (*TxExecution) MarshalToSizedBuffer Uses

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

func (*TxExecution) Name Uses

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

func (*TxExecution) Output Uses

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

func (*TxExecution) Permission Uses

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

func (*TxExecution) ProtoMessage Uses

func (*TxExecution) ProtoMessage()

func (*TxExecution) PushError Uses

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 Uses

func (m *TxExecution) Reset()

func (*TxExecution) Return Uses

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

Set result

func (*TxExecution) Size Uses

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

func (*TxExecution) StreamEvents Uses

func (txe *TxExecution) StreamEvents() []*StreamEvent

func (*TxExecution) String Uses

func (m *TxExecution) String() string

func (*TxExecution) TaggedEvents Uses

func (txe *TxExecution) TaggedEvents() Events

func (*TxExecution) Unmarshal Uses

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

func (*TxExecution) XXX_DiscardUnknown Uses

func (m *TxExecution) XXX_DiscardUnknown()

func (*TxExecution) XXX_Marshal Uses

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

func (*TxExecution) XXX_Merge Uses

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

func (*TxExecution) XXX_MessageName Uses

func (*TxExecution) XXX_MessageName() string

func (*TxExecution) XXX_Size Uses

func (m *TxExecution) XXX_Size() int

func (*TxExecution) XXX_Unmarshal Uses

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

type TxExecutionKey Uses

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 Uses

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

func (*TxExecutionKey) GetHeight Uses

func (m *TxExecutionKey) GetHeight() uint64

func (*TxExecutionKey) GetOffset Uses

func (m *TxExecutionKey) GetOffset() uint64

func (*TxExecutionKey) Marshal Uses

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

func (*TxExecutionKey) MarshalTo Uses

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

func (*TxExecutionKey) MarshalToSizedBuffer Uses

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

func (*TxExecutionKey) ProtoMessage Uses

func (*TxExecutionKey) ProtoMessage()

func (*TxExecutionKey) Reset Uses

func (m *TxExecutionKey) Reset()

func (*TxExecutionKey) Size Uses

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

func (*TxExecutionKey) String Uses

func (m *TxExecutionKey) String() string

func (*TxExecutionKey) Unmarshal Uses

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

func (*TxExecutionKey) XXX_DiscardUnknown Uses

func (m *TxExecutionKey) XXX_DiscardUnknown()

func (*TxExecutionKey) XXX_Marshal Uses

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

func (*TxExecutionKey) XXX_Merge Uses

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

func (*TxExecutionKey) XXX_MessageName Uses

func (*TxExecutionKey) XXX_MessageName() string

func (*TxExecutionKey) XXX_Size Uses

func (m *TxExecutionKey) XXX_Size() int

func (*TxExecutionKey) XXX_Unmarshal Uses

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

type TxHeader Uses

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 Uses

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

func (*TxHeader) GetHeight Uses

func (m *TxHeader) GetHeight() uint64

func (*TxHeader) GetIndex Uses

func (m *TxHeader) GetIndex() uint64

func (*TxHeader) GetOrigin Uses

func (m *TxHeader) GetOrigin() *Origin

func (*TxHeader) GetTxType Uses

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

func (*TxHeader) Marshal Uses

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

func (*TxHeader) MarshalTo Uses

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

func (*TxHeader) MarshalToSizedBuffer Uses

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

func (*TxHeader) ProtoMessage Uses

func (*TxHeader) ProtoMessage()

func (*TxHeader) Reset Uses

func (m *TxHeader) Reset()

func (*TxHeader) Size Uses

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

func (*TxHeader) String Uses

func (m *TxHeader) String() string

func (*TxHeader) Unmarshal Uses

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

func (*TxHeader) XXX_DiscardUnknown Uses

func (m *TxHeader) XXX_DiscardUnknown()

func (*TxHeader) XXX_Marshal Uses

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

func (*TxHeader) XXX_Merge Uses

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

func (*TxHeader) XXX_MessageName Uses

func (*TxHeader) XXX_MessageName() string

func (*TxHeader) XXX_Size Uses

func (m *TxHeader) XXX_Size() int

func (*TxHeader) XXX_Unmarshal Uses

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

type TxStack Uses

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

TxStack is able to consume potentially nested txs

func (*TxStack) Consume Uses

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 Uses

func (stack *TxStack) Length() int

func (*TxStack) Peek Uses

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

func (*TxStack) Pop Uses

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

func (*TxStack) Push Uses

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

Package exec imports 25 packages (graph) and is imported by 59 packages. Updated 2020-04-25. Refresh now. Tools for package owners.