Package org.platformlayer.service.memcache.ops

Source Code of org.platformlayer.service.memcache.ops.MemcacheServerController

package org.platformlayer.service.memcache.ops;

import java.io.File;
import java.io.IOException;

import org.platformlayer.ops.Handler;
import org.platformlayer.ops.OpsContext;
import org.platformlayer.ops.OpsException;
import org.platformlayer.ops.filesystem.TemplatedFile;
import org.platformlayer.ops.instances.InstanceBuilder;
import org.platformlayer.ops.networks.PublicEndpoint;
import org.platformlayer.ops.packages.PackageDependency;
import org.platformlayer.ops.service.ManagedService;
import org.platformlayer.ops.tree.OpsTreeBase;
import org.platformlayer.service.memcache.model.MemcacheServer;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

public class MemcacheServerController extends OpsTreeBase {

  private static final Logger log = LoggerFactory.getLogger(MemcacheServerController.class);

  public static final int MEMCACHE_PORT = 11211;

  @Handler
  public void handler() throws OpsException, IOException {
  }

  @Override
  protected void addChildren() throws OpsException {
    MemcacheServer model = OpsContext.get().getInstance(MemcacheServer.class);

    InstanceBuilder instance = InstanceBuilder.build(model.dnsName, this, model.getTags());

    // TODO: Memory _really_ needs to be configurable here!
    instance.publicPorts.add(MEMCACHE_PORT);

    instance.minimumMemoryMb = 1024;

    instance.hostPolicy.allowRunInContainer = true;
    addChild(instance);

    instance.addChild(PackageDependency.build("memcached"));

    MemcacheTemplateModel template = injected(MemcacheTemplateModel.class);

    instance.addChild(TemplatedFile.build(template, new File("/etc/memcached.conf")));

    // Collectd not restarting correctly (doesn't appear to be hostname problems??)
    // instance.addChild(CollectdCollector.build());

    {
      PublicEndpoint endpoint = injected(PublicEndpoint.class);
      // endpoint.network = null;
      endpoint.publicPort = MEMCACHE_PORT;
      endpoint.backendPort = MEMCACHE_PORT;
      endpoint.dnsName = model.dnsName;

      endpoint.tagItem = model.getKey();
      endpoint.parentItem = model.getKey();

      instance.addChild(endpoint);
    }

    instance.addChild(ManagedService.build("memcached"));
  }
}
TOP

Related Classes of org.platformlayer.service.memcache.ops.MemcacheServerController

TOP
Copyright © 2018 www.massapi.com. 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.