Skip to content

KIP-290 Prefixed ACLs #5117

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
ijuma merged 13 commits into from
Jun 6, 2018
Merged

KIP-290 Prefixed ACLs #5117

Show file tree
Hide file tree
Changes from 2 commits
Commits
Show all changes
13 commits
Select commit Hold shift + click to select a range
34c35aa
KAFKA-6841: Piyush changes
big-andy-coates Jun 1, 2018
8d07119
Add testing and Admin client changes.
big-andy-coates Jun 1, 2018
3f9b2ba
upgrade.html update.
big-andy-coates Jun 2, 2018
7303e7e
- review comments
big-andy-coates Jun 4, 2018
d5cca47
- don't use deprecated functions internally
big-andy-coates Jun 4, 2018
dc8a5e2
Merge branch 'trunk' into prefixed-acls
big-andy-coates Jun 4, 2018
8d37198
self review.
big-andy-coates Jun 4, 2018
105bb82
review changes
big-andy-coates Jun 5, 2018
d600682
review changesreview changes
big-andy-coates Jun 5, 2018
458e5aa
self review
big-andy-coates Jun 6, 2018
8ae4e11
Add additional test.
big-andy-coates Jun 6, 2018
b78d226
Add additional test.
big-andy-coates Jun 6, 2018
6f96d0d
Merge remote-tracking branch 'apache-github/trunk' into kip-290-acl-p…
ijuma Jun 6, 2018
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion checkstyle/import-control.xml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -146,7 +146,7 @@
</subpackage>

<subpackage name="utils">
<allow pkg="org.apache.kafka.common.metrics" />
<allow pkg="org.apache.kafka.common" />
</subpackage>
</subpackage>

Expand Down
5 changes: 1 addition & 4 deletions clients/src/main/java/org/apache/kafka/common/acl/AclBindingFilter.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -19,7 +19,6 @@

import org.apache.kafka.common.annotation.InterfaceStability;
import org.apache.kafka.common.resource.ResourceFilter;
import org.apache.kafka.common.resource.ResourceType;

import java.util.Objects;

