Documentation
¶
Index ¶
- type GRPCServer
- type GetExecutionDataFunc
- type GetStartHeightFunc
- type RestServer
- type StateStreamBackend
- func (b *StateStreamBackend) GetExecutionDataByBlockID(ctx context.Context, blockID flow.Identifier) (*execution_data.BlockExecutionData, error)
- func (b StateStreamBackend) GetRegisterValues(registerIDs flow.RegisterIDs, height uint64) ([]flow.RegisterValue, error)
- func (b StateStreamBackend) SubscribeAccountStatusesFromLatestBlock(context.Context, state_stream.AccountStatusFilter) subscription.Subscription
- func (b StateStreamBackend) SubscribeAccountStatusesFromStartBlockID(ctx context.Context, startBlockID flow.Identifier, ...) subscription.Subscription
- func (b StateStreamBackend) SubscribeAccountStatusesFromStartHeight(ctx context.Context, startHeight uint64, ...) subscription.Subscription
- func (b StateStreamBackend) SubscribeEvents(ctx context.Context, startBlockID flow.Identifier, startHeight uint64, ...) subscription.Subscription
- func (b StateStreamBackend) SubscribeEventsFromLatest(context.Context, state_stream.EventFilter) subscription.Subscription
- func (b StateStreamBackend) SubscribeEventsFromStartBlockID(ctx context.Context, startBlockID flow.Identifier, ...) subscription.Subscription
- func (b StateStreamBackend) SubscribeEventsFromStartHeight(ctx context.Context, startHeight uint64, filter state_stream.EventFilter) subscription.Subscription
- func (b *StateStreamBackend) SubscribeExecutionData(ctx context.Context, startBlockID flow.Identifier, startHeight uint64) subscription.Subscription
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type GRPCServer ¶
type GRPCServer struct {
// contains filtered or unexported fields
}
func NewGRPCServer ¶
func NewGRPCServer(logger *zerolog.Logger, adapter *adapters.AccessAdapter, chain flow.Chain, host string, port int, debug bool) *GRPCServer
func (*GRPCServer) Listen ¶
func (g *GRPCServer) Listen() error
func (*GRPCServer) Server ¶
func (g *GRPCServer) Server() *grpc.Server
func (*GRPCServer) Start ¶
func (g *GRPCServer) Start() error
func (*GRPCServer) Stop ¶
func (g *GRPCServer) Stop()
type GetExecutionDataFunc ¶ added in v0.58.0
type GetExecutionDataFunc func(context.Context, uint64) (*execution_data.BlockExecutionDataEntity, error)
type GetStartHeightFunc ¶ added in v0.58.0
type GetStartHeightFunc func(flow.Identifier, uint64) (uint64, error)
type RestServer ¶
type RestServer struct {
// contains filtered or unexported fields
}
func NewRestServer ¶
func NewRestServer(logger *zerolog.Logger, blockchain *emulator.Blockchain, adapter *adapters.AccessAdapter, chain flow.Chain, host string, port int, debug bool) (*RestServer, error)
func (*RestServer) Listen ¶
func (r *RestServer) Listen() error
func (*RestServer) Start ¶
func (r *RestServer) Start() error
func (*RestServer) Stop ¶
func (r *RestServer) Stop()
type StateStreamBackend ¶ added in v0.58.0
type StateStreamBackend struct {
// contains filtered or unexported fields
}
func NewStateStreamBackend ¶ added in v0.58.0
func NewStateStreamBackend(blockchain *emulator.Blockchain, log zerolog.Logger) *StateStreamBackend
func (*StateStreamBackend) GetExecutionDataByBlockID ¶ added in v0.58.0
func (b *StateStreamBackend) GetExecutionDataByBlockID(ctx context.Context, blockID flow.Identifier) (*execution_data.BlockExecutionData, error)
func (StateStreamBackend) GetRegisterValues ¶ added in v0.59.0
func (b StateStreamBackend) GetRegisterValues(registerIDs flow.RegisterIDs, height uint64) ([]flow.RegisterValue, error)
func (StateStreamBackend) SubscribeAccountStatusesFromLatestBlock ¶ added in v0.62.0
func (b StateStreamBackend) SubscribeAccountStatusesFromLatestBlock(context.Context, state_stream.AccountStatusFilter) subscription.Subscription
func (StateStreamBackend) SubscribeAccountStatusesFromStartBlockID ¶ added in v0.62.0
func (b StateStreamBackend) SubscribeAccountStatusesFromStartBlockID(ctx context.Context, startBlockID flow.Identifier, filter state_stream.AccountStatusFilter) subscription.Subscription
func (StateStreamBackend) SubscribeAccountStatusesFromStartHeight ¶ added in v0.62.0
func (b StateStreamBackend) SubscribeAccountStatusesFromStartHeight(ctx context.Context, startHeight uint64, filter state_stream.AccountStatusFilter) subscription.Subscription
func (StateStreamBackend) SubscribeEvents ¶ added in v0.58.0
func (b StateStreamBackend) SubscribeEvents(ctx context.Context, startBlockID flow.Identifier, startHeight uint64, filter state_stream.EventFilter) subscription.Subscription
func (StateStreamBackend) SubscribeEventsFromLatest ¶ added in v0.62.0
func (b StateStreamBackend) SubscribeEventsFromLatest(context.Context, state_stream.EventFilter) subscription.Subscription
func (StateStreamBackend) SubscribeEventsFromStartBlockID ¶ added in v0.62.0
func (b StateStreamBackend) SubscribeEventsFromStartBlockID(ctx context.Context, startBlockID flow.Identifier, filter state_stream.EventFilter) subscription.Subscription
func (StateStreamBackend) SubscribeEventsFromStartHeight ¶ added in v0.62.0
func (b StateStreamBackend) SubscribeEventsFromStartHeight(ctx context.Context, startHeight uint64, filter state_stream.EventFilter) subscription.Subscription
func (*StateStreamBackend) SubscribeExecutionData ¶ added in v0.58.0
func (b *StateStreamBackend) SubscribeExecutionData(ctx context.Context, startBlockID flow.Identifier, startHeight uint64) subscription.Subscription
Source Files
Click to show internal directories.
Click to hide internal directories.