-
Notifications
You must be signed in to change notification settings - Fork 28
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
* commit server,agents,clients, AMP Bootstrap and fixes reports (#519) * add bootstrap feature to AMP cluster CLI (#306) * update vendors (huge diff) * serverless prototype (#539) * Amp cleanup (#603) * Fix for issues #547,#561,#565 * minor cleanup * commit server,agents,clients, AMP Bootstrap and fixes reports (#519) * add bootstrap feature to AMP cluster CLI (#306) * update vendors (huge diff) * serverless prototype (#539) * Amp version more useful info
- Loading branch information
Showing
289 changed files
with
16,250 additions
and
2,033 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,80 @@ | ||
| package function | ||
|
|
||
| import ( | ||
| "github.com/appcelerator/amp/config" | ||
| "github.com/appcelerator/amp/data/storage" | ||
| "github.com/appcelerator/amp/pkg/nats-streaming" | ||
| "github.com/docker/docker/pkg/stringid" | ||
| "github.com/golang/protobuf/proto" | ||
| "golang.org/x/net/context" | ||
| "google.golang.org/grpc" | ||
| "google.golang.org/grpc/codes" | ||
| "log" | ||
| "path" | ||
| "strings" | ||
| ) | ||
|
|
||
| // Server is used to implement function.FunctionServer | ||
| type Server struct { | ||
| Store storage.Interface | ||
| NatsStreaming ns.NatsStreaming | ||
| } | ||
|
|
||
| // Create implements function.Server | ||
| func (s *Server) Create(ctx context.Context, in *CreateRequest) (*CreateReply, error) { | ||
| log.Println("rpc-function: Create", in.String()) | ||
| // Validate the function | ||
| fn := in.Function | ||
| fn.Name = strings.TrimSpace(fn.Name) | ||
| fn.Image = strings.TrimSpace(fn.Image) | ||
| if fn.Name == "" { | ||
| return nil, grpc.Errorf(codes.InvalidArgument, "function name is mandatory") | ||
| } | ||
| if fn.Image == "" { | ||
| return nil, grpc.Errorf(codes.InvalidArgument, "docker image is mandatory") | ||
| } | ||
|
|
||
| // Check if the function already exists | ||
| reply, err := s.List(ctx, &ListRequest{}) | ||
| if err != nil { | ||
| return nil, grpc.Errorf(codes.Internal, "error listing functions: %v, err") | ||
| } | ||
| for _, fn := range reply.Functions { | ||
| if strings.EqualFold(fn.Name, in.Function.Name) { | ||
| return nil, grpc.Errorf(codes.AlreadyExists, "function already exists: %s", in.Function.Name) | ||
| } | ||
| } | ||
|
|
||
| // Store the function | ||
| fn.Id = stringid.GenerateNonCryptoID() | ||
| if err := s.Store.Create(ctx, path.Join(amp.EtcdFunctionRootKey, fn.Id), fn, nil, 0); err != nil { | ||
| return nil, grpc.Errorf(codes.Internal, "error creating function: %v", err) | ||
| } | ||
| log.Println("Created function:", fn.String()) | ||
| return &CreateReply{Function: fn}, nil | ||
| } | ||
|
|
||
| // List implements function.Server | ||
| func (s *Server) List(ctx context.Context, in *ListRequest) (*ListReply, error) { | ||
| log.Println("rpc-function: List", in.String()) | ||
| var functions []proto.Message | ||
| if err := s.Store.List(ctx, amp.EtcdFunctionRootKey, storage.Everything, &FunctionEntry{}, &functions); err != nil { | ||
| return nil, grpc.Errorf(codes.Internal, "error listing functions: %v", err) | ||
| } | ||
| reply := &ListReply{} | ||
| for _, function := range functions { | ||
| reply.Functions = append(reply.Functions, function.(*FunctionEntry)) | ||
| } | ||
| log.Println("Listed functions") | ||
| return reply, nil | ||
| } | ||
|
|
||
| // Delete implements function.Server | ||
| func (s *Server) Delete(ctx context.Context, in *DeleteRequest) (*DeleteReply, error) { | ||
| log.Println("rpc-function: Delete", in.String()) | ||
| if err := s.Store.Delete(ctx, path.Join(amp.EtcdFunctionRootKey, in.Id), false, nil); err != nil { | ||
| return nil, grpc.Errorf(codes.NotFound, "function not found: %s", in.Id) | ||
| } | ||
| log.Println("Deleted function id: ", in.Id) | ||
| return &DeleteReply{}, nil | ||
| } |
Oops, something went wrong.