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 creates a new context that indicates a broadcast should be performed.

Types

type ClusterBuilder

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

ClusterBuilder helps to communicate with a cluster of services for a given `service`.

func NewClusterBuilder

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

NewClusterBuilder creates a new instance of ClusterBuilder with the provided parameters.

func (*ClusterBuilder) BuildUnaryInterceptor

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

BuildUnaryInterceptor creates a grpc.UnaryClientInterceptor that supports broadcasting.

type Response

type Response struct {
	Error error
	Reply interface{}
}

Response structure for holding either a reply or an error.