A B C D E F G H I J L M N O P Q R S T U V W 
All Classes All Packages

A

accept() - Method in interface se.arkalix.core.plugin.cp.TrustedContractNegotiatorResponder
accept(long) - Method in interface se.arkalix.core.plugin.cp.ArTrustedContractNegotiationService
Accepts contract offer identified by given session identifier.
accept(TrustedContractAcceptanceDto) - Method in interface se.arkalix.core.plugin.cp.ArTrustedContractNegotiationService
Accepts contract offer identified by given acceptance.
accept(TrustedContractAcceptanceDto) - Method in class se.arkalix.core.plugin.cp.HttpJsonTrustedContractNegotiationService
 
ACCEPTED - se.arkalix.core.plugin.cp.ContractNegotiationStatus
The session is closed and the current offer is accepted.
acceptedAt() - Method in interface se.arkalix.core.plugin.cp.TrustedContractAcceptance
The instant at which the offer was accepted.
acceptorName() - Method in interface se.arkalix.core.plugin.cp.TrustedContractAcceptance
Name of party accepting identified offer.
ArEventPublishService - Interface in se.arkalix.core.plugin.eh
Represents an Arrowhead event publishing service.
ArEventSubscriberPlugin - Interface in se.arkalix.core.plugin.eh
Event subscriber plugin.
ArEventSubscriberPluginFacade - Interface in se.arkalix.core.plugin.eh
Allows for plugins depending on an event subscriber plugin to create event subscriptions.
ArEventSubscribeService - Interface in se.arkalix.core.plugin.eh
Represents an Arrowhead event subscription service.
ArEventUnsubscribeService - Interface in se.arkalix.core.plugin.eh
Represents an Arrowhead event subscription cancellation service.
arguments() - Method in interface se.arkalix.core.plugin.cp.TrustedContract
Concrete template parameter name/value pairs.
ArOrchestrationService - Interface in se.arkalix.core.plugin.or
Represents an Arrowhead orchestration service.
ArServiceDiscoveryService - Interface in se.arkalix.core.plugin.sr
Represents an Arrowhead service discovery service.
ArTrustedContractNegotiationService - Interface in se.arkalix.core.plugin.cp
A service useful for making contract offers, as well as accepting or rejecting received contract offers.
ArTrustedContractNegotiatorPlugin - Interface in se.arkalix.core.plugin.cp
A plugin that helps manage the sending and receiving of contract negotiation messages.
ArTrustedContractNegotiatorPluginFacade - Interface in se.arkalix.core.plugin.cp
Facade allowing for contract negotiations to be carried out with state management support.
ArTrustedContractObservationService - Interface in se.arkalix.core.plugin.cp
A service useful for querying the state of some on-going or previously closed negotiation session.
ArTrustedContractObserverPlugin - Interface in se.arkalix.core.plugin.cp
A plugin that observes contract negotiation updates.
ArTrustedContractObserverPluginFacade - Interface in se.arkalix.core.plugin.cp
Facade allowing for contract negotiations to be observed.
attachTo(ArSystem, Map<Class<? extends Plugin>, PluginFacade>) - Method in class se.arkalix.core.plugin.cp.HttpJsonTrustedContractNegotiatorPlugin
 
attachTo(ArSystem, Map<Class<? extends Plugin>, PluginFacade>) - Method in class se.arkalix.core.plugin.cp.HttpJsonTrustedContractObserverPlugin
 
attachTo(ArSystem, Map<Class<? extends Plugin>, PluginFacade>) - Method in class se.arkalix.core.plugin.eh.HttpJsonEventSubscriberPlugin
 
attachTo(ArSystem, Map<Class<? extends Plugin>, PluginFacade>) - Method in class se.arkalix.core.plugin.HttpJsonCloudPlugin
 

B

build() - Method in class se.arkalix.core.plugin.cp.SimplifiedContractCounterOffer.Builder
Finalizes construction of SimplifiedContractCounterOffer.
build() - Method in class se.arkalix.core.plugin.HttpJsonCloudPlugin.Builder
 
Builder() - Constructor for class se.arkalix.core.plugin.cp.SimplifiedContractCounterOffer.Builder
 
Builder() - Constructor for class se.arkalix.core.plugin.HttpJsonCloudPlugin.Builder
 

C

cloud() - Method in interface se.arkalix.core.plugin.ServiceProvider
 
CloudDetails - Interface in se.arkalix.core.plugin
Details about an Arrowhead local cloud, as they appear in various core service messages.
CloudException - Exception in se.arkalix.core.plugin
Signifies the failure to complete a task related to becoming or remaining a member of an Arrowhead local cloud.
CloudException(String) - Constructor for exception se.arkalix.core.plugin.CloudException
Creates new cloud exception.
CloudException(String, Throwable) - Constructor for exception se.arkalix.core.plugin.CloudException
Creates new cloud exception.
code() - Method in interface se.arkalix.core.plugin.ErrorResponse
Error code.
company() - Method in interface se.arkalix.core.plugin.CloudDetails
Cloud company identifier.
ContractNegotiationConstants - Class in se.arkalix.core.plugin.cp
Various constants relevant to the Arrowhead Contract services.
ContractNegotiationStatus - Enum in se.arkalix.core.plugin.cp
Enumerates the different states a contract negotiation session can be in.
contracts() - Method in class se.arkalix.core.plugin.cp.SimplifiedContractCounterOffer
Offered contracts.
contracts() - Method in interface se.arkalix.core.plugin.cp.TrustedContractCounterOffer
Offered contracts.
contracts() - Method in interface se.arkalix.core.plugin.cp.TrustedContractOffer
Offered contracts.
contracts(List<TrustedContractDto>) - Method in class se.arkalix.core.plugin.cp.SimplifiedContractCounterOffer.Builder
Sets offered contracts.
contracts(TrustedContractDto...) - Method in class se.arkalix.core.plugin.cp.SimplifiedContractCounterOffer.Builder
Sets offered contracts.
counterOffer(TrustedContractCounterOfferDto) - Method in interface se.arkalix.core.plugin.cp.ArTrustedContractNegotiationService
counterOffer(TrustedContractCounterOfferDto) - Method in class se.arkalix.core.plugin.cp.HttpJsonTrustedContractNegotiationService
 
