client

Documentation

Index

• func NewSubstreamsClient(endpoint, jwt string, useInsecureTLSConnection, usePlainTextConnection bool) (cli pbsubstreams.StreamClient, closeFunc func() error, ...)

Functions

func NewSubstreamsClient

func NewSubstreamsClient(endpoint, jwt string, useInsecureTLSConnection, usePlainTextConnection bool) (cli pbsubstreams.StreamClient, closeFunc func() error, callOpts []grpc.CallOption, err error)

FIXME(abourget): plz no closeFunc() in here? We embed in our own struct and pass that around? Also, let's not have this being called from within the Firehose, let's pass the parameters down and let the `substreams` engine manage all those connections. This will avoid us needing to go to all `sf-chain` implementations to tweak for something that clearly belongs only inside Substreams.