grpc_resolver

Documentation

Index

• Constants
• func BuildConnAddrs(numCpu int) []string
• func RegMultiProcResolver(svrInfo *info.ServerInfo) error
• type MultiProcResolverBuilder
  • func NewMultiProcResolverBuilder(addrsList []string) *MultiProcResolverBuilder
  • func (m *MultiProcResolverBuilder) Build(target resolver.Target, cc resolver.ClientConn, opts resolver.BuildOptions) (resolver.Resolver, error)
  • func (*MultiProcResolverBuilder) Scheme() string

Constants

const (
	CustScheme      = "udf"
	CustServiceName = "numaflow.numaproj.io"
	ConnAddr        = "0.0.0.0"
)

Functions

func BuildConnAddrs

func BuildConnAddrs(numCpu int) []string

BuildConnAddrs Populate the connection list for the clients Format (serverAddr, serverIdx) : (0.0.0.0:5551, 1)

func RegMultiProcResolver

func RegMultiProcResolver(svrInfo *info.ServerInfo) error

RegMultiProcResolver is used to populate the connection properties based on multiprocessing TCP or UDS connection

Types

type MultiProcResolverBuilder

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

func NewMultiProcResolverBuilder

func NewMultiProcResolverBuilder(addrsList []string) *MultiProcResolverBuilder

func (*MultiProcResolverBuilder) Build

func (m *MultiProcResolverBuilder) Build(target resolver.Target, cc resolver.ClientConn, opts resolver.BuildOptions) (resolver.Resolver, error)

func (*MultiProcResolverBuilder) Scheme

func (*MultiProcResolverBuilder) Scheme() string