createdAt() - Method in interface se.arkalix.core.plugin.eh.EventIncoming
The time at which this event was created.
createdAt() - Method in interface se.arkalix.core.plugin.eh.EventOutgoing
The time at which this event was created.

D

data() - Method in interface se.arkalix.core.plugin.eh.EventIncoming
An arbitrary string payload associated with this event.
data() - Method in interface se.arkalix.core.plugin.eh.EventOutgoing
An arbitrary string payload associated with this event.
dependencies() - Method in interface se.arkalix.core.plugin.cp.ArTrustedContractNegotiatorPlugin
 
dependencies() - Method in interface se.arkalix.core.plugin.cp.ArTrustedContractObserverPlugin
 
dependencies() - Method in class se.arkalix.core.plugin.cp.HttpJsonTrustedContractNegotiatorPlugin
 
dependencies() - Method in class se.arkalix.core.plugin.cp.HttpJsonTrustedContractObserverPlugin
 
DYNAMIC_ONLY - Static variable in class se.arkalix.core.plugin.or.OrchestrationStrategy
Only request dynamic orchestration rules.

E

ENABLE_INTER_CLOUD - Static variable in class se.arkalix.core.plugin.or.OrchestrationOption
If set to true, the query is allowed to include services situated in other local clouds.
equals(Object) - Method in class se.arkalix.core.plugin.or.OrchestrationOption
 
equals(Object) - Method in class se.arkalix.core.plugin.or.OrchestrationWarning
 
error() - Method in exception se.arkalix.core.plugin.ErrorResponseException
 
ErrorResponse - Interface in se.arkalix.core.plugin
An error description, as provided by the core services when a request cannot be fulfilled.
ErrorResponseException - Exception in se.arkalix.core.plugin
Some error caused by a core service responding to a request with an ErrorResponse.
ErrorResponseException(HttpIncomingResponse, ErrorResponse) - Constructor for exception se.arkalix.core.plugin.ErrorResponseException
Creates new HTTP response containing given error.
EventIncoming - Interface in se.arkalix.core.plugin.eh
An event description, as received.
EventOutgoing - Interface in se.arkalix.core.plugin.eh
An event description, as sent.
EventSubscription - Class in se.arkalix.core.plugin.eh
 
EventSubscription() - Constructor for class se.arkalix.core.plugin.eh.EventSubscription
 
EventSubscriptionHandle - Interface in se.arkalix.core.plugin.eh
Handle useful for managing a registered EventSubscription.
EventSubscriptionHandler - Interface in se.arkalix.core.plugin.eh
An event receiver associated with a particular topic, a set of possible publishing systems and a required set of metadata parameters.
EventSubscriptionRequest - Interface in se.arkalix.core.plugin.eh
A request for some subscriber to receive events matching certain topic and metadata requirements.
EXPIRED - se.arkalix.core.plugin.cp.ContractNegotiationStatus
The session is closed and the current offer can no longer be replaced, rejected or accepted due to having expired.
expiresAt() - Method in interface se.arkalix.core.plugin.ServiceConsumable
The date and time at which the service definition entry expires, if ever.
expiresAt() - Method in interface se.arkalix.core.plugin.ServiceDetails
The date and time at which the service definition entry expires, if ever.
expiresIn() - Method in class se.arkalix.core.plugin.cp.SimplifiedContractCounterOffer
Duration until this counter-offer can no longer be accepted or rejected.
expiresIn() - Method in interface se.arkalix.core.plugin.cp.TrustedContractOffer
Duration until this offer expires.

F

factory() - Static method in class se.arkalix.core.plugin.cp.HttpJsonTrustedContractNegotiationService
 
factory() - Static method in class se.arkalix.core.plugin.cp.HttpJsonTrustedContractObservationService
 
factory() - Static method in class se.arkalix.core.plugin.eh.HttpJsonEventPublishService
 
factory() - Static method in class se.arkalix.core.plugin.eh.HttpJsonEventSubscribeService
 
factory() - Static method in class se.arkalix.core.plugin.eh.HttpJsonEventUnsubscribeService
 
from(List<TrustedContractDto>) - Static method in class se.arkalix.core.plugin.cp.SimplifiedContractCounterOffer
Creates new counter-offer from given contracts.
from(ArSystem) - Static method in interface se.arkalix.core.plugin.SystemDetails
 
from(TrustedContractDto...) - Static method in class se.arkalix.core.plugin.cp.SimplifiedContractCounterOffer
Creates new counter-offer from given contracts.
from(ServiceDescription) - Static method in interface se.arkalix.core.plugin.ServiceDetails
 
from(ServiceDescription) - Static method in interface se.arkalix.core.plugin.sr.ServiceRegistration
 
from(SystemDescription) - Static method in interface se.arkalix.core.plugin.SystemDetails
 
from(ServiceQuery) - Static method in interface se.arkalix.core.plugin.sr.ServiceQuery
 
FROM_OTHER_CLOUD - Static variable in class se.arkalix.core.plugin.or.OrchestrationWarning
Signifies that a certain service is located outside the local cloud of the receiving system.

G

getByNamesAndId(String, String, long) - Method in interface se.arkalix.core.plugin.cp.ArTrustedContractObservationService
Requests some negotiation session uniquely identified by the names of the two negotiating parties and an identifier.
getByNamesAndId(String, String, long) - Method in class se.arkalix.core.plugin.cp.HttpJsonTrustedContractObservationService
 

H

handler() - Method in class se.arkalix.core.plugin.eh.EventSubscription
 
handler(EventSubscriptionHandler) - Method in class se.arkalix.core.plugin.eh.EventSubscription
 
