starknet

Documentation

Index

• Constants
• func ClassesPID() protocol.ID
• func EventsPID() protocol.ID
• func HeadersPID() protocol.ID
• func StateDiffPID() protocol.ID
• func TransactionsPID() protocol.ID
• type Client
  • func NewClient(newStream NewStreamFunc, snNetwork *utils.Network, log utils.SimpleLogger) *Client
  • func (c *Client) RequestBlockHeaders(ctx context.Context, req *spec.BlockHeadersRequest) (iter.Seq[*spec.BlockHeadersResponse], error)
  • func (c *Client) RequestClasses(ctx context.Context, req *spec.ClassesRequest) (iter.Seq[*spec.ClassesResponse], error)
  • func (c *Client) RequestEvents(ctx context.Context, req *spec.EventsRequest) (iter.Seq[*spec.EventsResponse], error)
  • func (c *Client) RequestStateDiffs(ctx context.Context, req *spec.StateDiffsRequest) (iter.Seq[*spec.StateDiffsResponse], 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) ClassesHandler(stream network.Stream)
  • func (h *Handler) Close()
  • func (h *Handler) EventsHandler(stream network.Stream)
  • func (h *Handler) HeadersHandler(stream network.Stream)
  • func (h *Handler) StateDiffHandler(stream network.Stream)
  • func (h *Handler) TransactionsHandler(stream network.Stream)
• type NewStreamFunc

Constants

const Prefix = "/starknet"

Functions

func ClassesPID

func ClassesPID() protocol.ID

func EventsPID

func EventsPID() protocol.ID

func HeadersPID

func HeadersPID() protocol.ID

func StateDiffPID

func StateDiffPID() protocol.ID

func TransactionsPID

func TransactionsPID() 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) RequestBlockHeaders

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

func (*Client) RequestClasses

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

func (*Client) RequestEvents

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

func (*Client) RequestStateDiffs

func (c *Client) RequestStateDiffs(ctx context.Context, req *spec.StateDiffsRequest) (iter.Seq[*spec.StateDiffsResponse], 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) ClassesHandler

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

func (*Handler) Close

func (h *Handler) Close()

func (*Handler) EventsHandler

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

func (*Handler) HeadersHandler

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

func (*Handler) StateDiffHandler

func (h *Handler) StateDiffHandler(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)