Expand All @@ -36,9 +35,7 @@ public class AclBindingFilter {
/**
* A filter which matches any ACL binding.
*/
public static final AclBindingFilter ANY = new AclBindingFilter(
new ResourceFilter(ResourceType.ANY, null),
new AccessControlEntryFilter(null, null, AclOperation.ANY, AclPermissionType.ANY));
public static final AclBindingFilter ANY = new AclBindingFilter(ResourceFilter.ANY, AccessControlEntryFilter.ANY);

/**
* Create an instance of this filter with the provided parameters.
Expand Down
3 changes: 3 additions & 0 deletions clients/src/main/java/org/apache/kafka/common/protocol/CommonFields.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -17,6 +17,7 @@
package org.apache.kafka.common.protocol;

import org.apache.kafka.common.protocol.types.Field;
import org.apache.kafka.common.utils.AclUtils;

public class CommonFields {
public static final Field.Int32 THROTTLE_TIME_MS = new Field.Int32("throttle_time_ms",
Expand Down Expand Up @@ -45,6 +46,8 @@ public class CommonFields {
public static final Field.Int8 RESOURCE_TYPE = new Field.Int8("resource_type", "The resource type");
public static final Field.Str RESOURCE_NAME = new Field.Str("resource_name", "The resource name");
public static final Field.NullableStr RESOURCE_NAME_FILTER = new Field.NullableStr("resource_name", "The resource name filter");
public static final Field.Int8 RESOURCE_NAME_TYPE = new Field.Int8("resource_name_type", "The resource name type", AclUtils.LITERAL.code());
public static final Field.Int8 RESOURCE_NAME_TYPE_FILTER = new Field.Int8("resource_name_type", "The resource name type filter", AclUtils.LITERAL.code());

@piyushvijay piyushvijay Jun 5, 2018

Copy link
Copy Markdown
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

s/resource_name_type/resource_name_type_filter?

@big-andy-coates big-andy-coates Jun 5, 2018

Copy link
Copy Markdown
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

done.

public static final Field.Str PRINCIPAL = new Field.Str("principal", "The ACL principal");
public static final Field.NullableStr PRINCIPAL_FILTER = new Field.NullableStr("principal", "The ACL principal filter");
public static final Field.Str HOST = new Field.Str("host", "The ACL host");
Expand Down
3 changes: 3 additions & 0 deletions clients/src/main/java/org/apache/kafka/common/protocol/types/Field.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -50,6 +50,9 @@ public static class Int8 extends Field {
public Int8(String name, String docString) {
super(name, Type.INT8, docString, false, null);
}
public Int8(String name, String docString, byte defaultValue) {
super(name, Type.INT8, docString, true, defaultValue);
}
}

public static class Int32 extends Field {
Expand Down
15 changes: 13 additions & 2 deletions clients/src/main/java/org/apache/kafka/common/requests/CreateAclsRequest.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -36,6 +36,7 @@
import static org.apache.kafka.common.protocol.CommonFields.PERMISSION_TYPE;
import static org.apache.kafka.common.protocol.CommonFields.PRINCIPAL;
import static org.apache.kafka.common.protocol.CommonFields.RESOURCE_NAME;
import static org.apache.kafka.common.protocol.CommonFields.RESOURCE_NAME_TYPE;
import static org.apache.kafka.common.protocol.CommonFields.RESOURCE_TYPE;

public class CreateAclsRequest extends AbstractRequest {
Expand All @@ -51,9 +52,19 @@ public class CreateAclsRequest extends AbstractRequest {
PERMISSION_TYPE))));

/**
* The version number is bumped to indicate that on quota violation brokers send out responses before throttling.
* V1 sees a new `RESOURCE_NAME_TYPE` that controls how the resource name is interpreted.

@junrao junrao Jun 4, 2018

Copy link
Copy Markdown
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

We want to preserve the comment on quota violation.

@big-andy-coates big-andy-coates Jun 4, 2018

Copy link
Copy Markdown
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

done.

*
* For more info, see {@link org.apache.kafka.common.resource.ResourceNameType}.
*/
private static final Schema CREATE_ACLS_REQUEST_V1 = CREATE_ACLS_REQUEST_V0;
private static final Schema CREATE_ACLS_REQUEST_V1 = new Schema(
new Field(CREATIONS_KEY_NAME, new ArrayOf(new Schema(
RESOURCE_TYPE,
RESOURCE_NAME,
RESOURCE_NAME_TYPE,
PRINCIPAL,
HOST,
OPERATION,
PERMISSION_TYPE))));

@cmccabe cmccabe Jun 5, 2018

Copy link
Copy Markdown
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

I can't figure out how to add a comment to the correct line using github's terrible user interface. But on line 110 where you have the code:

        @Override
        public CreateAclsRequest build(short version) {
            return new CreateAclsRequest(version, creations);
        }

You must add verification that the version you are using supports the ACLs you are trying to send. If someone tries to set a prefix ACL when using CREATE_ACLS_REQUEST_V0, the code must throw UnsupportedVersionException. In fact, anything besides ResourceNameType.LITERAL should trigger a UVE there.

@big-andy-coates big-andy-coates Jun 5, 2018

Copy link
Copy Markdown
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Consider it done.

public static Schema[] schemaVersions() {
return new Schema[]{CREATE_ACLS_REQUEST_V0, CREATE_ACLS_REQUEST_V1};
Expand Down
3 changes: 2 additions & 1 deletion clients/src/main/java/org/apache/kafka/common/requests/CreateAclsResponse.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -43,7 +43,8 @@ public class CreateAclsResponse extends AbstractResponse {
ERROR_MESSAGE))));

/**
* The version number is bumped to indicate that on quota violation brokers send out responses before throttling.
* The version number is bumped to indicate that on quota violation brokers send out responses before throttling
* and request has additional resource_name_type
*/
private static final Schema CREATE_ACLS_RESPONSE_V1 = CREATE_ACLS_RESPONSE_V0;