hashCode() - Method in class se.arkalix.core.plugin.or.OrchestrationOption
 
hashCode() - Method in class se.arkalix.core.plugin.or.OrchestrationWarning
 
hostname() - Method in interface se.arkalix.core.plugin.SystemDetails
Hostname or textual representation of IP address of system.
HttpJsonCloudPlugin - Class in se.arkalix.core.plugin
HTTP/JSON cloud plugin.
HttpJsonCloudPlugin.Builder - Class in se.arkalix.core.plugin
Builder useful for constructing HttpJsonCloudPlugin instances.
HttpJsonEventPublishService - Class in se.arkalix.core.plugin.eh
A remote ArEventPublishService service that is communicated with via HTTP/JSON in either secure or insecure mode.
HttpJsonEventSubscriberPlugin - Class in se.arkalix.core.plugin.eh
HTTP/JSON event subscriber plugin.
HttpJsonEventSubscriberPlugin() - Constructor for class se.arkalix.core.plugin.eh.HttpJsonEventSubscriberPlugin
 
HttpJsonEventSubscribeService - Class in se.arkalix.core.plugin.eh
A remote ArEventSubscribeService service that is communicated with via HTTP/JSON in either secure or insecure mode.
HttpJsonEventUnsubscribeService - Class in se.arkalix.core.plugin.eh
A remote ArEventUnsubscribeService service that is communicated with via HTTP/JSON in either secure or insecure mode.
HttpJsonOrchestrationService - Class in se.arkalix.core.plugin.or
A remote ArOrchestrationService service that is communicated with via HTTP/JSON in either secure or insecure mode.
HttpJsonOrchestrationService(HttpConsumer) - Constructor for class se.arkalix.core.plugin.or.HttpJsonOrchestrationService
 
HttpJsonServiceDiscoveryService - Class in se.arkalix.core.plugin.sr
A remote ArServiceDiscoveryService service that is communicated with via HTTP/JSON in either secure or insecure mode.
HttpJsonServiceDiscoveryService(ArSystem, ServiceDescription) - Constructor for class se.arkalix.core.plugin.sr.HttpJsonServiceDiscoveryService
 
HttpJsonTrustedContractNegotiationService - Class in se.arkalix.core.plugin.cp
A remote ArTrustedContractNegotiationService service that is communicated with via HTTP/JSON in either secure or insecure mode.
HttpJsonTrustedContractNegotiatorPlugin - Class in se.arkalix.core.plugin.cp
A HTTP/JSON plugin that helps manage the sending and receiving of contract negotiation messages.
HttpJsonTrustedContractNegotiatorPlugin() - Constructor for class se.arkalix.core.plugin.cp.HttpJsonTrustedContractNegotiatorPlugin
 
HttpJsonTrustedContractObservationService - Class in se.arkalix.core.plugin.cp
A remote HttpJsonTrustedContractObservationService service that is communicated with via HTTP/JSON in either secure or insecure mode.
HttpJsonTrustedContractObserverPlugin - Class in se.arkalix.core.plugin.cp
A HTTP/JSON plugin that observes contract negotiation updates.
HttpJsonTrustedContractObserverPlugin() - Constructor for class se.arkalix.core.plugin.cp.HttpJsonTrustedContractObserverPlugin
 

I

id() - Method in interface se.arkalix.core.plugin.cp.TrustedContractNegotiation
Negotiation identifier, uniquely identifying this negotiation session in combination with the names of the two parties using it to negotiate.
InterfaceName - Interface in se.arkalix.core.plugin
The name of an interface triplet.
interfaces() - Method in interface se.arkalix.core.plugin.ServiceConsumable
List of supported network interface triplets.
interfaces() - Method in interface se.arkalix.core.plugin.ServiceDetails
List of supported network interface triplets.
interfaces() - Method in interface se.arkalix.core.plugin.sr.ServiceQuery
Supported service interfaces.
interfaces() - Method in interface se.arkalix.core.plugin.sr.ServiceRegistration
Interface triplets supported by the service.
isDynamic() - Method in class se.arkalix.core.plugin.or.OrchestrationPattern
Deprecated.
isDynamic(boolean) - Method in class se.arkalix.core.plugin.or.OrchestrationPattern
Deprecated.
isIncludingService() - Method in class se.arkalix.core.plugin.or.OrchestrationPattern
Whether or not the specific service requested is to be included in orchestration requests.
isIncludingService(boolean) - Method in class se.arkalix.core.plugin.or.OrchestrationPattern
Sets whether or not the specific service requested is to be included in orchestration requests.
isNeighbor() - Method in interface se.arkalix.core.plugin.CloudDetails
Whether or not this cloud is a so-called neighbor cloud of the cloud to which the sender or receiver of this message belongs to.
isPlainStorePattern() - Method in class se.arkalix.core.plugin.or.OrchestrationPattern
Whether or not this matches the so-called plain storage pattern, which does not include the requested services, has no provider preference and no options.
isSecure() - Method in interface se.arkalix.core.plugin.CloudDetails
Whether or not this cloud operates in secure mode.

J

joinViaServiceRegistryAt(InetSocketAddress) - Static method in class se.arkalix.core.plugin.HttpJsonCloudPlugin
Creates new HTTP/JSON cloud plugin that tries to make its systems join a certain local cloud via the service registry system available at the specified socketAddress.

L

listen(String, Supplier<TrustedContractNegotiatorHandler>) - Method in interface se.arkalix.core.plugin.cp.ArTrustedContractNegotiatorPluginFacade
Listens for incoming contract offers to a certain receiver.

M

MATCHMAKING - Static variable in class se.arkalix.core.plugin.or.OrchestrationOption
If set to true, only a single service is to be included in the result, unless no matching services are available at all.
message() - Method in interface se.arkalix.core.plugin.ErrorResponse
Human-readable description of error.
metadata() - Method in interface se.arkalix.core.plugin.eh.EventIncoming
Arbitrary details about this event.
metadata() - Method in interface se.arkalix.core.plugin.eh.EventOutgoing
Arbitrary details about this event.
metadata() - Method in class se.arkalix.core.plugin.eh.EventSubscription
 
