rpcevents

package
v0.0.0-...-25a45d7 Latest Latest
Warning

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

 Go to latest Published: Mar 5, 2019 License: Apache-2.0 Imports: 15 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")
)
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 RegisterExecutionEventsServer 

func RegisterExecutionEventsServer(s *grpc.Server, 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" json:"Start,omitempty"`
	End                  *Bound   `protobuf:"bytes,2,opt,name=End" 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 NewBlockRange 

func NewBlockRange(start, end *Bound) *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) 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 (dst *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" 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) 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 (dst *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) 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 (dst *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 ExecutionEventsClient 

type ExecutionEventsClient interface {
	// Get Blockexecution at particular height
	GetBlock(ctx context.Context, in *GetBlockRequest, opts ...grpc.CallOption) (*exec.BlockExecution, error)
	// Get BlockExecutions for a range of blocks
	GetBlocks(ctx context.Context, in *BlocksRequest, opts ...grpc.CallOption) (ExecutionEvents_GetBlocksClient, error)
	// Get a particular TxExecution
	GetTx(ctx context.Context, in *GetTxRequest, opts ...grpc.CallOption) (*exec.TxExecution, error)
	// Get TxExecutions for a range of block
	GetTxs(ctx context.Context, in *BlocksRequest, opts ...grpc.CallOption) (ExecutionEvents_GetTxsClient, 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
	GetEvents(ctx context.Context, in *BlocksRequest, opts ...grpc.CallOption) (ExecutionEvents_GetEventsClient, 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 

func NewExecutionEventsClient(cc *grpc.ClientConn) ExecutionEventsClient

type ExecutionEventsServer 

type ExecutionEventsServer interface {
	// Get Blockexecution at particular height
	GetBlock(context.Context, *GetBlockRequest) (*exec.BlockExecution, error)
	// Get BlockExecutions for a range of blocks
	GetBlocks(*BlocksRequest, ExecutionEvents_GetBlocksServer) error
	// Get a particular TxExecution
	GetTx(context.Context, *GetTxRequest) (*exec.TxExecution, error)
	// Get TxExecutions for a range of block
	GetTxs(*BlocksRequest, ExecutionEvents_GetTxsServer) 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
	GetEvents(*BlocksRequest, ExecutionEvents_GetEventsServer) error
}

ExecutionEventsServer is the server API for ExecutionEvents service.

func NewExecutionEventsServer 

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

type ExecutionEvents_GetBlocksClient 

type ExecutionEvents_GetBlocksClient interface {
	Recv() (*exec.BlockExecution, error)
	grpc.ClientStream
}

type ExecutionEvents_GetBlocksServer 

type ExecutionEvents_GetBlocksServer interface {
	Send(*exec.BlockExecution) error
	grpc.ServerStream
}

type ExecutionEvents_GetEventsClient 

type ExecutionEvents_GetEventsClient interface {
	Recv() (*GetEventsResponse, error)
	grpc.ClientStream
}

type ExecutionEvents_GetEventsServer 

type ExecutionEvents_GetEventsServer interface {
	Send(*GetEventsResponse) error
	grpc.ServerStream
}

type ExecutionEvents_GetTxsClient 

type ExecutionEvents_GetTxsClient interface {
	Recv() (*GetTxsResponse, error)
	grpc.ClientStream
}

type ExecutionEvents_GetTxsServer 

type ExecutionEvents_GetTxsServer interface {
	Send(*GetTxsResponse) 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) 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 (dst *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 GetEventsResponse 

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

func (*GetEventsResponse) Descriptor 

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

func (*GetEventsResponse) GetEvents 

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

func (*GetEventsResponse) GetHeight 

func (m *GetEventsResponse) GetHeight() uint64

func (*GetEventsResponse) Marshal 

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

func (*GetEventsResponse) MarshalTo 

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

func (*GetEventsResponse) ProtoMessage 

func (*GetEventsResponse) ProtoMessage()

func (*GetEventsResponse) Reset 

func (m *GetEventsResponse) Reset()

func (*GetEventsResponse) Size 

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

func (*GetEventsResponse) String 

func (m *GetEventsResponse) String() string

func (*GetEventsResponse) Unmarshal 

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

func (*GetEventsResponse) XXX_DiscardUnknown 

func (m *GetEventsResponse) XXX_DiscardUnknown()

func (*GetEventsResponse) XXX_Marshal 

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

func (*GetEventsResponse) XXX_Merge 

func (dst *GetEventsResponse) XXX_Merge(src proto.Message)

func (*GetEventsResponse) XXX_MessageName 

func (*GetEventsResponse) XXX_MessageName() string

func (*GetEventsResponse) XXX_Size 

func (m *GetEventsResponse) XXX_Size() int

func (*GetEventsResponse) XXX_Unmarshal 

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

type GetTxRequest 

type GetTxRequest 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 (*GetTxRequest) Descriptor 

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

func (*GetTxRequest) GetWait 

func (m *GetTxRequest) GetWait() bool

func (*GetTxRequest) Marshal 

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

func (*GetTxRequest) MarshalTo 

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

func (*GetTxRequest) ProtoMessage 

func (*GetTxRequest) ProtoMessage()

func (*GetTxRequest) Reset 

func (m *GetTxRequest) Reset()

func (*GetTxRequest) Size 

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

func (*GetTxRequest) String 

func (m *GetTxRequest) String() string

func (*GetTxRequest) Unmarshal 

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

func (*GetTxRequest) XXX_DiscardUnknown 

func (m *GetTxRequest) XXX_DiscardUnknown()

func (*GetTxRequest) XXX_Marshal 

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

func (*GetTxRequest) XXX_Merge 

func (dst *GetTxRequest) XXX_Merge(src proto.Message)

func (*GetTxRequest) XXX_MessageName 

func (*GetTxRequest) XXX_MessageName() string

func (*GetTxRequest) XXX_Size 

func (m *GetTxRequest) XXX_Size() int

func (*GetTxRequest) XXX_Unmarshal 

func (m *GetTxRequest) 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" 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) 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 (dst *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 a particular BlockExecution
	GetBlock(height uint64) (*exec.BlockExecution, error)
	// Get a partiualr TxExecution by hash
	GetTx(txHash []byte) (*exec.TxExecution, error)
	// Get events between startKey (inclusive) and endKey (exclusive) - i.e. the half open interval [start, end)
	GetBlocks(startHeight, endHeight uint64, consumer func(*exec.BlockExecution) (stop bool)) (stopped bool, err 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.