access

Documentation

Index

• type GRPCServer
  • func NewGRPCServer(logger *zerolog.Logger, blockchain *emulator.Blockchain, ...) *GRPCServer
  • func (g *GRPCServer) Listen() error
  • func (g *GRPCServer) Server() *grpc.Server
  • func (g *GRPCServer) Start() error
  • func (g *GRPCServer) Stop()
• type GetExecutionDataFunc
• type GetStartHeightFunc
• type RestServer
  • func NewRestServer(logger *zerolog.Logger, blockchain *emulator.Blockchain, ...) (*RestServer, error)
  • func (r *RestServer) Listen() error
  • func (r *RestServer) Start() error
  • func (r *RestServer) Stop()
• type StateStreamBackend
  • func NewStateStreamBackend(blockchain *emulator.Blockchain, log zerolog.Logger) *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(ctx context.Context, filter 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(ctx context.Context, filter 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

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 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

type GetExecutionDataFunc func(context.Context, uint64) (*execution_data.BlockExecutionDataEntity, error)

type GetStartHeightFunc

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

type StateStreamBackend struct {
	// contains filtered or unexported fields
}

func NewStateStreamBackend

func NewStateStreamBackend(blockchain *emulator.Blockchain, log zerolog.Logger) *StateStreamBackend

func (*StateStreamBackend) GetExecutionDataByBlockID

func (b *StateStreamBackend) GetExecutionDataByBlockID(ctx context.Context, blockID flow.Identifier) (*execution_data.BlockExecutionData, error)

func (StateStreamBackend) GetRegisterValues

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

func (*StateStreamBackend) SubscribeAccountStatusesFromLatestBlock

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

func (*StateStreamBackend) SubscribeAccountStatusesFromStartBlockID

func (b *StateStreamBackend) SubscribeAccountStatusesFromStartBlockID(
	ctx context.Context,
	startBlockID flow.Identifier,
	filter state_stream.AccountStatusFilter,
) subscription.Subscription

func (*StateStreamBackend) SubscribeAccountStatusesFromStartHeight

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

func (StateStreamBackend) SubscribeEvents

func (b StateStreamBackend) SubscribeEvents(ctx context.Context, startBlockID flow.Identifier, startHeight uint64, filter state_stream.EventFilter) subscription.Subscription

func (*StateStreamBackend) SubscribeEventsFromLatest

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

func (*StateStreamBackend) SubscribeEventsFromStartBlockID

func (b *StateStreamBackend) SubscribeEventsFromStartBlockID(
	ctx context.Context,
	startBlockID flow.Identifier,
	filter state_stream.EventFilter,
) subscription.Subscription

func (*StateStreamBackend) SubscribeEventsFromStartHeight

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

func (*StateStreamBackend) SubscribeExecutionData

func (b *StateStreamBackend) SubscribeExecutionData(ctx context.Context, startBlockID flow.Identifier, startHeight uint64) subscription.Subscription