metadata() - Method in interface se.arkalix.core.plugin.eh.EventSubscriptionRequest
Metadata key/value pairs that must exist in each EventOutgoing matched by this subscription.
metadata() - Method in interface se.arkalix.core.plugin.ServiceConsumable
Arbitrary service metadata.
metadata() - Method in interface se.arkalix.core.plugin.ServiceDetails
Arbitrary service metadata.
metadata() - Method in interface se.arkalix.core.plugin.sr.ServiceQuery
Required metadata pairs.
metadata() - Method in interface se.arkalix.core.plugin.sr.ServiceRegistration
Arbitrary metadata to associate with registered service.
metadata(String, String) - Method in class se.arkalix.core.plugin.eh.EventSubscription
 
metadata(Map<String, String>) - Method in class se.arkalix.core.plugin.eh.EventSubscription
 
METADATA_SEARCH - Static variable in class se.arkalix.core.plugin.or.OrchestrationOption
If set to true, the service metadata pairs in the query, if any, will be considered while searching for matching services.

N

name() - Method in interface se.arkalix.core.plugin.CloudDetails
Cloud identifier.
name() - Method in interface se.arkalix.core.plugin.InterfaceName
Interface triplet.
name() - Method in interface se.arkalix.core.plugin.ServiceConsumable
Service name.
name() - Method in interface se.arkalix.core.plugin.ServiceDetails
Service name.
name() - Method in interface se.arkalix.core.plugin.ServiceName
Service name.
name() - Method in interface se.arkalix.core.plugin.sr.ServiceQuery
Service name.
name() - Method in interface se.arkalix.core.plugin.sr.ServiceRegistration
Unique service name.
name() - Method in interface se.arkalix.core.plugin.SystemDetails
Name of system.
negotiationId() - Method in interface se.arkalix.core.plugin.cp.TrustedContractAcceptance
Identifies the negotiation session containing the accepted offer.
negotiationId() - Method in interface se.arkalix.core.plugin.cp.TrustedContractCounterOffer
Identifies the negotiation session containing the countered offer.
negotiationId() - Method in interface se.arkalix.core.plugin.cp.TrustedContractRejection
Identifies the negotiation session containing the rejected offer.

O

observe(TrustedContractObserverHandler) - Method in interface se.arkalix.core.plugin.cp.ArTrustedContractObserverPluginFacade
Registers observer to receive contract negotiation updates.
offer() - Method in interface se.arkalix.core.plugin.cp.TrustedContractNegotiation
The last offer to be submitted to this session.
offer(String, String, Duration, List<TrustedContractDto>, TrustedContractNegotiatorHandler) - Method in interface se.arkalix.core.plugin.cp.ArTrustedContractNegotiatorPluginFacade
Starts new contract negotiation by making the described offer and then uses provided negotiation handler to handle any response from the party receiving the offer.
offer(SimplifiedContractCounterOffer) - Method in interface se.arkalix.core.plugin.cp.TrustedContractNegotiatorResponder
offer(TrustedContractOfferDto) - Method in interface se.arkalix.core.plugin.cp.ArTrustedContractNegotiationService
Makes a new contract offer.
offer(TrustedContractOfferDto) - Method in class se.arkalix.core.plugin.cp.HttpJsonTrustedContractNegotiationService
 
offer(TrustedContractOfferDto, TrustedContractNegotiatorHandler) - Method in interface se.arkalix.core.plugin.cp.ArTrustedContractNegotiatorPluginFacade
Starts new contract negotiation by making given offer and then uses provided negotiation handler to handle any response from the party receiving the offer.
offeredAt() - Method in class se.arkalix.core.plugin.cp.SimplifiedContractCounterOffer
The time at which this counter-offer was created.
offeredAt() - Method in interface se.arkalix.core.plugin.cp.TrustedContractCounterOffer
Time at which this offer was created.
offeredAt() - Method in interface se.arkalix.core.plugin.cp.TrustedContractOffer
Time at which this offer was created.
OFFERING - se.arkalix.core.plugin.cp.ContractNegotiationStatus
Session is still active.
offerorName() - Method in interface se.arkalix.core.plugin.cp.TrustedContractAcceptance
Name of party originally making the accepted offer.
offerorName() - Method in interface se.arkalix.core.plugin.cp.TrustedContractCounterOffer
Name of offer sender.
offerorName() - Method in interface se.arkalix.core.plugin.cp.TrustedContractOffer
Name of offer sender.
offerorName() - Method in interface se.arkalix.core.plugin.cp.TrustedContractRejection
Name of party originally making the accepted offer.
onAccept(TrustedContractNegotiationDto) - Method in interface se.arkalix.core.plugin.cp.TrustedContractNegotiatorHandler
Called to indicate that a previously made contract offer was accepted by its receiver.
onExpiry(long) - Method in interface se.arkalix.core.plugin.cp.TrustedContractNegotiatorHandler
Called to indicate that a previously made or received contract offer expired before being responded to.
onFault(long, Throwable) - Method in interface se.arkalix.core.plugin.cp.TrustedContractNegotiatorHandler
Called to indicate that some submitted offer could not be sent due to an unexpected exception.
ONLY_PREFERRED - Static variable in class se.arkalix.core.plugin.or.OrchestrationOption
If set to true, only services provided by the systems listed in the query will be included in the query result.
onOffer(TrustedContractNegotiationDto, TrustedContractNegotiatorResponder) - Method in interface se.arkalix.core.plugin.cp.TrustedContractNegotiatorHandler
Called to notify about a new offer or counter-offer being received.
onPublish(Map<String, String>, String) - Method in interface se.arkalix.core.plugin.eh.EventSubscriptionHandler
Called to notify this handler about the availability of a matching event.
onReject(TrustedContractNegotiationDto) - Method in interface se.arkalix.core.plugin.cp.TrustedContractNegotiatorHandler
Called to indicate that a previously made contract offer was rejected by its receiver.
onUpdate(TrustedContractNegotiationDto) - Method in interface se.arkalix.core.plugin.cp.TrustedContractObserverHandler
Method to be invoked whenever a new contract negotiation update is observed.
option(OrchestrationOption, boolean) - Method in class se.arkalix.core.plugin.or.OrchestrationPattern
Sets orchestration option.
options() - Method in class se.arkalix.core.plugin.or.OrchestrationPattern
A map of orchestration options.
options() - Method in interface se.arkalix.core.plugin.or.OrchestrationQuery
A map of orchestration options.
options(Map<OrchestrationOption, Boolean>) - Method in class se.arkalix.core.plugin.or.OrchestrationPattern
Sets orchestration options, replacing any such previously set.
OrchestrationOption - Class in se.arkalix.core.plugin.or
OrchestrationPattern - Class in se.arkalix.core.plugin.or
Describes a particular way in which orchestration rules can be queried from an orchestration service.
OrchestrationPattern() - Constructor for class se.arkalix.core.plugin.or.OrchestrationPattern
 
