rpcevents

package
v0.0.0-...-2935fa7 Latest Latest
Warning

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

 Go to latest Published: Apr 10, 2021 License: Apache-2.0 Imports: 18 Imported by: 0

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 

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

func RegisterExecutionEventsServer 

func RegisterExecutionEventsServer(s grpc.ServiceRegistrar, srv ExecutionEventsServer)

Types

type BlockRange 

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 

func AbsoluteRange(start, end uint64) *BlockRange

func NewBlockRange 

func NewBlockRange(start, end *Bound) *BlockRange

func SingleBlock 

func SingleBlock(height uint64) *BlockRange

func (*BlockRange) Bounds 

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

Get bounds suitable for events.Provider

func (*BlockRange) Descriptor 

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

func (*BlockRange) GetEnd 

func (m *BlockRange) GetEnd() *Bound

func (*BlockRange) GetStart 

func (m *BlockRange) GetStart() *Bound

func (*BlockRange) Marshal 

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

func (*BlockRange) MarshalTo 

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

func (*BlockRange) MarshalToSizedBuffer 

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

func (*BlockRange) ProtoMessage 

func (*BlockRange) ProtoMessage()

func (*BlockRange) Reset 

func (m *BlockRange) Reset()

func (*BlockRange) Size 

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

func (*BlockRange) String 

func (m *BlockRange) String() string

func (*BlockRange) Unmarshal 

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

func (*BlockRange) XXX_DiscardUnknown 

func (m *BlockRange) XXX_DiscardUnknown()

func (*BlockRange) XXX_Marshal 

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

func (*BlockRange) XXX_Merge 

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

func (*BlockRange) XXX_MessageName 

func (*BlockRange) XXX_MessageName() string

func (*BlockRange) XXX_Size 

func (m *BlockRange) XXX_Size() int

func (*BlockRange) XXX_Unmarshal 

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

type BlocksRequest 

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 

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

func (*BlocksRequest) GetBlockRange 

func (m *BlocksRequest) GetBlockRange() *BlockRange

func (*BlocksRequest) GetQuery 

func (m *BlocksRequest) GetQuery() string

func (*BlocksRequest) Marshal 

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

func (*BlocksRequest) MarshalTo 

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

func (*BlocksRequest) MarshalToSizedBuffer 

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

func (*BlocksRequest) ProtoMessage 

func (*BlocksRequest) ProtoMessage()

func (*BlocksRequest) Reset 

func (m *BlocksRequest) Reset()

func (*BlocksRequest) Size 

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

func (*BlocksRequest) String 

func (m *BlocksRequest) String() string

func (*BlocksRequest) Unmarshal 

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

func (*BlocksRequest) XXX_DiscardUnknown 

func (m *BlocksRequest) XXX_DiscardUnknown()

func (*BlocksRequest) XXX_Marshal 

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

func (*BlocksRequest) XXX_Merge 

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

func (*BlocksRequest) XXX_MessageName 

func (*BlocksRequest) XXX_MessageName() string

func (*BlocksRequest) XXX_Size 

func (m *BlocksRequest) XXX_Size() int

func (*BlocksRequest) XXX_Unmarshal 

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

type Bound 

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 

func AbsoluteBound(index uint64) *Bound

func LatestBound 

func LatestBound() *Bound

func RelativeBound 

func RelativeBound(index uint64) *Bound

func StreamBound 

func StreamBound() *Bound

func (*Bound) Bound 

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

func (*Bound) Descriptor 

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

func (*Bound) GetIndex 

func (m *Bound) GetIndex() uint64

func (*Bound) GetType 

func (m *Bound) GetType() Bound_BoundType

func (*Bound) Marshal 

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

func (*Bound) MarshalTo 

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

func (*Bound) MarshalToSizedBuffer 

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

func (*Bound) ProtoMessage 

func (*Bound) ProtoMessage()

func (*Bound) Reset 

func (m *Bound) Reset()

func (*Bound) Size 

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

