orbit.shared.proto - orbit-proto

orbit-proto / orbit.shared.proto

Package orbit.shared.proto

Types

Addressable	`class Addressable`
AddressableManagementGrpc	`class AddressableManagementGrpc`
AddressableManagementImplBase	`abstract class AddressableManagementImplBase : BindableService, CoroutineScope`
AddressableManagementOuterClass	`class AddressableManagementOuterClass`
ConnectionGrpc	`class ConnectionGrpc`
ConnectionImplBase	`abstract class ConnectionImplBase : BindableService, CoroutineScope`
ConnectionOuterClass	`class ConnectionOuterClass`
Headers	`object Headers`
Messages	`class Messages`
Node	`class Node`
NodeManagementGrpc	`class NodeManagementGrpc`
NodeManagementImplBase	`abstract class NodeManagementImplBase : BindableService, CoroutineScope`
NodeManagementOuterClass	`class NodeManagementOuterClass`
TimestampProto	`typealias TimestampProto = Timestamp`

Extensions for External Classes

com.google.protobuf.Timestamp
io.grpc.Context.Key
kotlin.Throwable
orbit.shared.addressable.AddressableLease
orbit.shared.addressable.AddressableReference
orbit.shared.addressable.Key
orbit.shared.mesh.NodeCapabilities
orbit.shared.mesh.NodeId
orbit.shared.mesh.NodeInfo
orbit.shared.mesh.NodeLease
orbit.shared.mesh.NodeStatus
orbit.shared.net.Message
orbit.shared.net.MessageContent
orbit.shared.net.MessageTarget
orbit.util.time.Timestamp

Functions

abandonLease	`suspend fun AddressableManagementStub.abandonLease(request: AbandonAddressableLeaseRequestProto): AbandonAddressableLeaseResponseProto`
addBinaryHeader	Adds new binary header and returns the client `fun AddressableManagementStub.addBinaryHeader(header: String, bytes: ByteArray): AddressableManagementStub` `fun ConnectionStub.addBinaryHeader(header: String, bytes: ByteArray): ConnectionStub` `fun NodeManagementStub.addBinaryHeader(header: String, bytes: ByteArray): NodeManagementStub`
joinCluster	Kotlin extension functions for orbit.shared.proto.NodeManagementGrpc.NodeManagementStub `suspend fun NodeManagementStub.joinCluster(request: JoinClusterRequestProto): NodeLeaseResponseProto`
openStream	Kotlin extension functions for orbit.shared.proto.ConnectionGrpc.ConnectionStub `fun ConnectionStub.openStream(): ManyToManyCall<MessageProto, MessageProto>`
renewLease	Kotlin extension functions for orbit.shared.proto.AddressableManagementGrpc.AddressableManagementStub `suspend fun AddressableManagementStub.renewLease(request: RenewAddressableLeaseRequestProto): RenewAddressableLeaseResponseProtosuspend fun NodeManagementStub.renewLease(request: RenewNodeLeaseRequestProto): NodeLeaseResponseProto`
toAddressableKey	`fun AddressableKeyProto.toAddressableKey(): Key`
toAddressableLease	`fun AddressableLeaseProto.toAddressableLease(): AddressableLease`
toAddressableReference	`fun AddressableReferenceProto.toAddressableReference(): AddressableReference`
toCapabilities	`fun CapabilitiesProto.toCapabilities(): NodeCapabilities`
toLeaseProto	`fun NodeLeaseProto.toLeaseProto(): NodeLease`
toMessage	`fun MessageProto.toMessage(): Message`
toMessageContent	`fun MessageContentProto.toMessageContent(): MessageContent`
toMessageTarget	`fun MessageTargetProto.toMessageTarget(): MessageTarget?`
toNodeId	`fun NodeIdProto.toNodeId(): NodeId`
toNodeInfo	`fun NodeInfoProto.toNodeInfo(): NodeInfo`
toNodeStatus	`fun NodeStatusProto.toNodeStatus(): NodeStatus`