🚀 Just launched v1 of managed rate limiting service
Support us with your feedback and questions on Product Hunt or Discord
The aperture-go SDK provides an easy way to integrate your Golang Applications
with FluxNinja Aperture. It allows flow
control functionality on fine-grained features inside service code.
Refer documentation for more details.
Run the command below to install the SDK:
go get github.com/fluxninja/aperture-go/v2The next step is to create an Aperture Client instance, for which, the address of the organization created in Aperture Cloud and API key are needed. You can locate both these details by clicking on the Aperture tab in the sidebar menu of Aperture Cloud.
ApertureClient maintains a gRPC connection with Aperture Agent.
options := aperture.Options{
DialOptions: grpcOptions,
Address: "ORGANIZATION.app.fluxninja.com",
APIKey: "API_KEY",
}
// initialize Aperture Client with the provided options.
apertureClient, err := aperture.NewClient(options)
if err != nil {
log.Fatalf("failed to create client: %v", err)
}aperture-go provides an HTTP middleware to be used with routers.
// Create a new mux router
router := mux.NewRouter()
superRouter := mux.PathPrefix("/super").Subrouter()
superRouter.HandleFunc("", a.SuperHandler)
superRouter.Use(aperturegomiddleware.NewHTTPMiddleware(apertureClient, "awesomeFeature", nil, nil, false, 2000*time.Millisecond).Handle)aperture-go provides a gRPC unary interceptor to be used with gRPC clients.
// Create a new gRPC interceptor
interceptor := aperturegomiddleware.NewGRPCUnaryInterceptor(apertureClient, "awesomeFeature", nil, false, 2000*time.Millisecond)
// Create a new gRPC server
s := grpc.NewServer(grpc.UnaryInterceptor(interceptor))Flow is created every time ApertureClient.StartFlow is called.
// StartFlow performs a flowcontrolv1.Check call to Aperture Agent. It returns a Flow object.
flow := apertureClient.StartFlow(ctx, "awesomeFeature", labels, false, 200 * time.Millisecond)
// See whether flow was accepted by Aperture Agent.
if flow.ShouldRun() {
// Simulate work being done
time.Sleep(5 * time.Second)
} else {
// Flow has been rejected by Aperture Agent.
flow.SetStatus(aperture.Error)
}
// Need to call End() on the Flow in order to provide telemetry to Aperture Agent for completing the control loop. SetStatus() method of Flow object can be used to capture whether the Flow was successful or resulted in an error. If not set, status defaults to OK.
_ = flow.End()