func (*Bound) String 

func (m *Bound) String() string

func (*Bound) Unmarshal 

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

func (*Bound) XXX_DiscardUnknown 

func (m *Bound) XXX_DiscardUnknown()

func (*Bound) XXX_Marshal 

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

func (*Bound) XXX_Merge 

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

func (*Bound) XXX_MessageName 

func (*Bound) XXX_MessageName() string

func (*Bound) XXX_Size 

func (m *Bound) XXX_Size() int

func (*Bound) XXX_Unmarshal 

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

type Bound_BoundType 

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 

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

func (Bound_BoundType) String 

func (x Bound_BoundType) String() string

type EventsResponse 

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 

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

func (*EventsResponse) GetEvents 

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

func (*EventsResponse) GetHeight 

func (m *EventsResponse) GetHeight() uint64

func (*EventsResponse) Marshal 

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

func (*EventsResponse) MarshalTo 

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

func (*EventsResponse) MarshalToSizedBuffer 

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

func (*EventsResponse) ProtoMessage 

func (*EventsResponse) ProtoMessage()

func (*EventsResponse) Reset 

func (m *EventsResponse) Reset()

func (*EventsResponse) Size 

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

func (*EventsResponse) String 

func (m *EventsResponse) String() string

func (*EventsResponse) Unmarshal 

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

func (*EventsResponse) XXX_DiscardUnknown 

func (m *EventsResponse) XXX_DiscardUnknown()

func (*EventsResponse) XXX_Marshal 

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

func (*EventsResponse) XXX_Merge 

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

func (*EventsResponse) XXX_MessageName 

func (*EventsResponse) XXX_MessageName() string

func (*EventsResponse) XXX_Size 

func (m *EventsResponse) XXX_Size() int

func (*EventsResponse) XXX_Unmarshal 

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

type ExecutionEventsClient 

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 

func NewExecutionEventsClient(cc grpc.ClientConnInterface) ExecutionEventsClient

type ExecutionEventsServer 

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 

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

type ExecutionEvents_EventsServer 

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

type ExecutionEvents_StreamClient 

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

type ExecutionEvents_StreamServer 

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

type GetBlockRequest 

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 

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

func (*GetBlockRequest) GetHeight 

func (m *GetBlockRequest) GetHeight() uint64

func (*GetBlockRequest) GetWait 

func (m *GetBlockRequest) GetWait() bool

func (*GetBlockRequest) Marshal 

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

func (*GetBlockRequest) MarshalTo 

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

func (*GetBlockRequest) MarshalToSizedBuffer 

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

func (*GetBlockRequest) ProtoMessage 

func (*GetBlockRequest) ProtoMessage()

func (*GetBlockRequest) Reset 

func (m *GetBlockRequest) Reset()

func (*GetBlockRequest) Size 

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

func (*GetBlockRequest) String 

func (m *GetBlockRequest) String() string

func (*GetBlockRequest) Unmarshal 

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

func (*GetBlockRequest) XXX_DiscardUnknown 

func (m *GetBlockRequest) XXX_DiscardUnknown()

func (*GetBlockRequest) XXX_Marshal 

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

func (*GetBlockRequest) XXX_Merge 

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

func (*GetBlockRequest) XXX_MessageName 

func (*GetBlockRequest) XXX_MessageName() string

func (*GetBlockRequest) XXX_Size 

func (m *GetBlockRequest) XXX_Size() int

func (*GetBlockRequest) XXX_Unmarshal 

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

type GetTxsRequest 

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 

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

func (*GetTxsRequest) GetEndHeight 

func (m *GetTxsRequest) GetEndHeight() uint64

func (*GetTxsRequest) GetQuery 

func (m *GetTxsRequest) GetQuery() string

func (*GetTxsRequest) GetStartHeight 

func (m *GetTxsRequest) GetStartHeight() uint64

func (*GetTxsRequest) Marshal 

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

func (*GetTxsRequest) MarshalTo 

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

