public class KubernetesApiImpl extends java.lang.Object implements KubernetesApi, KubernetesJsonSupport
spray.json.BasicFormats.BigDecimalJsonFormat$, spray.json.BasicFormats.BigIntJsonFormat$, spray.json.BasicFormats.BooleanJsonFormat$, spray.json.BasicFormats.ByteJsonFormat$, spray.json.BasicFormats.CharJsonFormat$, spray.json.BasicFormats.DoubleJsonFormat$, spray.json.BasicFormats.FloatJsonFormat$, spray.json.BasicFormats.IntJsonFormat$, spray.json.BasicFormats.LongJsonFormat$, spray.json.BasicFormats.ShortJsonFormat$, spray.json.BasicFormats.StringJsonFormat$, spray.json.BasicFormats.SymbolJsonFormat$, spray.json.BasicFormats.UnitJsonFormat$| Constructor and Description |
|---|
KubernetesApiImpl(akka.actor.ActorSystem system,
KubernetesSettings settings) |
| Modifier and Type | Method and Description |
|---|---|
scala.concurrent.Future<LeaseResource> |
readOrCreateLeaseResource(java.lang.String name)
Reads a Lease from the API server.
|
scala.concurrent.Future<akka.Done> |
removeLease(java.lang.String name) |
scala.concurrent.Future<scala.util.Either<LeaseResource,LeaseResource>> |
updateLeaseResource(java.lang.String leaseName,
java.lang.String ownerName,
java.lang.String version,
long time)
Update the named resource.
|
long |
updateLeaseResource$default$4() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitleaseCustomResourceFormat, metadataFormat, specFormatsprayJsonByteStringUnmarshaller, sprayJsonMarshaller, sprayJsonMarshaller$default$2, sprayJsonMarshallerConverter, sprayJsonMarshallerConverter$default$2, sprayJsonSourceReader, sprayJsonUnmarshaller, sprayJsonUnmarshallerConverter, sprayJsValueByteStringUnmarshaller, sprayJsValueMarshaller, sprayJsValueMarshaller$default$1, sprayJsValueUnmarshallerBigDecimalJsonFormat, BigIntJsonFormat, BooleanJsonFormat, ByteJsonFormat, CharJsonFormat, DoubleJsonFormat, FloatJsonFormat, IntJsonFormat, LongJsonFormat, ShortJsonFormat, StringJsonFormat, SymbolJsonFormat, UnitJsonFormateitherFormat, optionFormat, tuple1Format, tuple2Format, tuple3Format, tuple4Format, tuple5Format, tuple6Format, tuple7FormatarrayFormat, immIndexedSeqFormat, immIterableFormat, immLinearSeqFormat, immSeqFormat, immSetFormat, indexedSeqFormat, iterableFormat, linearSeqFormat, listFormat, mapFormat, seqFormat, setFormat, vectorFormat, viaSeqextractFieldNames, fromField, jsonFormat0, productElement2Field, productElement2Field$default$4jsonFormat, jsonFormat, jsonFormat, jsonFormat, jsonFormat, jsonFormat, jsonFormat, jsonFormat, jsonFormat, jsonFormat, jsonFormat, jsonFormat, jsonFormat, jsonFormat, jsonFormat, jsonFormat, jsonFormat, jsonFormat, jsonFormat, jsonFormat, jsonFormat, jsonFormat, jsonFormat1, jsonFormat10, jsonFormat11, jsonFormat12, jsonFormat13, jsonFormat14, jsonFormat15, jsonFormat16, jsonFormat17, jsonFormat18, jsonFormat19, jsonFormat2, jsonFormat20, jsonFormat21, jsonFormat22, jsonFormat3, jsonFormat4, jsonFormat5, jsonFormat6, jsonFormat7, jsonFormat8, jsonFormat9public KubernetesApiImpl(akka.actor.ActorSystem system,
KubernetesSettings settings)
public scala.concurrent.Future<LeaseResource> readOrCreateLeaseResource(java.lang.String name)
KubernetesApireadOrCreateLeaseResource in interface KubernetesApiname - (undocumented)public scala.concurrent.Future<akka.Done> removeLease(java.lang.String name)
public scala.concurrent.Future<scala.util.Either<LeaseResource,LeaseResource>> updateLeaseResource(java.lang.String leaseName, java.lang.String ownerName, java.lang.String version, long time)
Must readOrCreateLeaseResource to first to get a resource version.
Can return one of three things: - Failure, e.g. timed out waiting for k8s api server to respond - Update failed due to version not matching current in the k8s api server. In this case resource is returned so the version can be used for subsequent calls - Success. Returns the LeaseResource that contains the clientName and new version. The new version should be used for any subsequent calls
updateLeaseResource in interface KubernetesApileaseName - (undocumented)ownerName - (undocumented)version - (undocumented)time - (undocumented)public long updateLeaseResource$default$4()
updateLeaseResource$default$4 in interface KubernetesApi