akka.lease.kubernetes.internal

Class KubernetesApiImpl

java.lang.Object

akka.lease.kubernetes.internal.KubernetesApiImpl

All Implemented Interfaces:

akka.http.scaladsl.marshallers.sprayjson.SprayJsonSupport, KubernetesJsonSupport, KubernetesApi, spray.json.AdditionalFormats, spray.json.BasicFormats, spray.json.CollectionFormats, spray.json.DefaultJsonProtocol, spray.json.ProductFormats, spray.json.ProductFormatsInstances, spray.json.StandardFormats

public class KubernetesApiImpl
extends java.lang.Object
implements KubernetesApi, KubernetesJsonSupport

INTERNAL API

Nested Class Summary

Nested classes/interfaces inherited from interface spray.json.BasicFormats

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$

Nested classes/interfaces inherited from interface spray.json.StandardFormats

spray.json.StandardFormats.OptionFormat<T>

Nested classes/interfaces inherited from interface spray.json.AdditionalFormats

spray.json.AdditionalFormats.JsValueFormat$, spray.json.AdditionalFormats.RootJsArrayFormat$, spray.json.AdditionalFormats.RootJsObjectFormat$

Constructor Summary

Constructors

Constructor and Description
KubernetesApiImpl(akka.actor.ActorSystem system, KubernetesSettings settings)

Method Summary

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()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface akka.lease.kubernetes.internal.KubernetesJsonSupport

leaseCustomResourceFormat, metadataFormat, specFormat

Methods inherited from interface akka.http.scaladsl.marshallers.sprayjson.SprayJsonSupport

sprayJsonByteStringUnmarshaller, sprayJsonMarshaller, sprayJsonMarshaller$default$2, sprayJsonMarshallerConverter, sprayJsonMarshallerConverter$default$2, sprayJsonSourceReader, sprayJsonUnmarshaller, sprayJsonUnmarshallerConverter, sprayJsValueByteStringUnmarshaller, sprayJsValueMarshaller, sprayJsValueMarshaller$default$1, sprayJsValueUnmarshaller

Methods inherited from interface spray.json.BasicFormats

BigDecimalJsonFormat, BigIntJsonFormat, BooleanJsonFormat, ByteJsonFormat, CharJsonFormat, DoubleJsonFormat, FloatJsonFormat, IntJsonFormat, LongJsonFormat, ShortJsonFormat, StringJsonFormat, SymbolJsonFormat, UnitJsonFormat

Methods inherited from interface spray.json.StandardFormats

eitherFormat, optionFormat, tuple1Format, tuple2Format, tuple3Format, tuple4Format, tuple5Format, tuple6Format, tuple7Format

Methods inherited from interface spray.json.CollectionFormats

arrayFormat, immIndexedSeqFormat, immIterableFormat, immLinearSeqFormat, immSeqFormat, immSetFormat, indexedSeqFormat, iterableFormat, linearSeqFormat, listFormat, mapFormat, seqFormat, setFormat, vectorFormat, viaSeq

Methods inherited from interface spray.json.ProductFormats

extractFieldNames, fromField, jsonFormat0, productElement2Field, productElement2Field$default$4

Methods inherited from interface spray.json.ProductFormatsInstances

jsonFormat, 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, jsonFormat9

Methods inherited from interface spray.json.AdditionalFormats

jsonFormat, JsValueFormat, lazyFormat, lift, lift, lift, lift, rootFormat, RootJsArrayFormat, RootJsObjectFormat, rootJsonFormat, safeReader

Constructor Detail

KubernetesApiImpl

public KubernetesApiImpl(akka.actor.ActorSystem system,
                         KubernetesSettings settings)

Method Detail

readOrCreateLeaseResource

public scala.concurrent.Future<LeaseResource> readOrCreateLeaseResource(java.lang.String name)

Description copied from interface: KubernetesApi

Reads a Lease from the API server. If it doesn't exist it tries to create it. The creation can fail due to another instance creating at the same time, in this case the read is retried.

Specified by:

readOrCreateLeaseResource in interface KubernetesApi

Parameters:

name - (undocumented)

Returns:

(undocumented)

removeLease

public scala.concurrent.Future<akka.Done> removeLease(java.lang.String name)

updateLeaseResource

public 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.

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

Specified by:

updateLeaseResource in interface KubernetesApi

Parameters:

leaseName - (undocumented)

ownerName - (undocumented)

version - (undocumented)

time - (undocumented)

Returns:

(undocumented)

updateLeaseResource$default$4

public long updateLeaseResource$default$4()

Specified by:

updateLeaseResource$default$4 in interface KubernetesApi