rpcevents

package
v0.30.5 Latest Latest
Warning

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

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

Documentation

Index

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")
	ErrUnexpectedEndOfGroupRpcevents = fmt.Errorf("proto: unexpected end of group")
)
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,
	continuityOptions ...exec.ContinuityOpt) 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) MarshalToSizedBuffer added in v0.30.0 

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

func (m *BlocksRequest) MarshalToSizedBuffer(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 AbsoluteBound(index uint64) *Bound

func LatestBound added in v0.20.0 

func LatestBound() *Bound

func RelativeBound added in v0.20.0 

func RelativeBound(index uint64) *Bound

func StreamBound added in v0.20.0 

func StreamBound() *Bound

func (*Bound) Bound added in v0.20.0 

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

func (*Bound) Descriptor added in v0.20.0 

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

func (*Bound) GetIndex added in v0.20.0 

func (m *Bound) GetIndex() uint64

func (*Bound) GetType added in v0.20.0 

func (m *Bound) GetType() Bound_BoundType

func (*Bound) Marshal added in v0.20.0 

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

func (*Bound) MarshalTo added in v0.20.0 

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

func (*Bound) MarshalToSizedBuffer added in v0.30.0 

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

func (*Bound) ProtoMessage added in v0.20.0 

func (*Bound) ProtoMessage()

func (*Bound) Reset added in v0.20.0 

func (m *Bound) Reset()

func (*Bound) Size added in v0.20.0 

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

func (*Bound) String added in v0.20.0 

func (m *Bound) String() string

func (*Bound) Unmarshal added in v0.20.0 

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

func (*Bound) XXX_DiscardUnknown added in v0.23.0 

func (m *Bound) XXX_DiscardUnknown()

func (*Bound) XXX_Marshal added in v0.23.0 

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

func (*Bound) XXX_Merge added in v0.23.0 

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

func (*Bound) XXX_MessageName added in v0.20.0 

func (*Bound) XXX_MessageName() string

func (*Bound) XXX_Size added in v0.23.0 

func (m *Bound) XXX_Size() int

func (*Bound) XXX_Unmarshal added in v0.23.0 

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

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

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

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

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

func (m *GetTxsResponse) MarshalToSizedBuffer(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(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 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) Descriptor() ([]byte, []int)

func (*TxRequest) GetWait added in v0.24.0 

func (m *TxRequest) GetWait() bool

func (*TxRequest) Marshal added in v0.24.0 

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

func (*TxRequest) MarshalTo added in v0.24.0 

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

func (*TxRequest) MarshalToSizedBuffer added in v0.30.0 

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

func (*TxRequest) ProtoMessage added in v0.24.0 

func (*TxRequest) ProtoMessage()

func (*TxRequest) Reset added in v0.24.0 

func (m *TxRequest) Reset()

func (*TxRequest) Size added in v0.24.0 

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

func (*TxRequest) String added in v0.24.0 

func (m *TxRequest) String() string

func (*TxRequest) Unmarshal added in v0.24.0 

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

func (*TxRequest) XXX_DiscardUnknown added in v0.24.0 

func (m *TxRequest) XXX_DiscardUnknown()

func (*TxRequest) XXX_Marshal added in v0.24.0 

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

func (*TxRequest) XXX_Merge added in v0.24.0 

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

func (*TxRequest) XXX_MessageName added in v0.24.0 

func (*TxRequest) XXX_MessageName() string

func (*TxRequest) XXX_Size added in v0.24.0 

func (m *TxRequest) XXX_Size() int

func (*TxRequest) XXX_Unmarshal added in v0.24.0 

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

type UnimplementedExecutionEventsServer added in v0.28.0 

type UnimplementedExecutionEventsServer struct {
}

UnimplementedExecutionEventsServer can be embedded to have forward compatible implementations.

func (*UnimplementedExecutionEventsServer) Events added in v0.28.0 

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

func (*UnimplementedExecutionEventsServer) Stream added in v0.28.0 

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

func (*UnimplementedExecutionEventsServer) Tx added in v0.28.0 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

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