Documentation ¶
Index ¶
- Variables
- func DoRPCCalls(noArchiveNode bool, blockNum uint64, rpcClient *rpc.Client, rpcCache *RPCCache, ...) ([]*subgraph.RPCResponse, error)
- func ModeNames() []string
- type Blk
- type Indexer
- type Mode
- type Option
- type RPCCache
- func (c *RPCCache) Get(k RPCCacheKey, out interface{}) (found bool)
- func (c *RPCCache) GetRaw(k RPCCacheKey) (v []byte, found bool)
- func (_ *RPCCache) Key(prefix string, items ...interface{}) RPCCacheKey
- func (c *RPCCache) Load(ctx context.Context)
- func (c *RPCCache) Save(ctx context.Context)
- func (c *RPCCache) Set(k RPCCacheKey, v interface{})
- type RPCCacheKey
- type StoreFactory
- type SyncStatus
- type TestBlocksClient
- func (t TestBlocksClient) CloseSend() error
- func (t TestBlocksClient) Context() context.Context
- func (t TestBlocksClient) Header() (metadata.MD, error)
- func (t *TestBlocksClient) Recv() (*pbfirehose.Response, error)
- func (t TestBlocksClient) RecvMsg(m interface{}) error
- func (t TestBlocksClient) SendMsg(m interface{}) error
- func (t TestBlocksClient) Trailer() metadata.MD
- type TestIntrinsics
- func (t TestIntrinsics) Block() subgraph.BlockRef
- func (t TestIntrinsics) Load(entity entity.Interface) error
- func (t TestIntrinsics) Remove(entity entity.Interface) error
- func (t TestIntrinsics) Save(entity entity.Interface) error
- func (t TestIntrinsics) SqlSelect(dest interface{}, query string, args ...interface{}) error
- func (t TestIntrinsics) StepAbove(step int) bool
- func (t TestIntrinsics) StepBelow(step int) bool
Constants ¶
This section is empty.
Variables ¶
View Source
var MetricSet = dmetrics.NewSet()
Functions ¶
func DoRPCCalls ¶
Types ¶
type Indexer ¶
func (*Indexer) Start ¶
func (i *Indexer) Start(makeStore StoreFactory) error
type Mode ¶
type Mode uint
ENUM(
Batch Live
)
func (Mode) MarshalText ¶
MarshalText implements the text marshaller method
func (*Mode) UnmarshalText ¶
UnmarshalText implements the text unmarshaller method
type Option ¶
type Option interface {
// contains filtered or unexported methods
}
func StartBlock ¶
func UseTransactionalFlush ¶
func UseTransactionalFlush() Option
func WithNonArchiveNode ¶
func WithNonArchiveNode() Option
func WithRPCCache ¶
func WithReversible ¶
func WithReversible() Option
type RPCCache ¶
type RPCCache struct {
// contains filtered or unexported fields
}
func (*RPCCache) Get ¶
func (c *RPCCache) Get(k RPCCacheKey, out interface{}) (found bool)
func (*RPCCache) Key ¶
func (_ *RPCCache) Key(prefix string, items ...interface{}) RPCCacheKey
func (*RPCCache) Set ¶
func (c *RPCCache) Set(k RPCCacheKey, v interface{})
type RPCCacheKey ¶
type RPCCacheKey string
type StoreFactory ¶
type SyncStatus ¶
type SyncStatus struct {
// contains filtered or unexported fields
}
func NewSyncStatus ¶
func NewSyncStatus() *SyncStatus
func (*SyncStatus) Update ¶
func (s *SyncStatus) Update(blockNum uint64)
type TestBlocksClient ¶
type TestBlocksClient struct {
// contains filtered or unexported fields
}
func (TestBlocksClient) CloseSend ¶
func (t TestBlocksClient) CloseSend() error
func (TestBlocksClient) Context ¶
func (t TestBlocksClient) Context() context.Context
func (*TestBlocksClient) Recv ¶
func (t *TestBlocksClient) Recv() (*pbfirehose.Response, error)
func (pbfirehose.Stream_BlocksClient).Recv() (*pbfirehose.Response, error)
func (TestBlocksClient) RecvMsg ¶
func (t TestBlocksClient) RecvMsg(m interface{}) error
func (TestBlocksClient) SendMsg ¶
func (t TestBlocksClient) SendMsg(m interface{}) error
func (TestBlocksClient) Trailer ¶
func (t TestBlocksClient) Trailer() metadata.MD
type TestIntrinsics ¶
type TestIntrinsics struct { }
func (TestIntrinsics) Block ¶
func (t TestIntrinsics) Block() subgraph.BlockRef
func (TestIntrinsics) SqlSelect ¶
func (t TestIntrinsics) SqlSelect(dest interface{}, query string, args ...interface{}) error
func (TestIntrinsics) StepAbove ¶
func (t TestIntrinsics) StepAbove(step int) bool
func (TestIntrinsics) StepBelow ¶
func (t TestIntrinsics) StepBelow(step int) bool
Click to show internal directories.
Click to hide internal directories.