grpcx

type Client interface {
	AddDialOptions(...grpc.DialOption)
	AddUnaryInterceptor(interceptor ...grpc.UnaryClientInterceptor)
	AddStreamInterceptor(interceptor ...grpc.StreamClientInterceptor)
	Dial() (*grpc.ClientConn, error)
	DialWithCall(ClientCallFunc) (any, error)
	Conn() *grpc.ClientConn
	Close()
}

type ClientCallFunc func(*grpc.ClientConn) (any, error)

type ClientConfig struct {
	Addr   string
	Secure bool
	Trace  bool
}

type ClientEntity struct {
	*ClientConfig
	// contains filtered or unexported fields
}

type Server interface {
	AddServerOptions(serverOption ...grpc.ServerOption)
	AddUnaryInterceptor(interceptor ...grpc.UnaryServerInterceptor)
	AddStreamInterceptor(interceptor ...grpc.StreamServerInterceptor)
	Start(ServerRegisterFunc) error
	Engine() *grpc.Server
	Shutdown() error
}

type ServerConfig struct {
	Addr  string
	Trace bool
}

type ServerEntity struct {
	*ServerConfig
	// contains filtered or unexported fields
}

type ServerRegisterFunc func(*grpc.Server)