Skip to content
Snippets Groups Projects

Resolve "Update gRPC abstraction API with missing calls and refactoring"

Merged Fabian Seidl requested to merge 359-update-grpc-abstraction-api-with-missing-calls into master
2 files
+ 57
0
Compare changes
  • Side-by-side
  • Inline
Files
2
+ 40
0
 
package api
 
 
import (
 
"context"
 
"time"
 
 
apb "code.fbi.h-da.de/danet/gosdn/api/go/gosdn/app"
 
nbi "code.fbi.h-da.de/danet/gosdn/controller/northbound/client"
 
)
 
 
// Register checks if the app already exists and if not creates a new one.
 
func Register(ctx context.Context, addr, appname, token string) (*apb.AppRegisterResponse, error) {
 
appClient, err := nbi.AppClient(addr, dialOptions...)
 
if err != nil {
 
return nil, err
 
}
 
 
req := &apb.AppRegisterRequest{
 
Timestamp: time.Now().UnixNano(),
 
Appname: appname,
 
Token: token,
 
}
 
 
return appClient.Register(ctx, req)
 
}
 
 
// Deregister deregisters an app.
 
func Deregister(ctx context.Context, addr, appname, token string) (*apb.AppDeregisterResponse, error) {
 
appClient, err := nbi.AppClient(addr, dialOptions...)
 
if err != nil {
 
return nil, err
 
}
 
 
req := &apb.AppDeregisterRequest{
 
Timestamp: time.Now().UnixNano(),
 
Appname: appname,
 
}
 
 
return appClient.Deregister(ctx, req)
 
}
Loading