starknet

Documentation

Index

• func BlockBodiesPID(n utils.Network) protocol.ID
• func BlockHeadersPID(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.Logger) *Client
  • func (c *Client) RequestBlockBodies(ctx context.Context, req *spec.BlockBodiesRequest) (Stream[*spec.BlockBodiesResponse], error)
  • func (c *Client) RequestBlockHeaders(ctx context.Context, req *spec.BlockHeadersRequest) (Stream[*spec.BlockHeadersResponse], error)
  • func (c *Client) RequestEvents(ctx context.Context, req *spec.EventsRequest) (Stream[*spec.EventsResponse], error)
  • func (c *Client) RequestReceipts(ctx context.Context, req *spec.ReceiptsRequest) (Stream[*spec.ReceiptsResponse], error)
  • func (c *Client) RequestTransactions(ctx context.Context, req *spec.TransactionsRequest) (Stream[*spec.TransactionsResponse], error)
• type Handler
  • func NewHandler(bcReader blockchain.Reader, log utils.Logger) *Handler
  • func (h *Handler) BlockBodiesHandler(stream network.Stream)
  • func (h *Handler) BlockHeadersHandler(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 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.Logger) *Client

func (*Client) RequestBlockBodies

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

func (*Client) RequestBlockHeaders

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

func (*Client) RequestEvents

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

func (*Client) RequestReceipts

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

func (*Client) RequestTransactions

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

type Handler

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

func NewHandler

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

func (*Handler) BlockBodiesHandler

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

func (*Handler) BlockHeadersHandler

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