client

Sep 10, 2024

Changes in this version

+ func DefaultClientMetrics(namespace string) *grpc_prometheus.ClientMetrics

+ type Config struct

+ ClientMetrics *grpc_prometheus.ClientMetrics

+ DefaultCallOptions []grpc.CallOption

+ DefaultRateLimit int

+ Log zerolog.Logger

+ Retries int

+ SpecificRateLimits map[string]int

+ Timeout time.Duration

+ func DefaultConfig() Config

+ func (c Config) Interceptors() []grpc.UnaryClientInterceptor

+ type Option func(*Config)

+ func WithLog(log zerolog.Logger) Option

Mar 29, 2023

Changes in this version

+ func DefaultClientInterceptors(logger zerolog.Logger) []grpc.UnaryClientInterceptor

+ func NewConnectionWithInterceptors(target string, inter ...grpc.UnaryClientInterceptor) (*grpc.ClientConn, error)

+ func NewConnectionWithMetrics(target string, metricsNamespace string, logger zerolog.Logger) (*grpc.ClientConn, error)

Jan 19, 2023

Changes in this version

+ func NewConnection(target string, logger zerolog.Logger) (*grpc.ClientConn, error)

+ func UnaryClientInterceptor(defaultRateLimit int, methodRateLimits map[string]int, ...) grpc.UnaryClientInterceptor

+ type Client interface

+ ExecuteScriptAtBlockHeight func(ctx context.Context, height uint64, script []byte, arguments []cadence.Value) (cadence.Value, error)

+ GetBlockByHeight func(ctx context.Context, height uint64) (*flow.Block, error)

+ GetCollection func(ctx context.Context, colID flow.Identifier) (*flow.Collection, error)

+ GetEventsForHeightRange func(ctx context.Context, query flowgrpc.EventRangeQuery) ([]flow.BlockEvents, error)

+ GetLatestBlockHeader func(ctx context.Context, isSealed bool) (*flow.BlockHeader, error)

+ GetTransaction func(ctx context.Context, txID flow.Identifier) (*flow.Transaction, error)

+ func NewClientFromConnection(conn grpc.ClientConnInterface) Client

+ type ClosableClient interface

+ func NewClient(target string, logger zerolog.Logger) (ClosableClient, error)