grpc_resolver

Documentation

Index

• Constants
• func RegMultiProcResolver(numServers int) error
• type 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        = "unix://"
)

Functions

func RegMultiProcResolver

func RegMultiProcResolver(numServers int) 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 (*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