rpcx

type Client interface {
	Next() (*grpc.ClientConn, bool)
}

type ClientConfig struct {
	Host                 string
	Name                 []string
	Timeout              string
	MaxAttempts          string
	InitialBackoff       string
	MaxBackoff           string
	BackoffMultiplier    string
	RetryableStatusCodes []string
	WaitForReady         string
	MaxTokens            string
	TokenRatio           string
	DialOptions          []grpc.DialOption
}

type ClientOption func(options *ClientOptions)

type ClientOptions struct {
	Timeout     time.Duration
	DialOptions []grpc.DialOption
}

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

type RegisterFn func(*grpc.Server)

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

type Server interface {
	AddOptions(options ...grpc.ServerOption)
	AddStreamInterceptors(interceptors ...grpc.StreamServerInterceptor)
	AddUnaryInterceptors(interceptors ...grpc.UnaryServerInterceptor)
	Start(register RegisterFn) error
}