Expand Down
17 changes: 14 additions & 3 deletions clients/src/main/java/org/apache/kafka/common/requests/DeleteAclsRequest.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -37,6 +37,7 @@
import static org.apache.kafka.common.protocol.CommonFields.PERMISSION_TYPE;
import static org.apache.kafka.common.protocol.CommonFields.PRINCIPAL_FILTER;
import static org.apache.kafka.common.protocol.CommonFields.RESOURCE_NAME_FILTER;
import static org.apache.kafka.common.protocol.CommonFields.RESOURCE_NAME_TYPE_FILTER;
import static org.apache.kafka.common.protocol.CommonFields.RESOURCE_TYPE;

public class DeleteAclsRequest extends AbstractRequest {
Expand All @@ -52,9 +53,19 @@ public class DeleteAclsRequest extends AbstractRequest {
PERMISSION_TYPE))));

/**
* The version number is bumped to indicate that on quota violation brokers send out responses before throttling.
* V1 sees a new `RESOURCE_NAME_TYPE_FILTER` that controls how the filter handles different resource name types.

@junrao junrao Jun 4, 2018

Copy link
Copy Markdown
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

We want to preserve the comment on quota violation.

@big-andy-coates big-andy-coates Jun 4, 2018

Copy link
Copy Markdown
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

done.

*
* For more info, see {@link org.apache.kafka.common.resource.ResourceNameType}.
*/
private static final Schema DELETE_ACLS_REQUEST_V1 = DELETE_ACLS_REQUEST_V0;
private static final Schema DELETE_ACLS_REQUEST_V1 = new Schema(
new Field(FILTERS, new ArrayOf(new Schema(
RESOURCE_TYPE,
RESOURCE_NAME_FILTER,
RESOURCE_NAME_TYPE_FILTER,
PRINCIPAL_FILTER,
HOST_FILTER,
OPERATION,
PERMISSION_TYPE))));

public static Schema[] schemaVersions() {
return new Schema[]{DELETE_ACLS_REQUEST_V0, DELETE_ACLS_REQUEST_V1};
Expand Down Expand Up @@ -124,7 +135,7 @@ public AbstractResponse getErrorResponse(int throttleTimeMs, Throwable throwable
List<DeleteAclsResponse.AclFilterResponse> responses = new ArrayList<>();
for (int i = 0; i < filters.size(); i++) {
responses.add(new DeleteAclsResponse.AclFilterResponse(
ApiError.fromThrowable(throwable), Collections.<DeleteAclsResponse.AclDeletionResult>emptySet()));
ApiError.fromThrowable(throwable), Collections.<DeleteAclsResponse.AclDeletionResult>emptySet()));
}
return new DeleteAclsResponse(throttleTimeMs, responses);
default:
Expand Down
35 changes: 30 additions & 5 deletions clients/src/main/java/org/apache/kafka/common/requests/DeleteAclsResponse.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -19,10 +19,10 @@
import org.apache.kafka.common.acl.AccessControlEntry;
import org.apache.kafka.common.acl.AclBinding;
import org.apache.kafka.common.protocol.ApiKeys;
import org.apache.kafka.common.protocol.Errors;
import org.apache.kafka.common.protocol.types.ArrayOf;
import org.apache.kafka.common.protocol.types.Field;
import org.apache.kafka.common.protocol.types.Schema;
import org.apache.kafka.common.protocol.Errors;
import org.apache.kafka.common.protocol.types.Struct;
import org.apache.kafka.common.resource.Resource;
import org.apache.kafka.common.utils.Utils;
Expand All @@ -43,6 +43,7 @@
import static org.apache.kafka.common.protocol.CommonFields.PERMISSION_TYPE;
import static org.apache.kafka.common.protocol.CommonFields.PRINCIPAL;
import static org.apache.kafka.common.protocol.CommonFields.RESOURCE_NAME;
import static org.apache.kafka.common.protocol.CommonFields.RESOURCE_NAME_TYPE;
import static org.apache.kafka.common.protocol.CommonFields.RESOURCE_TYPE;
import static org.apache.kafka.common.protocol.CommonFields.THROTTLE_TIME_MS;

