Portable API
Wrap any driver with recording, metrics, rate limiting, and error injection
Wrap any driver with recording, metrics, rate limiting, latency, and error injection — no HTTP involved. Every service category has its own portable wrapper.
two surfaces, one backend
Basic usage#
import (
"github.com/stackshy/cloudemu/v2/services/storage"
"github.com/stackshy/cloudemu/v2/features/recorder"
"github.com/stackshy/cloudemu/v2/features/metrics"
"github.com/stackshy/cloudemu/v2/features/inject"
"github.com/stackshy/cloudemu/v2/features/ratelimit"
)
rec := &recorder.Recorder{}
mc := &metrics.Collector{}
inj := inject.NewInjector()
limiter := ratelimit.NewLimiter(100) // 100 requests/sec
bucket := storage.NewBucket(aws.S3,
storage.WithRecorder(rec),
storage.WithMetrics(mc),
storage.WithErrorInjection(inj),
storage.WithRateLimiter(limiter),
storage.WithLatency(5 * time.Millisecond),
)
// Use bucket exactly like aws.S3 — same interface
bucket.CreateBucket(ctx, "my-bucket")
bucket.PutObject(ctx, "my-bucket", "key", data, "text/plain", nil)How it works#
Every operation passes through a middleware chain:
- Error Injection — if configured, checks whether the call should fail
- Rate Limiting — if configured, checks the token bucket
- Latency — if configured, sleeps for the specified duration
- Driver Call — executes the actual operation
- Metrics — records
calls_total,call_duration,errors_total - Recording — logs service, operation, input, output, error, duration
Available wrappers#
Each service has its own portable type:
| Service | Portable Type | Import |
|---|---|---|
| Storage | storage.Bucket | cloudemu/v2/services/storage |
| Compute | compute.Compute | cloudemu/v2/services/compute |
| Database | database.Database | cloudemu/v2/services/database |
| Serverless | serverless.Serverless | cloudemu/v2/services/serverless |
| Monitoring | monitoring.Monitoring | cloudemu/v2/services/monitoring |
| Message Queue | messagequeue.MessageQueue | cloudemu/v2/services/messagequeue |
| And more... |
All wrappers support the same set of With* options.
Cross-provider testing#
The portable API lets one test body run against all three providers:
func testStorage(t *testing.T, bucket *storage.Bucket) {
ctx := context.Background()
bucket.CreateBucket(ctx, "test")
bucket.PutObject(ctx, "test", "key", []byte("value"), "text/plain", nil)
obj, err := bucket.GetObject(ctx, "test", "key")
assert.NoError(t, err)
assert.Equal(t, []byte("value"), obj.Data)
}
func TestAWS(t *testing.T) {
testStorage(t, storage.NewBucket(cloudemu.NewAWS().S3))
}
func TestAzure(t *testing.T) {
testStorage(t, storage.NewBucket(cloudemu.NewAzure().BlobStorage))
}
func TestGCP(t *testing.T) {
testStorage(t, storage.NewBucket(cloudemu.NewGCP().GCS))
}