(ctx context.Context, tc *api.TxnContext)
| 2037 | } |
| 2038 | |
| 2039 | func validateNamespace(ctx context.Context, tc *api.TxnContext) error { |
| 2040 | if !x.WorkerConfig.AclEnabled { |
| 2041 | return nil |
| 2042 | } |
| 2043 | |
| 2044 | ns, err := x.ExtractNamespaceFrom(ctx) |
| 2045 | if err != nil { |
| 2046 | return err |
| 2047 | } |
| 2048 | if tc.Hash != getHash(ns, tc.StartTs) { |
| 2049 | return x.ErrHashMismatch |
| 2050 | } |
| 2051 | return nil |
| 2052 | } |
| 2053 | |
| 2054 | func (s *Server) UpdateExtSnapshotStreamingState(ctx context.Context, |
| 2055 | req *api.UpdateExtSnapshotStreamingStateRequest) (v *api.UpdateExtSnapshotStreamingStateResponse, err error) { |
no test coverage detected