broadcast

Documentation

Index

• func UseBroadcast(ctx context.Context) (context.Context, <-chan Response)
• type ClusterBuilder
  • func NewClusterBuilder(registry registry.Registry, service string, dialOptions ...grpc.DialOption) *ClusterBuilder
  • func (b *ClusterBuilder) BuildUnaryInterceptor() grpc.UnaryClientInterceptor
• type Response

Functions

func UseBroadcast

func UseBroadcast(ctx context.Context) (context.Context, <-chan Response)

UseBroadcast activates broadcasting for an RPC call, returning a context and a channel to receive the responses.

Types

type ClusterBuilder

type ClusterBuilder struct {
	// contains filtered or unexported fields
}

ClusterBuilder struct for building client interceptors with distributed service discovery.

func NewClusterBuilder

func NewClusterBuilder(registry registry.Registry, service string, dialOptions ...grpc.DialOption) *ClusterBuilder

NewClusterBuilder creates a new ClusterBuilder instance.

func (*ClusterBuilder) BuildUnaryInterceptor

func (b *ClusterBuilder) BuildUnaryInterceptor() grpc.UnaryClientInterceptor

BuildUnaryInterceptor constructs a unary client interceptor for broadcasting RPCs across instances.

type Response

type Response struct {
	Error error
	Reply interface{}
}

Response structure for holding either a reply or an error.