sync

package

v0.14.1 Latest Latest Go to latest Published: Mar 14, 2025 License: Apache-2.0 Imports: 25 Imported by: 0

Details

View Source

const Prefix = "/starknet"

This section is empty.

func ClassesPID() protocol.ID

func EventsPID() protocol.ID

func HeadersPID() protocol.ID

func StateDiffPID() protocol.ID

func TransactionsPID() protocol.ID

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

func NewClient(newStream NewStreamFunc, snNetwork *utils.Network, log utils.SimpleLogger) *Client

func (c *Client) RequestBlockHeaders(
	ctx context.Context, req *gen.BlockHeadersRequest,
) (iter.Seq[*gen.BlockHeadersResponse], error)

func (c *Client) RequestClasses(ctx context.Context, req *gen.ClassesRequest) (iter.Seq[*gen.ClassesResponse], error)

func (c *Client) RequestEvents(ctx context.Context, req *gen.EventsRequest) (iter.Seq[*gen.EventsResponse], error)

func (c *Client) RequestStateDiffs(ctx context.Context, req *gen.StateDiffsRequest) (iter.Seq[*gen.StateDiffsResponse], error)

func (c *Client) RequestTransactions(ctx context.Context, req *gen.TransactionsRequest) (iter.Seq[*gen.TransactionsResponse], error)

type NewStreamFunc func(ctx context.Context, pids ...protocol.ID) (network.Stream, error)

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

func New(bc *blockchain.Blockchain, h host.Host, n *utils.Network, log utils.SimpleLogger) *Service

func (s *Service) Run(ctx context.Context)

func (s *Service) WithListener(l junoSync.EventListener)