Advertisement
Guest User

Untitled

a guest
Jul 18th, 2019
87
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
Go 0.78 KB | None | 0 0
  1. package checker
  2.  
  3. import (
  4.     "errors"
  5.     "time"
  6.  
  7.     apb "google3/google/protobuf/any_go_proto"
  8.     "google3/net/proto2/go/ptypes"
  9. )
  10.  
  11. type CASChecker struct{}
  12.  
  13. func (casChecker *CASChecker) Check(any *apb.Any) (HealthState, error) {
  14.     var casCheckerReq CASCheckerRequest
  15.     if err := ptypes.UnmarshalAny(any, casCheckerReq); err != nil {
  16.         return "", errors.New("CASChecker: Check received message is not of CASCheckerRequest proto type message")
  17.     }
  18.     // send a request to CAS
  19. }
  20.  
  21. func (casChecker *CASChecker) Validate(any *apb.Any) bool {
  22.     var casCheckerReq CASCheckerRequest
  23.     if err := ptypes.UnmarshalAny(any, casCheckerReq); err != nil {
  24.         return false
  25.     }
  26.     if err := casChecker.Check(any); err != nil {
  27.         return false
  28.     }
  29.     casCheckerReq.SetArrivedAt(time.Now())
  30.     return true
  31. }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement