starknet

Documentation

Index

• func BlockBodiesPID(n *utils.Network) protocol.ID
• func BlockHeadersPID(n *utils.Network) protocol.ID
• func CurrentBlockHeaderPID(n *utils.Network) protocol.ID
• func EventsPID(n *utils.Network) protocol.ID
• func ReceiptsPID(n *utils.Network) protocol.ID
• func TransactionsPID(n *utils.Network) protocol.ID
• type Client
  • func NewClient(newStream NewStreamFunc, snNetwork *utils.Network, log utils.SimpleLogger) *Client
  • func (c *Client) RequestBlockBodies(ctx context.Context, req *spec.BlockBodiesRequest) (iter.Seq[*spec.BlockBodiesResponse], error)
  • func (c *Client) RequestBlockHeaders(ctx context.Context, req *spec.BlockHeadersRequest) (iter.Seq[*spec.BlockHeadersResponse], error)
  • func (c *Client) RequestCurrentBlockHeader(ctx context.Context, req *spec.CurrentBlockHeaderRequest) (iter.Seq[*spec.BlockHeadersResponse], error)
  • func (c *Client) RequestEvents(ctx context.Context, req *spec.EventsRequest) (iter.Seq[*spec.EventsResponse], error)
  • func (c *Client) RequestReceipts(ctx context.Context, req *spec.ReceiptsRequest) (iter.Seq[*spec.ReceiptsResponse], error)
  • func (c *Client) RequestTransactions(ctx context.Context, req *spec.TransactionsRequest) (iter.Seq[*spec.TransactionsResponse], error)
• type Handler
  • func NewHandler(bcReader blockchain.Reader, log utils.SimpleLogger) *Handler
  • func (h *Handler) BlockBodiesHandler(stream network.Stream)
  • func (h *Handler) BlockHeadersHandler(stream network.Stream)
  • func (h *Handler) CurrentBlockHeaderHandler(stream network.Stream)
  • func (h *Handler) EventsHandler(stream network.Stream)
  • func (h *Handler) ReceiptsHandler(stream network.Stream)
  • func (h *Handler) TransactionsHandler(stream network.Stream)
• type NewStreamFunc
• type Stream
  • func StaticStream[T any](elems ...T) Stream[T]

Functions

func BlockBodiesPID

func BlockBodiesPID(n *utils.Network) protocol.ID

func BlockHeadersPID

func BlockHeadersPID(n *utils.Network) protocol.ID

func CurrentBlockHeaderPID

func CurrentBlockHeaderPID(n *utils.Network) protocol.ID

Todo: consider merging this with BlockHeadersPID

func EventsPID

func EventsPID(n *utils.Network) protocol.ID

func ReceiptsPID

func ReceiptsPID(n *utils.Network) protocol.ID

func TransactionsPID

func TransactionsPID(n *utils.Network) protocol.ID

Types

type Client

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

func NewClient

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

func (*Client) RequestBlockBodies

func (c *Client) RequestBlockBodies(ctx context.Context, req *spec.BlockBodiesRequest) (iter.Seq[*spec.BlockBodiesResponse], error)

func (*Client) RequestBlockHeaders

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

func (*Client) RequestCurrentBlockHeader

func (c *Client) RequestCurrentBlockHeader(
	ctx context.Context, req *spec.CurrentBlockHeaderRequest,
) (iter.Seq[*spec.BlockHeadersResponse], error)

func (*Client) RequestEvents

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

func (*Client) RequestReceipts

func (c *Client) RequestReceipts(ctx context.Context, req *spec.ReceiptsRequest) (iter.Seq[*spec.ReceiptsResponse], error)

func (*Client) RequestTransactions

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

type Handler

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

func NewHandler

func NewHandler(bcReader blockchain.Reader, log utils.SimpleLogger) *Handler

func (*Handler) BlockBodiesHandler

func (h *Handler) BlockBodiesHandler(stream network.Stream)

func (*Handler) BlockHeadersHandler

func (h *Handler) BlockHeadersHandler(stream network.Stream)

func (*Handler) CurrentBlockHeaderHandler

func (h *Handler) CurrentBlockHeaderHandler(stream network.Stream)

func (*Handler) EventsHandler

func (h *Handler) EventsHandler(stream network.Stream)

func (*Handler) ReceiptsHandler

func (h *Handler) ReceiptsHandler(stream network.Stream)

func (*Handler) TransactionsHandler

func (h *Handler) TransactionsHandler(stream network.Stream)

type NewStreamFunc

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

type Stream

type Stream[T any] func() (T, bool)

Stream represents a series of messages that can be accessed by invoking Stream a number of times. After stream is entirely consumed of elements, it should return false as its second return value

func StaticStream

func StaticStream[T any](elems ...T) Stream[T]