grpc-utils/com.pambrose.common.dsl/GrpcDsl

GrpcDsl

object GrpcDsl

DSL entry point for building gRPC channels, servers, attributes, and stream observers.

Supports both Netty-based (network) and in-process transports, with optional TLS and retry configuration.

Types

StreamObserverHelper

class StreamObserverHelper<T> : StreamObserver<T>

A DSL-friendly StreamObserver implementation that delegates to user-supplied lambda callbacks.

Functions

attributes

fun attributes(block: Attributes.Builder.() -> Unit): Attributes

Builds gRPC Attributes using a DSL-style configuration block.

channel

fun channel(hostName: String = "", port: Int = -1, enableRetry: Boolean = false, maxRetryAttempts: Int = 5, tlsContext: TlsContext, overrideAuthority: String = "", inProcessServerName: String = "", block: ManagedChannelBuilder<*>.() -> Unit): ManagedChannel

Builds a ManagedChannel using either a Netty transport or an in-process transport.

server

fun server(port: Int = -1, tlsContext: TlsContext = PLAINTEXT_CONTEXT, inProcessServerName: String = "", block: ServerBuilder<*>.() -> Unit): Server

Builds a gRPC Server using either a Netty transport or an in-process transport.

streamObserver

fun <T> streamObserver(init: GrpcDsl.StreamObserverHelper<T>.() -> Unit): GrpcDsl.StreamObserverHelper<T>

Creates a StreamObserver using a DSL-style builder.