|
|
|
|
@ -97,6 +97,7 @@ var (
|
|
|
|
|
|
|
|
|
|
ValidateIngressWorkerFilterFn = IngressWorkerFilterUnsupported
|
|
|
|
|
AuthorizeSessionWorkerFilterFn = AuthorizeSessionWithWorkerFilter
|
|
|
|
|
WorkerFilterDeprecationMessage = fmt.Sprintf("This field is deprecated. Use %s instead.", globals.EgressWorkerFilterField)
|
|
|
|
|
)
|
|
|
|
|
|
|
|
|
|
func IngressWorkerFilterUnsupported(string) error {
|
|
|
|
|
@ -1556,7 +1557,7 @@ func validateCreateRequest(req *pbs.CreateTargetRequest) error {
|
|
|
|
|
badFields[globals.TypeField] = "Unknown type provided."
|
|
|
|
|
}
|
|
|
|
|
if workerFilter := req.GetItem().GetWorkerFilter(); workerFilter != nil {
|
|
|
|
|
badFields[globals.WorkerFilterField] = fmt.Sprintf("This field is deprecated. Use %s instead.", globals.EgressWorkerFilterField)
|
|
|
|
|
badFields[globals.WorkerFilterField] = WorkerFilterDeprecationMessage
|
|
|
|
|
}
|
|
|
|
|
if egressFilter := req.GetItem().GetEgressWorkerFilter(); egressFilter != nil {
|
|
|
|
|
if _, err := bexpr.CreateEvaluator(egressFilter.GetValue()); err != nil {
|
|
|
|
|
|