broadcast

Documentation

Index

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

Functions

func UseBroadCast

func UseBroadCast(ctx context.Context) (context.Context, <-chan Resp)

Types

type ClusterBuilder

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

func NewClusterBuilder

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

func (ClusterBuilder) BuildUnaryInterceptor

func (b ClusterBuilder) BuildUnaryInterceptor() grpc.UnaryClientInterceptor

type Resp

type Resp struct {
	Err   error
	Reply any
}