OrchestrationQuery - Interface in se.arkalix.core.plugin.or
A request for orchestration.
OrchestrationQueryResult - Interface in se.arkalix.core.plugin.or
The result of an orchestration query.
orchestrationStrategy(OrchestrationStrategy) - Method in class se.arkalix.core.plugin.HttpJsonCloudPlugin.Builder
Sets orchestration strategy to use when resolving what services to consume.
OrchestrationStrategy - Class in se.arkalix.core.plugin.or
Enumerates the different kind of strategies that can be used when querying an orchestration service for services to consume.
OrchestrationStrategy(List<OrchestrationPattern>) - Constructor for class se.arkalix.core.plugin.or.OrchestrationStrategy
Creates new orchestration strategy, which entails attempting the given orchestration requests in order until a matching service is found.
OrchestrationStrategy(OrchestrationPattern...) - Constructor for class se.arkalix.core.plugin.or.OrchestrationStrategy
Creates new orchestration strategy, which entails attempting the given orchestration requests in order until a matching service is found.
OrchestrationWarning - Class in se.arkalix.core.plugin.or
A warning included in a ServiceConsumable in the results of an orchestration query.
ordinal() - Method in class se.arkalix.core.plugin.HttpJsonCloudPlugin
 
OVERRIDE_STORE - Static variable in class se.arkalix.core.plugin.or.OrchestrationOption
If set to true, dynamic orchestration is enabled, which means that, if allowed, the orchestrator will ignore its orchestration rules and see if any mathing service exists that can be included in the query result.

P

patterns() - Method in class se.arkalix.core.plugin.or.OrchestrationStrategy
Orchestration strategy requests to attempt.
PING_PROVIDERS - Static variable in class se.arkalix.core.plugin.or.OrchestrationOption
If set to true, causes all services whose providers do not respond to a PING message to be removed from the query result.
port() - Method in interface se.arkalix.core.plugin.SystemDetails
Port number.
provider() - Method in interface se.arkalix.core.plugin.ServiceConsumable
Service provider.
provider() - Method in interface se.arkalix.core.plugin.ServiceDetails
Service provider.
provider() - Method in interface se.arkalix.core.plugin.sr.ServiceRegistration
The system providing the service.
provider(SystemDescription) - Method in class se.arkalix.core.plugin.eh.EventSubscription
 
providers() - Method in class se.arkalix.core.plugin.eh.EventSubscription
 
providers() - Method in class se.arkalix.core.plugin.or.OrchestrationPattern
A list of systems the querying system prefers to provide the requested service.
providers() - Method in interface se.arkalix.core.plugin.or.OrchestrationQuery
A list of systems the querying system prefers to provide the requested service.
providers(Collection<SystemDescription>) - Method in class se.arkalix.core.plugin.eh.EventSubscription
 
providers(List<ServiceProviderDto>) - Method in class se.arkalix.core.plugin.or.OrchestrationPattern
Sets preferred service providers.
providers(ServiceProviderDto...) - Method in class se.arkalix.core.plugin.or.OrchestrationPattern
Sets preferred service providers.
providers(SystemDescription...) - Method in class se.arkalix.core.plugin.eh.EventSubscription
 
publicKeyBase64() - Method in interface se.arkalix.core.plugin.CloudDetails
The public key of what? The service registry? The gatekeeper?
publicKeyBase64() - Method in interface se.arkalix.core.plugin.SystemDetails
Public key of system, if running in secure mode.
publish(String, ArSystem, String) - Method in interface se.arkalix.core.plugin.eh.ArEventPublishService
Publishes given arguments as an EventOutgoing.
publish(String, ArSystem, Map<String, String>, String) - Method in interface se.arkalix.core.plugin.eh.ArEventPublishService
Publishes given arguments as an EventOutgoing.
publish(EventOutgoingDto) - Method in interface se.arkalix.core.plugin.eh.ArEventPublishService
Publishes given event.
publish(EventOutgoingDto) - Method in class se.arkalix.core.plugin.eh.HttpJsonEventPublishService
 
publisher() - Method in interface se.arkalix.core.plugin.eh.EventIncoming
Information about the system publishing this event.
publisher() - Method in interface se.arkalix.core.plugin.eh.EventOutgoing
Information about the system publishing this event.
publishers() - Method in interface se.arkalix.core.plugin.eh.EventSubscriptionRequest
The systems from which events are to be received.

Q

query(OrchestrationQueryDto) - Method in interface se.arkalix.core.plugin.or.ArOrchestrationService
Queries orchestration service for services that should be consumed.
query(OrchestrationQueryDto) - Method in class se.arkalix.core.plugin.or.HttpJsonOrchestrationService
 
query(ServiceQueryDto) - Method in interface se.arkalix.core.plugin.sr.ArServiceDiscoveryService
Queries registry for certain service definitions.
query(ServiceQueryDto) - Method in class se.arkalix.core.plugin.sr.HttpJsonServiceDiscoveryService
 
