broadcast

Documentation

Index

• func UseBroadCast(ctx context.Context) context.Context
• type ClusterBuilder
  • func NewClusterBuilder(r registry.Registry, service string, dialOptions ...grpc.DialOption) *ClusterBuilder
  • func (c *ClusterBuilder) BuildUnaryInterceptor() grpc.UnaryClientInterceptor

Functions

func UseBroadCast

func UseBroadCast(ctx context.Context) context.Context

Types

type ClusterBuilder

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

func NewClusterBuilder

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

func (*ClusterBuilder) BuildUnaryInterceptor

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

BuildUnaryInterceptor 创建gRpc的一元拦截器，用于处理 gRPC 的单向调用