Package org.apache.curator.framework.api

Examples of org.apache.curator.framework.api.ACLProvider

179
180
181
182
183
184
185
186
187
188
189
        RetryPolicy retryPolicy = ZKUtils.getRetryPolicy();
        String zkConnectionString = ConfigurationService.get(ZK_CONNECTION_STRING);
        String zkNamespace = getZKNameSpace();
        zkConnectionTimeout = ConfigurationService.getInt(ZK_CONNECTION_TIMEOUT);

        ACLProvider aclProvider;
        if (Services.get().getConf().getBoolean(ZK_SECURE, false)) {
            log.info("Connecting to ZooKeeper with SASL/Kerberos and using 'sasl' ACLs");
            setJaasConfiguration();
            System.setProperty(ZooKeeperSaslClient.LOGIN_CONTEXT_NAME_KEY, "Client");
            System.setProperty("zookeeper.authProvider.1", "org.apache.zookeeper.server.auth.SASLAuthenticationProvider");
View Full Code Here
158
159
160
161
162
163
164
165
166
    /**
     * Builds a {@link org.apache.curator.framework.CuratorFramework} from the specified {@link java.util.Map<String, ?>}.
     */
    private synchronized CuratorFramework buildCuratorFramework(CuratorConfig curatorConfig) {
        ACLProvider aclProviderInstance = aclProvider;
        List<ConnectionStateListener> connectionListenerList = connectionStateListeners;
        return createCuratorFramework(curatorConfig, aclProviderInstance, connectionListenerList);
    }
View Full Code Here
193
194
195
196
197
198
199
200
201
202
203
        }

        String      aclId = commandLine.getOptionValue(ACL_ID);
        String      aclScheme = commandLine.getOptionValue(ACL_SCHEME);
        String      aclPerms = commandLine.getOptionValue(ACL_PERMISSIONS);
        ACLProvider aclProvider = null;
        if ( notNullOrEmpty(aclId) || notNullOrEmpty(aclScheme) || notNullOrEmpty(aclPerms) )
        {
            aclProvider = getAclProvider(cli, aclId, aclScheme, aclPerms);
            if ( aclProvider == null )
            {
View Full Code Here
496
497
498
499
500
501
502
503
504
505
506
        {
            aclScheme = "";
        }

        final ACL acl = new ACL(perms, new Id(aclScheme, aclId));
        return new ACLProvider()
        {
            @Override
            public List<ACL> getDefaultAcl()
            {
                return Collections.singletonList(acl);
View Full Code Here
TOP

Related Classes of org.apache.curator.framework.api.ACLProvider

  • com.netflix.exhibitor.standalone.ExhibitorCreator
  • io.fabric8.zookeeper.curator.ManagedCuratorFramework
  • org.apache.oozie.util.ZKUtils
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.