Expand All @@ -51,11 +52,27 @@ public class DeleteAclsResponse extends AbstractResponse {
private final static String FILTER_RESPONSES_KEY_NAME = "filter_responses";
private final static String MATCHING_ACLS_KEY_NAME = "matching_acls";

private static final Schema MATCHING_ACL = new Schema(
private static final Schema MATCHING_ACL_V0 = new Schema(
ERROR_CODE,
ERROR_MESSAGE,
RESOURCE_TYPE,
RESOURCE_NAME,
PRINCIPAL,
HOST,
OPERATION,
PERMISSION_TYPE);

/**
* V1 sees a new `RESOURCE_NAME_TYPE` that describes how the resource name is interpreted.
*
* For more info, see {@link org.apache.kafka.common.resource.ResourceNameType}.
*/
private static final Schema MATCHING_ACL_V1 = new Schema(
ERROR_CODE,
ERROR_MESSAGE,
RESOURCE_TYPE,
RESOURCE_NAME,
RESOURCE_NAME_TYPE,
PRINCIPAL,
HOST,
OPERATION,
Expand All @@ -67,12 +84,20 @@ public class DeleteAclsResponse extends AbstractResponse {
new ArrayOf(new Schema(
ERROR_CODE,
ERROR_MESSAGE,
new Field(MATCHING_ACLS_KEY_NAME, new ArrayOf(MATCHING_ACL), "The matching ACLs")))));
new Field(MATCHING_ACLS_KEY_NAME, new ArrayOf(MATCHING_ACL_V0), "The matching ACLs")))));

/**
* The version number is bumped to indicate that on quota violation brokers send out responses before throttling.
* V1 sees a new `RESOURCE_NAME_TYPE` field added to MATCHING_ACL_V1, that describes how the resource name is interpreted.

@junrao junrao Jun 4, 2018

Copy link
Copy Markdown
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

We want to preserve the comment on quota violation.

@big-andy-coates big-andy-coates Jun 4, 2018

Copy link
Copy Markdown
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

done.

*
* For more info, see {@link org.apache.kafka.common.resource.ResourceNameType}.
*/
private static final Schema DELETE_ACLS_RESPONSE_V1 = DELETE_ACLS_RESPONSE_V0;
private static final Schema DELETE_ACLS_RESPONSE_V1 = new Schema(
THROTTLE_TIME_MS,
new Field(FILTER_RESPONSES_KEY_NAME,
new ArrayOf(new Schema(
ERROR_CODE,
ERROR_MESSAGE,
new Field(MATCHING_ACLS_KEY_NAME, new ArrayOf(MATCHING_ACL_V1), "The matching ACLs")))));