func (*GetTxsRequest) MarshalToSizedBuffer 

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

func (*GetTxsRequest) ProtoMessage 

func (*GetTxsRequest) ProtoMessage()

func (*GetTxsRequest) Reset 

func (m *GetTxsRequest) Reset()

func (*GetTxsRequest) Size 

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

func (*GetTxsRequest) String 

func (m *GetTxsRequest) String() string

func (*GetTxsRequest) Unmarshal 

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

func (*GetTxsRequest) XXX_DiscardUnknown 

func (m *GetTxsRequest) XXX_DiscardUnknown()

func (*GetTxsRequest) XXX_Marshal 

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

func (*GetTxsRequest) XXX_Merge 

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

func (*GetTxsRequest) XXX_MessageName 

func (*GetTxsRequest) XXX_MessageName() string

func (*GetTxsRequest) XXX_Size 

func (m *GetTxsRequest) XXX_Size() int

func (*GetTxsRequest) XXX_Unmarshal 

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

type GetTxsResponse 

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 

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

func (*GetTxsResponse) GetHeight 

func (m *GetTxsResponse) GetHeight() uint64

func (*GetTxsResponse) GetTxExecutions 

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

func (*GetTxsResponse) Marshal 

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

func (*GetTxsResponse) MarshalTo 

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

func (*GetTxsResponse) MarshalToSizedBuffer 

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

func (*GetTxsResponse) ProtoMessage 

func (*GetTxsResponse) ProtoMessage()

func (*GetTxsResponse) Reset 

func (m *GetTxsResponse) Reset()

func (*GetTxsResponse) Size 

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

func (*GetTxsResponse) String 

func (m *GetTxsResponse) String() string

func (*GetTxsResponse) Unmarshal 

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

func (*GetTxsResponse) XXX_DiscardUnknown 

func (m *GetTxsResponse) XXX_DiscardUnknown()

func (*GetTxsResponse) XXX_Marshal 

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

func (*GetTxsResponse) XXX_Merge 

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

func (*GetTxsResponse) XXX_MessageName 

func (*GetTxsResponse) XXX_MessageName() string

func (*GetTxsResponse) XXX_Size 

func (m *GetTxsResponse) XXX_Size() int

func (*GetTxsResponse) XXX_Unmarshal 

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

type Provider 

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 

type TxRequest struct {
	// Height of block required
	TxHash github_com_klyed_hivesmartchain_binary.HexBytes `protobuf:"bytes,1,opt,name=TxHash,proto3,customtype=github.com/klyed/hivesmartchain/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 

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

func (*TxRequest) GetWait 

func (m *TxRequest) GetWait() bool

func (*TxRequest) Marshal 

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

func (*TxRequest) MarshalTo 

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

func (*TxRequest) MarshalToSizedBuffer 

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

func (*TxRequest) ProtoMessage 

func (*TxRequest) ProtoMessage()

func (*TxRequest) Reset 

func (m *TxRequest) Reset()

func (*TxRequest) Size 

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

func (*TxRequest) String 

func (m *TxRequest) String() string

func (*TxRequest) Unmarshal 

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

func (*TxRequest) XXX_DiscardUnknown 

func (m *TxRequest) XXX_DiscardUnknown()

func (*TxRequest) XXX_Marshal 

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

func (*TxRequest) XXX_Merge 

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

func (*TxRequest) XXX_MessageName 

func (*TxRequest) XXX_MessageName() string

func (*TxRequest) XXX_Size 

func (m *TxRequest) XXX_Size() int

func (*TxRequest) XXX_Unmarshal 

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

type UnimplementedExecutionEventsServer 

type UnimplementedExecutionEventsServer struct {
}

UnimplementedExecutionEventsServer must be embedded to have forward compatible implementations.

func (UnimplementedExecutionEventsServer) Events 

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

func (UnimplementedExecutionEventsServer) Stream 

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

func (UnimplementedExecutionEventsServer) Tx 

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

type UnsafeExecutionEventsServer 

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.