multiplex

package

v0.1.21 Latest Latest Go to latest Published: Mar 10, 2026 License: MPL-2.0 Imports: 7 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/chubo-dev/chubo

Links

Open Source Insights

Documentation ¶

Overview ¶

Package multiplex implements client-side multiplexing helpers.

Index ¶

func Streaming[ResponseT any](ctx context.Context, nodes []string, ...) <-chan Response[*ResponseT]
func Unary[ResponseT any](ctx context.Context, nodes []string, ...) <-chan Response[*ResponseT]
type Response

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func Streaming ¶

func Streaming[ResponseT any](ctx context.Context, nodes []string, initiate func(context.Context) (grpc.ServerStreamingClient[ResponseT], error)) <-chan Response[*ResponseT]

Streaming initiates a multiplexed streaming gRPC client call to multiple nodes.

func Unary ¶

func Unary[ResponseT any](ctx context.Context, nodes []string, initiate func(context.Context) (*ResponseT, error)) <-chan Response[*ResponseT]

Unary initiates a multiplexed unary gRPC client call to multiple nodes.

Types ¶

type Response ¶

type Response[ResponseT any] struct {
	Node    string
	Payload ResponseT
	Err     error
}

Response represents a multiplexed response from a specific node.

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL