firehoseClient, closeFunc, grpcCallOpts, err := NewFirehoseClient(endpoint, jwt, insecure, plaintext) defer closeFunc() stream, err := firehoseClient.Blocks(context.Background(), request, grpcCallOpts...).