burrow: github.com/hyperledger/burrow/rpc/rpcevents Index | Files

package rpcevents

import "github.com/hyperledger/burrow/rpc/rpcevents"

Index

Package Files

blocks.go execution_events_server.go rpcevents.pb.go

Constants

const SubscribeBufferSize = 100

Variables

var (
    ErrInvalidLengthRpcevents        = fmt.Errorf("proto: negative length found during unmarshaling")
    ErrIntOverflowRpcevents          = fmt.Errorf("proto: integer overflow")
    ErrUnexpectedEndOfGroupRpcevents = fmt.Errorf("proto: unexpected end of group")
)
var Bound_BoundType_name = map[int32]string{
    0:  "ABSOLUTE",
    1:  "RELATIVE",
    2:  "FIRST",
    3:  "LATEST",
    4:  "STREAM",
}
var Bound_BoundType_value = map[string]int32{
    "ABSOLUTE": 0,
    "RELATIVE": 1,
    "FIRST":    2,
    "LATEST":   3,
    "STREAM":   4,
}

func ConsumeBlockExecutions Uses

func ConsumeBlockExecutions(stream ExecutionEvents_StreamClient, consumer func(*exec.BlockExecution) error,
    continuityOptions ...exec.ContinuityOpt) error

func RegisterExecutionEventsServer Uses

func RegisterExecutionEventsServer(s *grpc.Server, srv ExecutionEventsServer)

type BlockRange Uses

