feeder

package

v0.9.0 Latest Latest Go to latest Published: Dec 13, 2023 License: Apache-2.0 Imports: 15 Imported by: 0

Details

This section is empty.

This section is empty.

func ExponentialBackoff(wait time.Duration) time.Duration

func NopBackoff(d time.Duration) time.Duration

type Backoff func(wait time.Duration) time.Duration

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

func NewClient(clientURL string) *Client

func NewTestClient(t *testing.T, network utils.Network) *Client

NewTestClient returns a client and a function to close a test server.

func (c *Client) Block(ctx context.Context, blockID string) (*starknet.Block, error)

func (c *Client) BlockTrace(ctx context.Context, blockHash string) (*starknet.BlockTrace, error)

func (c *Client) ClassDefinition(ctx context.Context, classHash *felt.Felt) (*starknet.ClassDefinition, error)

func (c *Client) CompiledClassDefinition(ctx context.Context, classHash *felt.Felt) (json.RawMessage, error)

func (c *Client) PublicKey(ctx context.Context) (*felt.Felt, error)

func (c *Client) Signature(ctx context.Context, blockID string) (*starknet.Signature, error)

func (c *Client) StateUpdate(ctx context.Context, blockID string) (*starknet.StateUpdate, error)

func (c *Client) StateUpdateWithBlock(ctx context.Context, blockID string) (*starknet.StateUpdateWithBlock, error)

func (c *Client) Transaction(ctx context.Context, transactionHash *felt.Felt) (*starknet.TransactionStatus, error)

func (c *Client) WithBackoff(b Backoff) *Client

func (c *Client) WithListener(l EventListener) *Client

func (c *Client) WithLogger(log utils.SimpleLogger) *Client

func (c *Client) WithMaxRetries(num int) *Client

func (c *Client) WithMaxWait(d time.Duration) *Client

func (c *Client) WithMinWait(d time.Duration) *Client

func (c *Client) WithTimeout(t time.Duration) *Client

func (c *Client) WithUserAgent(ua string) *Client

type EventListener interface {
	OnResponse(urlPath string, status int, took time.Duration)
}

type SelectiveListener struct {
	OnResponseCb func(urlPath string, status int, took time.Duration)
}

func (l *SelectiveListener) OnResponse(urlPath string, status int, took time.Duration)