InfluxElixir.Flight.Proto.FlightService.Stub (InfluxElixir v0.1.14)

Copy Markdown View Source

Generated gRPC client stub for FlightService.

Usage

{:ok, channel} = GRPC.Stub.connect("my-influx.example.com:443",
  cred: GRPC.Credential.new(ssl: []))

ticket = %InfluxElixir.Flight.Proto.Ticket{
  ticket: Jason.encode!(%{
    "database"   => "mydb",
    "sql_query"  => "SELECT * FROM cpu",
    "query_type" => "sql"
  })
}

{:ok, stream} = InfluxElixir.Flight.Proto.FlightService.Stub.do_get(channel, ticket)

data = Enum.map(stream, fn {:ok, flight_data} -> flight_data end)

Summary

Functions

do_get(channel, request, opts \\ [])

get_flight_info(channel, request, opts \\ [])