Class TestNexusEndpointStoreImpl

java.lang.Object

io.temporal.internal.testservice.TestNexusEndpointStoreImpl

All Implemented Interfaces:

TestNexusEndpointStore, Closeable, AutoCloseable

public class TestNexusEndpointStoreImpl
extends Object
implements TestNexusEndpointStore

TestNexusEndpointStoreImpl is an in-memory implementation of Nexus endpoint CRUD operations for use with the test server. Because conflict resolution is not required, there is no handling for created or updated timestamps.

Constructor Summary

Constructors

Constructor	Description
TestNexusEndpointStoreImpl()

Method Summary

Modifier and Type	Method	Description
void	close()
io.temporal.api.nexus.v1.Endpoint	createEndpoint(io.temporal.api.nexus.v1.EndpointSpec spec)
void	deleteEndpoint(String id, long version)
io.temporal.api.nexus.v1.Endpoint	getEndpoint(String id)
io.temporal.api.nexus.v1.Endpoint	getEndpointByName(String name)
List<io.temporal.api.nexus.v1.Endpoint>	listEndpoints(long pageSize, byte[] nextPageToken, String name)
io.temporal.api.nexus.v1.Endpoint	updateEndpoint(String id, long version, io.temporal.api.nexus.v1.EndpointSpec spec)
void	validateEndpointSpec(io.temporal.api.nexus.v1.EndpointSpec spec)

Methods inherited from class java.lang.Object

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

Constructor Details

TestNexusEndpointStoreImpl

public TestNexusEndpointStoreImpl()

Method Details

createEndpoint

public io.temporal.api.nexus.v1.Endpoint createEndpoint(io.temporal.api.nexus.v1.EndpointSpec spec)

Specified by:

createEndpoint in interface TestNexusEndpointStore

updateEndpoint

public io.temporal.api.nexus.v1.Endpoint updateEndpoint(String id,
 long version,
 io.temporal.api.nexus.v1.EndpointSpec spec)

Specified by:

updateEndpoint in interface TestNexusEndpointStore

deleteEndpoint

public void deleteEndpoint(String id,
 long version)

Specified by:

deleteEndpoint in interface TestNexusEndpointStore

getEndpoint

public io.temporal.api.nexus.v1.Endpoint getEndpoint(String id)

Specified by:

getEndpoint in interface TestNexusEndpointStore

getEndpointByName

public io.temporal.api.nexus.v1.Endpoint getEndpointByName(String name)

Specified by:

getEndpointByName in interface TestNexusEndpointStore

listEndpoints

public List<io.temporal.api.nexus.v1.Endpoint> listEndpoints(long pageSize,
 byte[] nextPageToken,
 String name)

Specified by:

listEndpoints in interface TestNexusEndpointStore

validateEndpointSpec

public void validateEndpointSpec(io.temporal.api.nexus.v1.EndpointSpec spec)

Specified by:

validateEndpointSpec in interface TestNexusEndpointStore

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Specified by:

close in interface TestNexusEndpointStore