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
protected void	akka$lease$kubernetes$internal$KubernetesJsonSupport$_setter_$leaseCustomResourceFormat_$eq(spray.json.RootJsonFormat<LeaseCustomResource> x$1)
protected void	akka$lease$kubernetes$internal$KubernetesJsonSupport$_setter_$metadataFormat_$eq(spray.json.JsonFormat<Metadata> x$1)
protected void	akka$lease$kubernetes$internal$KubernetesJsonSupport$_setter_$specFormat_$eq(spray.json.JsonFormat<Spec> x$1)
spray.json.BasicFormats.BigDecimalJsonFormat$	BigDecimalJsonFormat()
spray.json.BasicFormats.BigIntJsonFormat$	BigIntJsonFormat()
spray.json.BasicFormats.BooleanJsonFormat$	BooleanJsonFormat()
spray.json.BasicFormats.ByteJsonFormat$	ByteJsonFormat()
spray.json.BasicFormats.CharJsonFormat$	CharJsonFormat()
spray.json.BasicFormats.DoubleJsonFormat$	DoubleJsonFormat()
spray.json.BasicFormats.FloatJsonFormat$	FloatJsonFormat()
spray.json.BasicFormats.IntJsonFormat$	IntJsonFormat()
spray.json.AdditionalFormats.JsValueFormat$	JsValueFormat()
spray.json.RootJsonFormat<LeaseCustomResource>	leaseCustomResourceFormat()
spray.json.BasicFormats.LongJsonFormat$	LongJsonFormat()
spray.json.JsonFormat<Metadata>	metadataFormat()
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)
spray.json.AdditionalFormats.RootJsArrayFormat$	RootJsArrayFormat()
spray.json.AdditionalFormats.RootJsObjectFormat$	RootJsObjectFormat()
spray.json.BasicFormats.ShortJsonFormat$	ShortJsonFormat()
spray.json.JsonFormat<Spec>	specFormat()
spray.json.BasicFormats.StringJsonFormat$	StringJsonFormat()
spray.json.BasicFormats.SymbolJsonFormat$	SymbolJsonFormat()
spray.json.BasicFormats.UnitJsonFormat$	UnitJsonFormat()
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.http.scaladsl.marshallers.sprayjson.SprayJsonSupport

$init$, 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

$init$

Methods inherited from interface spray.json.StandardFormats

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

Methods inherited from interface spray.json.CollectionFormats

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

Methods inherited from interface spray.json.ProductFormats

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

Methods inherited from interface spray.json.ProductFormatsInstances

$init$, 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

$init$, jsonFormat, lazyFormat, lift, lift, lift, lift, rootFormat, rootJsonFormat, safeReader

Constructor Detail

KubernetesApiImpl

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

Method Detail

BigDecimalJsonFormat

public spray.json.BasicFormats.BigDecimalJsonFormat$ BigDecimalJsonFormat()

Specified by:

BigDecimalJsonFormat in interface spray.json.BasicFormats

BigIntJsonFormat

public spray.json.BasicFormats.BigIntJsonFormat$ BigIntJsonFormat()

Specified by:

BigIntJsonFormat in interface spray.json.BasicFormats

BooleanJsonFormat

public spray.json.BasicFormats.BooleanJsonFormat$ BooleanJsonFormat()

Specified by:

BooleanJsonFormat in interface spray.json.BasicFormats

ByteJsonFormat

public spray.json.BasicFormats.ByteJsonFormat$ ByteJsonFormat()

Specified by:

ByteJsonFormat in interface spray.json.BasicFormats

CharJsonFormat

public spray.json.BasicFormats.CharJsonFormat$ CharJsonFormat()

Specified by:

CharJsonFormat in interface spray.json.BasicFormats

DoubleJsonFormat

public spray.json.BasicFormats.DoubleJsonFormat$ DoubleJsonFormat()

Specified by:

DoubleJsonFormat in interface spray.json.BasicFormats

FloatJsonFormat

public spray.json.BasicFormats.FloatJsonFormat$ FloatJsonFormat()

Specified by:

FloatJsonFormat in interface spray.json.BasicFormats

IntJsonFormat

public spray.json.BasicFormats.IntJsonFormat$ IntJsonFormat()

Specified by:

IntJsonFormat in interface spray.json.BasicFormats

JsValueFormat

public spray.json.AdditionalFormats.JsValueFormat$ JsValueFormat()

Specified by:

JsValueFormat in interface spray.json.AdditionalFormats

LongJsonFormat

public spray.json.BasicFormats.LongJsonFormat$ LongJsonFormat()

Specified by:

LongJsonFormat in interface spray.json.BasicFormats

RootJsArrayFormat

public spray.json.AdditionalFormats.RootJsArrayFormat$ RootJsArrayFormat()

Specified by:

RootJsArrayFormat in interface spray.json.AdditionalFormats

RootJsObjectFormat

public spray.json.AdditionalFormats.RootJsObjectFormat$ RootJsObjectFormat()

Specified by:

RootJsObjectFormat in interface spray.json.AdditionalFormats

ShortJsonFormat

public spray.json.BasicFormats.ShortJsonFormat$ ShortJsonFormat()

Specified by:

ShortJsonFormat in interface spray.json.BasicFormats

StringJsonFormat

public spray.json.BasicFormats.StringJsonFormat$ StringJsonFormat()

Specified by:

StringJsonFormat in interface spray.json.BasicFormats

SymbolJsonFormat

public spray.json.BasicFormats.SymbolJsonFormat$ SymbolJsonFormat()

Specified by:

SymbolJsonFormat in interface spray.json.BasicFormats

UnitJsonFormat

public spray.json.BasicFormats.UnitJsonFormat$ UnitJsonFormat()

Specified by:

UnitJsonFormat in interface spray.json.BasicFormats

akka$lease$kubernetes$internal$KubernetesJsonSupport$_setter_$leaseCustomResourceFormat_$eq

protected void akka$lease$kubernetes$internal$KubernetesJsonSupport$_setter_$leaseCustomResourceFormat_$eq(spray.json.RootJsonFormat<LeaseCustomResource> x$1)

Specified by:

akka$lease$kubernetes$internal$KubernetesJsonSupport$_setter_$leaseCustomResourceFormat_$eq in interface KubernetesJsonSupport

akka$lease$kubernetes$internal$KubernetesJsonSupport$_setter_$metadataFormat_$eq

protected void akka$lease$kubernetes$internal$KubernetesJsonSupport$_setter_$metadataFormat_$eq(spray.json.JsonFormat<Metadata> x$1)

Specified by:

akka$lease$kubernetes$internal$KubernetesJsonSupport$_setter_$metadataFormat_$eq in interface KubernetesJsonSupport

akka$lease$kubernetes$internal$KubernetesJsonSupport$_setter_$specFormat_$eq

protected void akka$lease$kubernetes$internal$KubernetesJsonSupport$_setter_$specFormat_$eq(spray.json.JsonFormat<Spec> x$1)

Specified by:

akka$lease$kubernetes$internal$KubernetesJsonSupport$_setter_$specFormat_$eq in interface KubernetesJsonSupport

leaseCustomResourceFormat

public spray.json.RootJsonFormat<LeaseCustomResource> leaseCustomResourceFormat()

Specified by:

leaseCustomResourceFormat in interface KubernetesJsonSupport

metadataFormat

public spray.json.JsonFormat<Metadata> metadataFormat()

Specified by:

metadataFormat in interface KubernetesJsonSupport

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)

specFormat

public spray.json.JsonFormat<Spec> specFormat()

Specified by:

specFormat in interface KubernetesJsonSupport

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