query(ServiceQuery) - Method in interface se.arkalix.core.plugin.sr.ArServiceDiscoveryService
Queries registry for certain service definitions.

R

receiverName() - Method in interface se.arkalix.core.plugin.cp.TrustedContractCounterOffer
Name of offer receiver.
receiverName() - Method in interface se.arkalix.core.plugin.cp.TrustedContractOffer
Name of offer receiver.
register(ServiceRegistrationDto) - Method in interface se.arkalix.core.plugin.sr.ArServiceDiscoveryService
Registers a service.
register(ServiceRegistrationDto) - Method in class se.arkalix.core.plugin.sr.HttpJsonServiceDiscoveryService
 
register(ServiceDescription) - Method in interface se.arkalix.core.plugin.sr.ArServiceDiscoveryService
Registers a service.
reject() - Method in interface se.arkalix.core.plugin.cp.TrustedContractNegotiatorResponder
reject(long) - Method in interface se.arkalix.core.plugin.cp.ArTrustedContractNegotiationService
Rejects contract offer identified by given session identifier.
reject(TrustedContractRejectionDto) - Method in interface se.arkalix.core.plugin.cp.ArTrustedContractNegotiationService
Rejects contract offer identified by given rejection.
reject(TrustedContractRejectionDto) - Method in class se.arkalix.core.plugin.cp.HttpJsonTrustedContractNegotiationService
 
REJECTED - se.arkalix.core.plugin.cp.ContractNegotiationStatus
The session is closed and the current offer is rejected.
rejectedAt() - Method in interface se.arkalix.core.plugin.cp.TrustedContractRejection
The instant at which the offer was rejected.
rejectorName() - Method in interface se.arkalix.core.plugin.cp.TrustedContractRejection
Name of party rejecting identified offer.
requester() - Method in interface se.arkalix.core.plugin.or.OrchestrationQuery
Details about the system making the orchestration query.

S

se.arkalix.core.plugin - package se.arkalix.core.plugin
Arrowhead Kalix Core Service Plugins
se.arkalix.core.plugin.cp - package se.arkalix.core.plugin.cp
Contract Proxy Plugins and Utilities
se.arkalix.core.plugin.eh - package se.arkalix.core.plugin.eh
Event Handler Plugins and Utilities
se.arkalix.core.plugin.or - package se.arkalix.core.plugin.or
Orchestrator Utilities
se.arkalix.core.plugin.sr - package se.arkalix.core.plugin.sr
Service Registry Utilities
security() - Method in interface se.arkalix.core.plugin.ServiceConsumable
The security/authentication mode supported by the service.
security() - Method in interface se.arkalix.core.plugin.ServiceDetails
The security/authentication mode supported by the service.
security() - Method in interface se.arkalix.core.plugin.sr.ServiceRegistration
The access policy employed by the service.
securityModes() - Method in interface se.arkalix.core.plugin.sr.ServiceQuery
Permitted security/authentication modes.
sendToUri() - Method in interface se.arkalix.core.plugin.eh.EventSubscriptionRequest
The URI to which matching events will be sent as an HTTP POST request.
service() - Method in class se.arkalix.core.plugin.cp.HttpJsonTrustedContractNegotiationService
 
service() - Method in class se.arkalix.core.plugin.cp.HttpJsonTrustedContractObservationService
 
service() - Method in class se.arkalix.core.plugin.eh.HttpJsonEventPublishService
 
service() - Method in class se.arkalix.core.plugin.eh.HttpJsonEventSubscribeService
 
service() - Method in class se.arkalix.core.plugin.eh.HttpJsonEventUnsubscribeService
 
service() - Method in class se.arkalix.core.plugin.or.HttpJsonOrchestrationService
 
service() - Method in interface se.arkalix.core.plugin.or.OrchestrationQuery
Description of the specific kind of service the querying system desires to consume.
service() - Method in class se.arkalix.core.plugin.sr.HttpJsonServiceDiscoveryService
 
ServiceConsumable - Interface in se.arkalix.core.plugin
Details about some service with additional information related to how it can be accessed.
ServiceDetails - Interface in se.arkalix.core.plugin
A service definition, as it appears in a ServiceQueryResult.
serviceDiscoveryBasePath(String) - Method in class se.arkalix.core.plugin.HttpJsonCloudPlugin.Builder
Sets base path, or service URI, of the service discovery service provided by HttpJsonCloudPlugin.Builder.serviceRegistrySocketAddress(InetSocketAddress) the designated service registry system}.
ServiceName - Interface in se.arkalix.core.plugin
The name of a service.
ServiceProvider - Interface in se.arkalix.core.plugin
 
