Documentation ¶
Index ¶
- Constants
- Variables
- func ConsumeBlockExecutions(stream ExecutionEvents_StreamClient, consumer func(*exec.BlockExecution) error) error
- func RegisterExecutionEventsServer(s *grpc.Server, srv ExecutionEventsServer)
- type BlockRange
- func (br *BlockRange) Bounds(latestBlockHeight uint64) (startHeight, endHeight uint64, streaming bool)
- func (*BlockRange) Descriptor() ([]byte, []int)
- func (m *BlockRange) GetEnd() *Bound
- func (m *BlockRange) GetStart() *Bound
- func (m *BlockRange) Marshal() (dAtA []byte, err error)
- func (m *BlockRange) MarshalTo(dAtA []byte) (int, error)
- func (*BlockRange) ProtoMessage()
- func (m *BlockRange) Reset()
- func (m *BlockRange) Size() (n int)
- func (m *BlockRange) String() string
- func (m *BlockRange) Unmarshal(dAtA []byte) error
- func (m *BlockRange) XXX_DiscardUnknown()
- func (m *BlockRange) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *BlockRange) XXX_Merge(src proto.Message)
- func (*BlockRange) XXX_MessageName() string
- func (m *BlockRange) XXX_Size() int
- func (m *BlockRange) XXX_Unmarshal(b []byte) error
- type BlocksRequest
- func (*BlocksRequest) Descriptor() ([]byte, []int)
- func (m *BlocksRequest) GetBlockRange() *BlockRange
- func (m *BlocksRequest) GetQuery() string
- func (m *BlocksRequest) Marshal() (dAtA []byte, err error)
- func (m *BlocksRequest) MarshalTo(dAtA []byte) (int, error)
- func (*BlocksRequest) ProtoMessage()
- func (m *BlocksRequest) Reset()
- func (m *BlocksRequest) Size() (n int)
- func (m *BlocksRequest) String() string
- func (m *BlocksRequest) Unmarshal(dAtA []byte) error
- func (m *BlocksRequest) XXX_DiscardUnknown()
- func (m *BlocksRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *BlocksRequest) XXX_Merge(src proto.Message)
- func (*BlocksRequest) XXX_MessageName() string
- func (m *BlocksRequest) XXX_Size() int
- func (m *BlocksRequest) XXX_Unmarshal(b []byte) error
- type Bound
- func (b *Bound) Bound(latestBlockHeight uint64) uint64
- func (*Bound) Descriptor() ([]byte, []int)
- func (m *Bound) GetIndex() uint64
- func (m *Bound) GetType() Bound_BoundType
- func (m *Bound) Marshal() (dAtA []byte, err error)
- func (m *Bound) MarshalTo(dAtA []byte) (int, error)
- func (*Bound) ProtoMessage()
- func (m *Bound) Reset()
- func (m *Bound) Size() (n int)
- func (m *Bound) String() string
- func (m *Bound) Unmarshal(dAtA []byte) error
- func (m *Bound) XXX_DiscardUnknown()
- func (m *Bound) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Bound) XXX_Merge(src proto.Message)
- func (*Bound) XXX_MessageName() string
- func (m *Bound) XXX_Size() int
- func (m *Bound) XXX_Unmarshal(b []byte) error
- type Bound_BoundType
- type EventsResponse
- func (*EventsResponse) Descriptor() ([]byte, []int)
- func (m *EventsResponse) GetEvents() []*exec.Event
- func (m *EventsResponse) GetHeight() uint64
- func (m *EventsResponse) Marshal() (dAtA []byte, err error)
- func (m *EventsResponse) MarshalTo(dAtA []byte) (int, error)
- func (*EventsResponse) ProtoMessage()
- func (m *EventsResponse) Reset()
- func (m *EventsResponse) Size() (n int)
- func (m *EventsResponse) String() string
- func (m *EventsResponse) Unmarshal(dAtA []byte) error
- func (m *EventsResponse) XXX_DiscardUnknown()
- func (m *EventsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *EventsResponse) XXX_Merge(src proto.Message)
- func (*EventsResponse) XXX_MessageName() string
- func (m *EventsResponse) XXX_Size() int
- func (m *EventsResponse) XXX_Unmarshal(b []byte) error
- type ExecutionEventsClient
- type ExecutionEventsServer
- type ExecutionEvents_EventsClient
- type ExecutionEvents_EventsServer
- type ExecutionEvents_StreamClient
- type ExecutionEvents_StreamServer
- type GetBlockRequest
- func (*GetBlockRequest) Descriptor() ([]byte, []int)
- func (m *GetBlockRequest) GetHeight() uint64
- func (m *GetBlockRequest) GetWait() bool
- func (m *GetBlockRequest) Marshal() (dAtA []byte, err error)
- func (m *GetBlockRequest) MarshalTo(dAtA []byte) (int, error)
- func (*GetBlockRequest) ProtoMessage()
- func (m *GetBlockRequest) Reset()
- func (m *GetBlockRequest) Size() (n int)
- func (m *GetBlockRequest) String() string
- func (m *GetBlockRequest) Unmarshal(dAtA []byte) error
- func (m *GetBlockRequest) XXX_DiscardUnknown()
- func (m *GetBlockRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetBlockRequest) XXX_Merge(src proto.Message)
- func (*GetBlockRequest) XXX_MessageName() string
- func (m *GetBlockRequest) XXX_Size() int
- func (m *GetBlockRequest) XXX_Unmarshal(b []byte) error
- type GetTxsRequest
- func (*GetTxsRequest) Descriptor() ([]byte, []int)
- func (m *GetTxsRequest) GetEndHeight() uint64
- func (m *GetTxsRequest) GetQuery() string
- func (m *GetTxsRequest) GetStartHeight() uint64
- func (m *GetTxsRequest) Marshal() (dAtA []byte, err error)
- func (m *GetTxsRequest) MarshalTo(dAtA []byte) (int, error)
- func (*GetTxsRequest) ProtoMessage()
- func (m *GetTxsRequest) Reset()
- func (m *GetTxsRequest) Size() (n int)
- func (m *GetTxsRequest) String() string
- func (m *GetTxsRequest) Unmarshal(dAtA []byte) error
- func (m *GetTxsRequest) XXX_DiscardUnknown()
- func (m *GetTxsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetTxsRequest) XXX_Merge(src proto.Message)
- func (*GetTxsRequest) XXX_MessageName() string
- func (m *GetTxsRequest) XXX_Size() int
- func (m *GetTxsRequest) XXX_Unmarshal(b []byte) error
- type GetTxsResponse
- func (*GetTxsResponse) Descriptor() ([]byte, []int)
- func (m *GetTxsResponse) GetHeight() uint64
- func (m *GetTxsResponse) GetTxExecutions() []*exec.TxExecution
- func (m *GetTxsResponse) Marshal() (dAtA []byte, err error)
- func (m *GetTxsResponse) MarshalTo(dAtA []byte) (int, error)
- func (*GetTxsResponse) ProtoMessage()
- func (m *GetTxsResponse) Reset()
- func (m *GetTxsResponse) Size() (n int)
- func (m *GetTxsResponse) String() string
- func (m *GetTxsResponse) Unmarshal(dAtA []byte) error
- func (m *GetTxsResponse) XXX_DiscardUnknown()
- func (m *GetTxsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetTxsResponse) XXX_Merge(src proto.Message)
- func (*GetTxsResponse) XXX_MessageName() string
- func (m *GetTxsResponse) XXX_Size() int
- func (m *GetTxsResponse) XXX_Unmarshal(b []byte) error
- type Provider
- type TxRequest
- func (*TxRequest) Descriptor() ([]byte, []int)
- func (m *TxRequest) GetWait() bool
- func (m *TxRequest) Marshal() (dAtA []byte, err error)
- func (m *TxRequest) MarshalTo(dAtA []byte) (int, error)
- func (*TxRequest) ProtoMessage()
- func (m *TxRequest) Reset()
- func (m *TxRequest) Size() (n int)
- func (m *TxRequest) String() string
- func (m *TxRequest) Unmarshal(dAtA []byte) error
- func (m *TxRequest) XXX_DiscardUnknown()
- func (m *TxRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *TxRequest) XXX_Merge(src proto.Message)
- func (*TxRequest) XXX_MessageName() string
- func (m *TxRequest) XXX_Size() int
- func (m *TxRequest) XXX_Unmarshal(b []byte) error
Constants ¶
View Source
const SubscribeBufferSize = 100
Variables ¶
View Source
var ( ErrInvalidLengthRpcevents = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowRpcevents = fmt.Errorf("proto: integer overflow") )
View Source
var Bound_BoundType_name = map[int32]string{
0: "ABSOLUTE",
1: "RELATIVE",
2: "FIRST",
3: "LATEST",
4: "STREAM",
}
View Source
var Bound_BoundType_value = map[string]int32{
"ABSOLUTE": 0,
"RELATIVE": 1,
"FIRST": 2,
"LATEST": 3,
"STREAM": 4,
}
Functions ¶
func ConsumeBlockExecutions ¶ added in v0.24.0
func ConsumeBlockExecutions(stream ExecutionEvents_StreamClient, consumer func(*exec.BlockExecution) error) error
func RegisterExecutionEventsServer ¶ added in v0.20.0
func RegisterExecutionEventsServer(s *grpc.Server, srv ExecutionEventsServer)
Types ¶
type BlockRange ¶ added in v0.20.0
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 ¶ added in v0.24.0
func AbsoluteRange(start, end uint64) *BlockRange
func NewBlockRange ¶ added in v0.20.0
func NewBlockRange(start, end *Bound) *BlockRange
func SingleBlock ¶ added in v0.24.0
func SingleBlock(height uint64) *BlockRange
func (*BlockRange) Bounds ¶ added in v0.20.0
func (br *BlockRange) Bounds(latestBlockHeight uint64) (startHeight, endHeight uint64, streaming bool)
Get bounds suitable for events.Provider
func (*BlockRange) Descriptor ¶ added in v0.20.0
func (*BlockRange) Descriptor() ([]byte, []int)
func (*BlockRange) GetEnd ¶ added in v0.20.0
func (m *BlockRange) GetEnd() *Bound
func (*BlockRange) GetStart ¶ added in v0.20.0
func (m *BlockRange) GetStart() *Bound
func (*BlockRange) Marshal ¶ added in v0.20.0
func (m *BlockRange) Marshal() (dAtA []byte, err error)
func (*BlockRange) MarshalTo ¶ added in v0.20.0
func (m *BlockRange) MarshalTo(dAtA []byte) (int, error)
func (*BlockRange) ProtoMessage ¶ added in v0.20.0
func (*BlockRange) ProtoMessage()
func (*BlockRange) Reset ¶ added in v0.20.0
func (m *BlockRange) Reset()
func (*BlockRange) Size ¶ added in v0.20.0
func (m *BlockRange) Size() (n int)
func (*BlockRange) String ¶ added in v0.20.0
func (m *BlockRange) String() string
func (*BlockRange) Unmarshal ¶ added in v0.20.0
func (m *BlockRange) Unmarshal(dAtA []byte) error
func (*BlockRange) XXX_DiscardUnknown ¶ added in v0.23.0
func (m *BlockRange) XXX_DiscardUnknown()
func (*BlockRange) XXX_Marshal ¶ added in v0.23.0
func (m *BlockRange) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*BlockRange) XXX_Merge ¶ added in v0.23.0
func (m *BlockRange) XXX_Merge(src proto.Message)
func (*BlockRange) XXX_MessageName ¶ added in v0.20.0
func (*BlockRange) XXX_MessageName() string
func (*BlockRange) XXX_Size ¶ added in v0.23.0
func (m *BlockRange) XXX_Size() int
func (*BlockRange) XXX_Unmarshal ¶ added in v0.23.0
func (m *BlockRange) XXX_Unmarshal(b []byte) error
type BlocksRequest ¶ added in v0.20.0
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 ¶ added in v0.20.0
func (*BlocksRequest) Descriptor() ([]byte, []int)
func (*BlocksRequest) GetBlockRange ¶ added in v0.20.0
func (m *BlocksRequest) GetBlockRange() *BlockRange
func (*BlocksRequest) GetQuery ¶ added in v0.20.0
func (m *BlocksRequest) GetQuery() string
func (*BlocksRequest) Marshal ¶ added in v0.20.0
func (m *BlocksRequest) Marshal() (dAtA []byte, err error)
func (*BlocksRequest) MarshalTo ¶ added in v0.20.0
func (m *BlocksRequest) MarshalTo(dAtA []byte) (int, error)
func (*BlocksRequest) ProtoMessage ¶ added in v0.20.0
func (*BlocksRequest) ProtoMessage()
func (*BlocksRequest) Reset ¶ added in v0.20.0
func (m *BlocksRequest) Reset()
func (*BlocksRequest) Size ¶ added in v0.20.0
func (m *BlocksRequest) Size() (n int)
func (*BlocksRequest) String ¶ added in v0.20.0
func (m *BlocksRequest) String() string
func (*BlocksRequest) Unmarshal ¶ added in v0.20.0
func (m *BlocksRequest) Unmarshal(dAtA []byte) error
func (*BlocksRequest) XXX_DiscardUnknown ¶ added in v0.23.0
func (m *BlocksRequest) XXX_DiscardUnknown()
func (*BlocksRequest) XXX_Marshal ¶ added in v0.23.0
func (m *BlocksRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*BlocksRequest) XXX_Merge ¶ added in v0.23.0
func (m *BlocksRequest) XXX_Merge(src proto.Message)
func (*BlocksRequest) XXX_MessageName ¶ added in v0.20.0
func (*BlocksRequest) XXX_MessageName() string
func (*BlocksRequest) XXX_Size ¶ added in v0.23.0
func (m *BlocksRequest) XXX_Size() int
func (*BlocksRequest) XXX_Unmarshal ¶ added in v0.23.0
func (m *BlocksRequest) XXX_Unmarshal(b []byte) error
type Bound ¶ added in v0.20.0
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 ¶ added in v0.20.0
func LatestBound ¶ added in v0.20.0
func LatestBound() *Bound
func RelativeBound ¶ added in v0.20.0
func StreamBound ¶ added in v0.20.0
func StreamBound() *Bound
func (*Bound) Descriptor ¶ added in v0.20.0
func (*Bound) GetType ¶ added in v0.20.0
func (m *Bound) GetType() Bound_BoundType
func (*Bound) ProtoMessage ¶ added in v0.20.0
func (*Bound) ProtoMessage()
func (*Bound) XXX_DiscardUnknown ¶ added in v0.23.0
func (m *Bound) XXX_DiscardUnknown()
func (*Bound) XXX_Marshal ¶ added in v0.23.0
func (*Bound) XXX_MessageName ¶ added in v0.20.0
func (*Bound) XXX_Unmarshal ¶ added in v0.23.0
type Bound_BoundType ¶ added in v0.20.0
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 ¶ added in v0.20.0
func (Bound_BoundType) EnumDescriptor() ([]byte, []int)
func (Bound_BoundType) String ¶ added in v0.20.0
func (x Bound_BoundType) String() string
type EventsResponse ¶ added in v0.24.0
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 ¶ added in v0.24.0
func (*EventsResponse) Descriptor() ([]byte, []int)
func (*EventsResponse) GetEvents ¶ added in v0.24.0
func (m *EventsResponse) GetEvents() []*exec.Event
func (*EventsResponse) GetHeight ¶ added in v0.24.0
func (m *EventsResponse) GetHeight() uint64
func (*EventsResponse) Marshal ¶ added in v0.24.0
func (m *EventsResponse) Marshal() (dAtA []byte, err error)
func (*EventsResponse) MarshalTo ¶ added in v0.24.0
func (m *EventsResponse) MarshalTo(dAtA []byte) (int, error)
func (*EventsResponse) ProtoMessage ¶ added in v0.24.0
func (*EventsResponse) ProtoMessage()
func (*EventsResponse) Reset ¶ added in v0.24.0
func (m *EventsResponse) Reset()
func (*EventsResponse) Size ¶ added in v0.24.0
func (m *EventsResponse) Size() (n int)
func (*EventsResponse) String ¶ added in v0.24.0
func (m *EventsResponse) String() string
func (*EventsResponse) Unmarshal ¶ added in v0.24.0
func (m *EventsResponse) Unmarshal(dAtA []byte) error
func (*EventsResponse) XXX_DiscardUnknown ¶ added in v0.24.0
func (m *EventsResponse) XXX_DiscardUnknown()
func (*EventsResponse) XXX_Marshal ¶ added in v0.24.0
func (m *EventsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*EventsResponse) XXX_Merge ¶ added in v0.24.0
func (m *EventsResponse) XXX_Merge(src proto.Message)
func (*EventsResponse) XXX_MessageName ¶ added in v0.24.0
func (*EventsResponse) XXX_MessageName() string
func (*EventsResponse) XXX_Size ¶ added in v0.24.0
func (m *EventsResponse) XXX_Size() int
func (*EventsResponse) XXX_Unmarshal ¶ added in v0.24.0
func (m *EventsResponse) XXX_Unmarshal(b []byte) error
type ExecutionEventsClient ¶ added in v0.20.0
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 ¶ added in v0.20.0
func NewExecutionEventsClient(cc *grpc.ClientConn) ExecutionEventsClient
type ExecutionEventsServer ¶ added in v0.20.0
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 ¶
func NewExecutionEventsServer(eventsProvider Provider, emitter *event.Emitter, tip bcm.BlockchainInfo, logger *logging.Logger) ExecutionEventsServer
type ExecutionEvents_EventsClient ¶ added in v0.24.0
type ExecutionEvents_EventsClient interface { Recv() (*EventsResponse, error) grpc.ClientStream }
type ExecutionEvents_EventsServer ¶ added in v0.24.0
type ExecutionEvents_EventsServer interface { Send(*EventsResponse) error grpc.ServerStream }
type ExecutionEvents_StreamClient ¶ added in v0.24.0
type ExecutionEvents_StreamClient interface { Recv() (*exec.StreamEvent, error) grpc.ClientStream }
type ExecutionEvents_StreamServer ¶ added in v0.24.0
type ExecutionEvents_StreamServer interface { Send(*exec.StreamEvent) error grpc.ServerStream }
type GetBlockRequest ¶ added in v0.20.0
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 ¶ added in v0.20.0
func (*GetBlockRequest) Descriptor() ([]byte, []int)
func (*GetBlockRequest) GetHeight ¶ added in v0.20.0
func (m *GetBlockRequest) GetHeight() uint64
func (*GetBlockRequest) GetWait ¶ added in v0.20.0
func (m *GetBlockRequest) GetWait() bool
func (*GetBlockRequest) Marshal ¶ added in v0.20.0
func (m *GetBlockRequest) Marshal() (dAtA []byte, err error)
func (*GetBlockRequest) MarshalTo ¶ added in v0.20.0
func (m *GetBlockRequest) MarshalTo(dAtA []byte) (int, error)
func (*GetBlockRequest) ProtoMessage ¶ added in v0.20.0
func (*GetBlockRequest) ProtoMessage()
func (*GetBlockRequest) Reset ¶ added in v0.20.0
func (m *GetBlockRequest) Reset()
func (*GetBlockRequest) Size ¶ added in v0.20.0
func (m *GetBlockRequest) Size() (n int)
func (*GetBlockRequest) String ¶ added in v0.20.0
func (m *GetBlockRequest) String() string
func (*GetBlockRequest) Unmarshal ¶ added in v0.20.0
func (m *GetBlockRequest) Unmarshal(dAtA []byte) error
func (*GetBlockRequest) XXX_DiscardUnknown ¶ added in v0.23.0
func (m *GetBlockRequest) XXX_DiscardUnknown()
func (*GetBlockRequest) XXX_Marshal ¶ added in v0.23.0
func (m *GetBlockRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetBlockRequest) XXX_Merge ¶ added in v0.23.0
func (m *GetBlockRequest) XXX_Merge(src proto.Message)
func (*GetBlockRequest) XXX_MessageName ¶ added in v0.20.0
func (*GetBlockRequest) XXX_MessageName() string
func (*GetBlockRequest) XXX_Size ¶ added in v0.23.0
func (m *GetBlockRequest) XXX_Size() int
func (*GetBlockRequest) XXX_Unmarshal ¶ added in v0.23.0
func (m *GetBlockRequest) XXX_Unmarshal(b []byte) error
type GetTxsRequest ¶ added in v0.24.0
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 ¶ added in v0.24.0
func (*GetTxsRequest) Descriptor() ([]byte, []int)
func (*GetTxsRequest) GetEndHeight ¶ added in v0.24.0
func (m *GetTxsRequest) GetEndHeight() uint64
func (*GetTxsRequest) GetQuery ¶ added in v0.24.0
func (m *GetTxsRequest) GetQuery() string
func (*GetTxsRequest) GetStartHeight ¶ added in v0.24.0
func (m *GetTxsRequest) GetStartHeight() uint64
func (*GetTxsRequest) Marshal ¶ added in v0.24.0
func (m *GetTxsRequest) Marshal() (dAtA []byte, err error)
func (*GetTxsRequest) MarshalTo ¶ added in v0.24.0
func (m *GetTxsRequest) MarshalTo(dAtA []byte) (int, error)
func (*GetTxsRequest) ProtoMessage ¶ added in v0.24.0
func (*GetTxsRequest) ProtoMessage()
func (*GetTxsRequest) Reset ¶ added in v0.24.0
func (m *GetTxsRequest) Reset()
func (*GetTxsRequest) Size ¶ added in v0.24.0
func (m *GetTxsRequest) Size() (n int)
func (*GetTxsRequest) String ¶ added in v0.24.0
func (m *GetTxsRequest) String() string
func (*GetTxsRequest) Unmarshal ¶ added in v0.24.0
func (m *GetTxsRequest) Unmarshal(dAtA []byte) error
func (*GetTxsRequest) XXX_DiscardUnknown ¶ added in v0.24.0
func (m *GetTxsRequest) XXX_DiscardUnknown()
func (*GetTxsRequest) XXX_Marshal ¶ added in v0.24.0
func (m *GetTxsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetTxsRequest) XXX_Merge ¶ added in v0.24.0
func (m *GetTxsRequest) XXX_Merge(src proto.Message)
func (*GetTxsRequest) XXX_MessageName ¶ added in v0.24.0
func (*GetTxsRequest) XXX_MessageName() string
func (*GetTxsRequest) XXX_Size ¶ added in v0.24.0
func (m *GetTxsRequest) XXX_Size() int
func (*GetTxsRequest) XXX_Unmarshal ¶ added in v0.24.0
func (m *GetTxsRequest) XXX_Unmarshal(b []byte) error
type GetTxsResponse ¶ added in v0.20.0
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 ¶ added in v0.20.0
func (*GetTxsResponse) Descriptor() ([]byte, []int)
func (*GetTxsResponse) GetHeight ¶ added in v0.20.0
func (m *GetTxsResponse) GetHeight() uint64
func (*GetTxsResponse) GetTxExecutions ¶ added in v0.20.0
func (m *GetTxsResponse) GetTxExecutions() []*exec.TxExecution
func (*GetTxsResponse) Marshal ¶ added in v0.20.0
func (m *GetTxsResponse) Marshal() (dAtA []byte, err error)
func (*GetTxsResponse) MarshalTo ¶ added in v0.20.0
func (m *GetTxsResponse) MarshalTo(dAtA []byte) (int, error)
func (*GetTxsResponse) ProtoMessage ¶ added in v0.20.0
func (*GetTxsResponse) ProtoMessage()
func (*GetTxsResponse) Reset ¶ added in v0.20.0
func (m *GetTxsResponse) Reset()
func (*GetTxsResponse) Size ¶ added in v0.20.0
func (m *GetTxsResponse) Size() (n int)
func (*GetTxsResponse) String ¶ added in v0.20.0
func (m *GetTxsResponse) String() string
func (*GetTxsResponse) Unmarshal ¶ added in v0.20.0
func (m *GetTxsResponse) Unmarshal(dAtA []byte) error
func (*GetTxsResponse) XXX_DiscardUnknown ¶ added in v0.23.0
func (m *GetTxsResponse) XXX_DiscardUnknown()
func (*GetTxsResponse) XXX_Marshal ¶ added in v0.23.0
func (m *GetTxsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetTxsResponse) XXX_Merge ¶ added in v0.23.0
func (m *GetTxsResponse) XXX_Merge(src proto.Message)
func (*GetTxsResponse) XXX_MessageName ¶ added in v0.20.0
func (*GetTxsResponse) XXX_MessageName() string
func (*GetTxsResponse) XXX_Size ¶ added in v0.23.0
func (m *GetTxsResponse) XXX_Size() int
func (*GetTxsResponse) XXX_Unmarshal ¶ added in v0.23.0
func (m *GetTxsResponse) XXX_Unmarshal(b []byte) error
type Provider ¶ added in v0.20.0
type Provider interface { // Get transactions IterateStreamEvents(start, end *exec.StreamKey, consumer func(*exec.StreamEvent) error) (err error) // Get a particular TxExecution by hash TxByHash(txHash []byte) (*exec.TxExecution, error) }
type TxRequest ¶ added in v0.24.0
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 ¶ added in v0.24.0
func (*TxRequest) ProtoMessage ¶ added in v0.24.0
func (*TxRequest) ProtoMessage()
func (*TxRequest) XXX_DiscardUnknown ¶ added in v0.24.0
func (m *TxRequest) XXX_DiscardUnknown()
func (*TxRequest) XXX_Marshal ¶ added in v0.24.0
func (*TxRequest) XXX_MessageName ¶ added in v0.24.0
func (*TxRequest) XXX_Unmarshal ¶ added in v0.24.0
Click to show internal directories.
Click to hide internal directories.