type BlockRange struct {
    // Bounds can be set to:
    // absolute: block height
    // relative: block height counting back from latest
    // latest: latest block when call is processed
    // stream: for End keep sending new blocks, for start same as latest
    Start                *Bound   `protobuf:"bytes,1,opt,name=Start,proto3" json:"Start,omitempty"`
    End                  *Bound   `protobuf:"bytes,2,opt,name=End,proto3" json:"End,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

An inclusive range of blocks to include in output

func AbsoluteRange Uses

func AbsoluteRange(start, end uint64) *BlockRange

func NewBlockRange Uses

func NewBlockRange(start, end *Bound) *BlockRange

func SingleBlock Uses

func SingleBlock(height uint64) *BlockRange

func (*BlockRange) Bounds Uses

func (br *BlockRange) Bounds(latestBlockHeight uint64) (startHeight, endHeight uint64, streaming bool)

Get bounds suitable for events.Provider

func (*BlockRange) Descriptor Uses

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

func (*BlockRange) GetEnd Uses

func (m *BlockRange) GetEnd() *Bound

func (*BlockRange) GetStart Uses

func (m *BlockRange) GetStart() *Bound

func (*BlockRange) Marshal Uses

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

func (*BlockRange) MarshalTo Uses

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

func (*BlockRange) MarshalToSizedBuffer Uses

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

func (*BlockRange) ProtoMessage Uses

func (*BlockRange) ProtoMessage()

func (*BlockRange) Reset Uses

func (m *BlockRange) Reset()

func (*BlockRange) Size Uses

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

func (*BlockRange) String Uses

func (m *BlockRange) String() string

func (*BlockRange) Unmarshal Uses

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

func (*BlockRange) XXX_DiscardUnknown Uses

func (m *BlockRange) XXX_DiscardUnknown()

func (*BlockRange) XXX_Marshal Uses

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

func (*BlockRange) XXX_Merge Uses

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

func (*BlockRange) XXX_MessageName Uses

func (*BlockRange) XXX_MessageName() string

func (*BlockRange) XXX_Size Uses

func (m *BlockRange) XXX_Size() int

func (*BlockRange) XXX_Unmarshal Uses

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

type BlocksRequest Uses

type BlocksRequest struct {
    BlockRange *BlockRange `protobuf:"bytes,1,opt,name=BlockRange,proto3" json:"BlockRange,omitempty"`
    // Specify a query on which to match the tags of events.
    // Tag        | Match type | Values
    // -----------------------------------------
    //   All events
    // -----------------------------------------
    // TxType       | String     | "UnknownTx", "SendTx", "CallTx", "NameTx", "BondTx", "UnbondTx", "PermissionsTx", "GovernanceTx"
    // TxHash       | String     | bytes
    // EventType    | String     | "CallEvent", "LogEvent", "AccountInputEvent", "AccountOutputEvent"
    // EventID      | String     | string
    // Height       | Integer    | uint64
    // Index        | Integer    | uint64
    // MessageType  | String     | Go type name
    // -----------------------------------------
    //   Log event
    // -----------------------------------------
    // Address      | String     | Address (hex)
    // Log<0-4>     | String     | Word256 (hex)
    // Log<0-4>Text | String     | string (trimmed)
    // -----------------------------------------
    //   Call event
    // -----------------------------------------
    // Origin       | String     | Address (hex)
    // Callee       | String     | Address (hex)
    // Caller       | String     | Address (hex)
    // Value        | Integer    | uint64
    // Gas          | Integer    | uint64
    // StackDepth   | Integer    | uint64
    // Exception    | String     | string
    // -----------------------------------------
    //   Tx event (input/output)
    // -----------------------------------------
    // Exception  | String     | string
    //
    // For example:
    // EventType = 'LogEvent' AND EventID CONTAINS 'bar' AND TxHash = '020304' AND Height >= 34 AND Index < 3 AND Address = 'DEADBEEFDEADBEEFDEADBEEFDEADBEEFDEADBEEF'
    Query                string   `protobuf:"bytes,2,opt,name=Query,proto3" json:"Query,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*BlocksRequest) Descriptor Uses

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

func (*BlocksRequest) GetBlockRange Uses

func (m *BlocksRequest) GetBlockRange() *BlockRange

func (*BlocksRequest) GetQuery Uses

func (m *BlocksRequest) GetQuery() string

func (*BlocksRequest) Marshal Uses

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

func (*BlocksRequest) MarshalTo Uses

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

func (*BlocksRequest) MarshalToSizedBuffer Uses

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

func (*BlocksRequest) ProtoMessage Uses

func (*BlocksRequest) ProtoMessage()

func (*BlocksRequest) Reset Uses

func (m *BlocksRequest) Reset()

func (*BlocksRequest) Size Uses

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

func (*BlocksRequest) String Uses

func (m *BlocksRequest) String() string

func (*BlocksRequest) Unmarshal Uses

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

func (*BlocksRequest) XXX_DiscardUnknown Uses

func (m *BlocksRequest) XXX_DiscardUnknown()

func (*BlocksRequest) XXX_Marshal Uses

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

func (*BlocksRequest) XXX_Merge Uses

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

func (*BlocksRequest) XXX_MessageName Uses

func (*BlocksRequest) XXX_MessageName() string

func (*BlocksRequest) XXX_Size Uses

func (m *BlocksRequest) XXX_Size() int

func (*BlocksRequest) XXX_Unmarshal Uses

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

type Bound Uses

type Bound struct {
    Type                 Bound_BoundType `protobuf:"varint,1,opt,name=Type,proto3,enum=rpcevents.Bound_BoundType" json:"Type,omitempty"`
    Index                uint64          `protobuf:"varint,2,opt,name=Index,proto3" json:"Index,omitempty"`
    XXX_NoUnkeyedLiteral struct{}        `json:"-"`
    XXX_unrecognized     []byte          `json:"-"`
    XXX_sizecache        int32           `json:"-"`
}

func AbsoluteBound Uses

func AbsoluteBound(index uint64) *Bound

func LatestBound Uses

func LatestBound() *Bound

func RelativeBound Uses

func RelativeBound(index uint64) *Bound

func StreamBound Uses

func StreamBound() *Bound

func (*Bound) Bound Uses

func (b *Bound) Bound(latestBlockHeight uint64) uint64

func (*Bound) Descriptor Uses

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

func (*Bound) GetIndex Uses

func (m *Bound) GetIndex() uint64

func (*Bound) GetType Uses

func (m *Bound) GetType() Bound_BoundType

func (*Bound) Marshal Uses

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

func (*Bound) MarshalTo Uses

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

func (*Bound) MarshalToSizedBuffer Uses

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

func (*Bound) ProtoMessage Uses

func (*Bound) ProtoMessage()

func (*Bound) Reset Uses

func (m *Bound) Reset()

func (*Bound) Size Uses

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

func (*Bound) String Uses

func (m *Bound) String() string

func (*Bound) Unmarshal Uses

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

func (*Bound) XXX_DiscardUnknown Uses

func (m *Bound) XXX_DiscardUnknown()

func (*Bound) XXX_Marshal Uses

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

func (*Bound) XXX_Merge Uses

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

func (*Bound) XXX_MessageName Uses

func (*Bound) XXX_MessageName() string

func (*Bound) XXX_Size Uses

func (m *Bound) XXX_Size() int

func (*Bound) XXX_Unmarshal Uses

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

type Bound_BoundType Uses

type Bound_BoundType int32
const (
    // Index is absolute index of an item
    Bound_ABSOLUTE Bound_BoundType = 0
    // Index is an offset relative to last item
    Bound_RELATIVE Bound_BoundType = 1
    // The first block
    Bound_FIRST Bound_BoundType = 2
    // Ignore provided index and evaluate to latest index
    Bound_LATEST Bound_BoundType = 3
    // Ignore provided index and stream new objects as they are generated
    Bound_STREAM Bound_BoundType = 4
)

func (Bound_BoundType) EnumDescriptor Uses

func (Bound_BoundType) EnumDescriptor() ([]byte, []int)

func (Bound_BoundType) String Uses

func (x Bound_BoundType) String() string

type EventsResponse Uses

type EventsResponse struct {
    Height               uint64        `protobuf:"varint,1,opt,name=Height,proto3" json:"Height,omitempty"`
    Events               []*exec.Event `protobuf:"bytes,2,rep,name=Events,proto3" json:"Events,omitempty"`
    XXX_NoUnkeyedLiteral struct{}      `json:"-"`
    XXX_unrecognized     []byte        `json:"-"`
    XXX_sizecache        int32         `json:"-"`
}

func (*EventsResponse) Descriptor Uses

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

func (*EventsResponse) GetEvents Uses

func (m *EventsResponse) GetEvents() []*exec.Event

func (*EventsResponse) GetHeight Uses

func (m *EventsResponse) GetHeight() uint64

func (*EventsResponse) Marshal Uses

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

func (*EventsResponse) MarshalTo Uses

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

func (*EventsResponse) MarshalToSizedBuffer Uses

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

func (*EventsResponse) ProtoMessage Uses

func (*EventsResponse) ProtoMessage()

func (*EventsResponse) Reset Uses

func (m *EventsResponse) Reset()

func (*EventsResponse) Size Uses

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

func (*EventsResponse) String Uses

func (m *EventsResponse) String() string

func (*EventsResponse) Unmarshal Uses

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

func (*EventsResponse) XXX_DiscardUnknown Uses

func (m *EventsResponse) XXX_DiscardUnknown()

func (*EventsResponse) XXX_Marshal Uses

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

func (*EventsResponse) XXX_Merge Uses

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

func (*EventsResponse) XXX_MessageName Uses

func (*EventsResponse) XXX_MessageName() string

func (*EventsResponse) XXX_Size Uses

func (m *EventsResponse) XXX_Size() int

func (*EventsResponse) XXX_Unmarshal Uses

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

type ExecutionEventsClient Uses

type ExecutionEventsClient interface {
    // Get StreamEvents (including transactions) for a range of block heights
    Stream(ctx context.Context, in *BlocksRequest, opts ...grpc.CallOption) (ExecutionEvents_StreamClient, error)
    // Get a particular TxExecution by hash
    Tx(ctx context.Context, in *TxRequest, opts ...grpc.CallOption) (*exec.TxExecution, error)
    // GetEvents provides events streaming one block at a time - that is all events emitted in a particular block
    // are guaranteed to be delivered in each GetEventsResponse
    Events(ctx context.Context, in *BlocksRequest, opts ...grpc.CallOption) (ExecutionEvents_EventsClient, error)
}

ExecutionEventsClient is the client API for ExecutionEvents service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewExecutionEventsClient Uses

func NewExecutionEventsClient(cc *grpc.ClientConn) ExecutionEventsClient

type ExecutionEventsServer Uses

type ExecutionEventsServer interface {
    // Get StreamEvents (including transactions) for a range of block heights
    Stream(*BlocksRequest, ExecutionEvents_StreamServer) error
    // Get a particular TxExecution by hash
    Tx(context.Context, *TxRequest) (*exec.TxExecution, error)
    // GetEvents provides events streaming one block at a time - that is all events emitted in a particular block
    // are guaranteed to be delivered in each GetEventsResponse
    Events(*BlocksRequest, ExecutionEvents_EventsServer) error
}

ExecutionEventsServer is the server API for ExecutionEvents service.

func NewExecutionEventsServer Uses

func NewExecutionEventsServer(eventsProvider Provider, emitter *event.Emitter,
    tip bcm.BlockchainInfo, logger *logging.Logger) ExecutionEventsServer

type ExecutionEvents_EventsClient Uses

type ExecutionEvents_EventsClient interface {
    Recv() (*EventsResponse, error)
    grpc.ClientStream
}

type ExecutionEvents_EventsServer Uses

type ExecutionEvents_EventsServer interface {
    Send(*EventsResponse) error
    grpc.ServerStream
}

type ExecutionEvents_StreamClient Uses

type ExecutionEvents_StreamClient interface {
    Recv() (*exec.StreamEvent, error)
    grpc.ClientStream
}

type ExecutionEvents_StreamServer Uses

type ExecutionEvents_StreamServer interface {
    Send(*exec.StreamEvent) error
    grpc.ServerStream
}

type GetBlockRequest Uses

type GetBlockRequest struct {
    // Height of block required
    Height uint64 `protobuf:"varint,1,opt,name=Height,proto3" json:"Height,omitempty"`
    // Whether to wait for the block to become available
    Wait                 bool     `protobuf:"varint,2,opt,name=Wait,proto3" json:"Wait,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*GetBlockRequest) Descriptor Uses

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

func (*GetBlockRequest) GetHeight Uses

func (m *GetBlockRequest) GetHeight() uint64

func (*GetBlockRequest) GetWait Uses

func (m *GetBlockRequest) GetWait() bool

func (*GetBlockRequest) Marshal Uses

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

func (*GetBlockRequest) MarshalTo Uses

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

func (*GetBlockRequest) MarshalToSizedBuffer Uses

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

func (*GetBlockRequest) ProtoMessage Uses

func (*GetBlockRequest) ProtoMessage()

func (*GetBlockRequest) Reset Uses

func (m *GetBlockRequest) Reset()

func (*GetBlockRequest) Size Uses

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

func (*GetBlockRequest) String Uses

func (m *GetBlockRequest) String() string

func (*GetBlockRequest) Unmarshal Uses

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

func (*GetBlockRequest) XXX_DiscardUnknown Uses

func (m *GetBlockRequest) XXX_DiscardUnknown()

func (*GetBlockRequest) XXX_Marshal Uses

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

func (*GetBlockRequest) XXX_Merge Uses

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

func (*GetBlockRequest) XXX_MessageName Uses

func (*GetBlockRequest) XXX_MessageName() string

func (*GetBlockRequest) XXX_Size Uses

func (m *GetBlockRequest) XXX_Size() int

func (*GetBlockRequest) XXX_Unmarshal Uses

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

type GetTxsRequest Uses

type GetTxsRequest struct {
    StartHeight          uint64   `protobuf:"varint,1,opt,name=StartHeight,proto3" json:"StartHeight,omitempty"`
    EndHeight            uint64   `protobuf:"varint,2,opt,name=EndHeight,proto3" json:"EndHeight,omitempty"`
    Query                string   `protobuf:"bytes,3,opt,name=Query,proto3" json:"Query,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*GetTxsRequest) Descriptor Uses

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

func (*GetTxsRequest) GetEndHeight Uses

func (m *GetTxsRequest) GetEndHeight() uint64

func (*GetTxsRequest) GetQuery Uses

func (m *GetTxsRequest) GetQuery() string

func (*GetTxsRequest) GetStartHeight Uses

func (m *GetTxsRequest) GetStartHeight() uint64

func (*GetTxsRequest) Marshal Uses

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

func (*GetTxsRequest) MarshalTo Uses

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

func (*GetTxsRequest) MarshalToSizedBuffer Uses

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

func (*GetTxsRequest) ProtoMessage Uses

func (*GetTxsRequest) ProtoMessage()

func (*GetTxsRequest) Reset Uses

func (m *GetTxsRequest) Reset()

func (*GetTxsRequest) Size Uses

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

func (*GetTxsRequest) String Uses

func (m *GetTxsRequest) String() string

func (*GetTxsRequest) Unmarshal Uses

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

func (*GetTxsRequest) XXX_DiscardUnknown Uses

func (m *GetTxsRequest) XXX_DiscardUnknown()

func (*GetTxsRequest) XXX_Marshal Uses

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

func (*GetTxsRequest) XXX_Merge Uses

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

func (*GetTxsRequest) XXX_MessageName Uses

func (*GetTxsRequest) XXX_MessageName() string

func (*GetTxsRequest) XXX_Size Uses

func (m *GetTxsRequest) XXX_Size() int

func (*GetTxsRequest) XXX_Unmarshal Uses

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

type GetTxsResponse Uses

type GetTxsResponse struct {
    Height               uint64              `protobuf:"varint,1,opt,name=Height,proto3" json:"Height,omitempty"`
    TxExecutions         []*exec.TxExecution `protobuf:"bytes,2,rep,name=TxExecutions,proto3" json:"TxExecutions,omitempty"`
    XXX_NoUnkeyedLiteral struct{}            `json:"-"`
    XXX_unrecognized     []byte              `json:"-"`
    XXX_sizecache        int32               `json:"-"`
}

func (*GetTxsResponse) Descriptor Uses

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

func (*GetTxsResponse) GetHeight Uses

func (m *GetTxsResponse) GetHeight() uint64

func (*GetTxsResponse) GetTxExecutions Uses

func (m *GetTxsResponse) GetTxExecutions() []*exec.TxExecution

func (*GetTxsResponse) Marshal Uses

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

func (*GetTxsResponse) MarshalTo Uses

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

func (*GetTxsResponse) MarshalToSizedBuffer Uses

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

func (*GetTxsResponse) ProtoMessage Uses

func (*GetTxsResponse) ProtoMessage()

func (*GetTxsResponse) Reset Uses

func (m *GetTxsResponse) Reset()

func (*GetTxsResponse) Size Uses

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

func (*GetTxsResponse) String Uses

func (m *GetTxsResponse) String() string

func (*GetTxsResponse) Unmarshal Uses

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

func (*GetTxsResponse) XXX_DiscardUnknown Uses

func (m *GetTxsResponse) XXX_DiscardUnknown()

func (*GetTxsResponse) XXX_Marshal Uses

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

func (*GetTxsResponse) XXX_Merge Uses

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

func (*GetTxsResponse) XXX_MessageName Uses

func (*GetTxsResponse) XXX_MessageName() string

func (*GetTxsResponse) XXX_Size Uses

func (m *GetTxsResponse) XXX_Size() int

func (*GetTxsResponse) XXX_Unmarshal Uses

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

type Provider Uses

type Provider interface {
    // Get transactions
    IterateStreamEvents(startHeight, endHeight *uint64, sortOrder storage.SortOrder,
        consumer func(*exec.StreamEvent) error) (err error)
    // Get a particular TxExecution by hash
    TxByHash(txHash []byte) (*exec.TxExecution, error)
}

type TxRequest Uses

type TxRequest struct {
    // Height of block required
    TxHash github_com_hyperledger_burrow_binary.HexBytes `protobuf:"bytes,1,opt,name=TxHash,proto3,customtype=github.com/hyperledger/burrow/binary.HexBytes" json:"TxHash"`
    // Whether to wait for the block to become available
    Wait                 bool     `protobuf:"varint,2,opt,name=Wait,proto3" json:"Wait,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*TxRequest) Descriptor Uses

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

func (*TxRequest) GetWait Uses

func (m *TxRequest) GetWait() bool

func (*TxRequest) Marshal Uses

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

func (*TxRequest) MarshalTo Uses

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

func (*TxRequest) MarshalToSizedBuffer Uses

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

func (*TxRequest) ProtoMessage Uses

func (*TxRequest) ProtoMessage()

func (*TxRequest) Reset Uses

func (m *TxRequest) Reset()

func (*TxRequest) Size Uses

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

func (*TxRequest) String Uses

func (m *TxRequest) String() string

func (*TxRequest) Unmarshal Uses

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

func (*TxRequest) XXX_DiscardUnknown Uses

func (m *TxRequest) XXX_DiscardUnknown()

func (*TxRequest) XXX_Marshal Uses

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

func (*TxRequest) XXX_Merge Uses

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

func (*TxRequest) XXX_MessageName Uses

func (*TxRequest) XXX_MessageName() string

func (*TxRequest) XXX_Size Uses

func (m *TxRequest) XXX_Size() int

func (*TxRequest) XXX_Unmarshal Uses

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

type UnimplementedExecutionEventsServer Uses

type UnimplementedExecutionEventsServer struct {
}

UnimplementedExecutionEventsServer can be embedded to have forward compatible implementations.

func (*UnimplementedExecutionEventsServer) Events Uses

func (*UnimplementedExecutionEventsServer) Events(req *BlocksRequest, srv ExecutionEvents_EventsServer) error

func (*UnimplementedExecutionEventsServer) Stream Uses

func (*UnimplementedExecutionEventsServer) Stream(req *BlocksRequest, srv ExecutionEvents_StreamServer) error

func (*UnimplementedExecutionEventsServer) Tx Uses

func (*UnimplementedExecutionEventsServer) Tx(ctx context.Context, req *TxRequest) (*exec.TxExecution, error)

Package rpcevents imports 18 packages (graph) and is imported by 13 packages. Updated 2020-05-03. Refresh now. Tools for package owners.