ServiceQuery - Interface in se.arkalix.core.plugin.sr
A search query for service definitions.
ServiceQueryResult - Interface in se.arkalix.core.plugin.sr
The successful result of a ServiceQuery.
ServiceRegistration - Interface in se.arkalix.core.plugin.sr
A service registration request.
serviceRegistrationPredicate(Predicate<ServiceDescription>) - Method in class se.arkalix.core.plugin.HttpJsonCloudPlugin.Builder
Sets predicate function, used to test each service to be provided by the system using this plugin.
serviceRegistrySocketAddress(InetSocketAddress) - Method in class se.arkalix.core.plugin.HttpJsonCloudPlugin.Builder
Sets hostname/IP-address and port of the service registry system to use for entering into an Arrowhead local cloud.
services() - Method in interface se.arkalix.core.plugin.or.OrchestrationQueryResult
Services the querying system may consume.
services() - Method in interface se.arkalix.core.plugin.sr.ServiceQueryResult
Definitions of services matching original ServiceQuery.
SimplifiedContractCounterOffer - Class in se.arkalix.core.plugin.cp
A contract counter-offer useful when important details about the negotiation in question can be inferred.
SimplifiedContractCounterOffer.Builder - Class in se.arkalix.core.plugin.cp
Builder useful for creating SimplifiedContractCounterOffer instances.
startsAt() - Method in interface se.arkalix.core.plugin.eh.EventSubscriptionRequest
The instant at which this subscription starts to be applied, unless as soon as possible.
status() - Method in interface se.arkalix.core.plugin.cp.TrustedContractNegotiation
The current state of this negotiation session.
stopsAt() - Method in interface se.arkalix.core.plugin.eh.EventSubscriptionRequest
The instant at which this subscription is terminated, if ever.
STORED_ONLY - Static variable in class se.arkalix.core.plugin.or.OrchestrationStrategy
Only request predefined orchestration rules.
STORED_THEN_DYNAMIC - Static variable in class se.arkalix.core.plugin.or.OrchestrationStrategy
First request predefined orchestration rules, then request dynamic orchestration rules if no suitable predefined rules were available.
subscribe(String, Collection<SystemDescription>, EventSubscriptionHandler) - Method in interface se.arkalix.core.plugin.eh.ArEventSubscriberPlugin
Registers new default event subscription.
subscribe(String, Collection<SystemDescription>, EventSubscriptionHandler) - Method in interface se.arkalix.core.plugin.eh.ArEventSubscriberPluginFacade
Registers new event subscription.
subscribe(String, Map<String, String>, Collection<SystemDescription>, EventSubscriptionHandler) - Method in interface se.arkalix.core.plugin.eh.ArEventSubscriberPlugin
Registers new default event subscription.
subscribe(String, Map<String, String>, Collection<SystemDescription>, EventSubscriptionHandler) - Method in interface se.arkalix.core.plugin.eh.ArEventSubscriberPluginFacade
Registers new event subscription.
subscribe(String, Map<String, String>, EventSubscriptionHandler) - Method in interface se.arkalix.core.plugin.eh.ArEventSubscriberPlugin
Registers new default event subscription.
subscribe(String, Map<String, String>, EventSubscriptionHandler) - Method in interface se.arkalix.core.plugin.eh.ArEventSubscriberPluginFacade
Registers new event subscription.
subscribe(String, EventSubscriptionHandler) - Method in interface se.arkalix.core.plugin.eh.ArEventSubscriberPlugin
Registers new default event subscription.
subscribe(String, EventSubscriptionHandler) - Method in interface se.arkalix.core.plugin.eh.ArEventSubscriberPluginFacade
Registers new event subscription.
subscribe(EventSubscription) - Method in interface se.arkalix.core.plugin.eh.ArEventSubscriberPlugin
Registers new default event subscription.
subscribe(EventSubscription) - Method in interface se.arkalix.core.plugin.eh.ArEventSubscriberPluginFacade
Registers new event subscription.
subscribe(EventSubscription) - Method in class se.arkalix.core.plugin.eh.HttpJsonEventSubscriberPlugin
 
subscribe(EventSubscriptionRequestDto) - Method in interface se.arkalix.core.plugin.eh.ArEventSubscribeService
Sends given subscription request.
subscribe(EventSubscriptionRequestDto) - Method in class se.arkalix.core.plugin.eh.HttpJsonEventSubscribeService
 
subscriber() - Method in interface se.arkalix.core.plugin.eh.EventSubscriptionRequest
Information about the subscribing system.
system() - Method in interface se.arkalix.core.plugin.ServiceProvider
 
SystemDetails - Interface in se.arkalix.core.plugin
Details about an Arrowhead system, as they appear in various core service messages.

T

templateName() - Method in interface se.arkalix.core.plugin.cp.TrustedContract
Parameterized template.
tokens() - Method in interface se.arkalix.core.plugin.ServiceConsumable
Authorization tokens useful for consuming this service.
topic() - Method in interface se.arkalix.core.plugin.eh.EventIncoming
Category of event.
topic() - Method in interface se.arkalix.core.plugin.eh.EventOutgoing
Category of event.
topic() - Method in class se.arkalix.core.plugin.eh.EventSubscription
 
topic() - Method in interface se.arkalix.core.plugin.eh.EventSubscriptionRequest
Identifies the general category of events being subscribed to.
topic(String) - Method in class se.arkalix.core.plugin.eh.EventSubscription
 
TOPIC_UPDATE - Static variable in class se.arkalix.core.plugin.cp.ContractNegotiationConstants
Event handler topic used when negotiation updates are published.
toQuery(SystemDetailsDto, ServiceQuery) - Method in class se.arkalix.core.plugin.or.OrchestrationPattern
Converts this pattern into a concrete orchestration query.
toServiceDescription() - Method in interface se.arkalix.core.plugin.ServiceConsumable
Converts this objects into a ServiceDescription.
toServiceDescription() - Method in interface se.arkalix.core.plugin.ServiceDetails
Converts this objects into a ServiceDescription.
toString() - Method in class se.arkalix.core.plugin.eh.EventSubscription
 
toString() - Method in class se.arkalix.core.plugin.or.OrchestrationOption
 
toString() - Method in class se.arkalix.core.plugin.or.OrchestrationWarning
 
toSubscriptionRequest(SystemDetailsDto, String) - Method in class se.arkalix.core.plugin.eh.EventSubscription
 
