orbit-proto
Module Contents
alltypes
Module Contents
class Addressable
@Generated("by gRPC proto compiler (version 1.25.0)", "Source: orbit/shared/addressable_management.proto") class AddressableManagementGrpc
@Generated("Source: orbit/shared/addressable_management.proto", ["by gRPC Kotlin generator"]) abstract class AddressableManagementImplBase : BindableService, CoroutineScope
class AddressableManagementOuterClass
com.google.protobuf.Timestamp
@Generated("by gRPC proto compiler (version 1.25.0)", "Source: orbit/shared/connection.proto") class ConnectionGrpc
@Generated("Source: orbit/shared/connection.proto", ["by gRPC Kotlin generator"]) abstract class ConnectionImplBase : BindableService, CoroutineScope
class ConnectionOuterClass
class ContextCoroutineContextElement : ThreadContextElement<Context>
class ContinuationStreamObserver<E> : StreamObserver<E>
object Headers
@Generated("by gRPC proto compiler (version 1.25.0)", "Source: orbit/shared/health.proto") class HealthGrpc
@Generated("Source: orbit/shared/health.proto", ["by gRPC Kotlin generator"]) abstract class HealthImplBase : BindableService, CoroutineScope
class HealthOuterClass
io.grpc.Context.Key
kotlin.Throwable
Module Contents
fun Throwable.toAddressableLeaseResponseProto(): RenewAddressableLeaseResponseProto
fun Throwable.toNodeLeaseRequestResponseProto(): NodeLeaseResponseProto
class ManyToManyCall<in TRequest, out TResponse> : StreamObserverSendAdapter<TRequest>, ReceiveChannel<TResponse>
class ManyToOneCall<in TRequest, out TResponse> : StreamObserverSendAdapter<TRequest>, Deferred<TResponse>
class Messages
Module Contents
class ConnectionInfoRequestProto : GeneratedMessageV3, ConnectionInfoRequestProtoOrBuilder
interface ConnectionInfoRequestProtoOrBuilder : MessageOrBuilder
class ConnectionInfoResponseProto : GeneratedMessageV3, ConnectionInfoResponseProtoOrBuilder
interface ConnectionInfoResponseProtoOrBuilder : MessageOrBuilder
class ErrorProto : GeneratedMessageV3, ErrorProtoOrBuilder
interface ErrorProtoOrBuilder : MessageOrBuilder
static fun getDescriptor(): FileDescriptor!
class InvocationRequestProto : GeneratedMessageV3, InvocationRequestProtoOrBuilder
interface InvocationRequestProtoOrBuilder : MessageOrBuilder
class InvocationResponseProto : GeneratedMessageV3, InvocationResponseProtoOrBuilder
interface InvocationResponseProtoOrBuilder : MessageOrBuilder
class MessageContentProto : GeneratedMessageV3, MessageContentProtoOrBuilder
interface MessageContentProtoOrBuilder : MessageOrBuilder
class MessageProto : GeneratedMessageV3, MessageProtoOrBuilder
interface MessageProtoOrBuilder : MessageOrBuilder
class MessageTargetProto : GeneratedMessageV3, MessageTargetProtoOrBuilder
Module Contents
class Builder : Builder<Builder!>, MessageTargetProtoOrBuilder
fun equals(other: Any?): Boolean
static fun getDefaultInstance(): MessageTargetProto!
fun getDefaultInstanceForType(): MessageTargetProto!
static fun getDescriptor(): Descriptor!
fun getParserForType(): Parser<MessageTargetProto!>!
fun getRoutedUnicastTarget(): RoutedUnicast!
fun getRoutedUnicastTargetOrBuilder(): RoutedUnicastOrBuilder!
fun getSerializedSize(): Int
fun getTargetCase(): TargetCase!
fun getUnicastTarget(): Unicast!
fun getUnicastTargetOrBuilder(): UnicastOrBuilder!
fun getUnknownFields(): UnknownFieldSet!
fun hashCode(): Int
fun hasRoutedUnicastTarget(): Boolean
fun hasUnicastTarget(): Boolean
protected fun internalGetFieldAccessorTable(): FieldAccessorTable!
fun isInitialized(): Boolean
static fun newBuilder(): Builder!
static fun newBuilder(prototype: MessageTargetProto!): Builder!
fun newBuilderForType(): Builder!
protected fun newBuilderForType(parent: BuilderParent!): Builder!
protected fun newInstance(unused: UnusedPrivateParameter!): Any!
static fun parseDelimitedFrom(input: InputStream!): MessageTargetProto!
static fun parseDelimitedFrom(input: InputStream!, extensionRegistry: ExtensionRegistryLite!): MessageTargetProto!
static fun parseFrom(data: ByteBuffer!): MessageTargetProto!
static fun parseFrom(data: ByteBuffer!, extensionRegistry: ExtensionRegistryLite!): MessageTargetProto!
static fun parseFrom(data: ByteString!): MessageTargetProto!
static fun parseFrom(data: ByteString!, extensionRegistry: ExtensionRegistryLite!): MessageTargetProto!
static fun parseFrom(data: ByteArray!): MessageTargetProto!
static fun parseFrom(data: ByteArray!, extensionRegistry: ExtensionRegistryLite!): MessageTargetProto!
static fun parseFrom(input: InputStream!): MessageTargetProto!
static fun parseFrom(input: InputStream!, extensionRegistry: ExtensionRegistryLite!): MessageTargetProto!
static fun parseFrom(input: CodedInputStream!): MessageTargetProto!
static fun parseFrom(input: CodedInputStream!, extensionRegistry: ExtensionRegistryLite!): MessageTargetProto!
static fun parser(): Parser<MessageTargetProto!>!
class RoutedUnicast : GeneratedMessageV3, RoutedUnicastOrBuilder
interface RoutedUnicastOrBuilder : MessageOrBuilder
static val ROUTEDUNICASTTARGET_FIELD_NUMBER: Int
class TargetCase : EnumLite, InternalOneOfEnum
fun toBuilder(): Builder!
class Unicast : GeneratedMessageV3, UnicastOrBuilder
interface UnicastOrBuilder : MessageOrBuilder
static val UNICASTTARGET_FIELD_NUMBER: Int
fun writeTo(output: CodedOutputStream!): Unit
interface MessageTargetProtoOrBuilder : MessageOrBuilder
static fun registerAllExtensions(registry: ExtensionRegistryLite!): Unit
static fun registerAllExtensions(registry: ExtensionRegistry!): Unit
class Node
@Generated("by gRPC proto compiler (version 1.25.0)", "Source: orbit/shared/node_management.proto") class NodeManagementGrpc
@Generated("Source: orbit/shared/node_management.proto", ["by gRPC Kotlin generator"]) abstract class NodeManagementImplBase : BindableService, CoroutineScope
class NodeManagementOuterClass
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
class StreamObserverChannel<E> : StreamObserver<E>, ReceiveChannel<E>
class StreamObserverDeferred<E> : StreamObserver<E>, Deferred<E>
open class StreamObserverSendAdapter<in E>
typealias TimestampProto = Timestamp
package grpc.health.v1
package io.rouz.grpc
package orbit.shared.proto
Module Contents
suspend fun AddressableManagementStub.abandonLease(request: AbandonAddressableLeaseRequestProto): AbandonAddressableLeaseResponseProto
fun AddressableManagementStub.addBinaryHeader(: String, : ByteArray): AddressableManagementStub
fun ConnectionStub.addBinaryHeader(: String, : ByteArray): ConnectionStub
fun NodeManagementStub.addBinaryHeader(: String, : ByteArray): NodeManagementStub
class Addressable
@Generated("by gRPC proto compiler (version 1.25.0)", "Source: orbit/shared/addressable_management.proto") class AddressableManagementGrpc
@Generated("Source: orbit/shared/addressable_management.proto", ["by gRPC Kotlin generator"]) abstract class AddressableManagementImplBase : BindableService, CoroutineScope
class AddressableManagementOuterClass
com.google.protobuf.Timestamp
@Generated("by gRPC proto compiler (version 1.25.0)", "Source: orbit/shared/connection.proto") class ConnectionGrpc
@Generated("Source: orbit/shared/connection.proto", ["by gRPC Kotlin generator"]) abstract class ConnectionImplBase : BindableService, CoroutineScope
class ConnectionOuterClass
object Headers
io.grpc.Context.Key
suspend fun NodeManagementStub.joinCluster(request: JoinClusterRequestProto): NodeLeaseResponseProto
kotlin.Throwable
Module Contents
fun Throwable.toAddressableLeaseResponseProto(): RenewAddressableLeaseResponseProto
fun Throwable.toNodeLeaseRequestResponseProto(): NodeLeaseResponseProto
class Messages
Module Contents
class ConnectionInfoRequestProto : GeneratedMessageV3, ConnectionInfoRequestProtoOrBuilder
interface ConnectionInfoRequestProtoOrBuilder : MessageOrBuilder
class ConnectionInfoResponseProto : GeneratedMessageV3, ConnectionInfoResponseProtoOrBuilder
interface ConnectionInfoResponseProtoOrBuilder : MessageOrBuilder
class ErrorProto : GeneratedMessageV3, ErrorProtoOrBuilder
interface ErrorProtoOrBuilder : MessageOrBuilder
static fun getDescriptor(): FileDescriptor!
class InvocationRequestProto : GeneratedMessageV3, InvocationRequestProtoOrBuilder
interface InvocationRequestProtoOrBuilder : MessageOrBuilder
class InvocationResponseProto : GeneratedMessageV3, InvocationResponseProtoOrBuilder
interface InvocationResponseProtoOrBuilder : MessageOrBuilder
class MessageContentProto : GeneratedMessageV3, MessageContentProtoOrBuilder
interface MessageContentProtoOrBuilder : MessageOrBuilder
class MessageProto : GeneratedMessageV3, MessageProtoOrBuilder
interface MessageProtoOrBuilder : MessageOrBuilder
class MessageTargetProto : GeneratedMessageV3, MessageTargetProtoOrBuilder
Module Contents
class Builder : Builder<Builder!>, MessageTargetProtoOrBuilder
fun equals(other: Any?): Boolean
static fun getDefaultInstance(): MessageTargetProto!
fun getDefaultInstanceForType(): MessageTargetProto!
static fun getDescriptor(): Descriptor!
fun getParserForType(): Parser<MessageTargetProto!>!
fun getRoutedUnicastTarget(): RoutedUnicast!
fun getRoutedUnicastTargetOrBuilder(): RoutedUnicastOrBuilder!
fun getSerializedSize(): Int
fun getTargetCase(): TargetCase!
fun getUnicastTarget(): Unicast!
fun getUnicastTargetOrBuilder(): UnicastOrBuilder!
fun getUnknownFields(): UnknownFieldSet!
fun hashCode(): Int
fun hasRoutedUnicastTarget(): Boolean
fun hasUnicastTarget(): Boolean
protected fun internalGetFieldAccessorTable(): FieldAccessorTable!
fun isInitialized(): Boolean
static fun newBuilder(): Builder!
static fun newBuilder(prototype: MessageTargetProto!): Builder!
fun newBuilderForType(): Builder!
protected fun newBuilderForType(parent: BuilderParent!): Builder!
protected fun newInstance(unused: UnusedPrivateParameter!): Any!
static fun parseDelimitedFrom(input: InputStream!): MessageTargetProto!
static fun parseDelimitedFrom(input: InputStream!, extensionRegistry: ExtensionRegistryLite!): MessageTargetProto!
static fun parseFrom(data: ByteBuffer!): MessageTargetProto!
static fun parseFrom(data: ByteBuffer!, extensionRegistry: ExtensionRegistryLite!): MessageTargetProto!
static fun parseFrom(data: ByteString!): MessageTargetProto!
static fun parseFrom(data: ByteString!, extensionRegistry: ExtensionRegistryLite!): MessageTargetProto!
static fun parseFrom(data: ByteArray!): MessageTargetProto!
static fun parseFrom(data: ByteArray!, extensionRegistry: ExtensionRegistryLite!): MessageTargetProto!
static fun parseFrom(input: InputStream!): MessageTargetProto!
static fun parseFrom(input: InputStream!, extensionRegistry: ExtensionRegistryLite!): MessageTargetProto!
static fun parseFrom(input: CodedInputStream!): MessageTargetProto!
static fun parseFrom(input: CodedInputStream!, extensionRegistry: ExtensionRegistryLite!): MessageTargetProto!
static fun parser(): Parser<MessageTargetProto!>!
class RoutedUnicast : GeneratedMessageV3, RoutedUnicastOrBuilder
interface RoutedUnicastOrBuilder : MessageOrBuilder
static val ROUTEDUNICASTTARGET_FIELD_NUMBER: Int
class TargetCase : EnumLite, InternalOneOfEnum
fun toBuilder(): Builder!
class Unicast : GeneratedMessageV3, UnicastOrBuilder
interface UnicastOrBuilder : MessageOrBuilder
static val UNICASTTARGET_FIELD_NUMBER: Int
fun writeTo(output: CodedOutputStream!): Unit
interface MessageTargetProtoOrBuilder : MessageOrBuilder
static fun registerAllExtensions(registry: ExtensionRegistryLite!): Unit
static fun registerAllExtensions(registry: ExtensionRegistry!): Unit
class Node
@Generated("by gRPC proto compiler (version 1.25.0)", "Source: orbit/shared/node_management.proto") class NodeManagementGrpc
@Generated("Source: orbit/shared/node_management.proto", ["by gRPC Kotlin generator"]) abstract class NodeManagementImplBase : BindableService, CoroutineScope
class NodeManagementOuterClass
fun ConnectionStub.openStream(): ManyToManyCall<MessageProto, MessageProto>
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
suspend fun AddressableManagementStub.renewLease(request: RenewAddressableLeaseRequestProto): RenewAddressableLeaseResponseProto
suspend fun NodeManagementStub.renewLease(request: RenewNodeLeaseRequestProto): NodeLeaseResponseProto
typealias TimestampProto = Timestamp
fun AddressableKeyProto.toAddressableKey(): Key
fun AddressableLeaseProto.toAddressableLease(): AddressableLease
fun AddressableReferenceProto.toAddressableReference(): AddressableReference
fun CapabilitiesProto.toCapabilities(): NodeCapabilities
fun NodeLeaseProto.toLeaseProto(): NodeLease
fun MessageProto.toMessage(): Message
fun MessageContentProto.toMessageContent(): MessageContent
fun MessageTargetProto.toMessageTarget(): MessageTarget?
fun NodeIdProto.toNodeId(): NodeId
fun NodeInfoProto.toNodeInfo(): NodeInfo
fun NodeStatusProto.toNodeStatus(): NodeStatus