| Index: go/src/infra/gae/epservice/example/service_currentvalue.go
|
| diff --git a/go/src/infra/gae/epservice/example/service_currentvalue.go b/go/src/infra/gae/epservice/example/service_currentvalue.go
|
| new file mode 100644
|
| index 0000000000000000000000000000000000000000..ec64fcae55712f0ef80c3f21d0158d93593265e1
|
| --- /dev/null
|
| +++ b/go/src/infra/gae/epservice/example/service_currentvalue.go
|
| @@ -0,0 +1,43 @@
|
| +// Copyright 2015 The Chromium Authors. All rights reserved.
|
| +// Use of this source code is governed by a BSD-style license that can be
|
| +// found in the LICENSE file.
|
| +
|
| +package example
|
| +
|
| +import (
|
| + "golang.org/x/net/context"
|
| + "infra/gae/libs/wrapper"
|
| + "infra/gae/libs/wrapper/gae"
|
| +
|
| + "github.com/GoogleCloudPlatform/go-endpoints/endpoints"
|
| +)
|
| +
|
| +// CurrentValueReq describes the inputs to the CurrentValueReq RPC.
|
| +type CurrentValueReq struct {
|
| + Name string `endpoints:"required"`
|
| +}
|
| +
|
| +// CurrentValueRsp describes the outputs of the CurrentValueReq RPC.
|
| +type CurrentValueRsp struct {
|
| + Val int64 `json:",string"`
|
| +}
|
| +
|
| +// CurrentValue gets the current value of a counter (duh)
|
| +func (Example) CurrentValue(c endpoints.Context, r *CurrentValueReq) (rsp *CurrentValueRsp, err error) {
|
| + ds := wrapper.GetDS(gae.Use(context.Background(), c))
|
| +
|
| + ctr := &Counter{ID: r.Name}
|
| + if err = ds.Get(ctr); err != nil {
|
| + return
|
| + }
|
| +
|
| + rsp = &CurrentValueRsp{ctr.Val}
|
| + return
|
| +}
|
| +
|
| +func init() {
|
| + mi["CurrentValue"] = &endpoints.MethodInfo{
|
| + Path: "counter/{Name}",
|
| + Desc: "Returns the current value held by the named counter",
|
| + }
|
| +}
|
|
|