| 39 | } |
| 40 | |
| 41 | type executor struct { |
| 42 | fluxQuery flux.IFluxQuery |
| 43 | cfg InfluxdbV2Config |
| 44 | openApi api.QueryAPI |
| 45 | client influxdb2.Client |
| 46 | } |
| 47 | |
| 48 | func (e *executor) Init(ctx context.Context) error { |
| 49 | orgInfo, err := e.client.OrganizationsAPI().FindOrganizationByName(ctx, e.cfg.Org) |
nothing calls this directly
no outgoing calls
no test coverage detected