public static Schema[] schemaVersions() {
return new Schema[]{DELETE_ACLS_RESPONSE_V0, DELETE_ACLS_RESPONSE_V1};
Expand Down
14 changes: 12 additions & 2 deletions clients/src/main/java/org/apache/kafka/common/requests/DescribeAclsRequest.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -32,6 +32,7 @@
import static org.apache.kafka.common.protocol.CommonFields.PERMISSION_TYPE;
import static org.apache.kafka.common.protocol.CommonFields.PRINCIPAL_FILTER;
import static org.apache.kafka.common.protocol.CommonFields.RESOURCE_NAME_FILTER;
import static org.apache.kafka.common.protocol.CommonFields.RESOURCE_NAME_TYPE_FILTER;
import static org.apache.kafka.common.protocol.CommonFields.RESOURCE_TYPE;

public class DescribeAclsRequest extends AbstractRequest {
Expand All @@ -44,9 +45,18 @@ public class DescribeAclsRequest extends AbstractRequest {
PERMISSION_TYPE);

/**
* The version number is bumped to indicate that on quota violation brokers send out responses before throttling.
* V1 sees a new `RESOURCE_NAME_TYPE_FILTER` that controls how the filter handles different resource name types.

@junrao junrao Jun 4, 2018

Copy link
Copy Markdown
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

We want to preserve the comment on quota violation.

@big-andy-coates big-andy-coates Jun 4, 2018

Copy link
Copy Markdown
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

done

*
* For more info, see {@link org.apache.kafka.common.resource.ResourceNameType}.
*/
private static final Schema DESCRIBE_ACLS_REQUEST_V1 = DESCRIBE_ACLS_REQUEST_V0;
private static final Schema DESCRIBE_ACLS_REQUEST_V1 = new Schema(
RESOURCE_TYPE,
RESOURCE_NAME_FILTER,
RESOURCE_NAME_TYPE_FILTER,
PRINCIPAL_FILTER,
HOST_FILTER,
OPERATION,
PERMISSION_TYPE);

public static Schema[] schemaVersions() {
return new Schema[]{DESCRIBE_ACLS_REQUEST_V0, DESCRIBE_ACLS_REQUEST_V1};
Expand Down
32 changes: 27 additions & 5 deletions clients/src/main/java/org/apache/kafka/common/requests/DescribeAclsResponse.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -20,10 +20,10 @@
import org.apache.kafka.common.acl.AccessControlEntry;
import org.apache.kafka.common.acl.AclBinding;
import org.apache.kafka.common.protocol.ApiKeys;
import org.apache.kafka.common.protocol.Errors;
import org.apache.kafka.common.protocol.types.ArrayOf;
import org.apache.kafka.common.protocol.types.Field;
import org.apache.kafka.common.protocol.types.Schema;
import org.apache.kafka.common.protocol.Errors;
import org.apache.kafka.common.protocol.types.Struct;
import org.apache.kafka.common.resource.Resource;

Expand All @@ -41,14 +41,15 @@
import static org.apache.kafka.common.protocol.CommonFields.PERMISSION_TYPE;
import static org.apache.kafka.common.protocol.CommonFields.PRINCIPAL;
import static org.apache.kafka.common.protocol.CommonFields.RESOURCE_NAME;
import static org.apache.kafka.common.protocol.CommonFields.RESOURCE_NAME_TYPE;
import static org.apache.kafka.common.protocol.CommonFields.RESOURCE_TYPE;
import static org.apache.kafka.common.protocol.CommonFields.THROTTLE_TIME_MS;

public class DescribeAclsResponse extends AbstractResponse {
private final static String RESOURCES_KEY_NAME = "resources";
private final static String ACLS_KEY_NAME = "acls";

private static final Schema DESCRIBE_ACLS_RESOURCE = new Schema(
private static final Schema DESCRIBE_ACLS_RESOURCE_V0 = new Schema(
RESOURCE_TYPE,
RESOURCE_NAME,
new Field(ACLS_KEY_NAME, new ArrayOf(new Schema(
Expand All @@ -57,16 +58,37 @@ public class DescribeAclsResponse extends AbstractResponse {
OPERATION,
PERMISSION_TYPE))));

/**
* V1 sees a new `RESOURCE_NAME_TYPE` that describes how the resource name is interpreted.
*
* For more info, see {@link org.apache.kafka.common.resource.ResourceNameType}.
*/
private static final Schema DESCRIBE_ACLS_RESOURCE_V1 = new Schema(
RESOURCE_TYPE,
RESOURCE_NAME,
RESOURCE_NAME_TYPE,
new Field(ACLS_KEY_NAME, new ArrayOf(new Schema(
PRINCIPAL,
HOST,
OPERATION,
PERMISSION_TYPE))));

private static final Schema DESCRIBE_ACLS_RESPONSE_V0 = new Schema(
THROTTLE_TIME_MS,
ERROR_CODE,
ERROR_MESSAGE,
new Field(RESOURCES_KEY_NAME, new ArrayOf(DESCRIBE_ACLS_RESOURCE), "The resources and their associated ACLs."));
new Field(RESOURCES_KEY_NAME, new ArrayOf(DESCRIBE_ACLS_RESOURCE_V0), "The resources and their associated ACLs."));

/**
* The version number is bumped to indicate that on quota violation brokers send out responses before throttling.
* V1 sees a new `RESOURCE_NAME_TYPE` field added to DESCRIBE_ACLS_RESOURCE_V1, that describes how the resource name is interpreted.

@junrao junrao Jun 4, 2018

Copy link
Copy Markdown
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

We want to preserve the comment on quota violation.

@big-andy-coates big-andy-coates Jun 4, 2018

Copy link
Copy Markdown
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

done.

*
* For more info, see {@link org.apache.kafka.common.resource.ResourceNameType}.
*/
private static final Schema DESCRIBE_ACLS_RESPONSE_V1 = DESCRIBE_ACLS_RESPONSE_V0;
private static final Schema DESCRIBE_ACLS_RESPONSE_V1 = new Schema(
THROTTLE_TIME_MS,
ERROR_CODE,
ERROR_MESSAGE,
new Field(RESOURCES_KEY_NAME, new ArrayOf(DESCRIBE_ACLS_RESOURCE_V1), "The resources and their associated ACLs."));

public static Schema[] schemaVersions() {
return new Schema[]{DESCRIBE_ACLS_RESPONSE_V0, DESCRIBE_ACLS_RESPONSE_V1};
Expand Down
21 changes: 19 additions & 2 deletions clients/src/main/java/org/apache/kafka/common/requests/RequestUtils.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -24,6 +24,7 @@
import org.apache.kafka.common.resource.Resource;
import org.apache.kafka.common.resource.ResourceFilter;
import org.apache.kafka.common.resource.ResourceType;
import org.apache.kafka.common.resource.ResourceNameType;

import static org.apache.kafka.common.protocol.CommonFields.HOST;
import static org.apache.kafka.common.protocol.CommonFields.HOST_FILTER;
Expand All @@ -33,6 +34,8 @@
import static org.apache.kafka.common.protocol.CommonFields.PRINCIPAL_FILTER;
import static org.apache.kafka.common.protocol.CommonFields.RESOURCE_NAME;
import static org.apache.kafka.common.protocol.CommonFields.RESOURCE_NAME_FILTER;
import static org.apache.kafka.common.protocol.CommonFields.RESOURCE_NAME_TYPE;
import static org.apache.kafka.common.protocol.CommonFields.RESOURCE_NAME_TYPE_FILTER;
import static org.apache.kafka.common.protocol.CommonFields.RESOURCE_TYPE;

final class RequestUtils {
Expand All @@ -42,23 +45,37 @@ private RequestUtils() {}
static Resource resourceFromStructFields(Struct struct) {
byte resourceType = struct.get(RESOURCE_TYPE);
String name = struct.get(RESOURCE_NAME);
return new Resource(ResourceType.fromCode(resourceType), name);
ResourceNameType resourceNameType = ResourceNameType.LITERAL;
if (struct.hasField(RESOURCE_NAME_TYPE)) {
resourceNameType = ResourceNameType.fromCode(struct.get(RESOURCE_NAME_TYPE));
}
return new Resource(ResourceType.fromCode(resourceType), name, resourceNameType);
}

static void resourceSetStructFields(Resource resource, Struct struct) {
struct.set(RESOURCE_TYPE, resource.resourceType().code());
struct.set(RESOURCE_NAME, resource.name());
if (struct.hasField(RESOURCE_NAME_TYPE)) {
struct.set(RESOURCE_NAME_TYPE, resource.resourceNameType().code());
}
}

static ResourceFilter resourceFilterFromStructFields(Struct struct) {
byte resourceType = struct.get(RESOURCE_TYPE);
String name = struct.get(RESOURCE_NAME_FILTER);
return new ResourceFilter(ResourceType.fromCode(resourceType), name);
ResourceNameType resourceNameType = ResourceNameType.LITERAL;
if (struct.hasField(RESOURCE_NAME_TYPE_FILTER)) {
resourceNameType = ResourceNameType.fromCode(struct.get(RESOURCE_NAME_TYPE_FILTER));
}
return new ResourceFilter(ResourceType.fromCode(resourceType), name, resourceNameType);
}

static void resourceFilterSetStructFields(ResourceFilter resourceFilter, Struct struct) {
struct.set(RESOURCE_TYPE, resourceFilter.resourceType().code());
struct.set(RESOURCE_NAME_FILTER, resourceFilter.name());
if (struct.hasField(RESOURCE_NAME_TYPE_FILTER)) {
struct.set(RESOURCE_NAME_TYPE_FILTER, resourceFilter.resourceNameType().code());
}
}

static AccessControlEntry aceFromStructFields(Struct struct) {
Expand Down
Loading