Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- package checker
- import (
- "errors"
- "time"
- apb "google3/google/protobuf/any_go_proto"
- "google3/net/proto2/go/ptypes"
- )
- type CASChecker struct{}
- func (casChecker *CASChecker) Check(any *apb.Any) (HealthState, error) {
- var casCheckerReq CASCheckerRequest
- if err := ptypes.UnmarshalAny(any, casCheckerReq); err != nil {
- return "", errors.New("CASChecker: Check received message is not of CASCheckerRequest proto type message")
- }
- // send a request to CAS
- }
- func (casChecker *CASChecker) Validate(any *apb.Any) bool {
- var casCheckerReq CASCheckerRequest
- if err := ptypes.UnmarshalAny(any, casCheckerReq); err != nil {
- return false
- }
- if err := casChecker.Check(any); err != nil {
- return false
- }
- casCheckerReq.SetArrivedAt(time.Now())
- return true
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement