Instance Methodpackage-distributed-system 28.0.1DistributedSystem
connectToService(_:withFilter:clientFactory:serviceHandler:deadline:)
To be used to connect to a single service of the particular type. Function returns the service endpoint instance after connection to service is established and service endpoint is ready for use.
DistributedSystem.swift:617func connectToService<S, C>(_ serviceEndpointType: S.Type, withFilter serviceFilter: @escaping ServiceFilter, clientFactory: ((DistributedSystem) -> C)?, serviceHandler: ((S, ConsulServiceDiscovery.Instance) -> Void)? = nil, deadline: DispatchTime? = nil) async throws -> S where S : ServiceEndpoint, S.ActorSystem == DistributedSystem Parameters
- _
serviceEndpointType - type of the service endpoint
- serviceFilter
user can filter out services and create a distributed actors only to needed
- clientFactory
a closure creating a client side endpoint instance
- serviceHandler
a clusure getting an instance of the service endpoint and a service where the endpoint is connected to
Returns
service endpoint
Other members in extension
Types
Typealiases
typealias ActorIDtypealias InvocationDecodertypealias InvocationEncodertypealias ResultHandlertypealias SerializationRequirementtypealias ServiceFactorytypealias ServiceFilter
Type members
init(name: String, addressTag: String?, compressionMode: CompressionMode, logLevel: Logger.Level) init(systemName: String, addressTag: String?, compressionMode: CompressionMode, logLevel: Logger.Level)
Instance members
let consulServiceDiscovery: ConsulServiceDiscoveryvar logger: Loggervar loggerBox: Box<Logger>let systemName: Stringfunc actorReady<Actor>(Actor) func assignID<Actor>(Actor.Type) -> EndpointIdentifier func connectToService<S>(S.Type, withFilter: @escaping ServiceFilter, serviceHandler: ((S, ConsulServiceDiscovery.Instance) -> Void)?, deadline: DispatchTime?) async throws -> S To be used to connect to a single service of the particular type. Function returns the service endpoint instance after connection to service is established and service endpoint is ready for use.
func connectToServices<S, C>(S.Type, withFilter: @escaping ServiceFilter, clientFactory: ((DistributedSystem, ConsulServiceDiscovery.Instance) -> C)?, serviceHandler: @escaping (S, ConsulServiceDiscovery.Instance) -> Void, cancellationToken: CancellationToken?) -> Bool To be used to connect to multiple services of the same type. Service will be discovered with using a discovery system (consul by default).
func getBytesSent() async throws -> UInt64 func makeCancellationToken() -> CancellationToken func makeInvocationEncoder() -> RemoteCallEncoder func remoteCall<Actor, Err, Res>(on: Actor, target: RemoteCallTarget, invocation: inout InvocationEncoder, throwing: Err.Type, returning: Res.Type) async throws -> Res func remoteCallVoid<Actor, Err>(on: Actor, target: RemoteCallTarget, invocation: inout InvocationEncoder, throwing: Err.Type) async throws func resignID(EndpointIdentifier) func resolve<Actor>(id: EndpointIdentifier, as: Actor.Type) throws -> Actor? func start() throws Service lifecycle start
func stop() Service lifecycle stop