(ctx context.Context)
| 169 | } |
| 170 | |
| 171 | func (cfg *StreamConfig) makeStorage(ctx context.Context) (storage.ExternalStorage, error) { |
| 172 | u, err := storage.ParseBackend(cfg.Storage, &cfg.BackendOptions) |
| 173 | if err != nil { |
| 174 | return nil, errors.Trace(err) |
| 175 | } |
| 176 | opts := getExternalStorageOptions(&cfg.Config, u) |
| 177 | storage, err := storage.New(ctx, u, &opts) |
| 178 | if err != nil { |
| 179 | return nil, errors.Trace(err) |
| 180 | } |
| 181 | return storage, nil |
| 182 | } |
| 183 | |
| 184 | // DefineStreamStartFlags defines flags used for `stream start` |
| 185 | func DefineStreamStartFlags(flags *pflag.FlagSet) { |
no test coverage detected