rpcevents

package
v0.34.4 Latest Latest
Warning

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

 Go to latest Published: Jul 23, 2021 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,
}
View Source 
var ExecutionEvents_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "rpcevents.ExecutionEvents",
	HandlerType: (*ExecutionEventsServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Tx",
			Handler:    _ExecutionEvents_Tx_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Stream",
			Handler:       _ExecutionEvents_Stream_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "Events",
			Handler:       _ExecutionEvents_Events_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "rpcevents.proto",
}

ExecutionEvents_ServiceDesc is the grpc.ServiceDesc for ExecutionEvents service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func ConsumeBlockExecutions added in v0.24.0 

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

func RegisterExecutionEventsServer added in v0.20.0 

func RegisterExecutionEventsServer(s grpc.ServiceRegistrar, 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://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewExecutionEventsClient added in v0.20.0 

func NewExecutionEventsClient(cc grpc.ClientConnInterface) 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
	// contains filtered or unexported methods
}

ExecutionEventsServer is the server API for ExecutionEvents service. All implementations must embed UnimplementedExecutionEventsServer for forward compatibility

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 must be embedded to have forward compatible implementations.

func (UnimplementedExecutionEventsServer) Events added in v0.28.0 

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

func (UnimplementedExecutionEventsServer) Stream added in v0.28.0 

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

func (UnimplementedExecutionEventsServer) Tx added in v0.28.0 

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

type UnsafeExecutionEventsServer added in v0.31.0 

type UnsafeExecutionEventsServer interface {
	// contains filtered or unexported methods
}

UnsafeExecutionEventsServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ExecutionEventsServer will result in compilation errors.

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.