access

package
v1.11.0 Latest Latest
Warning

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

 Go to latest Published: Nov 6, 2025 License: Apache-2.0 Imports: 41 Imported by: 0

Documentation

Index

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, blockchain *emulator.Blockchain, adapter *adapters.AccessAdapter, chain flowgo.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(flowgo.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 flowgo.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()

func (*RestServer) UseMiddleware added in v1.4.0 

func (r *RestServer) UseMiddleware(middleware func(http.Handler) http.Handler)

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 flowgo.Identifier) (*execution_data.BlockExecutionData, error)

func (*StateStreamBackend) GetRegisterValues added in v0.59.0 

func (b *StateStreamBackend) GetRegisterValues(registerIDs flowgo.RegisterIDs, height uint64) ([]flowgo.RegisterValue, error)

func (*StateStreamBackend) SubscribeAccountStatusesFromLatestBlock added in v0.62.0 

func (b *StateStreamBackend) SubscribeAccountStatusesFromLatestBlock(
	ctx context.Context,
	filter state_stream.AccountStatusFilter,
) subscription.Subscription

func (*StateStreamBackend) SubscribeAccountStatusesFromStartBlockID added in v0.62.0 

func (b *StateStreamBackend) SubscribeAccountStatusesFromStartBlockID(
	ctx context.Context,
	startBlockID flowgo.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 flowgo.Identifier, startHeight uint64, filter state_stream.EventFilter) subscription.Subscription

func (*StateStreamBackend) SubscribeEventsFromLatest added in v0.62.0 

func (b *StateStreamBackend) SubscribeEventsFromLatest(
	ctx context.Context,
	filter state_stream.EventFilter,
) subscription.Subscription

func (*StateStreamBackend) SubscribeEventsFromStartBlockID added in v0.62.0 

func (b *StateStreamBackend) SubscribeEventsFromStartBlockID(
	ctx context.Context,
	startBlockID flowgo.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 flowgo.Identifier, startHeight uint64) subscription.Subscription

func (*StateStreamBackend) SubscribeExecutionDataFromLatest added in v1.0.0 

func (b *StateStreamBackend) SubscribeExecutionDataFromLatest(ctx context.Context) subscription.Subscription

func (*StateStreamBackend) SubscribeExecutionDataFromStartBlockHeight added in v1.0.0 

func (b *StateStreamBackend) SubscribeExecutionDataFromStartBlockHeight(ctx context.Context, startBlockHeight uint64) subscription.Subscription

func (*StateStreamBackend) SubscribeExecutionDataFromStartBlockID added in v1.0.0 

func (b *StateStreamBackend) SubscribeExecutionDataFromStartBlockID(ctx context.Context, startBlockID flowgo.Identifier) subscription.Subscription

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.