akka.lease.kubernetes

Interface KubernetesApi

All Known Implementing Classes:

KubernetesApiImpl

public interface KubernetesApi

INTERNAL API

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<scala.util.Either<LeaseResource,LeaseResource>>	updateLeaseResource(java.lang.String name, java.lang.String clientName, java.lang.String version, long time) Update the named resource.
long	updateLeaseResource$default$4()

Method Detail

readOrCreateLeaseResource

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

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.

Parameters:

name - (undocumented)

Returns:

(undocumented)

updateLeaseResource

scala.concurrent.Future<scala.util.Either<LeaseResource,LeaseResource>> updateLeaseResource(java.lang.String name,
                                                                                            java.lang.String clientName,
                                                                                            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: - Future failure e.g. timed out waiting for k8s api server to respond - Left - 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 - Right - Success

Any subsequent updates should also use the latest version or re-read with readOrCreateLeaseResource

Parameters:

name - (undocumented)

clientName - (undocumented)

version - (undocumented)

time - (undocumented)

Returns:

(undocumented)

updateLeaseResource$default$4

long updateLeaseResource$default$4()