toSystemDescription() - Method in interface se.arkalix.core.plugin.SystemDetails
Converts this objects into a SystemDescription.
TRIGGER_INTER_CLOUD - Static variable in class se.arkalix.core.plugin.or.OrchestrationOption
If set to true, the services provided by the local cloud will be ignored in favor of those offered by other clouds.
triggerPing() - Method in interface se.arkalix.core.plugin.sr.ServiceQuery
Whether or not to test if matching services are live before returning ServiceQueryResult.
TrustedContract - Interface in se.arkalix.core.plugin.cp
A parameterized reference to a contract template.
TrustedContractAcceptance - Interface in se.arkalix.core.plugin.cp
An acceptance of an offer to enter into one or more legally binding contacts.
TrustedContractCounterOffer - Interface in se.arkalix.core.plugin.cp
An offer countering a previously received such.
TrustedContractNegotiation - Interface in se.arkalix.core.plugin.cp
The state associated with an on-going or previously closed negotiation session.
TrustedContractNegotiatorHandler - Interface in se.arkalix.core.plugin.cp
Handler used to receive and react to different kinds of contract negotiation events.
TrustedContractNegotiatorResponder - Interface in se.arkalix.core.plugin.cp
Some object useful for responding to a contract offer.
TrustedContractObserverHandler - Interface in se.arkalix.core.plugin.cp
A receiver of contract negotiation updates.
TrustedContractOffer - Interface in se.arkalix.core.plugin.cp
A concrete offer for two parties to enter into a legally binding contract.
TrustedContractRejection - Interface in se.arkalix.core.plugin.cp
Signals the desire to end a contract negotiation.
TTL_EXPIRED - Static variable in class se.arkalix.core.plugin.or.OrchestrationWarning
Signifies that the service registry entry of a certain service recently expired.
TTL_EXPIRING - Static variable in class se.arkalix.core.plugin.or.OrchestrationWarning
Signifies that the service registry entry of a certain service is about to expire.
TTL_UNKNOWN - Static variable in class se.arkalix.core.plugin.or.OrchestrationWarning
Signifies that the service registry entry of a certain service might be stale.
type() - Method in interface se.arkalix.core.plugin.ErrorResponse
Error type descriptor.

U

unregister(String, String, String, int) - Method in interface se.arkalix.core.plugin.sr.ArServiceDiscoveryService
Unregisters a service that is currently registered.
unregister(String, String, String, int) - Method in class se.arkalix.core.plugin.sr.HttpJsonServiceDiscoveryService
 
unregister(String, ArSystem) - Method in interface se.arkalix.core.plugin.sr.ArServiceDiscoveryService
Unregisters a service that is currently registered.
unsubscribe() - Method in interface se.arkalix.core.plugin.eh.EventSubscriptionHandle
Causes represented subscription to be cancelled, if active.
unsubscribe(String, String, String, int) - Method in interface se.arkalix.core.plugin.eh.ArEventUnsubscribeService
Sends request for a subscription to be cancelled.
unsubscribe(String, String, String, int) - Method in class se.arkalix.core.plugin.eh.HttpJsonEventUnsubscribeService
 
unsubscribe(String, ArSystem) - Method in interface se.arkalix.core.plugin.eh.ArEventUnsubscribeService
Sends request for a subscription to be cancelled.
uri() - Method in interface se.arkalix.core.plugin.ServiceConsumable
Service qualifier, also referred to as service URI.
uri() - Method in interface se.arkalix.core.plugin.ServiceDetails
Service qualifier, also referred to as service URI.
uri() - Method in interface se.arkalix.core.plugin.sr.ServiceRegistration
Qualifier that distinguishes this service from other such provided by the same system.
useMetadata() - Method in interface se.arkalix.core.plugin.eh.EventSubscriptionRequest
true only if the metadata map is to be used when deciding what events to forward to the subscriber.

V

validAfter() - Method in class se.arkalix.core.plugin.cp.SimplifiedContractCounterOffer
Instant after which this counter-offer becomes acceptable.
validAfter() - Method in interface se.arkalix.core.plugin.cp.TrustedContractCounterOffer
Instant after which this offer becomes acceptable.
validAfter() - Method in interface se.arkalix.core.plugin.cp.TrustedContractOffer
Instant after which this offer becomes acceptable.
validAfter(Instant) - Method in class se.arkalix.core.plugin.cp.SimplifiedContractCounterOffer.Builder
Sets instant after which the created counter-offer becomes acceptable.
validFor(Duration) - Method in class se.arkalix.core.plugin.cp.SimplifiedContractCounterOffer.Builder
Sets instant after which the created counter-offer can no longer be accepted or rejected by adding given duration to whatever time was provided to SimplifiedContractCounterOffer.validAfter().
validUntil() - Method in class se.arkalix.core.plugin.cp.SimplifiedContractCounterOffer
Instant until this counter-offer can be accepted or rejected.
validUntil() - Method in interface se.arkalix.core.plugin.cp.TrustedContractCounterOffer
Instant after which this offer can no longer be accepted or rejected.
validUntil() - Method in interface se.arkalix.core.plugin.cp.TrustedContractOffer
Instant after which this offer can no longer be accepted or rejected.
validUntil(Instant) - Method in class se.arkalix.core.plugin.cp.SimplifiedContractCounterOffer.Builder
Sets instant after which the created counter-offer can no longer be accepted or rejected.
valueOf(String) - Static method in enum se.arkalix.core.plugin.cp.ContractNegotiationStatus
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in class se.arkalix.core.plugin.or.OrchestrationOption
Resolves OrchestrationOption from given name.
valueOf(String) - Static method in class se.arkalix.core.plugin.or.OrchestrationWarning
Resolves OrchestrationWarning from given name.
values() - Static method in enum se.arkalix.core.plugin.cp.ContractNegotiationStatus
Returns an array containing the constants of this enum type, in the order they are declared.
version() - Method in interface se.arkalix.core.plugin.ServiceConsumable
Service version.
version() - Method in interface se.arkalix.core.plugin.ServiceDetails
Service version.
version() - Method in interface se.arkalix.core.plugin.sr.ServiceQuery
Desired exact service version.
version() - Method in interface se.arkalix.core.plugin.sr.ServiceRegistration
Service version.
versionMax() - Method in interface se.arkalix.core.plugin.sr.ServiceQuery
The highest permitted service version.
versionMin() - Method in interface se.arkalix.core.plugin.sr.ServiceQuery
The lowest permitted service version.

W

warnings() - Method in interface se.arkalix.core.plugin.ServiceConsumable
Any notifications about the state of the service that might have bearing on whether or not the service will be consumed.
A B C D E F G H I J L M N O P Q R S T U V W 
All Classes All Packages