| 334 | } |
| 335 | |
| 336 | func (s *ObjectTokenStore) ensureBucket(ctx context.Context) error { |
| 337 | exists, err := s.client.BucketExists(ctx, s.cfg.Bucket) |
| 338 | if err != nil { |
| 339 | return fmt.Errorf("object store: check bucket: %w", err) |
| 340 | } |
| 341 | if exists { |
| 342 | return nil |
| 343 | } |
| 344 | if err = s.client.MakeBucket(ctx, s.cfg.Bucket, minio.MakeBucketOptions{Region: s.cfg.Region}); err != nil { |
| 345 | return fmt.Errorf("object store: create bucket: %w", err) |
| 346 | } |
| 347 | return nil |
| 348 | } |
| 349 | |
| 350 | func (s *ObjectTokenStore) syncConfigFromBucket(ctx context.Context, example string) error { |
| 351 | key := s.prefixedKey(objectStoreConfigKey) |